[
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-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-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-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
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
[
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-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
[
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
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
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
[
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
[
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
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-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
[
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
>
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
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
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
[
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-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:
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
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-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
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
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:
[
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
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 updated FLINK-35130:
--
Description:
The AvailabilityNotifierImpl in SingleInputGate has maps storing the channel
ids. But
[
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-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-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
[
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
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`
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 {
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
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
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-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-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.
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
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
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 @@
+/*
+
201 - 244 of 244 matches
Mail list logo
