青牛主题列表_海汼部落 | IT学习->实战为王

创始人

青牛

第 12 位会员

449 关注者

2251 评论

308 话题

WeChat
Website
公司
城市

解析多层 JSON 嵌套数据的时候，某些字段混有 “” {}导致解析失败？

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

不是括号的问题，而是括号前面冒号的问题
flink 消费 kafka 数据如何保证同一分区的顺序一致性？

flink以后的问题吧，分区之间保证one to one的传输
cdh 出现问题该如何解决？

弄个私有源吧
flink Linux 上运行抱错？

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

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

是不是你的上一条数据处理的太慢了，不然不可能呀
flink 写入 Redis 偶尔会出现 broken pipe ?

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

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

写sql转成第二列
flink:keyedprocessfuction 添加 state 后,报 Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy/failureRateRestart？

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

你也没给类中定义的变量复值呀
flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？

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

flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？

@张浩

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

槽设置大点

flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？

你里面是怎么配置env的