Configuration conf = new Configuration();
conf.setString("taskmanager.numberOfTaskSlots", "8");
StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf);槽设置大点
- flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？
-
flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？
你里面是怎么配置env的 - flink 读 kafka 数据源后，算子并行度不一致，导致不能输出？
- flink key by 后的 process 不执行？
- flink key by 后的 process 不执行？
- flink key by 后的 process 不执行？
- hive?
- spark 写入 Excel 问题 ？
- sparksql-广播变量？
- 本地跑 MR，配置都是为集群的，突然连不上？
- SPARK SQL CONTAINS 方法问题？
- hive 安装连接不到 MySQL 数据库？
- hive 安装连接不到 MySQL 数据库？
- hive 安装连接不到 MySQL 数据库？
- hive 安装连接不到 MySQL 数据库？