- 博客(25)
- 资源 (5)
- 收藏
- 关注
RSS订阅原创 flink Sql 1.11.2 executeSql报No operators defined in streaming topology. Cannot generate StreamGraph.
如下所示：不需要再次执行env.execute()
2020-12-12 12:46:33
1510
3
原创 Java使用html样式发送带表格的邮件
效果如图:以上截图是邮件的内容.实现:一`借鉴了大佬的文章:https://blog.csdn.net/u014653854/article/details/86021758想到的办法二`以下是具体的实现html的拼接,mapListCoinPhoneFee是查询数据库返回的结果,遍历: StringBuilder stringBuilder = new StringBuilder(); stringB...
2020-10-28 19:02:27
5105
5
原创 mvn assebmly:assembly 打可执行jar，找不到本地依赖问题解决
项目中有使用到友盟的sdk，但是不能通过maven下载，因此只能本地引用此jar。在打包过程中，由于使用了本地的jar，通过maven 命令：mvnassebmly:assembly 打好包后，发现找不到本地引用的jar。本地引用的lib如下：在查找资料后，找到一种相比较而言简单解决办法：1、在pom文件中，写上如下配置：2、新建对应目录和文件：3、文件内容如下：<assembly xmlns="http://maven.apache.org/plugins.
2020-05-20 15:21:54
1696
原创 windows10 上安装docker以及简单的操作实例
1、首先去下载Docker Desktop Installer.exe,https://download.docker.com/win/stable/Docker%20Desktop%20Installer.exe2、下载完成后安装，需要windows家庭版以上系统，由于我之前也是家庭版安装失败，后续让网络同事升级到pro版后，即安装顺利。3、安装完成之后，使用cmd命令，docker -...
2019-11-21 10:04:15
542
原创 解决ClickHouse短连接超时的一个问题
在通过消费kafka数据写入到CK中，经常会遇到CK的连接失败问题，例如以下报错信息：clickhouse exception, code: 1002, host: *.*.*.*, port: 8123; *.*.*.*:8123 failed to respond解决办法是在线程池设置中，标注中的时间小点，就可以，顺便可以看看这个参数所代表的含义：timeBetweenEvicti...
2019-08-08 17:26:31
22248
12
原创 Flume-RocketMQ整合
此篇文章,主要是借鉴了码云上某位大佬的项目,我这边根据自己的需求做了一个整合.需求是flume采集日志,sink到阿里的RocketMQ组件. 下面我先贴上我的flume配置,其中***为必填项,且是你RocketMQ的配置(在你开通的时候能获取到)gent1.sources=source1agent1.channels=channel1agent1.sinks=sink...
2019-08-03 11:13:43
1778
原创 ClickHouse 数据导出导入
1、导出 远程导出命令，默认分割符是tab：echo 'select * from table_name' | curl ip:8123?database=mybi -uroot:password -d @- > table_name.sql2、导入数据，以tab作为分割符： 导入数据库的本机执行：cat table_name.sql| clickhous...
2019-03-01 15:18:38
25920
3
原创 解决ClickHouse 引擎ReplacingMergeTree更新数据，数据double问题
在我们使用ReplacingMergeTree引擎更新数据时，ClickHouse会根据最新数据来刷新数据，刷新数据是有一个频率的，当我们更新数据但是数据库没有merge时，此时做sum或者count时，数据量会翻倍。而手动执行merge，又会压榨数据库性能，所以此方式不是一种有效的解决办法。这是我们需要的时最新的一批数据（或者说二选一）。 1、这时我们熟悉关系型数据...
2019-02-28 15:14:20
16725
6
原创 win10 共享文件夹 nplayer查看共享文件
win10：一、找到你要共享的文件夹，右键属性-共享，点击共享，选择你要共享的用户，点击共享，然后点击完成。二、去网络和共享中心设置，如下所示：三、先启用密码保护共享，设置电脑用户密码。四、打开手机端的nplayer，点击网络，右上角+，扫描网络，找到你电脑的名称（不知道名称的，此电脑-属性可以找到）。找到后，输入你共享的账户名称和密码，此时就可以看见你共享的文件夹了。...
2019-01-30 10:43:54
12378
原创 关于帆软软件的js和网页超链接实例
一、如图所示，我要点击店铺名称跳转到其他页面，如何并将参数传过去？二、在你的cpt模板需要点击栏目的单元格上建立超链接，这里提供两种方法 2.1 JavaScript方式 标注1：指的是，跳转目标cpt模板url中需要的参数 ，也是你需要拼接的参数 标注2：是指从源cpt模板中获得的参数（也就是你需要传递的参数，例如上图所示，我选哟传递的参数是店...
2018-05-21 14:37:24
10071
原创 java 获取当前时间的n周之前所在周的日期区间（n为整数表示之前，-n表示当前时间往后）
public String getWeeksDate(int n) { //获取当前日期 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); Calendar calendar1 = Calendar.getInstance(); Calendar calendar2 = Calendar.getIn...
2018-05-17 09:32:22
1158
原创 个人解决的一个IDEA项目中不能引用pom文件中添加的依赖问题
在某一次的开发过程中，发现在pom文件中已经添加好了依赖以及版本号等，可是代码中并不能引用这些依赖。最终还是找到了解决办法：在IDEA中找到MAVEN插件（file->setting->搜索框中输入maven->ignored files）,看看有没有把你的pom文件给忽略的，取消掉即可，我的就是这个问题。...
2018-02-11 15:29:26
10608
3
原创 maven部署项目到远程服务器
在项目部署的过程中，通常需要打war包，在将war包远程拷贝到目的服务器。操作有点麻烦，也是能接受。不过有了一种更方便的操作：是IDEA通过maven将打好的war直接部署到远程服务器的步骤。一、在安装的Tomcat目录下找到/conf/tomcat-user.xml这个文件，在文件的末尾添加以下ho红色内容：roles="manager-gui,m
2018-01-29 15:10:03
3697
原创 IDEA中将制表符换成\t
在一次项目开发中，分隔符是以\t来的。在某次模拟的过程中，建立了一个txt文件，按照tab来分割，发现程序运行的时候，并不能达到想要的效果，最后检查txt文件，发现是IDEA的默认tab并不是\t。所以去找度娘，解决了修改的办法，如下：settings-->code style-->other file types-->scheme下拉为project。将use tab character前面勾选
2018-01-18 16:03:01
4316
1
原创 解决定时任务中中文乱码问题
手动执行脚本不会出现乱码，使用定时任务后，发现日志文件中存在乱码，如下图所示解决方法：一、确定系统的编码：echo $LANG,我的是en_US.UTF-8二、确定后，在定时任务前加入export LANG=en_US.UTF-8，后面加上你的脚本即可，如三、最终结果
2017-09-22 11:01:56
1347
原创 nginx安装与配置
Liunxlinux环境下安装nginx步骤开始前，请确认gcc g++开发类库是否装好，默认已经安装。ububtu平台编译环境可以使用以下指令apt-get install build-essentialapt-get install libtoolcentos平台编译环境使用如下指令 安装make：yum -y install gcc automake aut
2017-09-18 15:23:21
375
原创 mongodb linux suse11 安装
一、下载mongodb安装包https://www.mongodb.com/download-center#community 选择相应的操作系统进行下载（以suse11为例）二、创建对应的文件目录mkdir /data/db:此目录为默认的数据库存储目录，如果没有手动创建则会./bin/mongod 启动失败三、新建mongodb目录，mkdir /data/mo
2017-09-05 10:46:38
718
原创 zookeeper和kafka集群搭建
一、下载zookeeper-3.4.6.tar.gz二、安装jdk1.7，并配置好hosts文件的机器名称三、在目录data下，建立zookeeper目录，拷贝安装包到zookeeper，解压tar -zxvf zookeeper-3.4.6.tar.gz四、进入解压目录的conf文件下，cp zoo_sample.cfg zoo.cfg复制一份zoo.cfg文件五
2017-09-04 18:24:03
267
原创 hive on spark 执行出错解决
Caused by: java.lang.RuntimeException: Expected only partition pruning predicates: (((isnotnull(TM_INTRVL_CD_DAY#8) && isnotnull(CHANNEL#7)) && (TM_INTRVL_CD_DAY#8 = 20170227)) && (CHANNEL#7 = youshus
2017-04-25 12:14:01
2908
原创 SFTP 报错 pipe closed
原因是代码中执行顺序错误，应该是先链接上SFTP 再创建ChannelSFTP。错误代码：ChannelSftp cs = para.sftp;if (!para.isConnected) connectSFTP(para, para.conFTPTryCount);正确的代码 应该如下：if (!para.isConnected) connectS
2017-04-12 16:31:50
27237
1
原创 Spark本地运行出错问题：Exception in thread "main" java.lang.NoSuchMethodError: scala.Predef$.refArrayOps([Lja
出错如下图所示：这问题是由于jar冲突导致的：我原先的jar包是：scala-sdk-2.12.1和spark-assembly-1.6.0-hadoop2.6.0由于spark1.6的支持最高的scala版本是scala-2.10.X 所以换成scala-2.10.6可以解决问题。下载地址：http://www.scala-lang.org
2017-03-21 18:09:04
20408
3
原创 Hive执行INSERT overwrite 报错：query returned non-zero code 1
解决办法：重新启动hive的metastore 等的相关进程即可。nohup hive --service metastore &nohup hive --service hiveserver -p 10002 &
2016-10-12 16:07:55
5499
原创 Flume-ng报错
java.io.FileNotFoundException: /opt/software/applog/UserCountLog/comlog/.flumespool/.flumespool-main.meta (权限不够)解决办法：进入目录：cd : /opt/software/applog/UserCountLog/comlog/.flumespool/ 然后给权限：chmod 777 .
2016-08-20 11:12:36
1423
1
原创 Caused by: java.lang.RuntimeException: Could not generate DH keypair异常处理
一、换新版本JDK7。二、下载下面两个jar，并放在你的jdk路径ext下（我的是C:\Program Files\Java\jdk1.6.0_45\jre\lib\ext），并修改C:\Program Files\Java\jdk1.6.0_45\jre\lib\security目录下的java.security文件，末尾加上security.provider.2=org.bouncycas
2016-06-27 16:55:32
8696
3
原创 使用AES加密解密在windows上使用没有问题，在Linux（Centos6.5）上出现解密失败的解决方法
据网上资料所知，是因为在加密后，因为不同系统环境差异所致解密失败。我把自己解决的方法说一下：在加密的时候最好用BASE64Encoder去封装一下即可（不封装的话解密的时候会莫名其妙的丢掉加密的字符）。当然这只是本人的解决办法（实验可用）。下面上加密和解密的代码：仅供参考，重点是红色部分。/** * 根据key 加密src * @param key * @param sr
2016-06-16 11:08:35
3523
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人