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
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:
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
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 SupportsFilterPushDown API to support nested fields filter push down.
Regards
Venkata krishnan
On Mon, Aug 7, 2023 at 8:28 PM yh z wrote:
> Hi
