1、JedisConnectionPool.scala package sparkstreaming import redis.clients.jedis.{Jedis, JedisPool, JedisPoolConfig} object JedisConnectionPool{ val conf ...
分类：
其他好文 时间：
2020-08-07 18:03:42
阅读次数：
62
ThreadPoolExecutor executor = new ThreadPoolExecutor(2, //核心线程数 5,//最大线程数 60L, //临时线程空闲时间 TimeUnit.SECONDS,//时间单位 new ArrayBlockingQueue<Runnable>(25) ...
分类：
编程语言 时间：
2020-08-06 17:06:28
阅读次数：
85
服务器列表 统一设置系统时间 timedatectl set-ntp no timedatectl set-time '2020-08-05 11:58:08' 规划：4个docker宿主机，两个manager节点互备，manager节点同时承担worker的角色 Server01节点以管理者身份加 ...
分类：
其他好文 时间：
2020-08-06 15:37:59
阅读次数：
96
类的结构： Executor-ExecutorService--AbstractExecutorService ThreadPoolExecutor ThreadPoolExecutor七大构造参数： package com.dwz.executors; import java.util.concu ...
分类：
其他好文 时间：
2020-08-05 10:39:42
阅读次数：
89
TensorFlow 是一个端到端开源机器学习平台 安装 pip3 install tensorflow 使用时报错如下 2020-06-03 09:42:51.737502: W tensorflow/stream_executor/platform/default/dso_loader.cc:5 ...
分类：
其他好文 时间：
2020-08-05 10:33:08
阅读次数：
111
长按二维码，关注我们项目在重新发布的过程中，如果有的请求时间比较长，还没执行完成，此时重启的话就会导致请求中断，影响业务功能，优雅重启可以保证在停止的时候，不接收外部的新的请求，等待未完成的请求执行完成，这样可以保证数据的完整性。SpringBoot1.Ximportjava.util.concurrent.Executor;importjava.util.concurrent.ThreadPoo
分类：
编程语言 时间：
2020-08-03 23:20:45
阅读次数：
70
针对hive on mapreduce 1：我们可以通过一些配置项来使Hive在执行结束后对结果文件进行合并： 参数详细内容可参考官网：https://cwiki.apache.org/confluence/display/Hive/Configuration+Properties 1 2 3 4 ...
分类：
数据库 时间：
2020-08-03 19:56:21
阅读次数：
103
多线程 创建线程的两种方式 1.继承Thread类，重写它的run方法； 2.实现Runnable接口，重写它的run方法； 延时睡眠 sleep(延时)使线程休眠不会释放锁 线程终止 定义一个标志位flag=false,不推荐使用stop（），destroy()方法 线程强制执行 join,可以想 ...
分类：
编程语言 时间：
2020-07-30 10:47:15
阅读次数：
77
