Kettle 8.3并行执行作业时偶现NullPointerException问题咨询

环境信息 #

• Pentaho版本：8.3.0.0-371

问题描述 #

并行执行作业时存在概率性空指针异常，会直接导致进程退出；但串行执行作业时无任何异常。

作业结构 #

转换节点执行完成后，并行启动多个工作节点，各工作节点之间无依赖关系，但都会读取转换节点中生成的变量，所有节点执行完成后统一进入「成功」节点结束作业。

错误堆栈信息 #

Caused by: org.pentaho.di.core.exception.KettleException: 
Unexpected error occurred while launching entry [成功.0]
 at java.lang.Thread.run (Thread.java:748)
 at org.pentaho.di.job.Job$1.run (Job.java:804)
 at org.pentaho.di.job.Job.access$000 (Job.java:121)
 at org.pentaho.di.job.Job.execute (Job.java:827)
 at org.pentaho.di.job.Job.execute (Job.java:632)
 at org.pentaho.di.base.AbstractMeta.disposeEmbeddedMetastoreProvider (AbstractMeta.java:2054)
 at org.pentaho.di.core.vfs.KettleVFS.closeEmbeddedFileSystem (KettleVFS.java:545)
 at org.pentaho.di.core.vfs.ConcurrentFileSystemManager.closeEmbeddedFileSystem (ConcurrentFileSystemManager.java:192)
 at org.pentaho.big.data.impl.vfs.hdfs.nc.NamedClusterProvider.closeFileSystem (NamedClusterProvider.java:196)
 at Proxyc5a58d92_3c85_4859_80e8_ab5b48556ae0.getExplicitMetastore (null:-1)
 at Proxyf7ed1ece_9270_4b74_90cb_3dc57fc39287.getExplicitMetastore (null:-1)
 at org.pentaho.osgi.metastore.locator.api.impl.MetastoreLocatorImpl.getExplicitMetastore (MetastoreLocatorImpl.java:39)
 at org.pentaho.osgi.blueprint.collection.utils.ServiceMap.getItem (ServiceMap.java:35)
    at org.pentaho.di.job.Job.execute(Job.java:830)
    at org.pentaho.di.job.Job.access$000(Job.java:121)
    at org.pentaho.di.job.Job$1.run(Job.java:804)
    ... 1 more
Caused by: java.lang.NullPointerException
    at org.pentaho.osgi.blueprint.collection.utils.ServiceMap.getItem(ServiceMap.java:35)
    at org.pentaho.osgi.metastore.locator.api.impl.MetastoreLocatorImpl.getExplicitMetastore(MetastoreLocatorImpl.java:39)
    at Proxyf7ed1ece_9270_4b74_90cb_3dc57fc39287.getExplicitMetastore(Unknown Source)
    at Proxyc5a58d92_3c85_4859_80e8_ab5b48556ae0.getExplicitMetastore(Unknown Source)
    at org.pentaho.big.data.impl.vfs.hdfs.nc.NamedClusterProvider.closeFileSystem(NamedClusterProvider.java:196)
    at org.pentaho.di.core.vfs.ConcurrentFileSystemManager.closeEmbeddedFileSystem(ConcurrentFileSystemManager.java:192)
    at org.pentaho.di.core.vfs.KettleVFS.closeEmbeddedFileSystem(KettleVFS.java:545)
    at org.pentaho.di.base.AbstractMeta.disposeEmbeddedMetastoreProvider(AbstractMeta.java:2054)
    at org.pentaho.di.job.Job.execute(Job.java:632)
    at org.pentaho.di.job.Job.execute(Job.java:827)
    ... 3 more
2023/09/10 14:03:29 - Kitchen - Finished!
2023/09/10 14:03:29 - Kitchen - ERROR (version 8.3.0.0-371, build 8.3.0.0-371 from 2019-06-11 11.09.08 by buildguy) : Finished with errors
2023/09/10 14:03:29 - Kitchen - Start=2023/08/31 09:55:14.915, Stop=2023/09/10 14:03:29.946
2023/09/10 14:03:29 - Kitchen - Processing ended after 10 days, 4 hours, 8 minutes and 15 seconds (878895 seconds total).

内容的提问来源于stack exchange，提问作者bigdou