flume配置好后,执行到一定的时候不执行了,停留在一个地方

-1.1.jar:/opt/hbase/lib/phoenix-server-4.7.0-HBase-1.1-runnable.jar:/opt/hbase/lib/phoenix-server-4.7.0-HBase-1.1-sources.jar:/opt/hbase/lib/phoenix-server-4.7.0-HBase-1.1-tests.jar:/opt/hbase/lib/phoenix-server-client-4.7.0-HBase-1.1.jar:/opt/hbase/lib/phoenix-server-client-4.7.0-HBase-1.1-sources.jar:/opt/hbase/lib/phoenix-server-client-4.7.0-HBase-1.1-tests.jar:/opt/hbase/lib/phoenix-spark-4.7.0-HBase-1.1.jar:/opt/hbase/lib/phoenix-spark-4.7.0-HBase-1.1-sources.jar:/opt/hbase/lib/phoenix-spark-4.7.0-HBase-1.1-tests.jar:/opt/hbase/lib/phoenix-tracing-webapp-4.7.0-HBase-1.1.jar:/opt/hbase/lib/phoenix-tracing-webapp-4.7.0-HBase-1.1-runnable.jar:/opt/hbase/lib/phoenix-tracing-webapp-4.7.0-HBase-1.1-sources.jar:/opt/hbase/lib/phoenix-tracing-webapp-4.7.0-HBase-1.1-tests.jar:/opt/hbase/lib/protobuf-java-2.5.0.jar:/opt/hbase/lib/servlet-api-2.5-6.1.14.jar:/opt/hbase/lib/servlet-api-2.5.jar:/opt/hbase/lib/snappy-java-1.0.4.1.jar:/opt/hbase/lib/spymemcached-2.11.6.jar:/opt/hbase/lib/xalan-2.7.0.jar:/opt/hbase/lib/xml-apis-1.3.03.jar:/opt/hbase/lib/xml-apis-ext-1.3.04.jar:/opt/hbase/lib/xmlenc-0.52.jar:/opt/hbase/lib/xom-1.2.5.jar:/opt/hbase/lib/xz-1.0.jar:/opt/hbase/lib/zookeeper-3.4.6.jar:/conf:/lib/*' -Djava.library.path=:/opt/hadoop/lib/native:/opt/hadoop/lib/native org.apache.flume.node.Application -f conf/example.conf --name a1
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/opt/flume/lib/slf4j-log4j12-1.6.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/opt/hbase/lib/phoenix-4.7.0-HBase-1.1-client.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. 就是停留在这里不往下面去执行了

0

1个回答

1
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
打断点异常----打了不执行,停在没有打断点的地方
1 clear all的存在导致断点无效2更改后未保存便运行,会停在奇怪的地方(并没有断点)
Flume面试题
1.Flume 丢包问题(☆☆☆☆☆)? 单机 upd 的 flume source 的配置,100+M/s 数据量,10w qps flume 就开始大量丢包,因此很多公司在搭建系统时,抛弃了 Flume,自己研发传输系统,但是往往会参考 Flume 的Source-Channel-Sink 模式。一些公司在 Flume 工作过程中,会对业务日志进行监控,例如 Flume agent 中有多少...
Java的finally语句不会被执行的唯一情况
Java的finally语句不会被执行的唯一情况是:先执行了用于终止程序的System.exit()方法。如下面的代码:   public class Test { public static void main(String[] args) { try { System....
flume配置文件与启动
客户端配置文件 a1.channels = ch1 a1.sources = exec-source1 a1.sinks = hdfs-sink1 a1.channels.ch1.type = memory a1.channels.ch1.capacity = 1000 a1.channels.ch1.transactionCapacity = 1000 a1.channels.ch1.kee...
@Scheduled 记录下没执行的问题 顺便记录下怎么配置
参考https://blog.csdn.net/qq_33556185/article/details/51852537 里面配置后,定时任务还是没有启动。 顺便把需要配置的地方都打出来。 xmlns:task="http://www.springframework.org/schema/task" http://www.springframework.org/schema/task ht...
spring+quartz定时任务启动服务后没有马上执行
写了一个spring+quartz的定时任务,但是发现服务启动后并没有马上执行。网上也没找到能解决的办法,只能自己慢慢试。此文章是自己作为笔记用的,仅供参考。本人菜鸟,文中很多用词可能不当,勿喷。
flume配置启动
flume学习核心:配置个性化-组件的类型Flume(2)组件概述与列表Flume 入
页面刷新新后让页面停留在原来点击的位置
 
【Flume】flume多个输出分支的配置,多sink,多channel
这里就简单贴个配置吧,有问题欢迎留言探讨 sink的配置 ##############################define [sink] begin############################## #define the sink k1 a1.sinks.k1.type=hdfs a1.sinks.k1.channel=c1 a1.sinks.k1.hdfs.useLoca
Excel 每次打开的时候,光标会停在上次保存时候的位置 但是word不会。要实现这个功能其实很简单
Excel 每次打开的时候,光标会停在上次保存时候的位置 但是word不会。要实现这个功能其实很简单
Flume启动与配置文件
Flume启动:   1、进入到Flume根目录。(cd flume -> cd flume/flume -> ll )可以看到以下内容  2、启动run.sh程序。( ./run.sh)。  3、启动nohup程序。(nohup: appending output to ‘nohup.out’)到此Flume启动成功。 Flume配置文件修改如下: [laps@hn10 flume
Quartz,启动不立即执行问题
Quartz,启动不立即执行问题 我的Quartz 是2.2版本,在java程序中写了两个加入计划方法?12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364////  添加简单计划任务 author:irese...
使用JUnit4进行测试时@BeforeClass不运行
@BeforeClass和@AfterClass是JUnit4得新特性,标记有@BeforeClass的方法会载所有的测试方法执行开始前运行,标记有@AfterClass的方法会在所有的测试方法运行结束后执行。 今天碰到一个问题,我有下面的一个测试类: [code="java"] public class TestXXX extends TestCase { @BeforeClas...
jQuery 滚动到指定位置触发动画
项目需求:将某一个div在滑动的时候固定在顶端,滑动到顶端的时候回到原来位置。 如gif所示:   所需jQuery文件:https://pan.baidu.com/s/1qXTEifU   1.css加上active    .active { position: fixed; top: -10px;//根据需要可以调整 就是活跃分区距离顶端的距离 lef...
安装flume-1.6.0后,测试所遇bug
案例1:Avro Avro可以发送一个给定的文件给Flume,Avro 源使用AVRO RPC机制。       a)创建agent配置文件 vi /usr/local/flume-1.6.0/conf/avro.conf a1.sources = r1 a1.sinks = k1 a1.channels = c1    # Describe/configure the s
关于ScheduledExecutorService执行一段时间之后就不执行的问
最近写了个程序,程序中使用到了ScheduledExecutorService的scheduleAtFixedRate方法,用于定时执行任务,但是发现程序运行一段时间之后定时任务不执行了,查看日志和perfcounter都没有看到任何异常,比较郁闷。最后看了一下JDK的源码,在源码的Java doc中的发现了如下一句话: If any execution of the task enco
c++程序执行时候,有的语句根本不执行的原因
(1)问题描述:咱们在写程序的时候,希望程序能够按照自己的想法顺利执行下去。但是有时候却出现根本不执行的情况。如以下程序显示 for(int j=0 ; j<=bmpWidth-1 ;j++) { for(int k=0 ; k<3; k++)           //控制rgb的变化  { //m=*(pBmpBuf+i*lineByte+j*3
linux的crontab定时任务完整配置和定时任务不执行分析
如果未安装需要先安装 CentOS(ubantu自行百度,原理类似)下面的安装方法: [root@CentOS ~]# yum install vixie-cron [root@CentOS ~]# yum install crontabs     1.crontab -e 新增 定时任务 10 0 * * * . /etc/profile;/bin/sh /home/appuser/...
Jenkins 配置一个构建任务中的“构建”步奏,失败后不执行下一步
问题背景:最近开发了一个插件,在一个任务的整个构建过程中的构建步奏,第一步执行脚本命令,第二步运行插件。 目标结果:现在发现第一步失败,第二步不会执行,而我想要的是不管第一步结果都运行第二步。 解决办法:在第一步构建命令的末尾加上“exit 0” 引出的问题:这样可以保证第二步一定运行,但是整个任务的运行状态就是SUCCESS,如果想调查哪次构建出错,那就要一个个log遍历查看了
Flume相关命令,跃点,参数及配置文件总结
flume----------------    收集、移动、聚合大量日志数据的服务。    基于流数据的架构,用于在线日志分析。    基于事件。    在生产和消费者之间启动协调作用。    提供了事务保证,确保消息一定被分发。    Source 多种    sink多种.    multihop        //多级跃点.    水平扩展:        //加节点           ...
Flume监听文件目录sink至hdfs配置
一:flume介绍         Flume是一个分布式、可靠、和高可用的海量日志聚合的系统,支持在系统中定制各类数据发送方,用于收集数据;同时,Flume提供对数据进行简单处理,并写到各种数据接受方(可定制)的能力。,Flume架构分为三个部分 源-Source,接收器-Sink,通道-Channel。   二:配置文件     此配置文件source为一个目录,注意,
Servlet的init()方法如何才会在服务器启动时执行
Servlet的init()方法如何才会在服务器启动时执行
Dotween切换场景再返回就不执行了
Dotween切换场景再返回就不执行了,比如A场景dotween正常,切换到B场景正常;再返回A场景就不正常了,不报错,就是不执行;原因:有可能是会来之后Time.scale变为0了;也有可能是切换场景的时候需要调用Dotween.Clear(true);参考链接:https://github.com/Demigiant/dotween/issues/59...
Flume1.4 相关参数设置,将收集的数据汇总到hdfs,解决许多小文件问题
参照官方文档,flume clflume sink收集端
js 刷新页面后保持页面原来的位置
使用js方法: 1.window.scrollTo(x, y);  页面左滚动
js 鼠标在一个元素上停留一段时间才执行某方法
$('body').on('mouseover','.ac_over',function() {        timer = setTimeout(function(){            preview($('.ac_over').attr('data-id'));        },500);    });    $('body').on('mouseout','.ac_over',fu...
vim打开文件光标停在上次退出的位置
翻阅了其他同学写的博客,我发现很多人在描述这个问题时写的不全面,我把自己的实践过程简单记录下: 两个必要条件 1、~/.vimrc与~/.viminfo的所有人需保持一致,并且要与打开文件的所有人保持一致,同时这三个文件的所有人都不能是root。如图情况才可以: 猜测原因是:修改个人目录下的.vimrc,其作用域无法触及到以root为所有人的文件。 2、~/.vimrc中需要包含如...
Core Animation动画结束回调 以及动画不还原的方法
iOS的Core Animation动画网上一抓一大把,写的都很好 比如这个(太详细了,我都懒得看完): Core Animation编程指南 - 士梦 - 博客园 还有这个 iOS开发基础知识:Core Animation(核心动画) - 简书 最近有个需求,想要动画结束后把视图删除掉,那么就需要在动画结束后判断是否是当前动画,以防误删。 Core An...
PostConstruct注解不执行
通过PostConstruct注解进行初始化操作,可是怎么都不执行各种配置都配烂了,最终发现是default-lazy-init=&quot;true&quot;的问题,惰性加载真的是用到的时候才初始化。在Bean上增加Lazy(false)解决...
【Flume】flume 容错环境的搭建 failover
关于failover网上也有很多例子,但是看到的有多重做法,个人觉得,本着职责单一的原则 1、一台机子运行一个flume agent 2、一个agent 的下游sink指向一个flume agent,不要一个flume agent配置多个端口【影响性能】 下面看具体实例: 首先是flumet agent client的配置 priority越高,优先级越高,会优先使用该sink
SpringMVC启动后自动执行
参考:http://kylin755.iteye.com/blog/1703542 通常做法是定义一个Servlet,并在web.xml中配置Servlet的启动顺序的值在DispatcherServlet之后。但这样做的缺点是在Servlet中无法使用Spring的依赖注入功能,只能使用WebApplicationContext的getBean()方法获取bean。  找到的解决
aop-aspectJ的通知不被执行
首先,确保配置文件都已经是正确的。1、首先,把所写的通知所在的类交于spring来管理<context:component-scan base-package="me.sui.user.aop" />注意,其头部文件:<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001
Flume传数据到Hadoop双namenode集群传数据可能出现的问题
现在的需求是在一台Flume采集机器上,往Hadoop集群上写HDFS,该机器没有安装Hadoop。 这里的Flume版本是1.6.0,Hadoop版本是2.7.1. 把Hadoop集群的hdfs-site.xml、core-site.xml两个配置文件复制到 flume安装目录的conf目录去,把hadoop-hdfs-2.7.1.jar复制到 Flume  lib目录。 一、
Flume fan out(扇出)详解
在flume中有时候需要将一个源(source)将数据发送到多个地方(sink),在flume中该术语叫做扇出(fan out),也就是从一个source向多个channel,就是向多个sink传递事件。下面就展示一个将同一事件传递到HDFS和logger。agent1.sources = source1 agent1.sinks = sink1a sink1b agent1.channels =
fragment 来回切换没有执行onResume
@Override public void setUserVisibleHint(boolean isVisibleToUser) { DLog.i(&quot;tag&quot;, &quot;myinfo setUserVisibleHint&quot;); super.setUserVisibleHint(isVisibleToUser); if (isVisibleToUser){ //相当于onR...
flume学习(四):Flume Interceptors的使用
对于flume拦截器,我的理解是:
使用vue钩子函数mounted,页面回退时不执行的问题
  本人近日做前端的后台管理系统项目,一个问题一直都没解决,就是页面中查看详情按钮第一次点击进去详情页可以被渲染,回退出来第二次进去钩子函数没有被执行,网上这类问题的解决方法并不多,一直以来都没解决,今天终于解决,特来记录下。 解决方法:   activated 可以使用这个钩子函数 以下为具体分析: html 部分 &amp;lt;template&amp;gt; &amp;lt;div class=&quot;...
return命令--后面的程序不执行
C或C++语言中有一个return命令,该命令很容易忽略1项功能,即return为函数结束符,如果函数中运行到return命令后,除了返回值,该函数也将运行结束,后面如果有程序也将不再运行,不过也不用担心这一点,后面程序不运行的前提是要运行到return命令,因为有些if判断,是不运行对应分支的return命令的。
spring+quartz项目,让一个quartz实例不执行。
最近有个项目,用到了tomcat集群。有需求,让quartz定时任务在某台服务器上不跑。于是一番搜索加询问,终于找到了解决方案。quartz.properties 实现让一个quartz实例不执行。# add org.quartz.threadExecutor.classorg.quartz.threadExecutor.class = com.xxx.job.service.impl.DryRu...
Flume的体系结构介绍以及Flume入门案例(往HDFS上传数据)
# Flume的体系结构 对java有兴趣的朋友可以加上面说的553175249这个群哦,一起学习,共同进步 . # Flume介绍 Flume是Cloudera提供的一个高可用的,高可靠的,分布式的海量日志采集、聚合和传输的系统,Flume支持在日志系统中定制各类数据发送方,用于收集数据;同时,Flume提供对数据进行简单处理,并写到各种数据接受方(可定制)的
文章热词 机器学习教程 Objective-C培训 交互设计视频教程 颜色模型 设计制作学习
相关热词 mysql关联查询两次本表 native底部 react extjs glyph 图标 学习区块链哪个地方好 flume大数据视频