1.配置就不讲了，首先创建一个简单的java项目，和git关联上，选择你的项目文件夹，此时项目右下角会出现master分支字样22.本地git项目和远程仓库关联，在github上建立一个仓库，最好名和项目名一样,然后新建First文件，在项目名上点右键，然后git选择commit directory,出现这个画面，只勾选新建的文件，其它IDEA生成的文件不要勾选，然后选择远程仓库的地址，点push

本篇主要讲述，flume收集日志数据，这里写了脚本，日志数据每隔一秒写入一条记录，flume将记录写到Kafka中，供Storm进行处理，这里的storm，可参考的我的其它文章，这里就不讲了。产生数据脚本。python脚本#!/usr/bin/pythonimport timefile1=open("/opt/app/log.log","a");mess="message";file

思路服务端设置修改server.properties 增加 log.message.timestamp.type=LogAppendTime具体可参考http://kafka.apache.org/0100/documentation.html#introduction参考代码public class ConsumerTimeStamp extends Thread {...

1.这个错误是启动 cloudera-scm-server服务出现的2. 先看一下报错的内容2017-04-29 18:45:25,476 INFO main:org.hibernate.service.jdbc.connections.internal.C3P0ConnectionProvider: HHH010002: C3P0 using driver: com.mysql.jdbc.D

文章目录背景antlr4定义语法文件查看生成的语法树生成代码测试结果背景开发es查询程序，每次都要进行编码，大部分代码都是重复代码，实际上最后生成的就是json，简单🤔下，有没有开发人员都会的一种表达语言，将表达语言转换成json,很明显sql可以，开发人员都会，然后生成项目时，只需用sql来描述，你想要的查询，然后把日期等参数在json中完成替换即可，即可生成查询结果。es json 如下{"