当前位置: 首页 > 知识库问答 >
问题:

我正在aws实例上运行flume代理,无法从aws实例上的avro接收器接收到本地计算机上的avro源的事件?

华凯捷
2023-03-14

这是在我的aws实例的控制台上出现的错误。

2014-08-09 12:22:41,803(lifecycleSupervisor-1-2)[info-org.apache.flume.source.avrosource.start(avrosource.java:142)]从本地启动Avro源代码:{bindaddress:ec2-54-221-143-114.compute-1.amazonaws.com,port:44444}...2014-08-09 12:22:42,072(lifecycleSupervisor-1-1)[warn-org.apache.flume.sink.avrosink.start(avrosink.java:244)]无法使用主机名:ec2-54-221-143-114.compute-1.amazonaws.com,端口:41414 org.apache.flume.flume.flume.flume.flumeException:NettyAvroRpcClient{host:ec2-54-221-143-114.compute-1.amazonaws.com,端口:41414}创建avro客户端cclient.java:117)在org.apache.flume.api.NettyAvroRpcClient.connect(NettyAvroRpcClient.java:93)在org.apache.flume.api.NettyAvroRpcClient.configur(NettyAvroRpcClient.java:514)在org.apache.flume.api.rpcclient.getinstance(rpcclientfactory.java:88)在org.apache.flume.api.rpcclient.getinstance(在org.apache.flume.sink.defaultsinkprocessor.start(defaultsinkprocessor.java:46)在org.apache.flume.sinkrunner.start(sinkrunner.java:79)在org.apache.flume.lifecycle.lifecyclesupervisor$monitorrunnable.run(LifecycleesUpervisor.java:236)在java.util.concurrent.executors$runnableadapter.call(executors.java:471)在java.util.concurrent.futuretask.runandreset(FutureTask.java:304)在java.util.concurrent.scheduledThreadPoolExecutor$scheduledFutureTask.access$301(在java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor.java:615)在java.lang.thread.run(thread.java:744),由:java.io.ioException:错误连接到ec2-54-221-143-114.compute-1.amazonaws.com/10.80.54.114:41414 at org.apache.avro.ipc.nettyTransceiver.getchannel(nettyTransceiver.261)at.nettyTranschiver.(nettyTranschiver.java:152)位于org.apache.flume.api.nettyavrorpcclient。连接(nettyavrorpcclient.java:106)...15多个原因是:java.net.connectexception:在sun.nio.ch.socketchannelimpl.checkconnect(本机方法)在sun.nio.ch.socketchannelimpl.finishconnect(socketchannelimpl.java:739)在org.jboss.netty.channel.socket.nio.nocklientsocketpipelinesink$boss.connect(nocketchannelimpl.java:401)在elinesink.java:370)位于org.jboss.netty.channel.socket.nio.nioclientsocketpipelinesink$boss.run(Nioclientsocketpipelinesink.java:292)

共有1个答案

秦新立
2023-03-14

首先在本地计算机上运行带有Avro源的flume代理,然后运行带有Avro接收器的flume代理。原因是Avro源代码启动绑定在给定IP和端口的Avro RPC服务器。Avro Sink是一个Avro rpc客户端,它监听Avro rpc服务器并向其发送水槽事件。

 类似资料:
  • 我在AWS中设置了一个新的MariaDB RDS实例,并向安全组添加了入站和出站规则,但当我试图通过mysql控制台连接到RDSendpoint时,总是会出现以下错误: 错误2003(HY000):无法连接到'db-xxxxxxx.eu-central-1.rds.amazonaws.com'上的MySQL服务器(10060“未知错误”) 我是AWS的新手。

  • 我用默认子网和VPC创建了一个EC2实例。我还向它添加了入站和出站规则(允许从任何地方使用端口22,出站流量可以到任何地方)。< br >互联网网关也连接到VPC,路由被定义为0.0.0.0/0。 但是当尝试从我的ubuntu机器ssh时,我得到以下错误 ssh:连接到主机 ec2-13-233-87-56.ap-south-1.compute.amazonaws.com 端口 22:连接超时 但

  • 我试图在AWS机器上运行NiFi,并访问本地计算机上的web GUI。

  • 我已经将Android应用程序上传到playstore。在第一次下载时,它会崩溃,但在那之后,它工作正常。它将错误显示为无法实例化接收器com。谷歌。Android应用程序。分析。由java引起的AnalyticsReceiver。lang.ClassNotFoundException:未找到类“com.google.android.apps.analytics.analytics.Analyti

  • 我在跟随一位导游http://www.androidhive.info/2012/10/android-push-notifications-using-google-cloud-messaging-gcm-php-and-mysql/对于GCM。 目前,我被困在接收通知的部分。有时,当我运行代码时,它会因以下错误而崩溃: 7.517:E/AndroidRuntime(8601):致命异常:mai