Fix style

gargvishesh · Oct 9, 2024 · f930bb3 · f930bb3
1 parent 00806de
commit f930bb3
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/...re/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQCompactionRunner.java b/...re/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQCompactionRunner.java
@@ -371,7 +371,8 @@ private static ColumnMappings getColumnMappings(DataSchema dataSchema)
                         ? TIME_VIRTUAL_COLUMN
                         : ColumnHolder.TIME_COLUMN_NAME;
     ColumnMapping timeColumnMapping = new ColumnMapping(timeColumn, ColumnHolder.TIME_COLUMN_NAME);
-    if (dataSchema.getDimensionsSpec().isForceSegmentSortByTime()){
+    if (dataSchema.getDimensionsSpec().isForceSegmentSortByTime()) {
+      // When not sorted by time, the __time column is missing from dimensionsSpec
       columnMappings.add(timeColumnMapping);
     }
     columnMappings.addAll(

diff --git a/...ulti-stage-query/src/test/java/org/apache/druid/msq/indexing/MSQCompactionRunnerTest.java b/...ulti-stage-query/src/test/java/org/apache/druid/msq/indexing/MSQCompactionRunnerTest.java
@@ -579,7 +579,8 @@ private static IndexSpec createIndexSpec()
                     .build();
   }
 
-  private static DataSourceMSQDestination getExpectedDestination(){
+  private static DataSourceMSQDestination getExpectedDestination()
+  {
     return new DataSourceMSQDestination(
         DATA_SOURCE,
         SEGMENT_GRANULARITY.getDefaultGranularity(),
@@ -590,7 +591,8 @@ private static DataSourceMSQDestination getExpectedDestination(){
     );
   }
 
-  private static MSQTuningConfig getExpectedTuningConfig() {
+  private static MSQTuningConfig getExpectedTuningConfig()
+  {
     return new MSQTuningConfig(
         1,
         MultiStageQueryContext.DEFAULT_ROWS_IN_MEMORY,