Hi, Xuannan.
Thanks for preparing the FLIP.
After this FLIP, we will have two ways to report isProcessingBacklog: 1.
>From the source; 2. Judged by the watermark lag. What is the priority
between them?
For example, what is the status isProcessingBacklog when the source report
`isProcessingBacklog
Sergey Nuyanzin created FLINK-32995:
---
Summary: TPC-DS end-to-end test fails with chmod: cannot access
'../target/generator/dsdgen_linux':
Key: FLINK-32995
URL: https://issues.apache.org/jira/browse/FLINK-32995
Sergey Nuyanzin created FLINK-32996:
---
Summary:
CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails
on AZP
Key: FLINK-32996
URL: https://issues.apache.org/jira/browse/FLINK-32996
Jiabao Sun created FLINK-32997:
--
Summary: [JUnit5 Migration] Module: flink-table-planner
(StreamingTestBase)
Key: FLINK-32997
URL: https://issues.apache.org/jira/browse/FLINK-32997
Project: Flink
zhou created FLINK-32998:
Summary: if function result not correct
Key: FLINK-32998
URL: https://issues.apache.org/jira/browse/FLINK-32998
Project: Flink
Issue Type: Bug
Components: API / Co
Sergey Nuyanzin created FLINK-32999:
---
Summary: Remove HBase connector from master branch
Key: FLINK-32999
URL: https://issues.apache.org/jira/browse/FLINK-32999
Project: Flink
Issue Type: S
Matthias Pohl created FLINK-33000:
-
Summary: SqlGatewayServiceITCase should utilize
TestExecutorExtension instead of using a ThreadFactory
Key: FLINK-33000
URL: https://issues.apache.org/jira/browse/FLINK-33000
Abdul created FLINK-33001:
-
Summary: KafkaSource in batch mode failing with exception if topic
partition is empty
Key: FLINK-33001
URL: https://issues.apache.org/jira/browse/FLINK-33001
Project: Flink
Hi Xuannan,
Thanks for the clarification. That is the part where I am trying to
understand your thoughts. I have some follow-up questions:
1. It depends strongly on the watermarkStrategy and how customized
watermark generation looks like. It mixes business logic with technical
implementation and
Martijn Visser created FLINK-33002:
--
Summary: Bump snappy-java from 1.1.4 to 1.1.10.1
Key: FLINK-33002
URL: https://issues.apache.org/jira/browse/FLINK-33002
Project: Flink
Issue Type: Techn
zhaozijun created FLINK-33003:
-
Summary: Flink ML add isolationForest algorithm
Key: FLINK-33003
URL: https://issues.apache.org/jira/browse/FLINK-33003
Project: Flink
Issue Type: New Feature
dalongliu created FLINK-33004:
-
Summary: Decoupling topology and network memory to support complex
job topologies
Key: FLINK-33004
URL: https://issues.apache.org/jira/browse/FLINK-33004
Project: Flink
Hi Jing,
Thanks for the reply.
1. You are absolutely right that the watermark lag threshold must be carefully
set with a thorough understanding of watermark generation. It is crucial for
users to take into account the WatermarkStrategy when setting the watermark lag
threshold.
2. Regarding pu
Please send email to user-unsubscr...@flink.apache.org if you want to
unsubscribe the mail from u...@flink.apache.org, and you can refer [1][2]
for more details.
[1]
https://flink.apache.org/zh/community/#%e9%82%ae%e4%bb%b6%e5%88%97%e8%a1%a8
[2] https://flink.apache.org/community.html#mailing-list
14 matches
Mail list logo
