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 <[email protected]>
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 = {