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

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

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

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:Re:flink的sql gateway支持自定义的UDF吗?

2023-11-19 Thread RS
Hi, 这种ADD JAR的方式测试了也可以用,谢谢了老哥 Thanks 在 2023-11-01 17:34:48,"Xuyang" 写道: >Hi, >你指的是sql gateway上 ADD JAR这种方式来上传自定义UDF的jar包[1]么? > > > > >[1] >https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/sql/jar/ > >-- > >Best! >Xuyang > > > > > >在 2023-11-01

Re:Re:flink的sql gateway支持自定义的UDF吗?

2023-11-19 Thread RS
Hi, 是的,自定义的UDF比较多,或者实现方式不同,所以加载的时候,想单独加载下, sql-client有个参数就可以支持,-j sql gateway为什么不提供了? Thanks 在 2023-11-01 17:34:48,"Xuyang" 写道: >Hi, >你指的是sql gateway上 ADD JAR这种方式来上传自定义UDF的jar包[1]么? > > > > >[1] >https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/sql/jar/ >

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