how to print for result1 in this code

I'm learning official document But the example is not complete. The code is: https://paste.ubuntu.com/p/Mx96MWjQ83/ Could you tell me how to print result1 in above code? (The above code is wrong) Thanks for your help.

????????flink sql???????? result????????

?? ?? https://paste.ubuntu.com/p/Mx96MWjQ83/ result1?? ??

????????flink sql???????? result????????

?? ?? https://paste.ubuntu.com/p/Mx96MWjQ83/ result1?? ??

Re: Remote Stateful Function Scalability

Hi Elias, On Sun, Oct 18, 2020 at 6:16 AM Elias Levy wrote: > After reading the Stateful Functions documentation, I am left wondering > how remote stateful functions scale. > > The documentation mentions that the use of remote functions allows the > state and compute tiers to scale

Re: PyFlink:

Hi Thilo, You need also add the transitive dependencies of Avro, e.g. jackson-core-asl, jackson-mapper-asl, etc. It will provided a uber jar since 1.12, you could refer https://issues.apache.org/jira/browse/FLINK-18802 for more details.

Remote Stateful Function Scalability

After reading the Stateful Functions documentation, I am left wondering how remote stateful functions scale. The documentation mentions that the use of remote functions allows the state and compute tiers to scale independently. But the documentation seems to imply that only a single instance of a

registerTableSink方法未来如何变化？

[cid:83274b41-5c64-43d6-a133-b316923dc1ed] 如上图registerTableSink已经标记了@Deprecated 会在哪个版本删除它。我看目前代码中即使使用tEnv.connect() 最终还是会调用registerTableSink。未来这里会如何设计。 来自 Outlook

????pyflink??udf??????????python3.5??????

?? ??apache-flink??python3.5?? ??: https://enjoyment.cool/2020/02/27/Three-Min-Series-How-to-create-UDF-in-PyFlink-1-10/ ??: File "dev/.conda/envs/3.5/lib/python3.5/site-packages/apache_beam/runners/common.pxd", line 85, in init

Re: Broadcasting control messages to a sink

Hi Julian, Glad to hear it worked! And thanks for coming back to us :) Best, Piotrek sob., 17 paź 2020 o 04:22 Jaffe, Julian napisał(a): > Hey Piotr, > > > > Thanks for your help! The main thing I was missing was the .broadcast > partition operation on a stream (searching for “broadcasting”

flink sql count distinct??????????

??flink sqldaugroupbycount distinct user_id??table.optimizer.distinct-agg.split.enabled=true job??mysql

Re: Flink SQL 1.11如何获取执行计划 & StreamGraph

如题所说，以下是我个人分析，希望社区大佬帮忙看看是否正确，根据源码 遇到No operators...异常的原因是transformations为空，在1.10版本，transformations的赋值动作(addOperator方法)在sqlUpdate()调用时触发，在1.11版本移除掉了该方法，transformations的赋值动作在statementSet.execute()时才会执行，是不是可以理解为transformations不会提前赋值，只有提交时才会初始化，所以在作业提交前无法获取作业的执行计划，我觉得这个是不是不太满足用户使用场景，不知道1.11这么做是有什么取舍吗？