如题,近期公司做的报表项目有用到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.