-
Notifications
You must be signed in to change notification settings - Fork 53
Description
source:mongodb4.0
use debezium,already load data into kafka ,and output stand json
but in bireme into greenplum ,raise the error:
4:59:14 INFO Bireme - start Bireme daemon.
14:59:14 INFO Bireme - Start getting metadata of target tables from target database.
14:59:14 INFO class cn.hashdata.bireme.GetPrimaryKeys - MySQL、Greenplum table check completed, the state is okay!
14:59:14 INFO class cn.hashdata.bireme.GetPrimaryKeys - Greenplum table primary key check is completed, the state is okay!
14:59:14 INFO Bireme - Finish getting metadata of target tables from target database.
14:59:14 INFO Bireme - Start establishing connections for loaders.
14:59:14 INFO Bireme - Finishing establishing 1 connections for loaders.
14:59:15 INFO Debezium-mongogp-mongogp.case.JudgementReferenceClosure - Create new Debezium PipeLine. Name: Debezium-mongogp-mongogp.case.JudgementReferenceClosure
14:59:15 INFO Scheduler - Scheduler start working.
15:01:26 ERROR Debezium-mongogp-mongogp.case.JudgementReferenceClosure - Dispatch failed. Message: Transform failed.
15:01:26 ERROR Debezium-mongogp-mongogp.case.JudgementReferenceClosure - Stack Trace:
cn.hashdata.bireme.BiremeException: Transform failed.
at cn.hashdata.bireme.Dispatcher.dispatch(Dispatcher.java:60) ~[bireme-2.0.0-alpha-1.jar:?]
at cn.hashdata.bireme.pipeline.PipeLine.startDispatch(PipeLine.java:150) [bireme-2.0.0-alpha-1.jar:?]
at cn.hashdata.bireme.pipeline.PipeLine.executePipeline(PipeLine.java:106) [bireme-2.0.0-alpha-1.jar:?]
at cn.hashdata.bireme.pipeline.PipeLine.call(PipeLine.java:87) [bireme-2.0.0-alpha-1.jar:?]
at cn.hashdata.bireme.pipeline.PipeLine.call(PipeLine.java:39) [bireme-2.0.0-alpha-1.jar:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_191]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_191]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_191]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_191]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_191]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191]
Caused by: java.lang.NullPointerException
at cn.hashdata.bireme.pipeline.DebeziumPipeLine$DebeziumTransformer$DebeziumRecord.(DebeziumPipeLine.java:237) ~[bireme-2.0.0-alpha-1.jar:?]