Re: emitValueWithRetract issue

hi Adam I have checked the code and indeed this feature is not available in the latest version of Flink code. This feature was originally implemented in the old planner: https://github.com/apache/flink/pull/8550/files However, this logic was not

Re: emitValueWithRetract issue

Many thanks for the sanity check, Feng. It’s a shame this well-documented feature was silently removed. emitValue() creates an unreasonable amount of unnecessary and disruptive chatter on the changelog stream, as evidenced by putting a print table after the flatAggregate. Lots of -D/+I RowData pai

Task Failure Strategy for Adaptive Scheduler

Hi All, We use Flink 1.13 with reactive mode for our streaming jobs. When we have an issue/exception on our pipeline. Flink rescheduled all tasks. Is there any way to reschedule only task that had exceptions ? Thanks

Re: 退订

退订请发送任意邮件到 user-unsubscr...@flink.apache.org，可以参考[1] [1] https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list Best, Weihua On Mon, Apr 10, 2023 at 9:04 AM 柒朵 <1303809...@qq.com> wrote: > 退订 >

Re: Task Failure Strategy for Adaptive Scheduler

Hi, AFAIK, the reactive mode always restarts the whole pipeline now. Best, Weihua On Tue, Apr 11, 2023 at 8:38 AM Talat Uyarer via user wrote: > Hi All, > > We use Flink 1.13 with reactive mode for our streaming jobs. When we have > an issue/exception on our pipeline. Flink rescheduled all ta

Re: Table API function and expression vs SQL

Hi,we have decided to use the Table API using Flink SQL syntax (NOT JAVA). Can SQL syntax be changed in the higher version?as per the doc "SQL support is based on Apache Calcite which implements the SQL standard." Thanks & Regards,RaviOn Saturday, 25 March, 2023 at 06:21:49 pm IST, Mate Cza