相关文章推荐
打篮球的煎饼  ·  JS ...·  1 年前    · 
兴奋的蘑菇  ·  [路由器] ...·  1 年前    · 

如题,近期公司做的报表项目有用到Kettle导数据到Elastic,然后用唯品会的Saturn定时调度kettle job文件进行增量导数据。

在java调用job文件时,报Can't run transformation due to plugin missing  错误初始化步骤 ElasticSearch Bulk Insert,

在网上找解决方法时,stackoverflow里有完整的 解决方法

以上意思是在Kettle环境初始化前,增加plugins。new PluginFolder("xxx/xxx/xxx")此处为kettle安装目录下的plugins文件夹,当然我kettle文件只用到elasticsearch-bulk-insert-plugin插件,那就可以只add (new PluginFolder("/home/data-integration/plugins/elasticsearch-bulk-insert-plugin"))。

同理,此方法可解决其他插件缺失错误。

java 调用 kettle 出现Can't run transformation due to plugin missing 我在项目中遇到的是xml的插件找不到,需要单独加上上图框起来的这句话,注意这段代码: Step Plugin Type.getInstance().get Plugin ... 解决 java 调用 kettle ,JSON input 缺少依赖问题 我用 kettle 工具创建了一个转换文件.ktr,其中包含一个json input组件, 本地执行ktr文件能正常转换数据。当使用 java 代码 调用 ktr文件 错:Can’t run transformation due to plugin missing 本地 调用 解决 方案 百度得到的 解决 办法基本差不多,在初始化代码 Kettle Environment.init();前增加一行引入依赖的代码: Step Plugin Type.getIn 在项目中,我们通常把 kettle 通过api的方式放到后台运行,很多人碰见了 kettle plugin s下的插件怎么加载。    下面我给大家讲一下怎么加载 plugin s插件。    在执行ktr的 候,设置一下变量即可。如下    String KETTLE _ PLUGIN _BASE_FOLDER = "D:\\pdi-ce-7.0.0.0-25\\data-integration\\plug springboot整合 kettle 实现数据处理导入jar包pom.xml配置 Kettle Controller. java 配置 解决 缺少jar包org.mozilla. java script. Java ScriptExceptionorg.apache.commons.codec.binary.Base64org.scannotation.AnnotationDBorg/apache/log4j/Logger代码 错Can't run transformation due to plugin missing 运行 2022/03/22 15:04:58 - JSON input.0 - ERROR (version 8.3.0.0-371, build 8.3.0.0-371 from 2019-06-11 11.09.08 by buildguy) : Can't run transformation due to plugin missing [ERROR][2022-03-22T15:04:58.073+0800][init of JSON input.0 (Thread-87)] org.pe export JAVA _HOME=/usr/ java /jdk1.8.0_144/ export JRE_HOME=${ JAVA _HOME}/jre export CLASSPATH=.:${ JAVA _HOME}/lib:${JRE_HOME}/lib export PATH=${ JAVA _HOME}/bin:$PATH currTime=$(date "+%Y-%m-%d") panName="t_" logName=$panName${currTime}.log 第一次写博客,没经验,比较乱,抱歉!下面步入正文。 使用 kettle 版本为8.2,开始 使用7.1但是7.1中写 java 代码片段 出现不少问题,换成8.2问题都消失了。 jar包问题(缺少jar包,jar包版本低) kettle 插件问题 package com.code; import org.pentaho.di.core. Kettle Envi... // 初始化 KETTLE _JSON_ PLUGIN 插件在 kettle 目录下/ plugin s的路径 Step Plugin Type.getInstance().get Plugin Folders().add(new Plugin Folder( KETTLE _JSON_ PLUGIN , false, true)); Kettle Environment.init(); --- 错2022/07/08 16:12:14 - General - ERROR (version 9.3.0.0-428, build 9.3.