xhh0168 commented on issue #5471:
URL: https://github.com/apache/seatunnel/issues/5471#issuecomment-1720425131
> > > > allow.null = true this parameter does not take effect. How to solve？
> > >
> > >
> > > What is the parameter? Can you provide the source
> >
> >
> > See the parameter in this reply
> >
https:github.com/apache/seatunnel/pull/4972/files/5514928cc4aab3e2031dcb43c593f87677a6e43d#diff-0373bc329ca47400f03abf6766ac649d1e649947a7b189fe77c9c69cc9aa4213
>
> #4972 It is not merged, you need to wait for it to merge, if you need to
try ahead, you need to compile and pull the corresponding branch compilation
thanks , try later.
Another error message
ERROR
org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcherManager
- Received uncaught exception.
java.lang.RuntimeException: SplitFetcher thread 0 received unexpected
exception while polling the records
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:81)
~[?:?]
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_372]
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
~[?:1.8.0_372]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_372]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_372]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_372]
Caused by: java.lang.NullPointerException
at
org.apache.seatunnel.connectors.seatunnel.cdc.mongodb.source.fetch.MongodbFetchTaskContext.isRecordBetween(MongodbFetchTaskContext.java:156)
~[?:?]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.external.IncrementalSourceScanFetcher.isChangeRecordInChunkRange(IncrementalSourceScanFetcher.java:227)
~[?:?]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.external.IncrementalSourceScanFetcher.pollSplitRecords(IncrementalSourceScanFetcher.java:158)
~[?:?]
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:75)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.FetchTask.run(FetchTask.java:54)
~[?:?]
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:162)
~[?:?]
... 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]
