青牛个人信息_海牛大数据技术交流社区 | 大数据论坛_海牛部落

创始人

青牛

第 12 位会员

注册于 2016-12-24 21:53:20

活跃于 2021-12-16 22:45:23

315 关注者

2077 评论

152 话题

WeChat
Website
公司
城市

Ta 发布的话题

Ta 发表的回复

Ta 关注的用户

Ta 赞过的话题

国内首批大数据从业者，就职于金山，担任大数据团队核心研发工程师

最近话题

[公告] 海牛大数据技术江湖召集令公告 ⋅ 15 点赞 ⋅ 0 回复 ⋅ 2020-06-10 03:08:22
spark 集群快速搭建下载 ⋅ 1 点赞 ⋅ 15 回复 ⋅ 2020-04-15 17:36:35
新手也能快速玩转大数据项目下载 ⋅ 0 点赞 ⋅ 22 回复 ⋅ 2020-03-31 16:03:54
大数据前奏之 javaee 实训项目迭代下载 ⋅ 0 点赞 ⋅ 14 回复 ⋅ 2020-03-31 16:03:40
从 Hadoop 应用到企业级 mapreduce 开发下载 ⋅ 2 点赞 ⋅ 30 回复 ⋅ 2020-03-31 16:03:21
Linux 实战精品课程下载 ⋅ 3 点赞 ⋅ 28 回复 ⋅ 2020-03-31 16:03:01
Hadoop 生态圈集群快速搭建下载 ⋅ 2 点赞 ⋅ 45 回复 ⋅ 2020-03-31 16:02:26
学会 python 只需要 2 天下载 ⋅ 1 点赞 ⋅ 22 回复 ⋅ 2020-03-31 16:02:07
javase 教程全套精品视频下载 ⋅ 1 点赞 ⋅ 50 回复 ⋅ 2020-03-31 16:01:39
7 天时间舒舒服服入门 Java 下载 ⋅ 1 点赞 ⋅ 21 回复 ⋅ 2020-03-31 16:00:40
Elasticsearch 一天速成下载 ⋅ 2 点赞 ⋅ 16 回复 ⋅ 2020-03-31 16:00:24
flink 集群快速搭建下载 ⋅ 4 点赞 ⋅ 25 回复 ⋅ 2020-03-31 15:58:35
Spark 架构师的开端之 scala 编程下载 ⋅ 1 点赞 ⋅ 15 回复 ⋅ 2020-03-31 15:58:11
kafka 一天速成下载 ⋅ 6 点赞 ⋅ 18 回复 ⋅ 2020-03-31 15:57:54
大数据 ETL 实战项目下载 ⋅ 4 点赞 ⋅ 36 回复 ⋅ 2020-03-31 15:57:28
腾讯课堂笔记软件资料领取处下载 ⋅ 4 点赞 ⋅ 9 回复 ⋅ 2020-03-31 15:26:29
[新手必读] 大数据的现在与将来分享 ⋅ 7 点赞 ⋅ 2 回复 ⋅ 2019-12-19 23:39:29
JavaEE 之数据库技术 MySQL 拓展应用文章 ⋅ 0 点赞 ⋅ 1 回复 ⋅ 2019-06-28 16:55:15
JavaEE 之数据库技术 MySQL 实战文章 ⋅ 0 点赞 ⋅ 0 回复 ⋅ 2019-06-28 16:51:03
JavaEE 之数据库技术多表查询文章 ⋅ 0 点赞 ⋅ 0 回复 ⋅ 2019-06-28 16:45:05

最新评论

jar 包打包失败,试了一晚上了,也没大成功? at 2021-12-10 15:17:35

@123456789987654321 检查一下linux的文件大小是否与你编译的一致
jar 包打包失败,试了一晚上了,也没大成功? at 2021-12-10 13:06:24

@123456789987654321 用jd guu反编译看一下jar包里面的东西
jar 包打包失败,试了一晚上了,也没大成功? at 2021-12-09 21:50:19

你把你的jar包加上执行权限
flink 窗口消费 kafak 的数据为什么数据能标准输出到控制台上，但是出不来设置的时间窗口 60 秒？ at 2021-12-09 15:31:33

你自定义一个waterMarker抽取器
flink 消费 kafka 的数据存入 MySQL，怎么检验存入 MySQL 数据的正确性？ at 2021-12-07 19:45:09

同样的的逻辑，这个跑批任务对一下数
解析多层 JSON 嵌套数据的时候，某些字段混有 “” {}导致解析失败？ at 2021-12-05 14:45:25

@LH 你把双引号和冒号替了，你只留个花括号
解析多层 JSON 嵌套数据的时候，某些字段混有 “” {}导致解析失败？ at 2021-12-05 09:28:34

不是括号的问题，而是括号前面冒号的问题
flink 消费 kafka 数据如何保证同一分区的顺序一致性？ at 2021-12-01 03:06:39

flink以后的问题吧，分区之间保证one to one的传输
cdh 出现问题该如何解决？ at 2021-11-26 17:39:07

弄个私有源吧
flink Linux 上运行抱错？ at 2021-11-22 20:35:06

-c后面写这个TestKafka类的绝对类地址
flink 在处理数据流中两条数据时，第一条数据处理完成，会有延迟一段时间再去处理下一条数据。请问采用什么方式避免这种情况？ at 2021-11-16 01:40:36

@张浩是不是其他过程反压了
flink 在处理数据流中两条数据时，第一条数据处理完成，会有延迟一段时间再去处理下一条数据。请问采用什么方式避免这种情况？ at 2021-11-15 11:52:54

是不是你的上一条数据处理的太慢了，不然不可能呀
flink 写入 Redis 偶尔会出现 broken pipe ? at 2021-10-28 18:01:52

是不是什么数据插入的时间太长了
用 Java poi 给 Excel 加颜色，本地测试通过了，在集群上运行出现 java.lang.IllegalArgumentException: InputStream of class class org.apache.commons.compress.archivers.zip.ZipArchiveInputStream is not implementing InputStreamStatistics？ at 2021-10-20 22:32:59

实现类错了吧，linux和windows对颜色处理的机制不一样，可能是linux上面再需要安装点东西
spark 中如何修改 datafraem 中的一列？ at 2021-09-27 14:41:02

写sql转成第二列
flink:keyedprocessfuction 添加 state 后,报 Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy/failureRateRestart？ at 2021-09-16 21:11:12

@张浩你改啥都没用，把这个去掉，我服了
flink:keyedprocessfuction 添加 state 后,报 Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy/failureRateRestart？ at 2021-09-16 20:12:24

你也没给类中定义的变量复值呀
flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？ at 2021-09-15 16:39:03

打断电看看PrintSinkFunction有没有数据进来

flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？ at 2021-09-15 14:59:08

        Configuration conf = new Configuration();
        conf.setString("taskmanager.numberOfTaskSlots", "8");
        StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf);

槽设置大点

flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？ at 2021-09-15 14:51:39

你里面是怎么配置env的