beryllw commented on PR #1774:
URL: https://github.com/apache/fluss/pull/1774#issuecomment-3350215714
During the batch-mode union read test for log tables, an exception occurred.
```
025-09-30 06:16:16,243 ERROR
org.apache.flink.runtime.source.coordinator.SourceCoordinatorContext [] -
Exception while handling result from async call in SourceCoordinator-Source:
fluss_order_log[5]. Triggering job failover.
org.apache.flink.util.FlinkRuntimeException: Failed to list splits for
fluss.fluss_order_log to read due to
at
org.apache.fluss.flink.source.enumerator.FlinkSourceEnumerator.handleSplitsAdd(FlinkSourceEnumerator.java:629)
~[fluss-flink-1.20-0.8-SNAPSHOT.jar:0.8-SNAPSHOT]
at
org.apache.flink.runtime.source.coordinator.ExecutorNotifier.lambda$null$1(ExecutorNotifier.java:83)
~[flink-dist-1.20.0.jar:1.20.0]
at
org.apache.flink.util.ThrowableCatchingRunnable.run(ThrowableCatchingRunnable.java:40)
[flink-dist-1.20.0.jar:1.20.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
[?:?]
at java.util.concurrent.FutureTask.run(Unknown Source) [?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown
Source) [?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
[?:?]
at java.lang.Thread.run(Unknown Source) [?:?]
Caused by: java.lang.UnsupportedOperationException: Currently, Batch mode
can only be supported if one lake snapshot exists for the table.
at
org.apache.fluss.flink.source.enumerator.FlinkSourceEnumerator.lambda$startInBatchMode$0(FlinkSourceEnumerator.java:289)
~[fluss-flink-1.20-0.8-SNAPSHOT.jar:0.8-SNAPSHOT]
at
org.apache.flink.runtime.source.coordinator.ExecutorNotifier.lambda$notifyReadyAsync$2(ExecutorNotifier.java:80)
~[flink-dist-1.20.0.jar:1.20.0]
... 6 more
2025-09-30 06:16:16,247 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Trying to recover from a global failure.
org.apache.flink.util.FlinkException: Global failure triggered by
OperatorCoordinator for 'Source: fluss_order_log[5] -> Calc[6] ->
HashAggregate[7]' (operator cbc357ccb763df2852fee8c4fc7d55f2).
at
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder$LazyInitializedCoordinatorContext.failJob(OperatorCoordinatorHolder.java:651)
~[flink-dist-1.20.0.jar:1.20.0]
at
org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$QuiesceableContext.failJob(RecreateOnResetOperatorCoordinator.java:259)
~[flink-dist-1.20.0.jar:1.20.0]
at
org.apache.flink.runtime.source.coordinator.SourceCoordinatorContext.failJob(SourceCoordinatorContext.java:432)
~[flink-dist-1.20.0.jar:1.20.0]
at
org.apache.flink.runtime.source.coordinator.SourceCoordinatorContext.handleUncaughtExceptionFromAsyncCall(SourceCoordinatorContext.java:445)
~[flink-dist-1.20.0.jar:1.20.0]
at
org.apache.flink.util.ThrowableCatchingRunnable.run(ThrowableCatchingRunnable.java:42)
~[flink-dist-1.20.0.jar:1.20.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
~[?:?]
at java.util.concurrent.FutureTask.run(Unknown Source) ~[?:?]
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown
Source) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
~[?:?]
at java.lang.Thread.run(Unknown Source) ~[?:?]
Caused by: org.apache.flink.util.FlinkRuntimeException: Failed to list
splits for fluss.fluss_order_log to read due to
at
org.apache.fluss.flink.source.enumerator.FlinkSourceEnumerator.handleSplitsAdd(FlinkSourceEnumerator.java:629)
~[fluss-flink-1.20-0.8-SNAPSHOT.jar:0.8-SNAPSHOT]
at
org.apache.flink.runtime.source.coordinator.ExecutorNotifier.lambda$null$1(ExecutorNotifier.java:83)
~[flink-dist-1.20.0.jar:1.20.0]
at
org.apache.flink.util.ThrowableCatchingRunnable.run(ThrowableCatchingRunnable.java:40)
~[flink-dist-1.20.0.jar:1.20.0]
... 6 more
Caused by: java.lang.UnsupportedOperationException: Currently, Batch mode
can only be supported if one lake snapshot exists for the table.
at
org.apache.fluss.flink.source.enumerator.FlinkSourceEnumerator.lambda$startInBatchMode$0(FlinkSourceEnumerator.java:289)
~[fluss-flink-1.20-0.8-SNAPSHOT.jar:0.8-SNAPSHOT]
at
org.apache.flink.runtime.source.coordinator.ExecutorNotifier.lambda$notifyReadyAsync$2(ExecutorNotifier.java:80)
~[flink-dist-1.20.0.jar:1.20.0]
... 6 more
```
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
