You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@fluss.apache.org by "wuchong (via GitHub)" <gi...@apache.org> on 2026/10/19 05:53:49 UTC
[I] [test] Unstable test Flink120TableSourceBatchITCase.testScanFullPrimaryKeyTable [fluss]
wuchong opened a new issue, #4723:
URL: https://github.com/apache/fluss/issues/4723
### Search before asking
- [x] I searched existing issues by test name, batch-source test class, list-offset errors, and `NotLeaderOrFollowerException` and found no matching test-failure report.
### Fluss version
Development (`1.1-SNAPSHOT`, PR #4242), Flink 1.20, Java 11.
### Description
`Flink120TableSourceBatchITCase.testScanFullPrimaryKeyTable(boolean)[1]` fails in Java 11 / flink1:
https://github.com/apache/fluss/actions/runs/39205033760/job/117905902249?pr=4242
Observed in PR #4242, CI run `39205033760` (attempt 1, 2026-10-19), PR head `e8f8200f14315c2153900bdcb4e638e007e0eb92`, tested merge commit `4d8702cee717db6e0654eed6ecf83544694ae262`.
The first parameterized invocation uses `partitionTable=true`. The batch query expects five rows, but fails before producing any rows while generating splits and retrieving latest bucket offsets.
```
[ERROR] org.apache.fluss.flink.source.Flink120TableSourceBatchITCase.testScanFullPrimaryKeyTable(boolean)[1] Time elapsed: 0.213 s <<< ERROR!
java.lang.RuntimeException: Unexpected error after waiting 100 ms for Flink job results. Expected 5 records but got 0 before error occurred.
at org.apache.fluss.flink.source.testutils.FlinkRowAssertionsUtils.collectRowsWithTimeout(FlinkRowAssertionsUtils.java:198)
at org.apache.fluss.flink.source.testutils.FlinkRowAssertionsUtils.collectRowsWithTimeout(FlinkRowAssertionsUtils.java:105)
at org.apache.fluss.flink.source.testutils.FlinkRowAssertionsUtils.assertResultsIgnoreOrder(FlinkRowAssertionsUtils.java:60)
at org.apache.fluss.flink.source.FlinkTableSourceBatchITCase.testScanFullPrimaryKeyTable(FlinkTableSourceBatchITCase.java:304)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
```
Relevant exception chain:
```
Caused by: org.apache.fluss.exception.FlussRuntimeException: Failed to list offsets for table buckets: [0, 1, 2, 3] due to
at org.apache.fluss.client.initializer.BucketOffsetsRetrieverImpl.listOffsets(BucketOffsetsRetrieverImpl.java:96)
at org.apache.fluss.client.initializer.BucketOffsetsRetrieverImpl.latestOffsets(BucketOffsetsRetrieverImpl.java:56)
at org.apache.fluss.client.initializer.LatestOffsetsInitializer.getBucketOffsets(LatestOffsetsInitializer.java:39)
at org.apache.fluss.flink.source.enumerator.FlussOnlyBatchSplitGenerator.getBatchSnapshotAndLogSplits(FlussOnlyBatchSplitGenerator.java:133)
at org.apache.fluss.flink.source.enumerator.FlussOnlyBatchSplitGenerator.generatePrimaryKeyTableSplits(FlussOnlyBatchSplitGenerator.java:99)
at org.apache.fluss.flink.source.enumerator.FlussOnlyBatchSplitGenerator.generate(FlussOnlyBatchSplitGenerator.java:84)
at org.apache.fluss.flink.source.enumerator.FlinkSourceEnumerator.generateFlussOnlyBatchSplits(FlinkSourceEnumerator.java:781)
at org.apache.fluss.flink.source.enumerator.FlinkSourceEnumerator.lambda$startInBatchMode$1(FlinkSourceEnumerator.java:745)
at org.apache.flink.runtime.source.coordinator.ExecutorNotifier.lambda$notifyReadyAsync$2(ExecutorNotifier.java:80)
Caused by: org.apache.fluss.exception.NotLeaderOrFollowerException: Leader not local for bucket TableBucket{tableId=14, partitionId=9, bucket=0} on tabletServer 2
```
[Parameterized test in the tested source](https://github.com/apache/fluss/blob/4d8702cee717db6e0654eed6ecf83544694ae262/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/source/FlinkTableSourceBatchITCase.java#L267).
### Investigation
Investigate leader readiness and offset lookup during batch split generation for a newly created partitioned primary-key table. The log establishes the `NotLeaderOrFollowerException`; it does not establish the underlying timing or metadata cause.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@fluss.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] [test] Unstable test Flink120TableSourceBatchITCase.testScanFullPrimaryKeyTable [fluss]
Posted by "wuchong (via GitHub)" <gi...@apache.org>.
wuchong commented on issue #4723:
URL: https://github.com/apache/fluss/issues/4723#issuecomment-6260797705
cc @loserwang1024
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@fluss.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org