Apache NiFi: InferAvroSchema将有符号值推断为字符串
Apache NiFi是一个开源的数据流处理和自动化工具，用于可视化、可编程地管理和处理数据流。它提供了一种简单而强大的方式来移动、转换和系统化数据，支持从各种来源（如传感器、日志文件、数据库等）收集数据，并将其传输到各种目标（如数据库、数据仓库、Hadoop集群等）。
InferAvroSchema是Apache NiFi中的一个处理器（Processor），用于将有符号值推断为字符串。在数据流处理中，有时候需要将数据从一种格式转换为另一种格式，而Avro是一种数据序列化系统，用于将数据进行结构化存储和传输。InferAvroSchema处理器可以根据输入数据的特征和模式，推断出数据中的有符号值，并将其转换为字符串类型。
该处理器的主要功能包括：
- 推断有符号值：根据输入数据的特征和模式，推断出数据中的有符号值。
- 转换为字符串类型：将推断出的有符号值转换为字符串类型，以便后续处理或存储。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云数据集成服务（Data Integration）：https://cloud.tencent.com/product/dts
- 腾讯云数据传输服务（Data Transmission Service）：https://cloud.tencent.com/product/dts
这些腾讯云产品提供了强大的数据集成和传输能力，可以与Apache NiFi结合使用，实现数据的高效处理和传输。
相关·内容
Apache v-1.7.1在AWS Centos机器上运行良好，但现在重新启动时引发错误：(在/nifi-app.log的内容下面)
org.apache.nifi:nifi-standard-nar:1.7.1 || ./work/nar/extensions/nifi-standard-nar-1.7.1.nar-unpacked
org.apache.nifi.processors.standard.FetchSFTP
org.apache.nifi:nifi-standard-nar:1.7.1 || ./work/nar/ex
浏览 2提问于2019-01-21得票数 6
回答已采纳
我试图加入两个不同的CSV的事情，其中有一个共同的专栏如下。
Csv1：(生成流程文件)
Emp_Id,Name,Address,Mobile_No
1,Name1,Add1,Mob1 2,Name2,Add2,Mob2
Csv2：(在CSVRecordLookupService配置中作为Lookup提供)
Emp_Id,Salary,Department
1,10k,dev
2,20k,mn
所需产出：
Emp_Id,Name,Address,Mobile_No,Salary,Department
1,Name1,Add1,Mob1,10k,dev
2,Name2,Add2,Mob2,20
浏览 17提问于2020-07-15得票数 1
回答已采纳
1回答
嗨，我是全新的docker和nifi，我需要在docker上设置nifi，但我收到以下错误。 下面的错误文本或(screenshot of error - on terminal) nifi01_1 | 2021-09-17 02:12:30,707 INFO [main] o.a.nifi.properties.NiFiPropertiesLoader Loaded 202 properties from /opt/nifi/nifi-current/./conf/nifi.properties
nifi01_1 | 2021-09-17 02:12:30,719 ERROR [m
浏览 259提问于2021-09-17得票数 1
如何在不访问apache nifi接口的情况下启动我创建的数据流。是否可以通过运行.bat文件来触发run？我是apache nifi的新手，对apache nifi的局限性一无所知。
我将数据流保存为模板，并希望在不访问apache nifi界面的情况下启动它。
浏览 0提问于2019-10-27得票数 0
在询问问题时，在csv文件中向BigQuery发送电子商务信息时出现了问题。在csv中，ORDER_DATE列的值应该进入BigQuery中的DATETIME类型列中的yyyy-MM-dd HH:mm:ss格式，试图在BigQuery上找到一些引用。
环境
Apache NiFi 1.14.0 on
Attempt1
将替换值策略选择为文字值，并将/ORDER_DATE添加为新字段。其价值如下：
${field.value:toDate('yyyyMMddhhmmss','GMT'):format('yyyy-MM-dd hh:mm:ss',
浏览 18提问于2022-01-17得票数 2
回答已采纳
我正在尝试使用NiFi的PutCassandraRecord处理器将一些JSON记录插入到Cassandra DB中。我试图将时间戳类型插入到Cassandra中，但是NiFi抱怨输入字符串"2019-02-02T08:00:00.000“的NumberFormatException。
所述时间戳字段的cassandra数据类型是(ts时间戳)我使用的Avro模式：{ "name"："ts"，" type "：{"type"："long"，"logicalType"：" timest
浏览 8提问于2019-05-14得票数 1
我只是尝试将Nifi UI作为本地实例启动，以便开始使用它。我已经解压了这个包，并确保将JAVA_HOME变量设置为我的Java1.8。当我尝试bin/run-nifi时，在我的nifi-app日志中，错误消息是：
2018-05-03 15:03:50,585 INFO [main] org.apache.nifi.NiFi Launching NiFi...
2018-05-03 15:03:52,330 INFO [main] o.a.nifi.properties.NiFiPropertiesLoader Determined default nifi.properties p
浏览 9提问于2018-05-04得票数 0
每当我重新启动NIFI应用程序时，我都会遇到NIFI 1.11.4的堆空间内存问题。初始bootstrap.conf was Xms4g to Xmx8g重启后，我们得到了java堆空间问题，所以我们已经增加到12 GB，它工作得很好。在1次重新启动后(5天内)，它不接受12 to作为最大大小，并且我们已将其更改为14 to，然后仅NIFI启动。有人能解释一下为什么NIFI每次重启都要求更多的内存吗？ ERROR [main] org.apache.nifi.NiFi Failure to launch NiFi due to java.lang.OutOfMemoryError: Ja
浏览 28提问于2021-04-20得票数 0
我正在尝试在Apache Nifi中设置一个简单的测试，以连接到现有的PostgreSQL实例。我可以使用dBeaver等其他工具在nifi之外进行连接，并且相当确定我的连接字符串是正确的。我尝试过将postgresql jdbc驱动程序放在所有地方，但仍然看到"No suitable“错误。我将包括我的DBCPConnectionPool控制器的一些屏幕截图以及我的堆栈跟踪。
我看过其他类似的帖子，但它们似乎都没有给我带来任何解决方案。任何帮助都是非常感谢的。
堆栈跟踪
19-11-05 23:50:09,933 ERROR [Timer-Driven Process Th
浏览 115提问于2019-11-06得票数 0
当UpdateAttribute添加的属性在表达式中发生异常时，有没有办法控制它的行为？ 我看到当流文件带着无效数据到达时，由UpdateAttribute处理器从表达式生成的ProcessException异常的连续流。根据我在文档中看到的，ProcessException被认为是可检索的，但在这种情况下，数据不会改变，并且没有办法限制尝试的次数。 报告的ProcessException是 2021-02-09 11:34:47,421 ERROR [Timer-Driven Process Thread-5] o.a.n.p.attributes.UpdateAttribute Upda
浏览 29提问于2021-02-09得票数 0
2回答
我试图在window 8机器上启动ApacheNifi1.2.0版本。开始的时候很正常。在我重新启动系统之后，nifi根本没有启动。我检查了状态，它的状态一直是“阿帕查·尼菲不跑”。
下面是来自nifi.bootstrap.log文件的日志：-
2017-07-05 15:41:57,105 WARN [NiFi Bootstrap Command Listener]
org.apache.nifi.bootstrap.RunNiFi Failed to set permissions so that only the
owner can read pid file E:\software
浏览 1提问于2017-07-05得票数 2
回答已采纳
2回答
我有以下的Json：
{"field1": "someText",
"field2": "Text Again",
"field3": "Text Again"}
我需要匹配以大写字母开头的任何短语的第一次出现(例如，“文本再次”)。
我写了以下几封信：
("[A-Za-z]+\s[A-Za-z]+")
例如，在用进行测试时，它确实工作得很好。但是，它似乎不能正确地作为 (Apache NiFi)使用的一部分。判决不正确吗？
谢谢你的帮助
浏览 3提问于2016-05-20得票数 2
回答已采纳
1回答
您好，我有一个Nifi docker容器停止，我想更新一个属性文件。
每当我更新一个字段时，当我运行docker-compose start时，它不会更新属性文件。
这怎么可能呢？
这是我的docker构图：
version: "3.3"
services:
nifi:
image: apache/nifi
volumes:
- /home/ubuntu/nifi/conf:/opt/nifi/nifi-current/conf
ports:
- "8080:8080"
谢谢
浏览 0提问于2019-09-10得票数 1
我们有一个使用ssl配置的Teiid12.3服务器正在运行。我们能够使用像pentaho etl、squirrel client、Tableau等工具连接这个teiid服务器，我们正在使用trustore文件连接这些工具。但是我们无法连接Apache NIfi中的Teiid服务器。我们尝试了以下方法来包括信任-
在运行的nifi.bat中添加trustore
- set JAVA\_ARGS=`-Dorg.apache.nifi.bootstrap.config.log.dir=%NIFI_LOG_DIR%` `-Dorg.apache.nifi.bootstrap.config.
浏览 5提问于2020-04-28得票数 0
1回答
如何在apache NiFi中将JSON转换为Avro？
也就是说，JSON是使用getTwitter获得的？
以前的版本似乎支持ConvertJSONToAvro。在我看来，现在应该使用convertRecord处理器：
例如，使用面向记录的处理来使用JSON树读取器读取JSON并将其写入Avro。但是，在哪里/如何指定架构呢？特别是对于这样一个复杂的模式，例如从Twitter获取。NiFi是否以某种方式自动猜测正确的模式？
编辑
事实上，一些相当明显的事情发生了：
ConvertRecord Failed to process StandardFlowFileRecord w
浏览 1提问于2020-06-11得票数 0
回答已采纳
如何在NiFi ValidateRecord processor / JsonRecordSetWriter中将时间戳序列化为Json字段。
在输入时，我有一个CSV文件，其中包含一个格式为yyyy-MM-dd HH:mm:ss.SSS的时间戳列。在我的NiFi流中，我有一个ValidateRecord处理器，它使用CSVReader进行读取，使用JsonRecordSetWriter作为编写器。它们都使用Avro模式，时间戳字段定义如下
"fields" : [ {
"name" : "timestamp",
"type
浏览 143提问于2018-10-19得票数 1
回答已采纳
我的python脚本中的代码：
import datetime
flowFile = session.get()
if flowFile is not None:
fltDt = flowFile.getAttribute('FLT_DT')
dateObj = datetime.datetime.strptime(fltDt, '%Y-%m-%d %H:%M:%S.%f')
weekday = dateObj.weekday() + 1
attrMap = {}
attrMap['WEEKDAY'] = wee
浏览 7提问于2017-07-16得票数 0
3回答
我正在使用Apache NiFi来摄取和预处理一些CSV文件，但是在长时间运行时，它总是失败的。错误总是相同的：
FlowFile Repository failed to update
在日志中搜索时，我总是看到以下错误：
2018-07-11 22:42:49,913 ERROR [Timer-Driven Process Thread-10] o.a.n.p.attributes.UpdateAttribute UpdateAttribute[id=c7f45dc9-ee12-31b0-8dee-6f1746b3c544] Failed to process session due to
浏览 0提问于2018-07-12得票数 6
回答已采纳
1回答
在将apache从1.13升级到1.18之后，我开始看到以下错误。此外，我还可以从使用该证书的流中看到webgui上的相同错误。
警告主要的不安全密码提供者算法PBEWITHMD5AND256BITAES-CBC-OPENSSL密码请求org.apache.nifi.deprecation.log.DeprecationException:参考类org.apache.nifi.security.util.crypto.NiFiLegacyCipherProvider ClassLoader [org.apache.nifi.nar.NarClassLoader./work/nar/framew
浏览 14提问于2022-11-03得票数 0
回答已采纳
1回答
我正试图使用"PutSQL“处理器来做到这一点。
我将流文件修改为使用"ReplaceText“并创建一个INSERT语句。我已经在MySQL数据库中测试了该语句，并且该语句工作正常。
以下是声明：
INSERT INTO monitor.security_nifi (RemoteIPAddress, Timestamp,RequestUrl, Status, Instance)
VALUES ('10.129.2.35', '2016-09-2016:44:16,347','/secure/Dashboard.jspa'
浏览 5提问于2016-09-21得票数 7
我正试图在我的Windows机器上本地构建Apache，方法是遵循以下说明：。
遇到以下问题：
未能在项目nifi-snmp-nar上执行目标:无法解决项目org.apache.nifi:nifi-snmp-nar:nar:0.7.0-SNAPSHOT:的依赖关系，在apache.snapshots () ->帮助中找不到工件org.apache.nifi:nifi-snmp-processors:jar:1.0.0-SNAPSHOT，有谁遇到过同样的问题吗？
浏览 3提问于2016-06-20得票数 1
我有Modbus TCP/IP格式的数据。我必须用Apache NiFi读取可用的数据。我不知道，确切地说哪个处理器必须使用(例如：GetTCP、ListenTCP、Plc4xSourceProcessor)。你能在这方面帮我吗？使用Apache NiFi是否可行？
浏览 123提问于2020-09-04得票数 1
回答已采纳
在我目前的项目中，我一直在使用apache进行一些实验。当我第一次配置好。nifi运行得非常完美(当我输入http://localhost:8080/nifi/时，我能够看到Google上的画布和工具栏)。但是，在重新启动计算机一次之后，我无法运行它。
当我输入nifi.0.7.0\bin\run-nifi.bat命令时，我会在控制台上看到以下消息。
2016-07-27 10:19:39,246 INFO [main] org.apache.nifi.bootstrap.Command Starting A
pache NiFi...
2016-07-27 10:19:39,246 INFO
浏览 4提问于2016-07-27得票数 6
我正在使用ExecuteSQL在NiFi上运行一个对Oracle12c的简单查询：
从DUAL；中选择1
配置- DBCPConnectionPool 1.11.4：
并得到以下错误：
org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Cannot create PoolableConnectionFactory (ORA-00933: SQL command not properly ended
)
at org.apache.nifi.dbcp.DBCPConnectionP
浏览 7提问于2020-11-27得票数 2
回答已采纳
我希望使用apache NiFi将一个处理器结果作为输入传递给另一个处理器。
我正在使用ExecuteSQL处理器.i从mysql中获取值，希望将此结果动态传递给apache nifi中的SelectHiveQL处理器。
浏览 1提问于2016-12-08得票数 0
我正在使用nifi构建一个数据流，其设置如下：
apache nifi 1.14.1
卡夫卡2.13-2.7.1
合流模式注册表
我还使用处理器ConsumeKafkaRecord_2_6处理来自一个主题的消息，在这个主题中，键和值都使用avro模式对键和值进行序列化，都存储在汇合模式注册表中。但是处理器无法解析消息，因为没有一种方法--我可以看到--指定键和值都是用存储在汇合模式注册表中的模式序列化的。命名架构的约定通常是主题名称-值和主题名称-键。使用kcat，以前使用kafkacat，我可以很好地读取消息：
kcat -b broker1:9092,broker2:9
浏览 16提问于2022-02-18得票数 0
回答已采纳
我有两个处理器：QueryDataBaseTable -> PutDatabaseRecord。
从Oracle经AvroReader到Postgresql。
这是来自Oracle的查询的结果
nmcl_id|assortment_id|nname |aname |modify_date |lo
浏览 2提问于2021-06-30得票数 1
回答已采纳
我正在寻找资源来配置Apache KNOXTOKEN服务，以访问Apache NIFI REST API。 我已经配置了KNOXSSO，并且能够通过它访问NIFI。但是，我找不到资源来通过Curl和JWT安全地访问NIFI REST服务。 感谢您的指点。
浏览 87提问于2019-01-31得票数 1
回答已采纳
我尝试使用一个非常简单的SQL查询来检索Oracle数据库中两个表的连接内容：
SELECT OWNER.CONTENT.ID, OWNER.CONTENT.TITLE, OWNER.BODYCONTENT.BODY
FROM OWNER.CONTENT, OWNER.BODYCONTENT
WHERE OWNER.CONTENT.ID = OWNER.BODYCONTENT.ID
AND OWNER.CONTENT.ID < 7
查询使用Oracle SQL Developer运行。
我在NiFi中使用ojdbc7.jar驱动程序。不包含联接的更简单的SQL查询使用"Exec
浏览 5提问于2016-05-03得票数 2
回答已采纳
2回答
我想使用https nginx代理运行在同一个框中的非安全nifi服务器。
到目前为止，我得到的最接近的方法是使用以下配置：
location ^~ /nifi {
proxy_set_header X-ProxyHost localhost;
proxy_set_header X-ProxyPort 6969;
proxy_set_header X-ProxyContextPath /nifi;
proxy_pass http://localhost:6969/nifi;
}
在nifi
浏览 0提问于2018-11-24得票数 1
我对apache/nifi很陌生，运行它时：
docker run --name nifi -p 8081:8080 -d apache/nifi:latest
然后拖了一些处理器。然后，我尝试使用以下方法将它们保存为新图像：
docker commit [container ID] apache/nifi:latest
但是，当我运行新提交的映像时，它不会保存更改。如果有任何错误，请通知我。提前谢谢。
更新
一开始，我推出了nifi，包括：
docker run --name nifi -p 8081:8080 -d apache/nifi:latest
这是我在web中添加的组：
浏览 0提问于2019-08-16得票数 2
回答已采纳
我遇到了一个NiFi写HDFS的问题。我收到一个错误：
ERROR [Timer-Driven Process Thread-10] o.apache.nifi.processors.hadoop.PutHDFS PutHDFS[id=4af43efa-a8ff-18ac-0000-00002377fba5] Failed to properly initialize Processor. If still scheduled to run, NiFi will attempt to initialize and run the Processor again after the &
浏览 0提问于2020-03-01得票数 1
我正在调试一个HiveProcessor，它遵循官方的PutHiveStreaming处理器，但是它写到Hive2.x，而不是3.x。该流在Nifi集群1.7.1中运行。尽管发生了这种异常，数据仍然被写入Hive。
例外是：
java.lang.NullPointerException: null
at org.apache.hadoop.hive.ql.security.authorization.plugin.AuthorizationMetaStoreFilterHook.getFilteredObjects(AuthorizationMetaStoreFilterHook.ja
浏览 0提问于2019-01-25得票数 0
回答已采纳
1回答
我在AWS上创建了一个NiFi集群。最初的部署运行良好。稍后，我将持久卷和持久卷声明附加到NiFi设置中。启动NiFi后，我将得到以下错误：
ERROR in ch.qos.logback.core.rolling.RollingFileAppender[USER_FILE] - openFile(/opt/nifi/nifi-current/logs/nifi-user.log,true) call failed. java.io.FileNotFoundException: /opt/nifi/nifi-current/logs/nifi-user.log (Permission deni
浏览 18提问于2022-02-03得票数 1
1回答
我正在运行mvn install和来自的建议mvn -T C2.0 clean install -Pinclude-grpc
这似乎是1.6.0快照依赖的一些问题。做-U也无济于事。
我从新的repo开始了很多次，它总是以失败告终。这是完整的-X日志
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------
浏览 17提问于2018-02-15得票数 0
回答已采纳
1回答
我已经知道如何编写自定义处理器(扩展org.apache.nifi.processor.AbstractProcessor)。我已经使用了这种技术，我很乐意创建自定义的org.apache.nifi.components.PropertyDescriptor & org.apache.nifi.processor.Relationship字段，以及重写onTrigger方法。此外，我知道如何设置构建、建立报表和创建我的.nar文件。
我还没有搞清楚的是，是否有一个合理的模式来扩展本地NiFi处理器。我希望扩展一个本机处理器，这样我就可以在新的Unit测试中使用我的扩展类(而不是其他类)
浏览 2提问于2018-07-11得票数 2
回答已采纳
我有一个自定义控制器服务，希望与ConnectWebSocket处理器一起使用。控制器服务依赖于nifi-websocket-services-api，不需要自定义接口( my-customer- controller - service -api文件夹为空)。我已经为控制器服务编写了一个测试，它正在通过测试。 但是，我不能选择控制器服务，因为ConnectWebSocket只接受来自nifi-websocket-service-api-nar的控制器服务api。 ? 我希望避免对整个ConnectWebSocket处理器进行重新编码。所以我的问题是： 是否可以配置依赖项，使我的自定
浏览 16提问于2019-04-23得票数 0
回答已采纳
2回答
我正面临着Apache NiFi日志记录方面的问题。NiFi是用Java编写的，并使用logback。
似乎所有的日志消息都以某种方式转移到了org.apache.nifi.StdOut日志记录器。下面是一个写入org.apache.nifi.StdOut的日志消息示例，但是应该已经到了名为org.eclipse.jetty.annotations.AnnotationParser的记录器那里
2022-09-21 14:21:17,316 INFO [NiFi logging handler] org.apache.nifi.StdOut 14:21:17.316 [NiFi Web Ser
浏览 14提问于2022-09-21得票数 0
我想使用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
浏览 2提问于2017-11-01得票数 1
我正在尝试升级到Apache，从1.9.2升级到1.12.1，无论我如何调整属性文件，我都会收到关于NiFi的错误。升级前我跑得很好。我能够使用keytool打开jks文件并输出其中的键。升级添加了信任库、truststoreType和truststorePasswd行，但是删除它们、填充它们等不会改变结果。如果有人知道一些明确的步骤，解决这个问题(要运行的命令等等)我会很感激的。
nifi.properties:
keystore.jks和truststore.jks文件都在conf文件夹中。
nifi.security.keystore=keystore.jks
nifi.security
浏览 5提问于2020-12-26得票数 4
回答已采纳
1回答
从Nifi消费Rest
、、、、
下面是我使用安全rest的nifi工作。
当我运行invokeHttp处理器时，我会得到以下异常：
2017-09-19 07:58:59,744 ERROR [Timer-Driven Process Thread-3] o.a.nifi.processors.standard.InvokeHTTP
java.lang.NullPointerException: null
at org.apache.nifi.processors.standard.InvokeHTTP.setHeaderProperties(InvokeHTTP.java:859) ~[nifi-
浏览 1提问于2017-09-20得票数 1
我已经创建了一个使用jackson json库的自定义处理器，单元测试运行良好。
我对构建哪个项目/模块来创建目标nar有点困惑。
处理器(Maven)项目的pom.xml是：
<?xml version="1.0" encoding="UTF-8"?>
<!-- Licensed to the Apache Software Foundation (ASF) under one or more contributor
license agreements. See the NOTICE file distributed with this
浏览 17提问于2017-03-07得票数 1
回答已采纳
我需要Apache安全集群配置方面的帮助。
我的目的是创建Nifi安全集群，并使用ldap管理登录帐户和策略。
首先，我只使用ldap-用户组提供程序，但它不能工作。Web中的错误消息是
Insufficient Permissions
Untrusted proxy CN=nifi, OU=NIFI
然后，我将我的authorizers.xml修改为复合用户组提供者，使其成为下面的post参考web日志。错误消息更改为
Unable to locate node CN=nifi, OU=NIFI to seed policies
我部署的步骤是：
我使用nifi-toolkit.sh生成证书
浏览 6提问于2022-03-15得票数 0
最近，我创建了一个Nifi映像，以便能够使用我的自定义配置和状态运行一个nifi对接程序。
一切正常，但是过了一段时间，我收到了以下错误：
2019-04-08 10:42:26,107 ERROR [Timer-Driven Process Thread-10] o.a.n.c.r.StandardProcessSession Failed to commit session java.lang.IllegalStateException: Cannot update journal file ./flowfile_repository/journals/449486.journal bec
浏览 0提问于2019-04-08得票数 4
回答已采纳
我正在集成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
浏览 93提问于2021-03-17得票数 0
回答已采纳
我看到NiFi偶尔会被重启。在nifi-app.log中，没有错误的指示。NiFi没有处理任何数据，服务器此时不忙。当我在nifi-bootstrap.log中看到时，我看到 2021-06-17 16:44:00,551 DEBUG [main] org.apache.nifi.bootstrap.RunNiFi Status File: /opt/nifi-1.10.0/run/nifi.status
2021-06-17 16:44:00,551 DEBUG [main] org.apache.nifi.bootstrap.RunNiFi Status File: /opt/nif
浏览 37提问于2021-06-18得票数 0
回答已采纳
2回答
我正在使用apache-nifi，除非在配置文件中使用公共DNS名称，否则在启动web服务器时，我似乎无法绑定到某个地址。使用DNS名称解析为的IP地址无效。同样，使用在/etc/hosts中分配的主机别名也不起作用。在每种情况下，我都在nifi日志中看到jetty抛出的异常，说明它不能分配请求的地址。
已经没有任何监听端口的内容了，正如netstat所验证的那样，并且当我使用DNS名称时，没有错误绑定到地址。这是故意的还是我做错了什么？
下面是我配置的详细信息。(实际上，我正在运行一个nifi集群，嵌入式动物园管理员也无法绑定IP地址或主机别名，但是可以使用DNS名称。因为如果我使用单个ni
浏览 4提问于2017-09-15得票数 1
回答已采纳
开始与Nifi合作，这是我的第一次练习。
因此，试图将csv文件放在Postgres表中。我定义了我的数据库驱动程序，如图所示。
错误是：
无法加载jdbc驱动程序类
在我的日志文件中，我有一条消息：
ERROR [StandardProcessScheduler Thread-1] o.a.n.c.s.StandardControllerServiceNode DBCPConnectionPool[id=c25f8f91-0161-1000-a496-8910832bdbd8] F$
org.apache.nifi.reporting.InitializationException:
浏览 0提问于2018-02-26得票数 4
我正在实现自定义NiFi处理器来解码一些文件。在解码过程中，我需要查找某些数据映射的外部CSV记录。注意，这个解码过程很复杂，所以它必须是一个自定义处理器。我知道可以设置外部CSVRecordLookupService，然后在CustomController中定义一个属性描述符，如下所示
public static final PropertyDescriptor CLIENT_LOOKUP_SERVICE =
new PropertyDescriptor.Builder()
.name("Client CSV L
浏览 4提问于2021-04-05得票数 2
回答已采纳
3回答
我面临着使用Nifi 处理器将时间戳插入到PostgreSQL数据库中的问题。
更具体地说，当尝试在时间戳列中插入“2018-01-31T19:01:09+00:00”格式的日期时，我会收到以下错误消息：
2018-04-01 19:29:40,091 ERROR [Timer-Driven Process Thread-5] o.apache.nifi.processors.standard.PutSQL PutSQL[id=7997503a-0162-1000-ee81-a0361cad5e0c] Failed to update database for StandardFlowFile
浏览 1提问于2018-04-02得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
