lvyanquan commented on code in PR #3128:
URL: https://github.com/apache/flink-cdc/pull/3128#discussion_r1568374817
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java:
##
@@ -85,5 +89,12 @@ public class PipelineOptions {
[
https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan reassigned FLINK-35130:
-
Assignee: Yuxin Tan
> Simplify AvailabilityNotifierImpl to support speculative scheduler and
gong commented on code in PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#discussion_r1568450309
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisRowConverter.java:
MartijnVisser commented on code in PR #732:
URL: https://github.com/apache/flink-web/pull/732#discussion_r1568486997
##
.github/workflows/docs.yml:
##
@@ -0,0 +1,68 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See
fredia merged PR #24657:
URL: https://github.com/apache/flink/pull/24657
--
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-34216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34216:
--
Fix Version/s: mongodb-1.3.0
(was: mongodb-1.2.0)
> Support
yuxiqian commented on PR #3231:
URL: https://github.com/apache/flink-cdc/pull/3231#issuecomment-2060583059
cc @banmoy
--
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
[
https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-35130:
--
Description:
The AvailabilityNotifierImpl in SingleInputGate has maps storing the channel
ids. But
MartijnVisser commented on code in PR #732:
URL: https://github.com/apache/flink-web/pull/732#discussion_r1568486342
##
.github/workflows/docs.yml:
##
@@ -0,0 +1,68 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See
[
https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35092:
---
Labels: pull-request-available (was: )
> Add integrated test for Doris / Starrocks sink
[
https://issues.apache.org/jira/browse/FLINK-35031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35031:
---
Summary: Latency marker emitting under async execution model (was: Event
timer firing under async
Danny Cranmer created FLINK-35131:
-
Summary: Support and Release Connectors for Flink 1.19
Key: FLINK-35131
URL: https://issues.apache.org/jira/browse/FLINK-35131
Project: Flink
Issue Type:
Danny Cranmer created FLINK-35138:
-
Summary: Release flink-connector-kafka vX.X.X for Flink 1.19
Key: FLINK-35138
URL: https://issues.apache.org/jira/browse/FLINK-35138
Project: Flink
Issue
Danny Cranmer created FLINK-35136:
-
Summary: Release flink-connector-hbase vX.X.X for Flink 1.19
Key: FLINK-35136
URL: https://issues.apache.org/jira/browse/FLINK-35136
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35140:
--
Description:
[https://github.com/apache/flink-connector-opensearch]
> Release
Danny Cranmer created FLINK-35140:
-
Summary: Release flink-connector-opensearch vX.X.X for Flink 1.19
Key: FLINK-35140
URL: https://issues.apache.org/jira/browse/FLINK-35140
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35140:
-
Assignee: Sergey Nuyanzin
> Release flink-connector-opensearch vX.X.X for Flink 1.19
>
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35139:
---
Labels: pull-request-available (was: )
> Release flink-connector-mongodb vX.X.X for Flink
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35139:
--
Fix Version/s: mongodb-1.2.0
> Release flink-connector-mongodb vX.X.X for Flink 1.19
>
ferenc-csaky commented on PR #1:
URL:
https://github.com/apache/flink-connector-kudu/pull/1#issuecomment-2060816220
> @ferenc-csaky I've asked the Legal team for a confirmation on this topic,
since the ASF owns both Bahir and Flink code. You can track
LadyForest commented on code in PR #24510:
URL: https://github.com/apache/flink/pull/24510#discussion_r1568258000
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/UncollectToTableFunctionScanRule.java:
##
@@ -0,0 +1,135 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35133:
--
Summary: Release flink-connector-cassandra v3.x.x for Flink 1.18/1.19
(was: Release
[
https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35133:
--
Component/s: Connectors / Cassandra
> Release flink-connector-cassandra v3.x.x for Flink
MartijnVisser commented on PR #24526:
URL: https://github.com/apache/flink/pull/24526#issuecomment-2060771945
> Furthermore, array_except was merged in version 1.20, and since 1.20 is
currently only a snapshot version and not officially released, there’s no
concern of causing compatibility
Danny Cranmer created FLINK-35134:
-
Summary: Release flink-connector-elasticsearch vX.X.X for Flink
1.18/1.19
Key: FLINK-35134
URL: https://issues.apache.org/jira/browse/FLINK-35134
Project: Flink
gong commented on code in PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#discussion_r1568504940
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisRowConverterTest.java:
fredia merged PR #24644:
URL: https://github.com/apache/flink/pull/24644
--
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-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35137:
-
Assignee: Danny Cranmer
> Release flink-connector-jdbc vX.X.X for Flink 1.19
>
[
https://issues.apache.org/jira/browse/FLINK-35131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35131:
-
Assignee: Danny Cranmer
> Support and Release Connectors for Flink 1.19
>
Zakelly commented on PR #24657:
URL: https://github.com/apache/flink/pull/24657#issuecomment-2060481241
Thanks @fredia and @yunfengzhou-hub for your detailed review! Really
appreciate it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-35025:
--
Assignee: Zakelly Lan
> Wire AsyncExecutionController to AbstractStreamOperator
>
Danny Cranmer created FLINK-35133:
-
Summary: Release flink-connector-cassandra v4.3.0 for Flink
1.18/1.19
Key: FLINK-35133
URL: https://issues.apache.org/jira/browse/FLINK-35133
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35132:
-
Assignee: Danny Cranmer
> Release flink-connector-aws v4.3.0 for Flink 1.18/1.19
>
[
https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35132:
--
Component/s: Connectors / AWS
> Release flink-connector-aws v4.3.0 for Flink 1.18/1.19
>
Danny Cranmer created FLINK-35132:
-
Summary: Release flink-connector-aws v4.3.0 for Flink 1.18/1.19
Key: FLINK-35132
URL: https://issues.apache.org/jira/browse/FLINK-35132
Project: Flink
TanYuxin-tyx opened a new pull request, #24674:
URL: https://github.com/apache/flink/pull/24674
## What is the purpose of the change
*The AvailabilityNotifierImpl in SingleInputGate has maps storing the
channel ids. But the map key is the result partition id, which
[
https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35132:
--
Description: https://github.com/apache/flink-connector-aws
> Release flink-connector-aws
masteryhx commented on PR #24651:
URL: https://github.com/apache/flink/pull/24651#issuecomment-2060813581
@flinkbot run azure
--
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
flinkbot commented on PR #24673:
URL: https://github.com/apache/flink/pull/24673#issuecomment-2060595395
## CI report:
* 057a0cd1d1fd47dc886b6e0ce6bb1ae1fd652b57 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
MartijnVisser commented on PR #1:
URL:
https://github.com/apache/flink-connector-kudu/pull/1#issuecomment-2060731374
@ferenc-csaky I've asked the Legal team for a confirmation on this topic,
since the ASF owns both Bahir and Flink code. You can track
yuxiqian commented on code in PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#discussion_r1568485784
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisRowConverterTest.java:
Zakelly commented on code in PR #24644:
URL: https://github.com/apache/flink/pull/24644#discussion_r1568486250
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java:
##
@@ -349,6
Danny Cranmer created FLINK-35141:
-
Summary: Release flink-connector-pulsar vX.X.X for Flink 1.19
Key: FLINK-35141
URL: https://issues.apache.org/jira/browse/FLINK-35141
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35138:
--
Component/s: Connectors / Kafka
> Release flink-connector-kafka vX.X.X for Flink 1.19
>
Danny Cranmer created FLINK-35139:
-
Summary: Release flink-connector-mongodb vX.X.X for Flink 1.19
Key: FLINK-35139
URL: https://issues.apache.org/jira/browse/FLINK-35139
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35135:
--
Component/s: Connectors / Google Cloud PubSub
> Release flink-connector-gcp-pubsub vX.X.X for
yunfengzhou-hub commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1568257919
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceAsyncImpl.java:
##
@@ -0,0 +1,145 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-35031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837980#comment-17837980
]
Yunfeng Zhou commented on FLINK-35031:
--
What is the relationship between this ticket and
yuxiqian opened a new pull request, #3231:
URL: https://github.com/apache/flink-cdc/pull/3231
This closes [FLINK-35092](https://issues.apache.org/jira/browse/FLINK-35092).
Currently, no integrated test are being applied to StarRocks pipeline
connector which runs on real docker
[
https://issues.apache.org/jira/browse/FLINK-35031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838022#comment-17838022
]
Yanfei Lei commented on FLINK-35031:
[~yunfengzhou] At first I planned to implement event timer and
[
https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-35130:
--
Description: The AvailabilityNotifierImpl in SingleInputGate has maps
storing the channel ids. But
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838045#comment-17838045
]
Etienne Chauchot commented on FLINK-35124:
--
[~dannycranmer] yes, it was because it lead to an
[
https://issues.apache.org/jira/browse/FLINK-34127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837982#comment-17837982
]
Mason Chen commented on FLINK-34127:
It seems to be a bug in junit.
JTaky opened a new pull request, #24673:
URL: https://github.com/apache/flink/pull/24673
## What is the purpose of the change
Provide a way to ingest http timeout configuration to gcs-cloud-storage
library in use.
## Brief change log
* exposed
Yuxin Tan created FLINK-35130:
-
Summary: Simplify AvailabilityNotifierImpl to support speculative
scheduler and improve performance
Key: FLINK-35130
URL: https://issues.apache.org/jira/browse/FLINK-35130
[
https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35135:
--
Summary: Release flink-connector-gcp-pubsub vX.X.X for Flink 1.19 (was:
Release
[
https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35133:
--
Summary: Release flink-connector-cassandra v3.x.x for Flink 1.19 (was:
Release
Danny Cranmer created FLINK-35135:
-
Summary: Release flink-connector-gcp-pubsub vX.X.X for Flink
1.18/1.19
Key: FLINK-35135
URL: https://issues.apache.org/jira/browse/FLINK-35135
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35136:
--
Description: https://github.com/apache/flink-connector-hbase
> Release flink-connector-hbase
[
https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838058#comment-17838058
]
Danny Cranmer commented on FLINK-35132:
---
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35139:
-
Assignee: Danny Cranmer
> Release flink-connector-mongodb vX.X.X for Flink 1.19
>
[
https://issues.apache.org/jira/browse/FLINK-34214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-34214:
--
Fix Version/s: mongodb-1.3.0
(was: mongodb-1.2.0)
> FLIP-377: Support
masteryhx commented on PR #24651:
URL: https://github.com/apache/flink/pull/24651#issuecomment-2060873955
Rebased again.
--
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
spoon-lz commented on code in PR #24461:
URL: https://github.com/apache/flink/pull/24461#discussion_r1568676454
##
flink-python/docs/reference/pyflink.datastream/checkpoint.rst:
##
@@ -81,7 +81,7 @@ The default limit of concurrently happening checkpoints: one.
GOODBOY008 commented on code in PR #732:
URL: https://github.com/apache/flink-web/pull/732#discussion_r1568682051
##
.github/workflows/docs.yml:
##
@@ -0,0 +1,68 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the
yuxiqian commented on PR #3227:
URL: https://github.com/apache/flink-cdc/pull/3227#issuecomment-2061021229
@leonardBang Seems it's `flink-cdc-pipeline-connector-values` test that
keeps failing recently. Will investigate this.
--
This is an automated message from the Apache Git Service.
Danny Cranmer created FLINK-35142:
-
Summary: Release flink-connector-rabbitmq vX.X.X for Flink 1.19
Key: FLINK-35142
URL: https://issues.apache.org/jira/browse/FLINK-35142
Project: Flink
Hongshun Wang created FLINK-35143:
-
Summary: Expose newly added tables capture in mysql pipeline
connector
Key: FLINK-35143
URL: https://issues.apache.org/jira/browse/FLINK-35143
Project: Flink
fredia commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1568656329
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -181,4 +182,73 @@ public class ExecutionOptions {
afedulov commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1568653505
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref:
gong commented on PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#issuecomment-2061042815
@PatrickRen Hello, Please help to rerun CI. CI fail is not relation with the
PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838130#comment-17838130
]
xuyang commented on FLINK-34583:
Hi, [~xccui] can you provide more details about this bug? I try to run
boring-cyborg[bot] commented on PR #35:
URL:
https://github.com/apache/flink-connector-mongodb/pull/35#issuecomment-2060869153
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
Jiabao-Sun merged PR #35:
URL: https://github.com/apache/flink-connector-mongodb/pull/35
--
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:
flinkbot commented on PR #24674:
URL: https://github.com/apache/flink/pull/24674#issuecomment-2060781312
## CI report:
* 70df259709d9640d587eef6c257d9c812b8dfb38 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35132:
--
Summary: Release flink-connector-aws v4.3.0 for Flink 1.19 (was: Release
flink-connector-aws
[
https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838093#comment-17838093
]
Zakelly Lan commented on FLINK-35025:
-
Merged into master via c7be45d0...fe8dde4e
> Wire
[
https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838092#comment-17838092
]
Zakelly Lan commented on FLINK-34936:
-
Merged into master via 31ea1a93
> Register reused state
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838121#comment-17838121
]
Vadim Vararu commented on FLINK-35115:
--
[~a.pilipenko] Yes, I can reproduce this consistently.
Congxian Qiu created FLINK-35144:
Summary: Support multi source sync for FlinkCDC
Key: FLINK-35144
URL: https://issues.apache.org/jira/browse/FLINK-35144
Project: Flink
Issue Type:
MartijnVisser commented on code in PR #732:
URL: https://github.com/apache/flink-web/pull/732#discussion_r1568720908
##
.github/workflows/docs.yml:
##
@@ -0,0 +1,68 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See
GOODBOY008 commented on code in PR #732:
URL: https://github.com/apache/flink-web/pull/732#discussion_r1568682051
##
.github/workflows/docs.yml:
##
@@ -0,0 +1,68 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the
[
https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35130:
---
Labels: pull-request-available (was: )
> Simplify AvailabilityNotifierImpl to support
[
https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30371:
--
Fix Version/s: jdbc-3.3.0
(was: jdbc-3.2.0)
> JdbcOutputFormat is at
[
https://issues.apache.org/jira/browse/FLINK-35134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35134:
--
Summary: Release flink-connector-elasticsearch vX.X.X for Flink 1.19 (was:
Release
dannycranmer opened a new pull request, #735:
URL: https://github.com/apache/flink-web/pull/735
(no comment)
--
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
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838086#comment-17838086
]
Danny Cranmer commented on FLINK-35139:
---
loserwang1024 commented on code in PR #3230:
URL: https://github.com/apache/flink-cdc/pull/3230#discussion_r1568614060
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java:
##
@@
[
https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35137:
--
Component/s: Connectors / JDBC
> Release flink-connector-jdbc vX.X.X for Flink 1.19
>
[
https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu updated FLINK-35144:
-
Summary: Support various source sync for FlinkCDC in one pipeline (was:
Support multi source
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35139:
--
Summary: Release flink-connector-mongodb v1.2.0 for Flink 1.19 (was:
Release
fredia commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1568659638
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -181,4 +182,73 @@ public class ExecutionOptions {
fredia commented on PR #24667:
URL: https://github.com/apache/flink/pull/24667#issuecomment-2060999083
@yunfengzhou-hub @Zakelly Thanks for the detailed review, I have rebased
this PR and addressed some comments, PTAL if you are free.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu updated FLINK-35144:
-
Summary: Support various sources sync for FlinkCDC in one pipeline (was:
Support various
[
https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35137:
--
Fix Version/s: jdbc-3.2.0
> Release flink-connector-jdbc vX.X.X for Flink 1.19
>
Zakelly commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1568659887
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java:
##
@@ -51,6 +52,21 @@ InternalTimerService
yuxiqian commented on code in PR #3230:
URL: https://github.com/apache/flink-cdc/pull/3230#discussion_r1568608219
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java:
##
@@ -159,7
[
https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-35025.
-
Resolution: Fixed
> Wire AsyncExecutionController to AbstractStreamOperator
>
leonardBang commented on PR #3227:
URL: https://github.com/apache/flink-cdc/pull/3227#issuecomment-2061013529
The CI failed, could you take a look ? @yuxiqian
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
fredia commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1568731699
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java:
##
@@ -117,6 +120,7 @@ public class
1 - 100 of 244 matches
Mail list logo
