如何解决Apache Nifi错误-由于未捕获的异常,以管理方式产生了ConvertJSONToSQL:java.lang.NullPointerException
在使用ConvertJsonToSql处理器时,在Nifi中出现以下错误,它在以前工作正常。.它现在已经出了下面的问题。.我在下面粘贴了错误日志。
2020-09-24 04:22:25,506警告:由于未捕获的异常,[计时器驱动的进程线程10] oancontroller.tasks.ConnectableTask可管理地产生ConvertJSONToSQL [id = 0174112e-bfbd-11a5-5dae-da245b5c6980]: java.lang.NullPointerException java.lang.NullPointerException:空 在org.apache.nifi.processors.standard.ConvertJSONToSQL $ ColumnDescription.from(ConvertJSONToSQL.java:916) 在org.apache.nifi.processors.standard.ConvertJSONToSQL $ TableSchema.from(ConvertJSONToSQL.java:853) 在org.apache.nifi.processors.standard.ConvertJSONToSQL.lambda $ onTrigger $ 0(ConvertJSONToSQL.java:318) 在com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda $ doComputeIfAbsent $ 14(BoundedLocalCache.java:2039) 在java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1853) 在com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2037) 在com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2020) 在com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:112) 在com.github.benmanes.caffeine.cache.LocalManualCache.get(LocalManualCache.java:54) 在org.apache.nifi.processors.standard.ConvertJSONToSQL.onTrigger(ConvertJSONToSQL.java:315) 在org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) 在org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1176) 在org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:213) 在org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent $ 1.run(TimerDrivenSchedulingAgent.java:117) 在org.apache.nifi.engine.FlowEngine $ 2.run(FlowEngine.java:110) 在java.util.concurrent.Executors $ RunnableAdapter.call(Executors.java:511) 在java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) 在java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.access $ 301(ScheduledThreadPoolExecutor.java:180) 在java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) 在java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) 在java.util.concurrent.ThreadPoolExecutor $ Worker.run(ThreadPoolExecutor.java:624) 在java.lang.Thread.run(Thread.java:748)
有人能让我知道为什么会发生这种情况吗,输入文件实际上来自Mysql binlog,它是使用JoltTransformation进行转换的...在进入ConvertJsonToSql处理器之前,流文件看起来如下图所示。
流文件: [{“ id”:82,“ gender”:“ M”,“ age”:23}]
我们将不胜感激。
谢谢
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。