[
https://issues.apache.org/jira/browse/FLINK-40950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18125005#comment-18125005
]
Chanhae Oh commented on FLINK-40950:
------------------------------------
Hi, [~martijnvisser], [~Sergey Nuyanzin] !
> [https://github.com/apache/flink/pull/29425]
Would it be okay change the status ticket clear?
I think It's merged.
Please take a look this.
> EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin fails with
> unexpected output
> -------------------------------------------------------------------------------------
>
> Key: FLINK-40950
> URL: https://issues.apache.org/jira/browse/FLINK-40950
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 2.4.0
> Reporter: Martijn Visser
> Priority: Blocker
> Labels: pull-request-available
>
> All builds on master are failing
> {code:java}
> Oct 07 19:44:19 19:44:19.932 [ERROR] Failures:
> Oct 07 19:44:19 19:44:19.932 [ERROR]
> EarlyFireJoinHintTest.testEarlyFireProcTimeOnRowTimeJoin:205->verify:282
> Expected:
> Oct 07 19:44:19 Calc(select=[a, b])
> Oct 07 19:44:19 +- IntervalJoin(joinType=[LeftOuterJoin],
> windowBounds=[isRowTime=true, leftLowerBound=-10000, leftUpperBound=3600000,
> leftTimeIndex=1, rightTimeIndex=2], where=[((a = a0) AND (rowtime >=
> (rowtime0 - 10000:INTERVAL SECOND)) AND (rowtime <= (rowtime0 +
> 3600000:INTERVAL HOUR)))], select=[a, rowtime, a0, b, rowtime0],
> earlyFireDelay=[5000], earlyFireTimeMode=[PROCTIME])
> Oct 07 19:44:19 :- Exchange(distribution=[hash[a]])
> Oct 07 19:44:19 : +- WatermarkAssigner(rowtime=[rowtime],
> watermark=[rowtime])
> Oct 07 19:44:19 : +- TableSourceScan(table=[[default_catalog,
> default_database, MyTable, project=[a, rowtime], metadata=[]]], fields=[a,
> rowtime])
> Oct 07 19:44:19 +- Exchange(distribution=[hash[a]])
> Oct 07 19:44:19 +- WatermarkAssigner(rowtime=[rowtime],
> watermark=[rowtime])
> Oct 07 19:44:19 +- TableSourceScan(table=[[default_catalog,
> default_database, MyTable2, project=[a, b, rowtime], metadata=[]]],
> fields=[a, b, rowtime])
> Oct 07 19:44:19 but was:
> Oct 07 19:44:19 Calc(select=[a, b])
> Oct 07 19:44:19 +- IntervalJoin(joinType=[LeftOuterJoin],
> windowBounds=[isRowTime=true, leftLowerBound=-10000, leftUpperBound=3600000,
> leftTimeIndex=1, rightTimeIndex=2], where=[((a = a0) AND (rowtime >=
> (rowtime0 - 10000:INTERVAL SECOND)) AND (rowtime <= (rowtime0 +
> 3600000:INTERVAL HOUR)))], select=[a, rowtime, a0, b, rowtime0],
> earlyFireDelay=[5000], earlyFireTimeMode=[PROCTIME])
> Oct 07 19:44:19 :- Exchange(distribution=[hash[a]])
> Oct 07 19:44:19 : +- WatermarkAssigner(rowtime=[rowtime],
> watermark=[rowtime])
> Oct 07 19:44:19 : +- TableSourceScan(table=[[default_catalog,
> default_database, MyTable, project=[a, rowtime]]], fields=[a, rowtime])
> Oct 07 19:44:19 +- Exchange(distribution=[hash[a]])
> Oct 07 19:44:19 +- WatermarkAssigner(rowtime=[rowtime],
> watermark=[rowtime])
> Oct 07 19:44:19 +- TableSourceScan(table=[[default_catalog,
> default_database, MyTable2, project=[a, b, rowtime]]], fields=[a, b, rowtime])
> Oct 07 19:44:19
> Oct 07 19:44:19 19:44:19.932 [INFO]
> Oct 07 19:44:19 19:44:19.932 [ERROR] Tests run: 11739, Failures: 1, Errors:
> 0, Skipped: 43
> {code}
> Examples:
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=79921&view=logs&j=086353db-23b2-5446-2315-18e660618ef2&t=87e39f83-bb6a-550a-8a36-1098f71ef110&l=9985
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=79917&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=019d96ac-af5c-5c6d-106d-b67f63cc6e96&l=9972
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=79919&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=019d96ac-af5c-5c6d-106d-b67f63cc6e96&l=9973
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
