[
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 pip
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 contain
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 uns
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 gs.http.connect-tim
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 {
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`
[
https://issues.apache.org/jira/browse/FLINK-35031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838022#comment-17838022
]
Yanfei Lei commented on FLINK-35031:
[~yunfengzhou] At first I planned to implement
[
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 e
[
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
> ---
[
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 the
[
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 th
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-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 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
https://issues.apache.org/jira/browse/L
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838045#comment-17838045
]
Etienne Chauchot commented on FLINK-35124:
--
[~dannycranmer] yes, it was because
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 t
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 +
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:
##
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: I
[
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
Issu
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 wil
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:
--
Description: https://github.com/apache/flink-connector-aws
> Release flink-connector-aws v4.3.
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
[
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 flink-con
[
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 1.18/
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
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-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 flink-connect
[
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 flink-connecto
[
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 v
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 t
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 T
[
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
Issue
[
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
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
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 T
[
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 flink-connec
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
Is
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:
##
[
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
]
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-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838058#comment-17838058
]
Danny Cranmer commented on FLINK-35132:
---
https://lists.apache.org/thread/0nw9smt23
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 comment.
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
https://issues.apache.org/jira/browse/
[
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 1
[
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
> ---
[
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 fine-graine
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: issues-unsubscr...@flink.apache
[
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
> -
[
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
>
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: issues-unsubscr...@flink.apache
[
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 specu
[
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
> -
[
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 ri
[
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 flink-conn
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 o
dannycranmer opened a new pull request, #734:
URL: https://github.com/apache/flink-web/pull/734
(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 unsubscribe,
Danny Cranmer created FLINK-35137:
-
Summary: Release flink-connector-jdbc vX.X.X for Flink 1.19
Key: FLINK-35137
URL: https://issues.apache.org/jira/browse/FLINK-35137
Project: Flink
Issue Ty
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 unsubscribe,
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838086#comment-17838086
]
Danny Cranmer commented on FLINK-35139:
---
https://lists.apache.org/thread/s18g7obgp
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:
##
@@ -15
[
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
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: issues-unsubscr
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-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-34936.
-
Resolution: Fixed
> Register reused state handles to FileMergingSnapshotManager
> --
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
Issu
[
https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838093#comment-17838093
]
Zakelly Lan commented on FLINK-35025:
-
Merged into master via c7be45d0...fe8dde4e
>
[
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
>
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
[
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 sy
[
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 f
[
https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838101#comment-17838101
]
Ferenc Csaky commented on FLINK-35136:
--
Currently we have a v3.0.0 HBase connector
[
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 flink-connector-
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 {
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 getInternalT
[
https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838092#comment-17838092
]
Zakelly Lan commented on FLINK-34936:
-
Merged into master via 31ea1a93
> Register r
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838077#comment-17838077
]
Jiabao Sun commented on FLINK-35139:
mongodb main: 660ffe4f33f3ce60da139159741644f48
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.
CheckpointCon
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: '#/compo
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 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
> --
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838121#comment-17838121
]
Vadim Vararu commented on FLINK-35115:
--
[~a.pilipenko] Yes, I can reproduce this co
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 Se
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.
To
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-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 source
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: Improvemen
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: '#/compo
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 ab
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 t
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&focusedCommentId=17838130#comment-17838130
]
xuyang commented on FLINK-34583:
Hi, [~xccui] can you provide more details about this bu
1 - 100 of 252 matches
Mail list logo