Re: Flink parameter configuration does not take effect

2021-06-17 Thread Jason Lee
Hi Robert, Thank you for your enthusiastic answer I have understood the current problem and look forward to a good solution and optimization by the community. I will continue to pay attention to changes in the community. Best, Jason | | JasonLee1781 | | jasonlee1...@163.com | 签名由网易邮箱大师定制

Re: Flink parameter configuration does not take effect

2021-06-17 Thread Robert Metzger
Hi Jason, I hope you don't mind that I brought back the conversation to the user@ mailing list, so that others can benefit from the information as well. Thanks a lot for sharing your use case. I personally believe that Flink should support invocations like "flink run -m yarn-cluster xxx.FlinkStre

Re: Flink parameter configuration does not take effect

2021-06-16 Thread Robert Metzger
Hi Jason, How are you deploying your Flink SQL tasks? (are you using per-job/application clusters, or a session cluster? ) I agree that the configuration management is not optimal in Flink. By default, I would recommend assuming that all configuration parameters are cluster settings, which requir

Flink parameter configuration does not take effect

2021-06-15 Thread Jason Lee
Hi everyone, When I was researching and using Flink recently, I found that the official documentation on how to configure parameters is confusing, and when I set the parameters in some ways, it does not take effect. mainly as follows: we usually use a DDL Jar package to execute Flink SQL tas