-
-
0
-
0
-
0flume-ng : The term 'flume-ng' is not recognized as the name of a cmdlet, function, script file, or operable program. C heck the spelling of the name, or if a path was included, verify that the path is correct and try again. At line:1 char:1 + flume-ng version + ~~~~~~~~ + CategoryInfo : ObjectNotFound: (flume-ng:String) [], CommandNotFoundException + FullyQualifiedErrorId : CommandNotFoundException
-
0
-
4我是学习Java的,刚开始学习的时候,觉得还是可以的,并没有想象中的那么难,
-
3学习编程的时候,刚开始真心觉得还可以的,
-
10资料是文件的形式受到限制。有视频,面试题,PDF教程等,不方便直接发送,一些学习手册,面试题,开发工具,PDF文档书籍教程,或者留下邮箱我发给你们。
-
0
-
0
-
2真的累了
-
2爱的痛了
-
2若要盼的啊
-
1寒冬腊月啊
-
1夜半三更啊
-
1有是美好一天,下班学习😊
-
5好学哪
-
24感觉程序员怎么样
-
2现在需要的是跨集群传hdfs指定目录的新增文件,求指点 目前想到的就只有flume了 sparkstreaming 不懂拷贝。。。。 也就是 hdfs 传给 另一个hdfs
-
1
-
2#me the components on this agent a1.sources = r1 a1.sinks = k1 a1.channels = c1 # Describe/configure the source a1.sources.r1.type = exec a1.sources.r1.command = tail -F /usr/local/test1.txt a1.sources.r1.fileHeader = true a1.sources.r1.deserializer.outputCharset=UTF-8 # Describe the sink a1.sinks.k1.type = org.apache.flume.sink.kafka.KafkaSink a1.sinks.k1.brokerList = c100:9092,c200:9092,c300:9092 a1.sinks.k1.topic = test5 a1.sinks.k1.requiredAcks = 1 a1.sinks.k1.batchSize = 20 a1.sinks.k1.channel = memcnl #a1.sinks.k1.type = avro #a1.sinks.k1.hostname = 192.168.28.134 #a1.sinks.k1.port = 444
-
1怎么使用flume将a服务器上的某个文件采集到b服务器,一直读取某个a服务器上的文件,然后发送到B服务器,存到本地磁盘上,以单个文件的方式存储,有大佬能教一下吗?
-
0各位大神,我想用flume将收集到的日志放到elasticsearch中,在es中按照日志字段显示,应该怎么配置?拜托拜托……
-
4
-
0Flume 怎么监听端口 然后按照时间每天生成一个文件存入到hdfs 呢?
-
0那个大哥发个ua-parser-1.3.0.jar 给我啊 网上找不到 跪求!!
-
1
-
0分享一套hadoop/spark视频课程,授课老师是 金山 hadoop 核心架构师 ,内容包括hadoop入门、hadoop生态架构、spar
-
1一楼度娘,如标题哈哈,这是求组队帖,求不沉。
-
3有什么问题,都可以进此贴哦,欢迎大家来建楼