luoyuxia commented on PR #1774:
URL: https://github.com/apache/fluss/pull/1774#issuecomment-3350294172
> During the batch-mode union read test for log tables, an exception
occurred.
>
> ```
> 2025-09-30 06:17:05,276 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[35] -> Calc[36] ->
HashAggregate[37]' (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
> ```
Expected since we have to wait lake snapshot generated.
--
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]
