我正在集成Apache 1.9.2 (安全集群)和NiFi 3.1.4。HDP包含带有SASL身份验证(Kerberos)的Zookeeper 3.4.6。NiFi节点成功连接到此Zookeeper,同步流和日志心跳。 同时,使用Zookeeper的NiFi处理器无法连接。GenerateTableFetch抛出: org.apache.commons.dbcp.SQLNestedException: Cannot create PoolableConnectionFactory (Could not open client transport for any of the Server U
我无法使用sql server连接nifi,请帮助我获得以下错误。
Error
00:52:36 ISTERRORcf6cf1cb-0173-1000-1496-523d316e3cff
ExecuteSQL[id=cf6cf1cb-0173-1000-1496-523d316e3cff] ExecuteSQL[id=cf6cf1cb-0173-1000-1496-523d316e3cff] failed to process session due to Cannot invoke method public default java.sql.Connection org.apache.n
我正在扩展一个标准处理器来创建一个自定义的nifi处理器。这个项目构建得很好。但是,当我在将新生成的nar添加到lib/目录后重新启动nifi时,nifi无法启动NoclassDefFoundError:
java.lang.NoClassDefFoundError: org/apache/nifi/processor/util/list/AbstractListProcessor
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoad
我在我的nifi集群中看到了一些奇怪的错误,我有一个3节点安全的nifi集群,当我们在所有节点中部署2个节点时,我们有一些定制库nars,启动时没有任何问题,但在一个节点中,我看到了以下错误。
2017-04-20 23:43:34,516 ERROR [main] org.apache.nifi.NiFi Failure to launch NiFi due to java.lang.NoSuchMethodError: org.apache.nifi.processor.util.StandardValidators.createControllerServiceExistsValidat
我有Nifi 1.4.0和Hive 2.3.0。元存储服务运行正常,但由于某种原因,Nifi无法执行PutHiveStreaming处理器。
下面是完整的堆栈。对此有什么想法吗?
at org.apache.nifi.processors.hive.PutHiveStreaming.lambda$onHiveRecordsError$1(PutHiveStreaming.java:527)
at org.apache.nifi.processors.hive.PutHiveStreaming$$Lambda$392/1467727491.apply(Unknow
我想使用getFileSytem()来拉入任何比我们拥有的时间戳更新的文件,但我不能导入它(我的意思是getFileSytem())我有以下代码:
final FileSystem hdfs = getFileSystem();
final boolean recursive = context.getProperty(RECURSE_SUBDIRS).asBoolean();
final Set<FileStatus> statuses;
try {
final Path rootPath = new Path(directory);
statuses = ge
我已经编写了一个用于在BigQuery上执行某些任务的自定义NiFi处理器。我希望能够重用与NiFi捆绑在一起的GCP凭据提供者控制器服务,以用于身份验证。这个是可能的吗?我尝试将nifi-gcp-processors maven依赖项添加到我的项目中,它成功地构建了,但是当我尝试使用我的nar启动NiFi时,它失败了,并显示以下错误消息。
2017-12-14 05:09:27,406 ERROR [main] org.apache.nifi.NiFi Failure to launch NiFi due to java.util.ServiceConfigurationError: org
我尝试用Nifi更新Oracle数据库中的一些DB列。
我有这么一部分的电路:
我对上一次PutDatabaserecord有意见
nifi_ml_nifi.1.rb4f8g690fro@KoshDomain | 2021-07-12 17:34:20,919 ERROR [Timer-Driven Process Thread-2] o.a.n.p.standard.PutDatabaseRecord PutDatabaseRecord[id=017a10b4-fe2c-1b89-f752-67545ebb8406] Failed to put Records to data
我正在开发以下Nifi控制器服务包:
nifi-controllers-bundle nifi-controllersnifi-controllers-apinifi-controllers-narnifi-controllers-api-nar
我创建了一个自定义控制器服务(StandardMyService),它扩展了nifi控制器模块中的DBCPConnectionPool,当我尝试在UI中使用它时,我在日志中得到以下异常:ERROR [NiFi Web Server-36] o.a.nifi.controller.ExtensionBuilder Could not create Co
是否有可能在NiFi中执行impala操作?
我已经设置了一个连接到黑斑羚的DBCPConnectionPool,我可以在ExecuteSQL处理器上很好地执行select语句。
现在我想知道(如果可能的话)如何执行
Alter Table "X" recover partitions;
在Apache NiFi中
我已经安装了开放源码hadoop集群并使用了Nifi。当我每天早上检查服务状态时:状态如下。
INFO [main] org.apache.nifi.bootstrap.Command Apache NiFi is running at PID 23164
但是没有响应ping请求。
重新启动服务后:状态如下:它将在一天内正常工作。
INFO [main] org.apache.nifi.bootstrap.Command Apache NiFi is currently running, listening to Bootstrap on port YYYY, PID=XXXX
ERROR
我正在尝试用mvn archetype:generate在NiFi中实现一个自定义处理器,我想从org.apache.nifi.processors导入一个类(特别是standard.util.*),但它给了我错误(cannot be resolved)。
我目前的解决办法是复制我想要的包中的类,但是我应该做什么才能使它直接从nifi包中可见?我应该修改pom.xml吗?提前感谢
pom.xml的内容是由mvn archetype:generate命令生成的内容:
<project xmlns="http://maven.apache.org/POM/4.0.0" xml
我正在实现自定义NiFi处理器来解码一些文件。在解码过程中,我需要查找某些数据映射的外部CSV记录。注意,这个解码过程很复杂,所以它必须是一个自定义处理器。我知道可以设置外部CSVRecordLookupService,然后在CustomController中定义一个属性描述符,如下所示
public static final PropertyDescriptor CLIENT_LOOKUP_SERVICE =
new PropertyDescriptor.Builder()
.name("Client CSV L
我在Nifi中导入了一个新的OPCUA包。Here 这个处理器在一天多的时间里都读得很好,但后来我得到了这个错误: 2019-06-04 15:09:17,727 ERROR [Timer-Driven Process Thread-7] d.f.fit.processors.opcua.GetOPCData GetOPCData[id=1e5f35cf-3df7-1e7d-1521-5c8fe9fbd8f6] Failed to process session due to org.apache.nifi.processor.exception.ProcessException: java
我有一个扩展MergeContent进程的自定义处理器,当NiFi启动时,我在日志中看到以下错误:
2016-09-09 18:17:00,607 ERROR [main] org.apache.nifi.NiFi Failure to launch NiFi due to java.util.ServiceConfigurationError: org.apache.nifi.processor.Processor: Provider org.apache.nifi.processors.standard.DetectDuplicate could not be instantiated
j