[flink] branch master updated: [hotfix][table-planner] Disable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs until FLINK-24443 is fixed

[tw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 9ab85e1  [hotfix][table-planner] Disable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs until FLINK-24443 is fixed
9ab85e1 is described below

commit 9ab85e1d10f0848ce43c01bfdb6788d7288dada7
Author: Timo Walther <tw...@apache.org>
AuthorDate: Mon Oct 4 17:09:16 2021 +0200

    [hotfix][table-planner] Disable IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs until FLINK-24443 is fixed
---
 .../flink/table/planner/runtime/stream/sql/IntervalJoinITCase.scala   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/IntervalJoinITCase.scala b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/IntervalJoinITCase.scala
index 4f637db..bda4b97 100644
--- a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/IntervalJoinITCase.scala
+++ b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/IntervalJoinITCase.scala
@@ -18,7 +18,6 @@
 
 package org.apache.flink.table.planner.runtime.stream.sql
 
-import org.apache.flink.api.common.eventtime.{SerializableTimestampAssigner, WatermarkStrategy}
 import org.apache.flink.api.scala._
 import org.apache.flink.streaming.api.functions.AssignerWithPunctuatedWatermarks
 import org.apache.flink.streaming.api.watermark.Watermark
@@ -28,9 +27,9 @@ import org.apache.flink.table.planner.runtime.utils.StreamingWithStateTestBase.S
 import org.apache.flink.table.planner.runtime.utils._
 import org.apache.flink.types.Row
 import org.junit.Assert._
-import org.junit.Test
 import org.junit.runner.RunWith
 import org.junit.runners.Parameterized
+import org.junit.{Ignore, Test}
 
 import scala.collection.mutable
 
@@ -373,6 +372,7 @@ class IntervalJoinITCase(mode: StateBackendMode) extends StreamingWithStateTestB
   }
 
   /** test row time inner join with equi-times **/
+  @Ignore // see FLINK-24443
   @Test
   def testRowTimeInnerJoinWithEquiTimeAttrs(): Unit = {