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问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
页面刷新新后让页面停留在原来点击的位置
 
quartz个别任务不执行处理
偶然发现生产环境配置的多个定时任务,有一个突然不执行了。而且重启jboss多次也无效。将代码拉到测试环境,修改测试配置,发现也是无法执行。想到使用的是quartz的数据库管理,在对应的数据库表里删除对应那个任务的数据。重启jboss来重新生成任务,任务配置数据自动插入数据库。查看日志,一切正常。
关于某些时候notifyDataSetChanged不运行的问题
如果遇到再Adapter中遇到notifyDataSetChanged方法不起作用的时候,不妨试试,使用把message发送到Handler里,在Handler里调用,具体不知道为什么,但是确实有效0.0
Flume学习(一)Flume初始
一、FLUME介绍 Flume是一个分布式、可靠、和高可用的海量日志聚合的系统,支持在系统中定制各类数据发送方,用于收集数据;同时,Flume提供对数据进行简单处理,并写到各种数据接受方(可定制)的能力。 设计目标: (1) 可靠性 当节点出现故障时,日志能够被传送到其他节点上而不会丢失。Flume提供了三种级别的可靠性保障,从强到弱依次分别为:end-to-end(收到数
Activity onDestroy方法未能及时执行原因
网上出现的情况也不少,大致看了下主要有以下几类: AndroidManifest 针对某个activity 设置的theme为 @android:style/Theme.NoTitleBar 在目前项目中(android2.0),发现一个严重BUG。当打开了A,B两个页面的时候,此时当前页面为B,如果在B中调用finish()后,虽然已经回到了A,但B却并没有执行onDestroy()方法,只有...
Flume NG源码分析(四)使用ExecSource从本地日志文件中收集日志
常见的日志收集方式有两种,一种是经由本地日志文件做媒介,异步地发送到远程日志仓库,一种是基于RPC方式的同步日志收集,直接发送到远程日志仓库。这篇讲讲Flume NG如何从本地日志文件中收集日志。 ExecSource是用来执行本地shell命令,并把本地日志文件中的数据封装成Event事件流在Flume NG中流动。它的典型配置如下,指定source类型是exec,指定Source下游
Flume监听文件目录sink至hdfs配置
一:flume介绍         Flume是一个分布式、可靠、和高可用的海量日志聚合的系统,支持在系统中定制各类数据发送方,用于收集数据;同时,Flume提供对数据进行简单处理,并写到各种数据接受方(可定制)的能力。,Flume架构分为三个部分 源-Source,接收器-Sink,通道-Channel。   二:配置文件     此配置文件source为一个目录,注意,
js 鼠标在一个元素上停留一段时间才执行某方法
$('body').on('mouseover','.ac_over',function() {        timer = setTimeout(function(){            preview($('.ac_over').attr('data-id'));        },500);    });    $('body').on('mouseout','.ac_over',fu...
关于Java安装中环境变量的配置 或 Javac可执行但是Java -version不可执行
今天是本学期重装系统后再次安装JDK,在安装过程中发现了以前没有注意到的环境配置问题。 从网上的一些安装教程,以及前辈们的blog都学到了一些新东西, 一、JAVA_HOME              作用:给别的software 使用的, like  tomcat; 二、CLASSPATH               作用:告诉自己所写的java program 去哪找引用的类(别人已经写...
web.xml中配置的listener,什么时候执行?
在web.xml中配置listener 在web服务器启动时调用,即工程启动时调用。 参考链接:http://blog.csdn.net/lanchengxiaoxiao/article/details/7402246 filter和listener相同点: 和web.xml中配置的filter一样,listener也是在程序启动时就完成初始化。 filter和listener不同点:
SSH客户端不能执行过多SQL命令时的解决办法
SSH客户端执行SQL命令时对sql命令的长度由限制,过长则会报一些无缘无故的错误,搞得你二丈和尚摸不着头脑,对于一个项目的全部sql语句最好分几次执行,每次不超过100行格式良好的sql。
安卓动画——让控件停留在动画结束的位置
private void showReleaseAnimation(final View view,float y){ TranslateAnimation translateAnimation = new TranslateAnimation( 0f, 0f,
FutureTask进入完成状态,会永远停止在这个状态
      今天在使用ScheduledExecutorService的时候,发现scheduleWithFixedDelay和scheduleAtFixedRate的参数都是Runnable,于是想到使用FutureTask封装一下:FutureTask<String> task = new FutureTask<String>(new ComputeTask(1000)...
flume常用source问题总结
一、SpoolDirectorySource 作用: 监测配置的目录下新增的文件,并将文件中的数据读取出来。 问题: 1.spool目录下的文件不可以再打开编辑;spool目录下不可包含相应的子目录2.SpoolSource无法实现实时的收集数据 解决:log4j TimeRolling的插件,分割机制设为1分钟一次,需改log4j配置文件3.无法使用TimeRolling插件,手工cop
打断点异常----打了不执行,停在没有打断点的地方
1 clear all的存在导致断点无效2更改后未保存便运行,会停在奇怪的地方(并没有断点)
[Untiy3d技巧学习]Untiy中用作计数器,或在间隔时间内执行某一代码的方法。
在游戏制作中,我们需要用到类似于在一定时间后执行某一段代码的方法来实现一些效果,其逻辑等同于如现实世界中的“红绿灯”。 在Untiy当中,存在两种常用的代码去实现这一功能。 方法一:计数器累加 先定义好一个用于计数的变量_currenTimeCnt = 0; 再一定一个用于比较的变量_waitTime =1.0f; 通过Update()方法,用if..else循环比较两个
js 刷新页面后保持页面原来的位置
使用js方法: 1.window.scrollTo(x, y);  页面左滚动
flume多个agent连接(配置文件)
-------从tail命令获取数据发送到avro端口另一个节点可配置一个avro源来中继数据,发送外部存储tail-avro.conf################### Name the components on this agenta1.sources = r1a1.sinks = k1a1.channels = c1# Describe/configure the sourcea1.s...
flume使用(四):taildirSource多文件监控实时采集
flume使用(一):入门demo flume使用(二):采集远程日志数据到MySql数据库 ...
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简单案例2 多个source一个sink
案例设计 flume3的配置文件 # Name the components on this agent a1.sources = r1 r2 r3 a1.sinks = k1 a1.channels = c1 # # Describe/configure the source a1.sources.r1.type = exec a1.sources.r1.command =
完数据库后JOB不执行问题处理
完数据库后JOB不执行问题处理 sqlplus /nolog conn /as sysdba show parameter job; alter system set job_queue_processes=30; exec  dbms_ijob.set_enabled(true); oradebug setmypid oradebug  dumpvar sga kkjsre
c++程序执行时候,有的语句根本不执行的原因
(1)问题描述:咱们在写程序的时候,希望程序能够按照自己的想法顺利执行下去。但是有时候却出现根本不执行的情况。如以下程序显示 for(int j=0 ; j<=bmpWidth-1 ;j++) { for(int k=0 ; k<3; k++)           //控制rgb的变化  { //m=*(pBmpBuf+i*lineByte+j*3
【转】js在页面滚动到一定位置时触发事件?
function getTop(e) { var offset=e.offsetTop; if(e.offsetParent!=null) //只要还有父元素,也就是当前元素不是根节点就继续往上累计元素的高度 offset+=getTop(e.offsetParent); return offset; } var myBlockTop = getTop(do
ServletContextListener 使用。web启动监听启动和结束时的调用
web.xml监听配置 org.springframework.web.context.request.RequestContextListener XXXX.ContextDestroyListener import java.sql.Driver; import java.sql.DriverManager; import java.sql.SQ
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日志写入hbase问题记录
flume日志写入hbase问题记录 标签(空格分隔): flume flume使用kafkachannel,source为avro,应用通过logback写入 logback-flume-appender数据发送body内容异常 这个问题在单进程写日志的时候不会出现,在2个以上的进程时出现event的body数据异常,导致flume的自定义sink中无法解析数据 ...
子程序执行return语句,之后未执行的语句将不再执行
在函数定义的函数体中,只要遇到return语句就立即返回,该return语句后面即使有未执行的语句,也不再执行。
android 一定间隔时间后执行操作,如防止重复点击、5s后弹出对话框
private static long lastClickTime; public void onClick(View v) if (isFastDoubleClick()) {  System.out.println("TRUE");        return;        }else{          //弹出Toast或者Dialog       System.o
flume参数配置详解
一、什么是flume Flume是一个高可用的,高可靠的,分布式的海量日志采集、聚合和传输的系统,Flume支持在日志系统中定制各类数据发送方,用于收集数据;同时,Flume提供对数据进行简单处理,并写到各种数据接受方(可定制)的能力。 二、flume特点 flume的数据流由事件(Event)贯穿始终。事件是Flume的基本数据单位,它携带日志数据(字节数组形式)并且携带有头信息,这些Ev...
flume配置及问题处理
一、flume配置 一台机器做负载均衡,二台服务器做存储hdfs ============================================ hadoop01   ============================================ #声明Agent a1.sources = r1 a1.sinks = k1 k2 a1.channels = ...
解决Flume采集数据时在HDFS上产生大量小文件的问题
问题:flume指定HDFS类型的Sink时,采集数据至HDFS指定目录,会产生大量小文件。问题重现:1、创建flume配置文件flume-env.sh,:flume配置文件如下(根据自身需要修改):    因为flume可以配置多种采集方式,每种采集方式对应一个agent配置文件,flume即通过运行agent完成采集工作,这里为了方便重现问题,直接监控整个目录。flume的agent配置文件如...
Flume Sink到Kafka遇到的问题
1、版本问题 2018-12-02 15:23:06,334 (conf-file-poller-0) [ERROR - org.apache.flume.node.AbstractConfigurationProvider.loadSinks(AbstractConfigurationProvider.java:427)] Sink k1 has been removed due to an e...
Ambari学习1_Ambari——大数据平台的搭建利器
虽然大数据越来越流行,但其学习的门槛却一直阻碍着很多的分布式应用初学者或者大数据的业务应用开发者。多个产品之间的不兼容问题,快速集成和维护也显得比较困难。不管是 Hadoop V1 或者 V2 的安装,又或者 Spark/YARN 等的集成,都不是几行简单的命令可以完成的,而是需要手工修改很多的集群配置,这进一步增加了业务开发者的学习和使用难度。有了 Ambari,这些都不再是难题。  
【Flume】flume 容错环境的搭建 failover
关于failover网上也有很多例子,但是看到的有多重做法,个人觉得,本着职责单一的原则 1、一台机子运行一个flume agent 2、一个agent 的下游sink指向一个flume agent,不要一个flume agent配置多个端口【影响性能】 下面看具体实例: 首先是flumet agent client的配置 priority越高,优先级越高,会优先使用该sink
Flume常用配置参数
概述 本篇文章是根据Flume官网对Flume组件(Source,Channel,Sink)的常用配置参数做一个主要介绍,如有表达意思错误希望不吝指出。 Sources Flume中常用的Source有NetCat,Avro,Exec,Spooling Directory,Taildir,也可以根据业务场景的需要自定义Source,具体介绍如下。 NetCat Source ...
关于oracle创建定时器和定时器创建成功后不运行的问题解决
一、创建一个定时器 1.首先创建一个存储过程,代码和注释如下 //存储过程 CREATE OR REPLACE PROCEDURE delete_t_check_data --delete_data1为存储过程名 IS BEGIN delete t_check t where t.createtime <= add_months(sysdate,-3); --sql语句
debounce函数让一个方法在一定时间内只能执行一次
debounce函数让一个方法在一定时间内只能执行一次 源码: function debounce(func, wait, immediate) { let timeout, args, context, timestamp, result const later = function() { // 据上一次触发时间间隔 const last = +new Da
Flume(一) Flume初识 环境的搭建和配置
Flume初识本文主要包括如下的几个部分: 下载Flume 配置Flume 启动Flume 及其命令解析 1. 下载Flume到Flume的官方网站下载相关文件Flume官网,本人下载的是最新的稳定版本:1.7.0。(ps:下载编译后的文件,不要下载源文件。我们的目标是使用Flume,而不是研究Flume的源码。) 下载图示如下: 2. 配置Flume的配置文件 为什么需要配置Flume的文
flume消费文件夹消费不及处理办法
文件生产速度过快,flume会出现消费不及的现象,下面这个参数调节一下应该会有改善: maxBackoff 这个参数代表当source向channel放数据时检测到channel满了后等待多久再进行重试,默认是4秒。如果已经出现消费不及现象,channel频繁被撑满,然而满了后还要等很久,造成文件越来越多,降低这个参数可以有效缓解消费不及。 官网链接:http://flume.apache.o
文章热词 Python爬虫框架Django配置 Python爬虫框架scrapy配置 SmartContract插件配置 Java zuul配置教程 编程语言学哪个好
相关热词 c++执行后一闪而过 c#3秒后执行 bootstraptable绑定后执行 学习区块链哪个地方好 哪里好的python培训班好