[
https://issues.apache.org/jira/browse/FLINK-33551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786437#comment-17786437
]
Matthias Pohl edited comment on FLINK-33551 at 11/15/23 5:06 PM:
-----------------------------------------------------------------
The issue started appearing in
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=54508&view=results
(3dd98430). The previous nightly (7542b56f) didn't have this error.
{code}
$ git log 7542b56f..3dd98430 --oneline --name-only
[...]
4cd8285274a [FLINK-33023][table-planner][JUnit5 Migration] Module:
flink-connectors/flink-connector-hive (TableTestBase)
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTemporalJoinITCase.java
[...]
{code}
The test was touched in FLINK-33023. I'm marking this as the cause for now.
[~jiabao.sun] can you have a look into it?
was (Author: mapohl):
The issue started appearing in
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=54508&view=results
(3dd98430). The previous nightly (7542b56f
) didn't have this error.
{code}
$ git log 7542b56f..3dd98430 --oneline --name-only
[...]
4cd8285274a [FLINK-33023][table-planner][JUnit5 Migration] Module:
flink-connectors/flink-connector-hive (TableTestBase)
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTemporalJoinITCase.java
[...]
{code}
The test was touched in FLINK-33023. I'm marking this as the cause for now.
[~jiabao.sun] can you have a look into it?
> HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable failed due to
> unsupported feature
> ------------------------------------------------------------------------------------------
>
> Key: FLINK-33551
> URL: https://issues.apache.org/jira/browse/FLINK-33551
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Hive
> Affects Versions: 1.19.0
> Reporter: Matthias Pohl
> Priority: Major
> Labels: test-stability
>
> https://github.com/XComp/flink/actions/runs/6865564561/job/18670787612#step:12:23311
> {code}
> Error: 16:08:30 16:08:30.479 [ERROR] Tests run: 2, Failures: 0, Errors: 1,
> Skipped: 0, Time elapsed: 19.706 s <<< FAILURE! - in
> org.apache.flink.connectors.hive.HiveTemporalJoinITCase
> Error: 16:08:30 16:08:30.480 [ERROR]
> org.apache.flink.connectors.hive.HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable
> Time elapsed: 2.618 s <<< ERROR!
> Nov 14 16:08:30 org.apache.flink.table.api.TableException: Processing-time
> temporal join is not supported yet.
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecTemporalJoin.createJoinOperator(StreamExecTemporalJoin.java:293)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecTemporalJoin.getJoinOperator(StreamExecTemporalJoin.java:255)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecTemporalJoin.translateToPlanInternal(StreamExecTemporalJoin.java:179)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:167)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:258)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:94)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:167)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:258)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecSink.translateToPlanInternal(StreamExecSink.java:177)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:167)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.delegation.StreamPlanner.$anonfun$translateToPlan$1(StreamPlanner.scala:85)
> Nov 14 16:08:30 at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> Nov 14 16:08:30 at scala.collection.Iterator.foreach(Iterator.scala:937)
> Nov 14 16:08:30 at
> scala.collection.Iterator.foreach$(Iterator.scala:937)
> Nov 14 16:08:30 at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
> Nov 14 16:08:30 at
> scala.collection.IterableLike.foreach(IterableLike.scala:70)
> Nov 14 16:08:30 at
> scala.collection.IterableLike.foreach$(IterableLike.scala:69)
> Nov 14 16:08:30 at
> scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> Nov 14 16:08:30 at
> scala.collection.TraversableLike.map(TraversableLike.scala:233)
> Nov 14 16:08:30 at
> scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> Nov 14 16:08:30 at
> scala.collection.AbstractTraversable.map(Traversable.scala:104)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.delegation.StreamPlanner.translateToPlan(StreamPlanner.scala:84)
> Nov 14 16:08:30 at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:184)
> Nov 14 16:08:30 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1277)
> Nov 14 16:08:30 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1055)
> Nov 14 16:08:30 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1120)
> Nov 14 16:08:30 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:735)
> Nov 14 16:08:30 at
> org.apache.flink.connectors.hive.HiveTemporalJoinITCase.testProcTimeTemporalJoinHiveTable(HiveTemporalJoinITCase.java:109)
> Nov 14 16:08:30 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> [...]
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
