You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Matthias Pohl (Jira)" <ji...@apache.org> on 2024/07/03 07:27:00 UTC
[jira] [Created] (FLINK-35748) DeduplicateITCase.testLastRowWithoutAllChangelogOnRowtime with MiniBatch mode and RocksDB backend enabled
Matthias Pohl created FLINK-35748:
-------------------------------------
Summary: DeduplicateITCase.testLastRowWithoutAllChangelogOnRowtime with MiniBatch mode and RocksDB backend enabled
Key: FLINK-35748
URL: https://issues.apache.org/jira/browse/FLINK-35748
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.20.0
Reporter: Matthias Pohl
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=60613&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=075c2716-8010-5565-fe08-3c4bb45824a4&l=12259
{code}
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)
[...]
{code}
The test failure appeared in a CI run for FLINK-35553. Which does some changes to how checkpointing is triggered. I checked the logs and couldn't find any evidence that the test run included the FLINK-35553 change (no restoring from checkpoint happens in the failed and successful of the test; see attached logs).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)