Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
1.20.0
-
None
Description
Jul 02 14:44:36 14:44:36.737 [ERROR] Tests run: 40, Failures: 1, Errors: 0, Skipped: 4, Time elapsed: 18.45 s <<< FAILURE! -- in org.apache.flink.table.planner.runtime.stream.sql.DeduplicateITCase Jul 02 14:44:36 14:44:36.737 [ERROR] org.apache.flink.table.planner.runtime.stream.sql.DeduplicateITCase.testLastRowWithoutAllChangelogOnRowtime -- Time elapsed: 0.860 s <<< FAILURE! Jul 02 14:44:36 org.opentest4j.AssertionFailedError: Jul 02 14:44:36 Jul 02 14:44:36 expected: List(+I(1,1,Hi,1970-01-01T00:00:00.001), +I(1,2,Hello world,1970-01-01T00:00:00.002), +I(2,3,I am fine.,1970-01-01T00:00:00.003), +I(2,6,Comment#1,1970-01-01T00:00:00.006), +I(3,5,Comment#2,1970-01-01T00:00:00.005), +I(4,4,Comment#3,1970-01-01T00:00:00.004)) Jul 02 14:44:36 but was: ArrayBuffer(+I(1,1,Hi,1970-01-01T00:00:00.001), +I(1,2,Hello world,1970-01-01T00:00:00.002), +I(1,3,Hello,1970-01-01T00:00:00.003), +I(2,6,Comment#1,1970-01-01T00:00:00.006), +I(3,5,Comment#2,1970-01-01T00:00:00.005), +I(4,4,Comment#3,1970-01-01T00:00:00.004), +U(2,3,I am fine.,1970-01-01T00:00:00.003), -U(1,3,Hello,1970-01-01T00:00:00.003)) Jul 02 14:44:36 at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) Jul 02 14:44:36 at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) Jul 02 14:44:36 at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) Jul 02 14:44:36 at org.apache.flink.table.planner.runtime.stream.sql.DeduplicateITCase.testLastRowWithoutAllChangelogOnRowtime(DeduplicateITCase.scala:364) Jul 02 14:44:36 at java.lang.reflect.Method.invoke(Method.java:498) [...]
The test failure appeared in a CI run for FLINK-35553 which changes how rescaling is triggered. I checked the logs and couldn't find any evidence that the test run includes job restarts and, therefore, wouldn't touch the FLINK-35553 changes (see attached logs).