Hang Ruan created FLINK-32862:
-
Summary: Support INIT operation type to be compatible with DTS on
Alibaba Cloud
Key: FLINK-32862
URL: https://issues.apache.org/jira/browse/FLINK-32862
Project: Flink
Thanks for the explanation.
I wonder if it makes sense to not expose this detail via the configuration
option. To be specific, I suggest not mentioning the "watermark" keyword in
the configuration key and description.
- From the users' perspective, I think they only need to know there's a
l
Hi Xintong,
Thanks for the reply.
I have considered using the timestamp in the records to determine the backlog
status, and decided to use watermark at the end. By definition, watermark is
the time progress indication in the data stream. It indicates the stream’s
event time has progressed to s
zhengyuan created FLINK-32861:
-
Summary: Batch mode, sink to multables the task graph of web page
monitor jobs , lack sink task graph block
Key: FLINK-32861
URL: https://issues.apache.org/jira/browse/FLINK-32861
Jane Chan created FLINK-32860:
-
Summary: Add missing visibility annotation for Table APIs
Key: FLINK-32860
URL: https://issues.apache.org/jira/browse/FLINK-32860
Project: Flink
Issue Type: Improv
Rui Fan created FLINK-32859:
---
Summary: Improve the state of adaptive sheduler with
StateWithoutExecutionGraph
Key: FLINK-32859
URL: https://issues.apache.org/jira/browse/FLINK-32859
Project: Flink
Hi, Venkata krishnan
Thanks for driving this work, look forward to your FLIP.
Best,
Ron
Venkatakrishnan Sowrirajan 于2023年8月13日周日 14:34写道：
> Thanks Yunhong. That's correct. I am able to make it work locally.
> Currently, in the process of writing a FLIP for the necessary changes to
> the Suppor
