青牛主题列表_海汼部落 | 高品质的技术社区

创始人

青牛

第 12 位会员

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

活跃于 2024-04-02 22:38:12

437 关注者

2233 评论

299 话题

WeChat
Website
公司
城市

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的
flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？ at 2021-09-15 14:50:02

比如你一共有2个槽，然后你关闭了槽共享，或者你给你的operator起了新的组名，不然不会没有输出结果的。
flink key by 后的 process 不执行？ at 2021-09-14 16:54:35

你看一下webui呗，你的task都跑起来了吗
flink key by 后的 process 不执行？ at 2021-09-14 10:56:33

改完并行度要加槽