LadyForest commented on code in PR #24510:
URL: https://github.com/apache/flink/pull/24510#discussion_r1554809993
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalUnnestRule.scala:
##
@@ -20,12 +20,13 @@ package
PatrickRen commented on code in PR #3194:
URL: https://github.com/apache/flink-cdc/pull/3194#discussion_r1557144006
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/ConfigurationUtils.java:
##
@@ -37,15 +38,34 @@ public static Configuration
flinkbot commented on PR #24635:
URL: https://github.com/apache/flink/pull/24635#issuecomment-2044384665
## CI report:
* b7400216aa4ca7c444622cb977c35cf391396485 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-35040:
--
Assignee: Rui Fan
> The performance of serializerHeavyString regresses since April 3
[
https://issues.apache.org/jira/browse/FLINK-34997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-34997:
--
Assignee: Robert Metzger
> PyFlink YARN per-job on Docker test failed on azure
>
[
https://issues.apache.org/jira/browse/FLINK-35037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35037:
---
Labels: pull-request-available (was: )
> Optimize uniqueKeys and upsertKeys inference of
RubyChou opened a new pull request, #24638:
URL: https://github.com/apache/flink/pull/24638
## What is the purpose of the change
The PR aims to add valid uniqueKeys and uniqueKeys candidates for windows
with ROW_NUMBER. The candidates are pairs of partition by keys and field of
chendaping created FLINK-35063:
--
Summary: Flink sql connector pulsar/hive
com.fasterxml.jackson.annotation.JsonFormat$Value conflict
Key: FLINK-35063
URL: https://issues.apache.org/jira/browse/FLINK-35063
[
https://issues.apache.org/jira/browse/FLINK-35059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35059:
---
Labels: pull-request-available (was: )
> Bump org.postgresql:postgresql from 42.5.1 to
snuyanzin merged PR #110:
URL: https://github.com/apache/flink-connector-jdbc/pull/110
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835321#comment-17835321
]
Muhammet Orazov commented on FLINK-34470:
-
Hey [~dongwoo.kim] ,
Would you like to send a PR
LadyForest commented on PR #24510:
URL: https://github.com/apache/flink/pull/24510#issuecomment-2044375318
I just noticed that FLINK-34162 has been merged. Would you mind rebasing the
master and resolving the conflicts?
--
This is an automated message from the Apache Git Service.
To
liuyongvs opened a new pull request, #24635:
URL: https://github.com/apache/flink/pull/24635
## What is the purpose of the change
A bit reasoning for the change
The reason is that since 1.28.0 (
[CALCITE-4787](https://issues.apache.org/jira/browse/CALCITE-4787) - Move core
to
flinkbot commented on PR #24636:
URL: https://github.com/apache/flink/pull/24636#issuecomment-2044385119
## CI report:
* c7611b8740840d149e9e191f94b321a1f99c21aa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35061:
---
Labels: pull-request-available (was: )
> Migrate TemporalJoinUtil
>
Jacky Lau created FLINK-35061:
-
Summary: Migrate TemporalJoinUtil
Key: FLINK-35061
URL: https://issues.apache.org/jira/browse/FLINK-35061
Project: Flink
Issue Type: Sub-task
liuyongvs opened a new pull request, #24637:
URL: https://github.com/apache/flink/pull/24637
## What is the purpose of the change
The PR migrates TemporalJoinUtil to java
## Verifying this change
This change is already covered by existing tests
## Does this pull
shibd commented on PR #86:
URL:
https://github.com/apache/flink-connector-pulsar/pull/86#issuecomment-2044459569
@tisonkun @syhily hi, can you help review this? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835338#comment-17835338
]
Ryan Skraba commented on FLINK-35023:
-
It looks like these JVM args are meant to be applied to the
RyanSkraba opened a new pull request, #24641:
URL: https://github.com/apache/flink/pull/24641
## What is the purpose of the change
For JDK 17+, some configuration is necessary to use the Datastream V2
(FLINK-34548 and FLIP-409). This was added to `surefire.module.config` for
most
yunfengzhou-hub opened a new pull request, #260:
URL: https://github.com/apache/flink-ml/pull/260
## What is the purpose of the change
This PR fixes a bug in the iteration logic, where the input record was not
unwrapped from the IterationRecord before setKeyContext() methods.
[
https://issues.apache.org/jira/browse/FLINK-35066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35066:
---
Labels: pull-request-available (was: )
> TwoInputOperator in IterationBody cannot use
flinkbot commented on PR #24641:
URL: https://github.com/apache/flink/pull/24641#issuecomment-2044638650
## CI report:
* d747f820b8f168151b84ca7ed2a7d3b4f8413fa6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35060:
---
Labels: pull-request-available (was: )
> Provide compatibility of old CheckpointMode for
Zakelly opened a new pull request, #24636:
URL: https://github.com/apache/flink/pull/24636
## What is the purpose of the change
After FLINK-34516, the `org.apache.flink.streaming.api.CheckpointingMode`
has been moved to `org.apache.flink.core.execution.CheckpointingMode`. It
[
https://issues.apache.org/jira/browse/FLINK-35054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35054:
---
Labels: pull-request-available (was: )
> Migrate TemporalJoinRewriteWithUniqueKeyRule
>
flinkbot commented on PR #24637:
URL: https://github.com/apache/flink/pull/24637#issuecomment-2044415829
## CI report:
* 9c2bc8371546952922ecf6db044711fa79f29208 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Jacky Lau created FLINK-35062:
-
Summary: Migrate RewriteMultiJoinConditionRule
Key: FLINK-35062
URL: https://issues.apache.org/jira/browse/FLINK-35062
Project: Flink
Issue Type: Sub-task
fredia opened a new pull request, #24639:
URL: https://github.com/apache/flink/pull/24639
## What is the purpose of the change
As described in
https://github.com/apache/flink/pull/22669#issuecomment-1593370772, It is best
for the materialization Interval to be greater than
flinkbot commented on PR #24639:
URL: https://github.com/apache/flink/pull/24639#issuecomment-2044450479
## CI report:
* 7c706d038643d116582b9688f26d5d79e7c3c626 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
chendaping created FLINK-35064:
--
Summary: Flink sql connector pulsar/hive
com.fasterxml.jackson.annotation.JsonFormat$Value conflict
Key: FLINK-35064
URL: https://issues.apache.org/jira/browse/FLINK-35064
Yunfeng Zhou created FLINK-35066:
Summary: TwoInputOperator in IterationBody cannot use keyBy
Key: FLINK-35066
URL: https://issues.apache.org/jira/browse/FLINK-35066
Project: Flink
Issue
ljz2051 opened a new pull request, #24640:
URL: https://github.com/apache/flink/pull/24640
## What is the purpose of the change
This pull request introduces the restoration mechanism for
FileMergingSnapshotManager. See FLIP-306 for more information.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-32080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32080:
---
Labels: pull-request-available (was: )
> Restoration of FileMergingSnapshotManager
>
Hongshun Wang created FLINK-35067:
-
Summary: Support metadata 'op_type' virtual column for Postgres
CDC Connector.
Key: FLINK-35067
URL: https://issues.apache.org/jira/browse/FLINK-35067
Project:
yunfengzhou-hub commented on PR #260:
URL: https://github.com/apache/flink-ml/pull/260#issuecomment-2044649370
Hi @zhipeng93 could you please take a look at this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Jiabao-Sun merged PR #32:
URL: https://github.com/apache/flink-connector-mongodb/pull/32
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
Zakelly commented on PR #24636:
URL: https://github.com/apache/flink/pull/24636#issuecomment-2044713422
@masteryhx Would you please take a look? Also ping @ruanhang1993
@PatrickRen since you may know the background of `TestSemantics`. Thanks a lot!
--
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-35009:
---
Assignee: Martijn Visser
> Change on getTransitivePredecessors breaks connectors
>
flinkbot commented on PR #24638:
URL: https://github.com/apache/flink/pull/24638#issuecomment-2044438947
## CI report:
* 47e9fe2fbdc2a0ebd9084a2d4acdce12fd917d47 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Piotr Nowojski created FLINK-35065:
--
Summary: Add numFiredTimers and numFiredTimersPerSecond metrics
Key: FLINK-35065
URL: https://issues.apache.org/jira/browse/FLINK-35065
Project: Flink
ljz2051 commented on PR #24640:
URL: https://github.com/apache/flink/pull/24640#issuecomment-2044605255
@Zakelly @fredia @masteryhx Could you please take a look ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
X-czh commented on code in PR #24634:
URL: https://github.com/apache/flink/pull/24634#discussion_r1557445325
##
docs/content/docs/dev/datastream/fault-tolerance/serialization/types_serialization.md:
##
@@ -37,15 +37,16 @@ Flink places some restrictions on the type of elements
tisonkun commented on PR #86:
URL:
https://github.com/apache/flink-connector-pulsar/pull/86#issuecomment-2044469879
Generally looks good. Please check the CI failure.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-35063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chendaping closed FLINK-35063.
--
Resolution: Duplicate
> Flink sql connector pulsar/hive
>
boring-cyborg[bot] commented on PR #113:
URL:
https://github.com/apache/flink-connector-jdbc/pull/113#issuecomment-2044493572
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
[
https://issues.apache.org/jira/browse/FLINK-35059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835313#comment-17835313
]
Sergey Nuyanzin commented on FLINK-35059:
-
Merged as
[
https://issues.apache.org/jira/browse/FLINK-35059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-35059.
---
> Bump org.postgresql:postgresql from 42.5.1 to 42.7.3 in flink-connector-jdbc
>
[
https://issues.apache.org/jira/browse/FLINK-35059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-35059.
-
Fix Version/s: jdbc-3.2.0
Resolution: Fixed
> Bump org.postgresql:postgresql
[
https://issues.apache.org/jira/browse/FLINK-35066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunfeng Zhou updated FLINK-35066:
-
Issue Type: Bug (was: Technical Debt)
> TwoInputOperator in IterationBody cannot use keyBy
>
flinkbot commented on PR #24640:
URL: https://github.com/apache/flink/pull/24640#issuecomment-2044601959
## CI report:
* 475bd17770242252ed449148afe8d4021f833176 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35023:
---
Labels: pull-request-available (was: )
> YARNApplicationITCase failed on Azure
>
snuyanzin merged PR #105:
URL: https://github.com/apache/flink-connector-jdbc/pull/105
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
morazow commented on PR #89:
URL:
https://github.com/apache/flink-connector-kafka/pull/89#issuecomment-2044272245
Looks good, thanks @hugogu for quick update! Hopefully the CI is green this
time 爛
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-35056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yandufeng updated FLINK-35056:
--
Attachment: sqlserver-bug.png
> when initial sqlserver table that's primary key is datetime type, it
[
https://issues.apache.org/jira/browse/FLINK-34805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34805:
---
Labels: github-import pull-request-available (was: github-import)
> [Bug] About
[
https://issues.apache.org/jira/browse/FLINK-35037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835158#comment-17835158
]
Benchao Li commented on FLINK-35037:
[~nilerzhou] Assigned to you :)
> Optimize uniqueKeys and
[
https://issues.apache.org/jira/browse/FLINK-35037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-35037:
--
Assignee: yisha zhou
> Optimize uniqueKeys and upsertKeys inference of windows with
[
https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun updated FLINK-35010:
---
Summary: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for
Flink Mongodb connector
[
https://issues.apache.org/jira/browse/FLINK-34613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-34613:
-
Assignee: LvYanquan
> allow specifing a savepoint file to restart using cli script.
>
[
https://issues.apache.org/jira/browse/FLINK-34613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-34613.
---
Resolution: Fixed
> allow specifing a savepoint file to restart using cli script.
>
[
https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-35010.
Fix Version/s: mongodb-1.2.0
Resolution: Fixed
Fixed via mongodb-connector main:
PatrickRen commented on code in PR #3187:
URL: https://github.com/apache/flink-cdc/pull/3187#discussion_r1557080409
##
flink-cdc-cli/src/test/resources/definitions/pipeline-definition-full.yaml:
##
@@ -53,3 +53,8 @@ pipeline:
name: source-database-sync-pipe
parallelism: 4
PatrickRen merged PR #3204:
URL: https://github.com/apache/flink-cdc/pull/3204
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/FLINK-34952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835287#comment-17835287
]
Qingsheng Ren commented on FLINK-34952:
---
flink-cdc master:
[
https://issues.apache.org/jira/browse/FLINK-35057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835170#comment-17835170
]
Sergey Nuyanzin commented on FLINK-35057:
-
Merged as
[
https://issues.apache.org/jira/browse/FLINK-35057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-35057.
-
Fix Version/s: jdbc-3.2.0
Resolution: Fixed
> Bump
[
https://issues.apache.org/jira/browse/FLINK-35057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35057:
---
Labels: pull-request-available (was: )
> Bump org.apache.commons:commons-compress from
[
https://issues.apache.org/jira/browse/FLINK-35057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-35057.
---
> Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink jdbc
> connector
>
Sergey Nuyanzin created FLINK-35059:
---
Summary: Bump org.postgresql:postgresql from 42.5.1 to 42.5.5 in
flink-connector-jdbc
Key: FLINK-35059
URL: https://issues.apache.org/jira/browse/FLINK-35059
[
https://issues.apache.org/jira/browse/FLINK-35059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-35059:
Summary: Bump org.postgresql:postgresql from 42.5.1 to 42.7.3 in
flink-connector-jdbc
skymilong commented on code in PR #3194:
URL: https://github.com/apache/flink-cdc/pull/3194#discussion_r1557102504
##
flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/ConfigurationUtils.java:
##
@@ -37,15 +38,34 @@ public static Configuration
[
https://issues.apache.org/jira/browse/FLINK-35010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun closed FLINK-35010.
--
> Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink
> Mongodb connector
>
[
https://issues.apache.org/jira/browse/FLINK-34516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835180#comment-17835180
]
Zakelly Lan commented on FLINK-34516:
-
Created FLINK-35060 to address this.
> Move
Jiabao-Sun closed pull request #29: Bump org.apache.commons:commons-compress
from 1.24.0 to 1.26.0
URL: https://github.com/apache/flink-connector-mongodb/pull/29
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
GOODBOY008 commented on code in PR #3208:
URL: https://github.com/apache/flink-cdc/pull/3208#discussion_r1556997233
##
docs/content/_index.md:
##
@@ -22,177 +22,163 @@ specific language governing permissions and limitations
under the License.
-->
-
-
-
-
Jiabao-Sun commented on PR #29:
URL:
https://github.com/apache/flink-connector-mongodb/pull/29#issuecomment-2044283706
Closed by #32
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the
dependabot[bot] commented on PR #29:
URL:
https://github.com/apache/flink-connector-mongodb/pull/29#issuecomment-2044283758
OK, I won't notify you again about this release, but will get in touch when
a new version is available. If you'd rather skip all updates until the next
major or
PatrickRen merged PR #2959:
URL: https://github.com/apache/flink-cdc/pull/2959
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/FLINK-34613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835286#comment-17835286
]
Qingsheng Ren commented on FLINK-34613:
---
flink-cdc master:
[
https://issues.apache.org/jira/browse/FLINK-34952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren resolved FLINK-34952.
---
Resolution: Fixed
> Flink CDC pipeline supports SinkFunction
>
Zakelly Lan created FLINK-35060:
---
Summary: Provide compatibility of old CheckpointMode for connector
testing framework
Key: FLINK-35060
URL: https://issues.apache.org/jira/browse/FLINK-35060
Project:
[
https://issues.apache.org/jira/browse/FLINK-35065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35065:
---
Labels: pull-request-available (was: )
> Add numFiredTimers and numFiredTimersPerSecond
[
https://issues.apache.org/jira/browse/FLINK-35070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835398#comment-17835398
]
niliushall commented on FLINK-35070:
@[~mapohl], hi~, please have a look at this issue in your free
[
https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835353#comment-17835353
]
Zhanghao Chen commented on FLINK-35068:
---
[~fangyong] May I take this task?
> Introduce built-in
jiexray commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1557531709
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software
snuyanzin opened a new pull request, #24645:
URL: https://github.com/apache/flink/pull/24645
This is a cherry-pick backport of https://github.com/apache/flink/pull/24280
to 1.19
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
niliushall created FLINK-35070:
--
Summary: remove unused duplicate code
Key: FLINK-35070
URL: https://issues.apache.org/jira/browse/FLINK-35070
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-34936:
Summary: Register reused state handles to FileMergingSnapshotManager (was:
Register shared state
jiexray commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1557546908
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software
ljz2051 opened a new pull request, #24647:
URL: https://github.com/apache/flink/pull/24647
## What is the purpose of the change
This pull request avoids registering times in a loop at the end of the
window for ContinuousProcessingTimeTrigger
## Brief change log
-
[
https://issues.apache.org/jira/browse/FLINK-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35069:
---
Labels: pull-request-available (was: )
> ContinuousProcessingTimeTrigger continuously
flinkbot commented on PR #24647:
URL: https://github.com/apache/flink/pull/24647#issuecomment-2045101879
## CI report:
* 8e80ff889701ed1abbb5c15cd3943b254f1fb5cc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on code in PR #24614:
URL: https://github.com/apache/flink/pull/24614#discussion_r1557607902
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software
LaviniaMaria closed pull request #76: Flk 1380
URL: https://github.com/apache/flink-training/pull/76
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
liuyongvs opened a new pull request, #24642:
URL: https://github.com/apache/flink/pull/24642
## What is the purpose of the change
A bit reasoning for the change
The reason is that since 1.28.0 (
[CALCITE-4787](https://issues.apache.org/jira/browse/CALCITE-4787) - Move core
to
[
https://issues.apache.org/jira/browse/FLINK-35062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35062:
---
Labels: pull-request-available (was: )
> Migrate RewriteMultiJoinConditionRule
>
pnowojski opened a new pull request, #24643:
URL: https://github.com/apache/flink/pull/24643
## Brief change log
This PR adds numFiredTimers and numFiredTimersPerSecond metrics
## Verifying this change
-
## Does this pull request potentially affect one of the
Zhanghao Chen created FLINK-35068:
-
Summary: Introduce built-in serialization support for Set
Key: FLINK-35068
URL: https://issues.apache.org/jira/browse/FLINK-35068
Project: Flink
Issue
fredia commented on code in PR #24640:
URL: https://github.com/apache/flink/pull/24640#discussion_r1557536559
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -547,4 +548,43 @@ private void
1 - 100 of 169 matches
Mail list logo
