NiFi ConvertAvroToParquet IllegalArgumentException您不能多次调用toBytes()而不调用reset()
NiFi是一个开源的数据流处理工具，用于可靠、可扩展、可管理的数据流处理。它提供了直观且功能强大的图形界面，可以用于构建、调试和管理数据流。NiFi支持将数据从各种来源收集、路由、转换和传输到各种目标系统。
在NiFi中，ConvertAvroToParquet是一个处理器（Processor），用于将Avro格式的数据转换为Parquet格式。Avro是一种数据序列化系统，Parquet是一种列式存储格式，通常用于大规模数据分析。ConvertAvroToParquet处理器接收Avro格式的数据流，并将其转换为Parquet格式的数据流，以便更高效地进行数据存储和分析。
然而，当使用ConvertAvroToParquet处理器时，如果多次调用toBytes()方法而不调用reset()方法，就会引发IllegalArgumentException异常。这是因为toBytes()方法会将Avro数据转换为字节数组，而不调用reset()方法则没有重置处理器的状态，导致重复调用toBytes()方法时出现错误。
为了解决这个问题，应该在每次调用toBytes()方法之后调用reset()方法，以确保处理器的状态被正确重置。这样可以避免重复调用toBytes()方法而导致异常。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云数据集成（Data Integration）：https://cloud.tencent.com/product/dci
- 腾讯云大数据分析（Data Analytics）：https://cloud.tencent.com/product/dca
- 腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos
- 腾讯云数据仓库（CDW）：https://cloud.tencent.com/product/cdw
请注意，以上仅为示例链接，实际使用时应根据具体需求和情况选择适合的产品和服务。
相关·内容
我无法使用ConvertAvroToParquet将3.7 am的avro文件转换为拼图格式。 我的设置是: ExecuteSQL 1.10.0 > ConvertAvroToParquet 1.10.0 > PutS3Object 1.10.0。 默认情况下ConvertAvroToParquet设置为。 2020-09-24 20:54:40,534 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWr
浏览 182提问于2020-09-25得票数 0
我的问题是，Nifi无法完成它的启动。大约40岁以后，运行nifi.bat设置的CMD窗口消失了。所以GUI不连接，我不能更改属性。有人知道我是否可以在某个地方编辑一个文件来更改属性，这样Nifi就可以启动了？如果是的话，文件在哪里？这是nifi-app.log中的突出行：
org.apache.nifi.controller.serialization.FlowSynchronizationException: java.lang.IllegalArgumentException:不能将组件b480dc3c-0173-1000-fd71-482c5a9f 6526的并发任务设置为0，因为调度
浏览 0提问于2020-08-24得票数 0
回答已采纳
1回答
你能告诉我，有没有办法把视频流传输到Nifi上？我使用Nifi "ExecuteProcess“来运行python和OpenCV来捕获视频流，但我不能制作多个流文件。我的程序运行python代码，然后将所有捕获的帧放入一个流文件中。因为我想在直播视频上使用YOLOV3进行分析，所以我希望每个帧都在不同的流文件中。代码如下所示。我的程序使用"ExecuteProcess“运行python代码，当程序完成时，它将输出控制台上的所有内容存储到一个流文件中，但我需要多个流文件。 如果有更好的方式使用Nifi获取视频直播，请分享它。 import cv2
cap = cv2.Vide
浏览 23提问于2020-09-11得票数 0
我目前正在尝试让NiFi启动并运行，它现在正在自行初始化，但我不太确定如何解决这些异常。我的第一个猜测是，我没有正确设置PATH变量，并且NiFi不能访问所有java。我知道第二个异常只是因为第一个，但我仍然不确定是什么参数导致了标志。
第一个例外：
2016-05-26 09:07:54,029 WARN [main] org.eclipse.jetty.webapp.WebAppContext Failed startup of context o.e.j.w.WebAppContext@6dcc40f5{/nifi,file:/home/devin/example-nifi-deploy
浏览 1提问于2016-05-26得票数 0
4回答
我对AS400和RPG的了解非常有限。但是我们有一个迫切的需求，那就是我们需要从java类调用RPG程序。所以我发现我们可以通过JTOpen来实现它。但是我被困在声明ProgramParameter列表上。我有以下关于RPG计划的信息
程序名称: ZM30000R参数:分支7,0 (数字)
帐户类型2(01-支票，02储蓄)
账号20 (字符)
错误代码7(字符) DR/CR指示器1(字符D、C)
但是没有关于什么是用于声明ProgramParameter的输入和输出.How的线索。我已经做了如下工作。我也不能测试，因为我没有连接到这些系统。
// Create AS400 Text obje
浏览 4提问于2010-01-21得票数 0
回答已采纳
检查代码时，会将错误抛出到需要转换为avro架构的未定义数据类型上。然而，我选择的唯一一列是NVARCHAR(5000)类型，它在代码中。
2017-04-21 01:33:51,446警告定时器驱动的进程线程-1 o.a.n.c.t.ContinuallyRunProcessorTask java.lang.IllegalArgumentException: createSchema:未知SQL类型2011不能转换为Avro类型在org.apache.nifi.processors.standard.util.JdbcCommon. ~na:na在org.apache.nifi.proces
浏览 3提问于2017-04-21得票数 0
回答已采纳
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
我似乎无法创建一个定制的DistributedMapCacheClientService (名为TestDistributedMapCacheClientService)，以供股票nifi处理器(例如等待和PutDistributedMapCache)使用。我能够让等待和PutDistributedMapCache看到我的定制服务，但是处理器无法启动，因为nifi说我的nar“与AtomicDistributedMapCacheClient不兼容”。
public class TestDistributedMapCacheClientService extends AbstractContro
浏览 0提问于2020-01-24得票数 2
我想使用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
我想使用下面的yaml文件使用docker部署一个NiFi集群：
version: "3"
services:
zookeeper:
hostname: zookeeper
container_name: zookeeper
image: 'bitnami/zookeeper:latest'
environment:
- ALLOW_ANONYMOUS_LOGIN=yes
nifi:
image: apache/nifi:1.12.0-SNAPSHOT-dockermaven
ports:
浏览 11提问于2022-03-04得票数 1
回答已采纳
我想扫描一个hbase表，我的代码如下。
public void start() throws IOException {
SparkConf conf = new SparkConf().setAppName("Simple Application");
JavaSparkContext sc = new JavaSparkContext(conf);
Configuration hbaseConf = HBaseConfiguration.create();
Scan scan = new Scan();
scan.setStartRow(Bytes.toBytes(
浏览 0提问于2015-03-02得票数 1
1回答
我想通过NIFI在GCP大查询中存储一些日期，我尝试了很多次，但是我在NIFI中有一个错误
我想这是许可错误，但我是主人。所以我不太明白。
浏览 4提问于2022-03-10得票数 0
回答已采纳
2回答
INFO [main] org.apache.nifi.bootstrap.Command Apache NiFi is currently running, listening to Bootstrap on port 20740, PID=31405 这意味着NiFi正在运行，我可以在logs/nifi-app.log中看到它的日志。 用户界面可以在https://servername:9443/nifi上找到。它成功启动了与Bootstrap的通信。 但是我有这个错误，UI不能出现。你有什么解决方案吗？ Failed to invoke @OnEnabled method of Je
浏览 71提问于2019-03-12得票数 0
1回答
服务器上有NiFi和NiFi注册表，这是没有连接的，我不能通过本地NiFi instance.But连接到NiFi注册表，我可以通过远程桌面访问NiFi和NiFi注册表。 在我的本地开发系统上安装了另一个版本的NiFi和NiFi注册表。有没有办法离线更新(同步)远程NiFi注册表流并将新的更新应用到远程NiFi？ ?
浏览 19提问于2020-11-07得票数 1
1回答
我遇到了一个问题--在一个不可接受的角色中遇到了一个障碍
角色/apps_nifi//main.yml :的提取
- debug:
msg: "nifi_extra_instances_name is defined"
when: nifi_extra_instances_name is defined
- debug:
msg: "nifi_extra_instances_name is not defined"
when: nifi_extra_instances_name is not defined
- name: Imp
浏览 4提问于2020-10-14得票数 1
回答已采纳
我使用NiFi来使用专用处理工具(运行在NiFi外部)来编排大型二进制文件的处理。
NiFi将源文件放到磁盘上，我调用外部工具(使用ExecuteScript处理器)，该工具加载二进制文件并继续生成许多较小的文件。
当外部工具完全完成时，我需要“拾取”较小(生成)文件的目录，并继续通过NiFi进行处理。我需要等待，因为输出目录、文件数量和处理所需的时间是动态的。
问题：
GetFile (获取目录)没有上游连接，因此我无法在处理完成时触发它。
ListFile + FetchFile组合不能工作b/c ListFile没有上行连接，所以--再次--我不能在处理完成时触发它。
.
浏览 1提问于2018-08-16得票数 0
回答已采纳
2回答
当我单击播放列表第一次播放下一首歌曲的任何歌曲时，这个问题只在第二次或更多次单击播放列表中的任何歌曲时才会出现。
但最大的问题是，它无法在任何时候播放完任何歌曲的下一首歌曲。
mediaPlayer.setOnCompletionListener(new MediaPlayer.OnCompletionListener() {
@Override
public void onCompletion(MediaPlayer mediaPlayer) {
mediaPlayer.reset();
// p
浏览 1提问于2017-07-23得票数 1
是否有不可重复的IEnumerable类？
所谓不可重复，是指您不能安全地多次调用GetEnumerator，或者调用GetEnumerator会产生明显的副作用。
浏览 0提问于2009-11-29得票数 1
回答已采纳
我遇到了一个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
1回答
码头群中的分布式Java应用
、、、、
我的目标是在码头集群中运行一个分布式NIFI集群。我为正式的NIFI对接者映像所做的配置是以一种能够运行集群的方式工作的。
对于集群，我使用一个服务，每个副本都是一个单独的NIFI实例。既然这是可行的，我现在想继续进行安全工作。我首先使用一个秘密(交出信任和密钥存储库)向java应用程序应用一个公开签名的通配符证书。在我看来，对于大多数分布式java应用程序来说，这可能是一种可行的方法。但是，对于NIFI，我现在遇到了一个问题，即NIFI本身不支持通配符证书。
我目前正在考虑如何以每个容器都有自己的证书的方式运行集群。我目前的想法是在容器中使用一个自管理内部CA运行自签名证书，NIFI可以信任
浏览 0提问于2018-10-15得票数 0
回答已采纳
我正在开发一个自定义处理器，它同时使用DBCPService和RecordReader。
对于maven项目，我不能添加这两个服务的NAR依赖项，因为这会导致错误。
对于我的处理器模块，pom.xml，
<dependencies>
<dependency>
<groupId>org.apache.nifi</groupId>
<artifactId>nifi-api</artifactId>
</dependency>
浏览 3提问于2020-09-29得票数 0
回答已采纳
我试图从Server中提取数据，并使用generate表fetch。当我使用MYSQL数据库而不是Server进行相同的生成表提取时，它就像预期的那样工作。每当我用于连接Server时，我都会收到以下错误。
GenerateTableFetch[id=07bed292-0162-1000-0000-00004bc12345] failed to process session due to java.lang.IllegalArgumentException: Order by clause cannot be null or empty when using row paging: Orde
浏览 3提问于2018-03-13得票数 0
回答已采纳
1回答
我不能去尼菲
、、
我已经在Ubuntu21.04上安装了docker，并且我尝试在上面运行apache/nifi。我使用的命令是：docker run --name nifi -dp 8443:8443 apache/nifi。从日志上看，一切似乎都很好：
Generated Username [24a06eea-579f-443a-ad81-b9fe95d46bd3]
Generated Password [9D3NKqhLElChcXHw0jzfO/wkT8yOV+uV]
2022-03-24 15:39:27,726 INFO [main] org.apache.nifi.web.server.Jett
浏览 8提问于2022-03-24得票数 0
回答已采纳
我有两个场景，每个场景都需要建议使用哪个NiFi处理器：
我在NiFi之外运行了Restful web服务。NiFi希望通过调用特定的restful获取/post/delete/更新一些数据。一旦Restful接收到来自NiFi的请求，它就会将响应发送回NiFi。这里使用哪个NiFi处理器？
在第二个场景中，我在NiFi之外运行了一个应用程序。这个应用程序有自己的GUI。用户需要一些信息，所以他想向NiFi发送请求。在NiFi中，是否有任何处理器接受来自应用程序的请求、处理请求并将响应发回？
实际上，我用getHTTP和invokeHTTP阅读了所有的问题。
我最初尝试过使用i
浏览 0提问于2019-01-03得票数 2
回答已采纳
我想将我的Nifi管道(主要是PUTSQL-处理器)从我的开发实例转移到我的Apache Nifi的生产实例中，最好是使用Python来实现可重用性。
我想我可以试着复制粘贴它们。
从DEV获取处理器，在/nifi-api/processors/{id}上具有GET -请求
将处理器放到PRD实例中，其中具有PUT-request on /nifi/processors/{id}
代码：
# GET processor and parse to JSON
response = requests.get(nifi_url_dev + 'processors/' +
浏览 1提问于2021-03-24得票数 0
回答已采纳
我有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
浏览 1提问于2017-11-09得票数 0
2回答
我正在尝试使用的导入端点。我已经使用UI导出了一个模板为XML，并试图使用Postman导入它。请求如下：
POST /nifi-api/process-groups/63dcaf98-0158-1000-04da-dd54bbb3a5b8/templates/import HTTP/1.1
Host: localhost:8080
Content-Type: application/xml
Cache-Control: no-cache
Postman-Token: 37a10e8b-b30d-b5c8-4219-ca1ba34f79da
<?xml version="1.0
浏览 0提问于2016-11-14得票数 2
回答已采纳
1回答
将普通类委托给特定类
、、、
我有以下接口：
public interface IModel
{
ModelTypes ModelType { get; } // ModelTypes is an enum
}
public interface IModelConverter<T>
{
byte[] ToBytes(T model);
}
另外，我有3个IModel实现：ModelA、ModelB、ModelC和以下类：
public class ModelAConverter : IModelConverter<ModelA>
public class ModelBConver
浏览 6提问于2015-04-23得票数 3
回答已采纳
据我所知，这个问题可能已经重复了很多次--我对Nifi并不熟悉，不幸的是，以前的回答对我都没有用。
我试图使用处理器(在Windows 10中)运行一个简单的python脚本。但是，我不能直接从Nifi调用python脚本，因为它需要激活conda环境(它给我一个python包的导入错误--在从nifi和命令提示符调用脚本时也是如此)。
此后，我编写了一个基本的批处理脚本来激活conda环境并运行python脚本(参见下面)。
activate.bat
CALL conda activate base
python sample.py
CALL conda deactivate
这样可以
浏览 1提问于2021-02-17得票数 0
我使用以下方法来保存结构--很多是在很短的时间内(数据库读写)。我是否需要清除缓冲区，还是在垃圾收集之后立即将其清除？
或者dI是否应该使用buffer.Reset()
func ToBytes(p interface{}) []byte {
buf := bytes.Buffer{}
enc := gob.NewEncoder(&buf)
err := enc.Encode(p)
if err != nil {
log.Fatal(err)
}
fmt.Println("uncompressed size (by
浏览 4提问于2022-01-10得票数 2
回答已采纳
目前，我正在将ca文件路径添加到mqtt服务器中。要使用或发布，我需要将此证书添加到nifi处理器中，但我找不到在nifi中添加certicate的任何选项。
所以我尝试添加一个证书属性，但是抛出错误。
浏览 0提问于2020-04-09得票数 1
1回答
对象没有被嘲笑。抛出空指针异常
、、、、
我正在用mockito框架运行我的代码。框架是为一个实现创建模拟对象，而不是为其他对象创建任何模拟对象，因为它正在抛出空指针异常。下面是我的代码和输出：
package com.sohi;
import java.io.IOException;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HTableInterface;
import org.apache.hadoop.hbase.client.HTablePool;
import org.apache.hadoop.hb
浏览 2提问于2014-12-17得票数 1
回答已采纳
我每周都会将文件放到一个S3位置，我需要在处理后将这些文件移动到另一个S3位置来归档这些文件。我在亚马逊网络服务上托管了cloudera NiFi。我不能在流程的末尾使用putS3Object+DeleteS3Object处理器，因为在这个NiFi过程中，我要解压缩文件并添加额外的列(压缩文件和删除列会影响性能)。我需要一个python/groovy脚本来移动来自S3 loaction的文件。有没有其他方法可以做到这一点？
浏览 0提问于2020-11-18得票数 0
1回答
我使用Mockito来做一些模拟/测试。我的场景很简单:我使用mock()模拟了一个类，并且我多次(间接地)调用这个类(即~100 k)
Mockito似乎为每次调用保存了一些数据，因此我在某一点上耗尽了内存。
我想告诉mockito不要保存任何数据(我不打算打电话给verify()，等等，我只是不在乎，对于这个特定的测试，这个模拟达到了什么程度)。我不想每次调用都创建新的模拟。
浏览 1提问于2013-10-03得票数 5
回答已采纳
我将解释我的用例，以了解要使用哪个DB提取实用程序。
我需要每天从不同频率的Server表中提取数据。每个提取查询都是一个复杂的SQL语句，涉及连接等中的5-10个表，有多种原因。大约有20-30份这样的声明。
所有这些提取查询都可能需要每天以不同频率多次运行。这取决于我们从源系统或其他情况接收数据的次数。
我们计划使用Kafka发布一条消息，让Nifi工作流知道无论何时RDBMS表被更新并需要触发流(我不能仅仅基于“增量”列值触发Nifi流，可能只有所有的行更新场景，我们可能不会在表中创建新的行)。
我该如何设计我的Nifi。有各种可用的ExecuteSQL/Genera
浏览 0提问于2019-02-04得票数 0
我想配置一个带有外部TLS zookeeper集群的NIFI集群(部署在kubernetes集群中)。一切正常(quorum，zookeeper tls...)但是当我将zookeeper连接字符串设置为…时myzk:3181，myzk2:3181…当Nifi尝试连接到zookeeper集群时，我收到以下消息：
SSL: io.netty.handler.ssl.NotSslRecordException:非SSL/TLS记录: 0000002d0000
我认为这是因为Nifi正在与zookeeper HTTP对话，而3181是HTTPS
提前感谢，致以敬意
NIFI版本: 1.12.1 Zo
浏览 0提问于2021-09-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
我已经创建了一个自定义的码头容器来运行Apache NiFi，并在NiFi之上创建了其他一些比特。容器正在运行Ubuntu 18，nifi.properties文件非常普通。这是我的码头文件。
FROM ubuntu:18.04
FROM openjdk:8-jre
RUN apt-get update
RUN apt-get install unzip
RUN apt-get install wget -y
RUN mkdir /opt/MicroFocus
RUN apt-get install dos2unix
WORKDIR /opt/nifi/
RUN wget https:/
浏览 2提问于2021-06-16得票数 1
回答已采纳
我已经编写了一个mapreduce程序，在这个程序中，我需要从特定列族的HBase表中读取数据。
例如，HBase表中的数据如下：
Row Column+Cell
1 column=Name:FName, timestamp=...,value=ABC
1 column=Name:LName, timestamp=...,value=XYZ
现在，我需要将FName和LName附加到同一列族下作为FullName的另一列中。在map中，我提取数据并将其追加并发送到reducer。
在Reducer中，我只是获取键、值对，并尝试将FullName添加到表中。
浏览 0提问于2016-12-23得票数 0
我正在尝试将Nifi中的xlsb文件转换为csv。我现在在Nifi中使用ConvertExcelToCSVProcessor，但是它给了我错误并且不能工作。xlsb是excel二进制文件。我在谷歌上搜索了很多，并试图让这个工作，但徒劳无功。请在这方面提供帮助。
浏览 4提问于2020-09-03得票数 0
使用java，我希望在我的HBase数据库中插入数据。我需要在插入之前创建一个put类，如下所示：
Put p = new Put(Bytes.toBytes("row1"));
我的程序从用户那里获取数据并放入数据库，但问题是插入时需要行名(此处为row1)，但我不知道如何唯一和自动地生成它，因为对于每一行，它应该是不同的，如果不是，它会覆盖数据。
这是我的代码：
String fName, lName, number ;
Scanner in = new Scanner (System.in) ;
System.out.println("Wainti
浏览 2提问于2016-02-20得票数 1
回答已采纳
Test test;
Mc_WriteUserData(McHandle, (unsigned char *)&test, sizeof(test));
以上是c++函数使用的方式，我将2EDArg的工作方式集中在了它的工作方式上，并希望在android中使用java来实现它。下面是我的android代码。我用toBytes()函数来模拟它。想像这样使用它：
Test test;
test.toByte();
但是它不起作用，任何帮助都很感激！
final class Kits{
public static byte[] intToByte(int number){
浏览 2提问于2013-07-26得票数 1
回答已采纳
1回答
HBase支持单行原子事务。
几乎检查了一下。我写了以下代码
Increment inc=new Increment();//For writing it to WAL
inc.getWritetoWAL();
Put p = new Put(Bytes.toBytes("name10"));
p.add(Bytes.toBytes("cf"), Bytes.toBytes("name"),Bytes.toBytes("Some Value 10"));
table.setAutoFlus
浏览 2提问于2013-03-15得票数 0
我正在使用python脚本抓取一个页面(例如facebook页面)，并希望将每个帖子传递给一个文件(类似于gettwitter进程)。我正在使用Apache处理器来调用python脚本。
然而，我得到了SyntaxError: no viable alternative at input
我可以在处理器之间成功地传输数据，但是当我试图添加报废代码时，我总是会出错。我使用的是python版本2.7.8。据我所知，executeScript在内部使用jython，jython可以翻译python代码。
下面是代码，如果我们删除与nifi相关的代码(内部类和流文件)，它可以很好地处理nifi之外的p
浏览 1提问于2017-04-02得票数 0
回答已采纳
1回答
看上去是个成功的开端之后：
nifi run
INFO [main] org.apache.nifi.bootstrap.Command Starting Apache NiFi...
...
INFO [main] org.apache.nifi.bootstrap.Command Launched Apache NiFi with Process ID 14532
我仍然不能访问(默认)指定地址127.0.0.1:8443/nifi/的应用程序。
通过cat nifi-app.log在自制安装目录中查看应用程序日志，我可以看到它似乎再次可用：
INFO [main] org.apache.
浏览 26提问于2022-11-07得票数 -1
尼菲还没开始呢。当我运行./nifi.sh status时，它会出现这样的错误，
org.apache.nifi.bootstrap.Command Apache NiFi没有运行
下面是log nifi-app.log文件中的错误：
2016-12-21 11:54:30,653 INFO [main] o.a.nifi.properties.NiFiPropertiesLoader Determined default nifi.properties path to be '/root/HDF-2.0.0.0/nifi/./conf/nifi.properties'
浏览 16提问于2016-12-21得票数 1
我使用的是NiFi 1.9.2
我正在读取一个文本文件，恰好是一个csv文件。我在flowFile的内容中包含了文件的内容。
内容如下
a,b,c
d,e,f
g,h,i
我想在流文件中的所有记录前加一个行号，然后
1,a,b,c
2,d,e,f
3,g,h,i
每次我通过这个处理器传送一个文件
通过使用带有属性的ReplaceText处理器，我可以实现以下目标：
Search Value : (?m)(^.*$)
Replacement Value : ${nextInt()},$1
但是由于nextInt()持久化，所以在运行的NiFi实例的生存期内它的值
0,a,b,c
浏览 1提问于2021-09-09得票数 0
回答已采纳
2回答
我有一个火花流Scala项目，使用阿帕奇NiFi接收器。这些项目在Eclipse/Scala IDE下运行良好，现在我想将其打包以进行部署。当我添加它为
libraryDependencies += "org.apache.nifi" %% "nifi-spark-receiver" % "0.3.0"
sbt假设它是一个Scala库，并试图解析它。
如何将NiFi receiver及其所有依赖项添加到项目SBT文件中？
此外，有没有可能将依赖项pint到本地目录，而不是sbt尝试解析？
提前谢谢。
以下是我的sbt文件内容：
name := &
浏览 1提问于2015-11-30得票数 4
我尝试使用一个非常简单的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
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
