Jepson created FLINK-34253:
------------------------------
Summary: Offsets out of range with no configured reset policy for
partitions
Key: FLINK-34253
URL: https://issues.apache.org/jira/browse/FLINK-34253
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.14.4
Environment: flink 1.14.4
Reporter: Jepson
java.lang.RuntimeException: SplitFetcher thread 0 received unexpected exception
while polling the records at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:150)
~[flink-table_2.12-1.14.4.jar:1.14.4] at
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105)
[flink-table_2.12-1.14.4.jar:1.14.4] at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_241] at java.util.concurrent.FutureTask.run(FutureTask.java:266)
[?:1.8.0_241] at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_241] at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_241] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_241] Caused by:
org.apache.kafka.clients.consumer.OffsetOutOfRangeException: Offsets out of
range with no configured reset policy for partitions: {dp-oracle-sllv-0=12734616
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
