9:06
> To:Jun Zhang <825875...@qq.com; user-zh@flink.apache.org <
> user-zh@flink.apache.org
> Cc:user-zh@flink.apache.org likeg...@163.com
> Subject:Re: 使用Flink1.10.0读取hive时source并行度问题
>
>
> Hi jun,
>
> 很好的建议~ 这是一个优化点~ 可以建一个JIRA
>
> Best,
> Jingsong Lee
he.org ; like
Subject:Re: 使用Flink1.10.0读取hive时source并行度问题
Hi jun,
很好的建议~ 这是一个优化点~ 可以建一个JIRA
Best,
Jingsong Lee
--
From:Jun Zhang <825875...@qq.com>
Send Time:2020年3月3日(星期二) 18:45
To:user-zh@flink.apache.org ; JingsongLee
ng Lee
--
From:like
Send Time:2020年3月2日(星期一) 16:35
To:lzljs3620...@aliyun.com
Subject:回复: 使用Flink1.10.0读取hive时source并行度问题
我使用的是 StreamTableEnvironment,确实有碰到这个问题呢。
在2020年3月2日 16:16,JingsongLee 写道:
自动推断可能面临资源不足无法启动的问题
理论上不应该呀?Batch作业是可以部分运行的。
Best,
Jingso
建议使用Batch模式来读取Hive table。
Best,
Jingsong Lee
--
From:like
Send Time:2020年3月2日(星期一) 16:35
To:lzljs3620...@aliyun.com
Subject:回复: 使用Flink1.10.0读取hive时source并行度问题
我使用的是 StreamTableEnvironment,确实有碰到这个问题呢。
在2020年3月2日 16:16
> 自动推断可能面临资源不足无法启动的问题
理论上不应该呀?Batch作业是可以部分运行的。
Best,
Jingsong Lee
--
From:like
Send Time:2020年3月2日(星期一) 15:35
To:user-zh@flink.apache.org ; lzljs3620...@aliyun.com
Subject:回复: 使用Flink1.10.0读取hive时source并行度问题
非常感谢!我尝试关闭自动
同,如果有Shuffle,使用配置的统一并发。
Best,
Jingsong Lee
--
From:like
Send Time:2020年3月2日(星期一) 14:58
To:user-zh@flink.apache.org
Subject:使用Flink1.10.0读取hive时source并行度问题
hi,大家好
我使用flink1.10.0读取hive表,启动时设置了全局的并行度,但是在读取的时候,发现sink并行度是受约束的,
而source
--
From:like
Send Time:2020年3月2日(星期一) 14:58
To:user-zh@flink.apache.org
Subject:使用Flink1.10.0读取hive时source并行度问题
hi,大家好
我使用flink1.10.0读取hive表,启动时设置了全局的并行度,但是在读取的时候,发现sink并行度是受约束的,
而source的并行度不受此约束,会根据source的大小改变,大的时候并行度大到1000,请问一下怎么处理这个并行度呢?
hi,大家好
我使用flink1.10.0读取hive表,启动时设置了全局的并行度,但是在读取的时候,发现sink并行度是受约束的,
而source的并行度不受此约束,会根据source的大小改变,大的时候并行度大到1000,请问一下怎么处理这个并行度呢?