Paul Lin

I think this could be a temporary fix if it causes instability in tests. But I can't reproduce the issue, the test runs fine on my machine. I had a...

> > cc @yanghua @SteNicholas @link3280 > > +1 for supporting 1.16, can we find a good way to keep 1.14 for a longer time? +1 to keep Flink 1.14...

Yes. Do you mean adding the annotation alone or also with the `exception` field? I think the exception msg is helpful and should be exposed to users properly.

@waywtdcc This feature is on the roadmap but not yet implemented. The problem is that Flink doesn't support stop/restart jobs via SQL statements at the moment, see [FLIP-222](https://cwiki.apache.org/confluence/display/FLINK/FLIP-222%3A+Support+full+job+lifecycle+statements+in+SQL+client). Once FLIP-222...

@yaooqinn shall we make this a KPIP and let the corresponding issues follow the naming pattern like `[SUBTASK][KPIP-X]`?

@yaooqinn LGTM

> > @waywtdcc technically, I don't think there is any blocker in Kyuubi framework, the JDBC driver retrieves result from Kyuubi Server in mini-batch, and we do similar thing in...

@wForget I have the same question with @pan3793 . Why do users need to override the yarn tags for flink applications and only flink applications? IIUC, the tags are mainly...

@zhuzhihao94 Thanks for reporting this issue! It is a valid requirement to have a configurable buffer queue. BTW, do you have an interest in fixing this? Or I will take...

Supported via https://github.com/mongo-flink/mongo-flink/commit/4bfe39070989b6efad11211326c96301ee785ae0 . It would be included in the coming 1.0.0 version.