some unrelated

kgyrtkirk · Feb 5, 2024 · 0c132df · 0c132df
1 parent 0ba43ac
commit 0c132df
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 1 deletion.
diff --git a/...essing/src/main/java/org/apache/druid/query/operator/SegmentToRowsAndColumnsOperator.java b/...essing/src/main/java/org/apache/druid/query/operator/SegmentToRowsAndColumnsOperator.java
@@ -44,7 +44,7 @@ public Closeable goOrContinue(Closeable continuation, Receiver receiver)
   {
     try (final CloseableShapeshifter shifty = segment.as(CloseableShapeshifter.class)) {
       if (shifty == null) {
-        throw new ISE("Segment[%s] cannot shapeshift", segment.getClass());
+        throw new ISE("Segment[%s] cannot shapeshift", segment);
       }
       RowsAndColumns rac;
       if (shifty instanceof RowsAndColumns) {

diff --git a/sql/src/test/java/org/apache/druid/sql/calcite/CalciteWindowQueryTest.java b/sql/src/test/java/org/apache/druid/sql/calcite/CalciteWindowQueryTest.java
@@ -218,6 +218,25 @@ public void windowQueryTest() throws Exception
           .run();
     }
   }
+  @Test
+  @SuppressWarnings("unchecked")
+  public void windowQueryTest2() throws Exception
+  {
+    TestCase testCase = new TestCase(filename);
+
+    assumeThat(testCase.getType(), Matchers.not(TestType.failingTest));
+
+    if (testCase.getType() == TestType.operatorValidation) {
+      testBuilder()
+          .skipVectorize(true)
+          .sql(testCase.getSql())
+          .queryContext(ImmutableMap.of(PlannerContext.CTX_ENABLE_WINDOW_FNS, true,
+              QueryContexts.ENABLE_DEBUG, true,
+              QueryContexts.MAX_SUBQUERY_BYTES_KEY, "100000"))
+          .addCustomVerification(QueryVerification.ofResults(testCase))
+          .run();
+    }
+  }
 
   private WindowOperatorQuery getWindowOperatorQuery(List<Query<?>> queries)
   {