啥情况，你是调整了sql部分实现嘛。有示例嘛。
zilong xiao 于2020年8月29日周六 下午5:19写道：
> SQL 算子并行度设置可以自己实现，可以私下交流下，正好在做这块，基本能工作了
>
> JasonLee <17610775...@163.com> 于2020年8月23日周日 下午2:07写道：
>
> > hi
> > checkpoint savepoint的问题可以看下这个
> > https://mp.weixin.qq.com/s/Vl6_GsGeG0dK84p9H2Ld0Q
> >
> >
> >
> > --
> > Sent from:
SQL 算子并行度设置可以自己实现，可以私下交流下，正好在做这块，基本能工作了
JasonLee <17610775...@163.com> 于2020年8月23日周日 下午2:07写道：
> hi
> checkpoint savepoint的问题可以看下这个
> https://mp.weixin.qq.com/s/Vl6_GsGeG0dK84p9H2Ld0Q
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>
写道：
>> >>检查点呢，大多数用FlinkSQL的同学们，你们的任务是随时可运行那种吗，不是必须保证不可间断的准确性级别吗？
>> >>
>> > >Xingbo Huang 于2020年8月14日周五 下午12:01写道：
>> >>
>> >>> Hi,
>> >>>
>> >>> 关于并行度的问题，据我所知，目前Table API上还没法对每
hi
checkpoint savepoint的问题可以看下这个
https://mp.weixin.qq.com/s/Vl6_GsGeG0dK84p9H2Ld0Q
--
Sent from: http://apache-flink.147419.n8.nabble.com/
> >>> 关于并行度的问题，据我所知，目前Table API上还没法对每一个算子单独设置并行度
> > >>
> >>> Best,
> >>> Xingbo
> >>>
> >>> Zhao,Yi(SEC) 于2020年8月14日周五 上午10:49写道：
> >>>
> >>> >
> 并行度问题
补充个相关问题，除了并行度，flink-sql情况下，能做检查点/保存点，并基于检查点/保存点重启sql任务吗。
>> >
>> > 发件人: "Zhao,Yi(SEC)"
>> > 日期: 2020年8月13日 星期四 上午11:44
>> > 收件人: "user-zh@flink.apache.org"
>> > 主题: 如何设置FlinkSQL并行度
>> >
>> &g
务吗。
>> >
>> > 发件人: "Zhao,Yi(SEC)"
>> > 日期: 2020年8月13日 星期四 上午11:44
>> > 收件人: "user-zh@flink.apache.org"
>> > 主题: 如何设置FlinkSQL并行度
>> >
>> > 看配置文件有 execution. Parallelism，但这个明显是全局类型的配置。
>> > 如何给Sql生成的数据源结点，window结点，sink结点等设置不同的并行度呢？
>> >
>> > 比如数据源理论上应该和kafka分区数一致比较好，window则需要根据数据量考虑计算压力，sink也应该有相应的场景考虑。
>> >
>> >
>>
Hi,
>>
>> 关于并行度的问题，据我所知，目前Table API上还没法对每一个算子单独设置并行度
>>
>> Best,
>> Xingbo
>>
>> Zhao,Yi(SEC) 于2020年8月14日周五 上午10:49写道：
>>
>> > 并行度问题有人帮忙解答下吗，此外补充个相关问题，除了并行度，flink-sql情况下，能做检查点/保存点，并基于检查点/保存点重启sql任务吗。
>> >
>> > 发件人: "
l情况下，能做检查点/保存点，并基于检查点/保存点重启sql任务吗。
> >
> > 发件人: "Zhao,Yi(SEC)"
> > 日期: 2020年8月13日 星期四 上午11:44
> > 收件人: "user-zh@flink.apache.org"
> > 主题: 如何设置FlinkSQL并行度
> >
> > 看配置文件有 execution. Parallelism，但这个明显是全局类型的配置。
> > 如何给Sql生成的数据源结点，window结点，sink结点等设置不同的并行度呢？
> >
> > 比如数据源理论上应该和kafka分区数一致比较好，window则需要根据数据量考虑计算压力，sink也应该有相应的场景考虑。
> >
> >
>
Hi,
关于并行度的问题，据我所知，目前Table API上还没法对每一个算子单独设置并行度
Best,
Xingbo
Zhao,Yi(SEC) 于2020年8月14日周五 上午10:49写道：
> 并行度问题有人帮忙解答下吗，此外补充个相关问题，除了并行度，flink-sql情况下，能做检查点/保存点，并基于检查点/保存点重启sql任务吗。
>
> 发件人: "Zhao,Yi(SEC)"
> 日期: 2020年8月13日 星期四 上午11:44
> 收件人: "user-zh@flink.apache.org&quo
并行度问题有人帮忙解答下吗，此外补充个相关问题，除了并行度，flink-sql情况下，能做检查点/保存点，并基于检查点/保存点重启sql任务吗。
发件人: "Zhao,Yi(SEC)"
日期: 2020年8月13日 星期四 上午11:44
收件人: "user-zh@flink.apache.org"
主题: 如何设置FlinkSQL并行度
看配置文件有 execution. Parallelism，但这个明显是全局类型的配置。
如何给Sql生成的数据源结点，window结点，sink结点等设置不同的并行度呢？
比如数据源理论上应该和kaf
看配置文件有 execution. Parallelism，但这个明显是全局类型的配置。
如何给Sql生成的数据源结点，window结点，sink结点等设置不同的并行度呢？
比如数据源理论上应该和kafka分区数一致比较好，window则需要根据数据量考虑计算压力，sink也应该有相应的场景考虑。
12 matches
Mail list logo
