我正在尝试使用Flume测试日志聚合。
在ubuntu机器host1上安装了CDH3u3 (名称节点、辅助名称节点、作业跟踪器、数据节点、任务跟踪器)和Flume (flume、flume-master和flume- node )。对于Flume安装，我关注的是。
我想在同一个节点上运行flume master、收集器节点和代理节点。当我使用普通的flume命令时，我可以成功地运行所有这三个服务：(参考： )
$ flume master
$ flume node -n flume-collector
$ flume node -n flume-agent
但是，不可能使用flume-node
浏览 3提问于2012-03-16得票数 2
回答已采纳
5回答
我试图在Ubuntu16.04上作为systemd服务运行flume，并在/etc/systemd/system/flume-ng.service中使用以下内容
[Unit]
Description=Apache Flume
[Service]
ExecStart=/usr/bin/nohup /opt/flume/current/bin/flume-ng agent -c /etc/flume-ng/conf -f /etc/flume-ng/conf/flume.conf --name a1 &
ExecStop=/opt/flume/current/bin/flume-ng a
浏览 0提问于2016-11-07得票数 47
回答已采纳
3回答
我正在尝试为创建systemd服务文件，我已经创建了包含以下内容的/etc/systemd/system/flume-ng.service
[Unit]
Description=Apache Flume
[Service]
Environment=FLUME_CLASSPATH=/opt/flume/current/lib/
ExecStart=/usr/bin/nohup /usr/bin/flume-ng agent -c /etc/flume-ng/conf -f /etc/flume-ng/conf/flume.conf --name a1 &
[Install]
Want
浏览 6提问于2016-11-04得票数 13
回答已采纳
]# /etc/init.d/flume-master start
Starting Flume master daemon (flume-master): starting master, logging to /var/log/flume/flume-flume-master-localhost.localdomain.log
/usr/lib/flume/bin/flume: line 193: java: command not found
/usr/lib/flume/bin/flume: line 271: exec: java not found
当我执行通道-主机和水槽节点时，
浏览 0提问于2014-11-20得票数 0
回答已采纳
3回答
当我将flume安装到Linux.I中时，我在运行flume时收到了一些警告，我按照以下步骤安装了flume。
>> sudo tar -xvf flume-ng-1.1.0-cdh4.0.1\(1\).tar.gz
>> export PATH=/home/hduser/downloads/flume-1.1.0- cdh4.0.1/bin:$PATH
>> $ sudo cp conf/flume-conf.properties.template conf/flume.conf
为了运行flume，我使用了以下命令
>> $ bin/flum
浏览 0提问于2012-09-05得票数 1
1回答
我在c:\hadoop2.5.2中安装hadoop，然后在c：\hador2.5.2\apache- flume -1.6.0下解压flume二进制文件。
我得到的错误如下所示，有任何想法吗？
C:\hadoop2.5.2\apache-flume-1.6.0\bin>flume-ng agent -conf -f conf/flume-twitter.conf -Dflume.root.logger=DEBUG,console -n TwitterAgent
C:\hadoop2.5.2\apache-flume-1.6.0\bin>powershell.exe -No
浏览 3提问于2016-01-28得票数 0
1回答
我已经从""..but下载了flume我无法构建it..do我需要先安装thrift才能构建flume？？如果是，原因是什么..当我运行mvn it..do时收到以下错误-
mohammad@ubuntu:~/apache-flume-b01a760$ mvn compile
[INFO] Scanning for projects...
[INFO] Reactor build order:
[INFO] Flume
[INFO] Flume Core
[INFO] Flume Master Config Web Application
[INFO] Flu
浏览 3提问于2012-06-04得票数 0
回答已采纳
2回答
如果运行hadoop节点，默认情况下，它将使用log4j在/var/log/flume下生成日志。这些文件看起来就像
/var/log/flume/flume-$FLUME_IDENT_STRING-$command-$HOSTNAME.log
根据flume用户指南，更改flume日志配置的唯一方法是使用flume-daemon.sh使用flume环境变量运行Flume节点，如：
export FLUME_LOGFILE=flume-$FLUME_IDENT_STRING-$command-$HOSTNAME.log
export FLUME_ROOT_LOGGER="INFO,DR
浏览 10提问于2012-05-02得票数 0
回答已采纳
1回答
我试图建立一个基本的卡夫卡-水槽-HDFS管道。卡夫卡已经开始运作了，但是当我启动水槽代理时
bin/flume-ng agent -n flume1 -c conf -f conf/flume-conf.properties -D flume.root.logger=INFO,console
似乎代理并不是作为我得到的唯一控制台日志出现的：
Info: Sourcing environment configuration script /opt/hadoop/flume/conf/flume-env.sh
Info: Including Hive libraries found via ()
浏览 5提问于2017-03-08得票数 1
回答已采纳
1回答
我想在我的windows10上安装冲水槽代理，以便将日志带到安装在虚拟盒子上的hortonworks沙盒中。我做了所有的设置都引用了这个链接-，但是当我运行这个链接时，它出现了一些问题
命令-“flume-ng代理-conf %FLUME_CONF% -CONF-file%flume_conf%/flume-conf.properties.template-name代理”
错误-采购环境配置脚本C:\flume\apache-flume-1.7.0-bin\conf\flume-env.ps1警告:未找到在(C:\ Hadoop \hadoop-2.6.0)中找到的C:\flume\apach
浏览 1提问于2017-04-16得票数 2
1回答
我一直在尝试在我的windows系统上运行flume代理来获取twitter数据。我正在关注这个博客https://acadgild.com/blog/streaming-twitter-data-using-flume 但是，每当我尝试运行flume代理程序时，我都会得到以下错误- flume-ng agent -n TwitterAgent -f ./conf/flume.conf
E:\apache-flume-1.7.0-bin\apache-flume-1.7.0-bin\bin>powershell.exe -NoProfile -InputFormat none -Ex
浏览 25提问于2019-03-19得票数 1
回答已采纳
1回答
我尝试在安装了CDH5的AWS EC2机器(RedHat)上启动Flume代理。我使用以下命令：
sudo /etc/init.d/flume-ng-agent status
我得到的回应是：
-bash: /etc/init.d/flume-ng-agent: No such file or directory
我已经检查了CDH5指南，它说这是启动代理的方法…我做错了什么？
当我运行flume-ng版本时，我得到
Flume 1.6.0-cdh5.9.0
编辑:当我运行sudo service flume-ng-agent stop命令时，它会显示Failed to stop flume-
浏览 0提问于2016-10-30得票数 0
我有水槽流，我想把它存储在HDFS通过火花。下面是我正在运行的火花代码
object FlumePull {
def main(args: Array[String]) {
if (args.length < 2) {
System.err.println(
"Usage: FlumePollingEventCount <host> <port>")
System.exit(1)
}
val batchInterval = Milliseconds(60000)
val
浏览 3提问于2016-04-01得票数 2
回答已采纳
我在水槽工作了一段时间，最近遇到了这个问题。(顺便说一句，我目前正在研究水槽-ng 1.3.1)
当我们使用flume代理启动命令时，
"flume-ng agent --conf conf --conf-file /usr/lib/flume/conf/Agent.conf --name Agent"
它必须获取/conf/log4j.properties。但是，它并没有提到这些细节。我希望将root.flume.logger更改为首次发布，以查看/var/log/flume/flme.log中的logger.debug消息，但无法这样做。
log4j.properties文
浏览 1提问于2013-08-16得票数 3
回答已采纳
2回答
我已经为flume创建了一个自定义源代码，并将jar文件复制到以下位置：
mkdir -p /usr/lib/flume-ng/plugins.d/MyFlumeSource/lib/MyFlumeSource.jar
chown -R flume:flume /var/lib/flume-ng/
也在/etc/flume-ng/conf/flume-env.sh中
FLUME_CLASSPATH="/usr/lib/flume-ng/plugins.d/MyFlumeSource/lib/MyFlumeSource.jar"
已将Flume配置文件更新为
# Name
浏览 5提问于2015-04-07得票数 1
我正在尝试使用从kafka源到hdfs的水槽来摄取数据。下面是我的水槽文件。
flume1.sources = kafka-source-1
flume1.channels = hdfs-channel-1
flume1.sinks = hdfs-sink-1
flume1.sources.kafka-source-1.type = org.apache.flume.source.kafka.KafkaSource
flume1.sources.kafka-source-1.bootstrap.servers = localhost:9092
flume1.sources.kafka-sour
浏览 0提问于2018-03-12得票数 2
1回答
REGISTER 'hdfs:///user/flume/elephant-bird-hadoop-compat-4.1.jar';
REGISTER 'hdfs:///user/flume/elephant-bird-pig-4.1.jar';
REGISTER 'hdfs:///user/flume/elephant-bird-core-4.1.jar';
REGISTER 'hdfs:///user/flume/json-simple-1.1.1.jar';
load_tweets = LOAD '/user/fl
浏览 2提问于2017-04-21得票数 0
我正在测试Flume NG (1.2.0)来收集日志。这是一个简单的测试，Flume收集日志文件flume_test.log并将收集到的日志作为sysout打印到控制台。conf/flume.conf是：
agent.sources = tail
agent.channels = memoryChannel
agent.sinks = loggerSink
agent.sources.tail.type = exec
agent.sources.tail.command = tail -f /Users/pj/work/flume_test.log
agent.sources.tail.ch
浏览 1提问于2012-09-12得票数 6
回答已采纳
1回答
码头集装箱间通信
、、、
我想运行Hadoop和Flume。我有一个具有所有默认值的标准Hadoop映像。我看不出这些服务如何在分开的容器中相互通信。
Flume的Dockerfile看起来是这样的：
FROM ubuntu:14.04.4
RUN apt-get update && apt-get install -q -y --no-install-recommends wget
RUN mkdir /opt/java
RUN wget --no-check-certificate --header "Cookie: oraclelicense=accept-securebackup-c
浏览 6提问于2016-04-02得票数 2
回答已采纳
我尝试执行flume streaming的示例，但是我的jars文件无法工作:在这里，他们指出了
bin/spark-submit --jars \
external/flume-assembly/target/scala-*/spark-streaming-flume-assembly-*.jar
我不知道这个“外部”目录是什么？
在我的spark ( 1.6.0 )库中，我放了几个jars (我同时尝试了1.6.0和1.6.0)：
$ pwd
/Users/romain/Informatique/zoo/spark-1.6.0-bin-hadoop2.4/lib
$ ls *
浏览 3提问于2016-08-11得票数 0
我正在尝试理解Flume，并参考flume在flume.apache.org的官方页面
特别是，在提到时，我对此感到有点困惑。
我们是否需要在实际的we服务器上运行flume代理，或者我们是否可以在不同的物理服务器上运行flume代理并从we服务器获取数据？
如果上面是正确的，那么flume agent是如何从then服务器日志中获取数据的？webserver如何使其数据可供flume代理使用？
有人能帮助理解这一点吗？
浏览 1提问于2018-04-09得票数 0
2回答
在漫游中编辑bashrc
、、、
我正在使用vagrant来设置一个Debian VM。安装flume时，其中一个步骤是将路径添加到bashrc文件。在大多数情况下，使用vi或nano打开文件并添加所需的行似乎很简单。然而，bashrc文件的格式在vagrant中有很大的不同，因为这是我第一次使用它，我非常简单，不知道如何添加我想要的行。任何帮助都将不胜感激。
我正在尝试添加以下代码行
export FLUME_HOME = "/usr/lib/flume/apache-flume-1.4.0.1-bin"
export FLUME_CONF_DIR = "$FLUME_HOME/conf"
e
浏览 6提问于2015-07-29得票数 1
当我运行命令时Flume运行成功
/opt/module/flume/bin/flume-ng agent --conf /opt/module/flume/conf --conf-file /opt/module/flume/conf/file_flume_kafka.conf --name a1 -Dflume.root.logger=INFO,console
[root@master bin]# jps
12193 Application
10259 QuorumPeerMain
12310 Jps
10751 Kafka
但是当我运行我写的启动脚本时，它不起作用。脚本如下：
#! /b
浏览 15提问于2020-10-25得票数 0
我是Apache Flume的新手。我知道Apache Flume可以帮助传输数据。
但是我仍然看不到Apache Flume提供的最终好处。如果我可以配置一个软件或者让一个软件把哪些数据发送到哪里，为什么我需要Flume？
也许有人可以解释一下Apache Flume的好处？
浏览 2提问于2014-01-10得票数 1
我正在读取data.csv文件的列，并试图在使用正则表达式从列中的字符串中提取上一次正斜杠之前提取所需的文本。我的列数据如下：
class:
org/apache/flume/api/virtual/loeadBalancing.java
org/apache/flume/file/Channel/testing/test2.java
org/apache/flume/recoverable/memory/test1.java
org/apache/flume/source/scribe/LogEntry.java
org/apache/flume/source/jms/TestJMSMes
浏览 1提问于2016-11-27得票数 0
回答已采纳
1回答
我试图在linux脚本中捕获flume命令的进程id。
脚本正在以nohup模式执行: nohup flume.sh &
flume.sh：
flume-ng agent --conf . -Dflume.root.logger=info,console -Djavax.net.debug=info,console --conf-file FLUME_Surya.conf --name IBMMQ --classpath $CLASSPATH -Dcom.ibm.mq.cfg.useIBMCipherMappings=false
echo $! > /biph/edl/SG/j
浏览 1提问于2016-09-10得票数 1
1回答
我正在尝试用hdfs接收器运行flume。hdfs在不同的机器上正常运行，我甚至可以从flume机器与hdfs交互，但当我运行flume并向其发送事件时，我得到以下错误：
2013-05-26 14:22:11,399 (SinkRunner-PollingRunner-DefaultSinkProcessor) [WARN - org.apache.flume.sink.hdfs.HDFSEventSink.process(HDFSEventSink.java:456)] HDFS IO error
java.io.IOException: Callable timed out after
浏览 1提问于2013-05-26得票数 2
我曾尝试从创建jar文件，但一直失败。在将和cd下载到其中之后，我运行了mvn clean package。它失败了，错误如下：
[INFO] Scanning for projects...
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Building flume-ng-sql-source 1.3-SNAPSHOT
[INFO] ------------------------------------------------------------
浏览 0提问于2015-10-13得票数 1
我已经在CDH5.8.0集群上安装了Flume。flume代理位于运行Flume任务的单个节点上。我使用linux终端通过flume运行两个独立的数据采集，使用独立的配置文件。
我想通过Cloudera Manager监控这两个摄取过程。虽然CM中的flume configuration面板提供了添加自定义conf属性的选项，但这是针对单个flume代理的。
我不能在同一台主机上通过CM添加另一个冲水池代理。如何使用Cloudera Manager监控这两个摄取过程？
浏览 22提问于2017-03-14得票数 1
回答已采纳
我正在尝试使用flume连接器来处理一个获取syslog消息的flume实例。
我的storm配置如下
flumeConf.put("flume-agent.source.type", "AVRO");
flumeConf.put("flume-agent.source.bind", "localhost");
flumeConf.put("flume-agent.source.port", "3564");
flumeConf.put("flume-agent.channel.type&#
浏览 4提问于2013-11-25得票数 1
回答已采纳
我尝试在syslog源和hbase接收器中使用水槽。
当我运行flume代理时，我得到了以下错误：Failed to start agent because dependencies were not found in classpath. Error follows. java.lang.NoClassDefFoundError: org/apache/hadoop/hbase/HBaseConfiguration，这意味着(从那个)缺少一些hbase，要解决这个问题，我需要在flume-env.sh文件中设置这些库的路径，并运行flume，但是这里的错误是我用来运行flume代理的命令：b
浏览 3提问于2016-12-07得票数 0
1回答
我有一个用例，我必须使用Flume猫文件并将其加载到本地dir中。我知道flume不是为这样的用例设计的，但我没有任何流data.So，我决定使用它来处理这个问题，我已经创建了我的配置文件，使用sources.type作为exec和channels.type作为文件，sink.types作为file_roll，我还为checkpointDirs和dataDir这样的通道配置了适当的配置。但是，当我运行代理时，它在源语句(flume.log)上失败了
文件
#### Define a source, a channel, and a sink
agent.sources = src1
agent
浏览 2提问于2017-04-27得票数 2
回答已采纳
我测试了Apache Flume将文件从本地传输到HDFS。但是，如果源文件来自多个服务器(从不同服务器的本地文件传输到HDFS)，我是否可以只运行一个Flume实例并将更多代理添加到flume-conf.properties中？
如果可以，如何在flume-conf.properties中编辑以下参数：
agent1.sources.spooldirSource1.spoolDir = ?(server1/path)
agent2.sources.spooldirSource2.spoolDir = ?(server2/path)
还有，我怎样才能运行flume？
./flume-ng ag
浏览 2提问于2013-10-08得票数 1
1回答
我写了一个Java应用程序，它构建flume配置文件，并将它们写入Linux机器上的磁盘。然后，应用程序构建flume命令，并尝试通过运行以下代码中的命令来启动flume代理：
try {
Process p = Runtime.getRuntime().exec(flumeStartCommand.toString());
p.waitFor();
BufferedReader in = new BufferedReader(new InputStreamReader
浏览 1提问于2015-02-16得票数 0
我有一个水槽配置文件filename.conf，当我在终端上执行这个文件时，它工作得很好。但是我试图用Runtime.getRuntime().exec函数在java程序中执行相同的文件，但不起作用。
这是我的flume执行命令：
/home/path/flume/bin/flume-ng agent --conf-file /home/path/flume/filename.conf --name Agent -Dflume.root.logger=INFO,console
这是我的java代码：
Process p;
p = Runtime.getRuntime().exec("
浏览 2提问于2014-04-22得票数 1
1回答
Flume代理无法传送事件
、、、、
我有3个代理。1个运行在使用内存通道的windows上，另外2个运行在Linux上，使用文件通道从windows代理获取数据并放入Hbase。
谁能建议一下为什么会发生下面的错误，以及采取什么步骤来阻止它？
2013-12-23 14:50:15,290 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG - org.apache.flume.sink.AvroSink.destroyConnection(AvroSink.java:199)] Avro sinksink1 closing avro client: NettyAvroR
浏览 5提问于2013-12-23得票数 1
我正在构建一个spring引导独立应用程序，它需要使用来自远程服务器的消息并将它们写入Syslog Server。我正在使用Flume嵌入式代理可靠地记录消息。但我会跟着错误走。
由: org.apache.flume.agent.embedded.EmbeddedAgentConfiguration.checkAllowed(EmbeddedAgentConfiguration.java:308) ~flume org.apache.flume.agent.embedded.EmbeddedAgentConfiguration.validate(EmbeddedAgentConfigura
浏览 0提问于2019-06-26得票数 2
1回答
我可以查看由Flume应用程序放置在HDFS上的文件-
sudo -u flume hadoop fs -cat tweets/2015/05/06/15/FlumeData.1430952817762
但是当我试着删除上面的文件夹，推文，和所有的内容时-
sudo -u flume hadoop fs -rm -r tweets
我得到了这个错误-
Failed to move to trash: hdfs://quickstart.cloudera:8020/user/flume/tweets: Permission denied: user=flume, access=WRITE, in
浏览 2提问于2015-05-07得票数 2
3回答
我第一次安装了Flume。我使用的是hadoop-1.2.1和flume 1.6.0
我尝试通过跟踪来设置冲水沟代理。
我执行了这个命令：$ bin/flume-ng agent -n $agent_name -c conf -f conf/flume-conf.properties.template
上面写着log4j:ERROR setFile(null,true) call failed. java.io.FileNotFoundException: ./logs/flume.log (No such file or directory)
flume.log文件不是自动生成的吗？如果没有
浏览 1提问于2015-06-03得票数 1
我使用的是Flume 1.7.0和HDFS接收器。我将Flume配置为将数据放入HDFS的date目录中，以便在新的一天到来时自动更改目录。问题是，我将flume设置为滚动文件大小(240MB)，但是当目录每天发生变化时，flume会留下.tmp文件。似乎flume更改为新的一天的目录，而没有关闭未完成的文件(小于240MB)。
例如。如果我启动3个冲水槽代理。则当flume代理改变到新目录20180410时，将在目录20180411中留下3个.tmp文件。
有没有办法让flume在切换到新的目录之前关闭.tmp文件？谢谢你们所有人的帮助。
浏览 2提问于2018-04-11得票数 0
我已经配置了flume来读取日志文件并写入HDFS。当我启动水槽时，会读取日志文件，但它不会写入HDFS。flume.log有警告消息- could not configure sink - no channel configured for sink，但我已经在conf-文件中分配了一个接收通道。
下面是conf文件和错误消息：
File: spool-to-hdfs.properties
# List all components.
agent1.sources = source1
agent1.sinks = sink1
agent1.channels = channel1
# Des
浏览 3提问于2015-08-04得票数 1
回答已采纳
我有10个文件，其中一些数据的长度变化，我想将相应的数据存储在同一个文件和同一个文件名中，但是flume正在分割数据并保存为FlumeData.timestamp。我使用的配置如下：
a1.sources = r1
a1.sinks = k2
a1.channels = c1
a1.channels.c1.type = file
a1.channels.c1.checkpointDir = /mnt/flume/checkpoint
a1.channels.c1.dataDirs = /mnt/flume/data
a1.channels.c1.trackerDir = /mnt/flu
浏览 0提问于2014-12-02得票数 2
回答已采纳
我正在尝试使用Flume进行twitter分析。为了从twitter获取tweet，我在flume.conf文件中设置了所有必需的参数(consumerKey、consumerSecret、accessToken和accessTokenSecret)。
TwitterAgent.sources = Twitter
TwitterAgent.channels = MemChannel
TwitterAgent.sinks = HDFS
TwitterAgent.sources.Twitter.type = com.cloudera.flume.source.TwitterSource
Twit
浏览 6提问于2015-10-30得票数 1
当我试图运行一个水槽作业时，我得到了下面的错误。我是在cloudera安装程序上运行的。
卡夫卡
Morphline被用作拦截器，由它创建avro记录。
接收器是HDFS
测试环境中完全相同的文件(变形线、avro模式等、flume配置)。但是在另一个环境中，它会抛出这个错误。
2019-07-15 14:24:17,669 WARN org.apache.flume.sink.hdfs.BucketWriter: Caught IOException writing to HDFSWriter (no protocol: value). Closing file (hdf
浏览 0提问于2019-07-15得票数 0
回答已采纳
某些HDFS接收器文件未关闭 有人说，如果接收器进程因超时等问题而失败，它不会再次尝试关闭文件。 我已经检查了我冲水槽日志文件，但没有错误。然而，日志文件显示，每个周期，flume会生成两个tmp文件，并且只关闭一个tmp文件... 如果您对配置有任何建议，将不胜感激！谢谢! #Name the components on this agent
a1.sources = r1
a1.sinks = k1
a1.channels = c1
#Configure the Kafka Source
a1.sources.r1.type = org.apache.flume.source.ka
浏览 63提问于2019-04-23得票数 0
我正在运行一个带有Netcat源、文件通道和mongodb接收器的flume代理，我想将log4j配置为使用服务器，因为flume是作为后台进程运行的。我的配置文件在/opt/ flume /conf/log4j.properties中，请让我知道log4j属性文件是否包含在flume start中，如果是这样，为什么不创建flume.log。
下面是给出的配置
flume.root.logger=INFO,LOGFILE
flume.log.dir=/opt/apache-flume-1.4.0-bin/logs
flume.log.file=flume.log
log4j.logger.
浏览 3提问于2014-02-06得票数 1
我正在尝试使用Flume和Hive进行twitter分析。为了从twitter获取tweet，我在flume.conf文件中设置了所有必需的参数(consumerKey、consumerSecret、accessToken和accessTokenSecret)。
TwitterAgent.sources = Twitter TwitterAgent.channels = MemChannel
TwitterAgent.sinks = HDFS TwitterAgent.sources.Twitter.type =
com.cloudera.flume.source.TwitterSourc
浏览 5提问于2015-06-24得票数 1
1回答
我以根用户身份执行Flume agent，希望将保存在位置/root/data-pipeline/input的XML文件复制到hdfs中hdfs:///user/root/data_pipeline_demo/input..位置的目标位置。
当我以flume-ng agent -c /etc/flume/conf -f /etc/flume/conf/flume.conf -n sandbox身份执行Flume代理时，...It没有将文件写入目标位置&抛出异常：
org.apache.hadoop.ipc.RemoteException
(org.apache.hadoop.secu
浏览 0提问于2016-02-15得票数 0
当我尝试运行flume代理时，我得到以下语句repeatedly.unless我正在强制停止任务它连续显示，这可能是什么问题
请帮帮我
2013-05-27 03:47:12,517 (conf-file-poller-0) DEBUG - org.apache.flume.conf.file.AbstractFileConfigurationProvider$FileWatcherRunnable.run(AbstractFileConfigurationProvider.java:188)检查文件:/etc/flume-ng/conf/loclog.conf是否有更改
2013-05-27
浏览 1提问于2013-05-27得票数 1
我正在尝试使flume-ng-sql-source与Apache Flume一起工作，这样我就可以将Oracle DB流式传输到Kafka。
在这里找到基本教程
我正在使用以下版本Flume 1.8.0、flume-ng-sql-source 1.4.4和ojdbc7.jar
现在，当我尝试启动代理时，我得到错误org.hibernate.boot.registry.classloading.spi.ClassLoadingException: Unable to load class oracle.jdbc.OracleDriver
这是我的flume.conf
agent.channels
浏览 0提问于2017-11-11得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
