Re: Questions about the client synchronously obtaining task execution results

2023-11-19 Thread 刘峻池
Sorry I forgot to add the version information, the version is 1.17 刘峻池 于2023年11月20日周一 13:59写道: > Hi Flink Community > > When I run this command `flink run-application -t yarn-application -sae > mainClass somejar` to submit some batch-task on YARN with Application > Mode, my shell client always

Questions about the client synchronously obtaining task execution results

2023-11-19 Thread 刘峻池
Hi Flink Community When I run this command `flink run-application -t yarn-application -sae mainClass somejar` to submit some batch-task on YARN with Application Mode, my shell client always terminates after task submission success, then the dispatcher cannot receive the client heartbeat for a lon

Re: [DISCUSS] FLIP-391: Deprecate RuntimeContext#getExecutionConfig

2023-11-19 Thread Junrui Lee
Hi Jing, Thank you for your feedback. I understand your concerns regarding putting all methods into the RuntimeContext flat. I would like to share some of my thoughts on this matter. Firstly, this FLIP only proposes the addition of three additional methods, which should not impose too much extra

Re: [DISCUSS] Change the default restart-strategy to exponential-delay

2023-11-19 Thread Rui Fan
Hi David and Mason, Thanks for your feedback! To David: > Given that the new default feels more complex than the current behavior, if we decide to do this I think it will be important to include the rationale you've shared in the documentation. Sounds make sense to me, I will add the related do

Re: The generated schema is not correct when using filesystem connector and avro format

2023-11-19 Thread Hang Ruan
Hi, julia. I have read the code about this part. The problem as you said is that the RowType passed to the avro-confluent format is nullable, which will cause union with null in the schema. I think FLINK-30438 is the same problem as yours. But I find the RowType passed to avro-confluent format in

Re: [DISCUSS] FLIP-391: Deprecate RuntimeContext#getExecutionConfig

2023-11-19 Thread Jing Ge via user
Hi Junrui, Thanks for bringing this to our attention. First of all, it makes sense to deprecate RuntimeContext#getExecutionConfig. Afaic, this is an issue of how we design API with clean concepts/aspects. There are two issues mentioned in the FLIP: 1. short of user-facing abstraction - we just e