[
https://issues.apache.org/jira/browse/FLINK-35073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837259#comment-17837259
]
Julien Tournay edited comment on FLINK-35073 at 4/15/24 1:32 PM:
-
caicancai commented on PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#issuecomment-2056897700
@RocMarshal PATL，thank you
--
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
[
https://issues.apache.org/jira/browse/FLINK-35095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837273#comment-17837273
]
Ryan Skraba commented on FLINK-35095:
-
1.20 Java 17: Test (module: misc)
caicancai commented on PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#issuecomment-2056898849
cc @1996fanrui
--
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
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837272#comment-17837272
]
Ryan Skraba commented on FLINK-35041:
-
* 1.20 Test (module:core)
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837271#comment-17837271
]
Ryan Skraba commented on FLINK-31472:
-
1.20 Hadoop 3.1.3: Test (module: connect)
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-35094.
-
Fix Version/s: elasticsearch-3.2.0
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-35094:
---
Assignee: Sergey Nuyanzin
> SinkTestSuiteBase.testScaleDown is hanging for
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837323#comment-17837323
]
Sergey Nuyanzin commented on FLINK-35094:
-
Merged as
dannycranmer merged PR #688:
URL: https://github.com/apache/flink-web/pull/688
--
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:
klam-shop commented on code in PR #24482:
URL: https://github.com/apache/flink/pull/24482#discussion_r1565935343
##
flink-formats/flink-protobuf-confluent-registry/src/test/java/org/apache/flink/formats/protobuf/registry/confluent/utils/FlinkToProtoSchemaConverterTest.java:
##
jeyhunkarimov commented on PR #24658:
URL: https://github.com/apache/flink/pull/24658#issuecomment-2057338536
Ah no worries at all, there was a misunderstanding in communication.
--
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-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837324#comment-17837324
]
Sergey Nuyanzin commented on FLINK-35094:
-
Opensearch connector was fixed within
[
https://issues.apache.org/jira/browse/FLINK-35094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-35094:
Fix Version/s: opensearch-1.2.0
> SinkTestSuiteBase.testScaleDown is hanging for
[
https://issues.apache.org/jira/browse/FLINK-34931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-34931:
-
Summary: Update Kudu connector DataStream Sink implementation (was: Update
Kudu connector
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837319#comment-17837319
]
Hong Liang Teoh commented on FLINK-35115:
-
[~dannycranmer] That is true, unless it is a problem
dannycranmer merged PR #137:
URL: https://github.com/apache/flink-connector-aws/pull/137
--
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-35113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-35113.
---
Resolution: Fixed
> Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for
[
https://issues.apache.org/jira/browse/FLINK-35113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837249#comment-17837249
]
Danny Cranmer commented on FLINK-35113:
---
Merged commit
[
https://issues.apache.org/jira/browse/FLINK-35073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837259#comment-17837259
]
Julien Tournay commented on FLINK-35073:
Closing this issue because even though I captured a
ferenc-csaky commented on PR #1:
URL:
https://github.com/apache/flink-connector-kudu/pull/1#issuecomment-2056866715
After I took a look at the logs, the error was environmental, it failed to
connect to the Dockerized Kudu:
```
ERROR org.apache.kudu.client.Connection [] - [peer
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837260#comment-17837260
]
Martijn Visser commented on FLINK-35111:
Do note that grammar/spelling doesn't need a Jira
[
https://issues.apache.org/jira/browse/FLINK-35073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julien Tournay closed FLINK-35073.
--
Resolution: Workaround
> Deadlock in LocalBufferPool when segments become available in the
dannycranmer merged PR #661:
URL: https://github.com/apache/flink-web/pull/661
--
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:
snuyanzin merged PR #24:
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/24
--
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-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vadim Vararu updated FLINK-35115:
-
Summary: Kinesis connector writes wrong Kinesis sequence number at stop
with savepoint (was:
boring-cyborg[bot] commented on PR #24:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/24#issuecomment-2057011070
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
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837318#comment-17837318
]
Danny Cranmer commented on FLINK-35115:
---
Stop with savepoint checkpointing logic is no different
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837315#comment-17837315
]
Hong Liang Teoh commented on FLINK-35115:
-
[~a.pilipenko] Assigned to you, as you mentioned you
snuyanzin commented on PR #97:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/97#issuecomment-2057107944
Thanks for taking 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
URL above to go
snuyanzin merged PR #97:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/97
--
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-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837257#comment-17837257
]
Martijn Visser commented on FLINK-35112:
[~dianfu] [~hxbks2ks] WDYT?
> Membership for Row class
ferenc-csaky commented on PR #1:
URL:
https://github.com/apache/flink-connector-kudu/pull/1#issuecomment-2056968781
Thanks, it passed now! is it okay to merge this change at this point for now?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vadim Vararu updated FLINK-35115:
-
Affects Version/s: 1.18.1
> Kinesis connector writes wrong sequence number at stop with
Vadim Vararu created FLINK-35115:
Summary: Kinesis connector writes wrong sequence number at stop
with savepoint
Key: FLINK-35115
URL: https://issues.apache.org/jira/browse/FLINK-35115
Project: Flink
snuyanzin commented on PR #24:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/24#issuecomment-2057010314
thanks for taking 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
URL above to go to
[
https://issues.apache.org/jira/browse/FLINK-32212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837354#comment-17837354
]
Ricky Saltzer commented on FLINK-32212:
---
Verified we started hitting this pretty consistently when
[
https://issues.apache.org/jira/browse/FLINK-34928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-34928:
-
Component/s: Connectors / Kudu
> FLIP-439: Externalize Kudu Connector from Bahir
>
[
https://issues.apache.org/jira/browse/FLINK-35114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-35114:
-
Component/s: Connectors / Kudu
> Remove old Table API implementations
>
[
https://issues.apache.org/jira/browse/FLINK-35097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837268#comment-17837268
]
David Perkins commented on FLINK-35097:
---
Great! Thanks for the fast response.
> Table API
MartijnVisser commented on PR #1:
URL:
https://github.com/apache/flink-connector-kudu/pull/1#issuecomment-2056886905
> @MartijnVisser can that one case be retriggered? Or of not, I hope another
run would be green.
Re-triggered all failing jobs!
--
This is an automated message
d20162416 commented on PR #24593:
URL: https://github.com/apache/flink/pull/24593#issuecomment-2057057881
@reswqa Excuse me, could you please help me check this PR? I appreciate your
support very much.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-35115:
---
Assignee: Aleksandr Pilipenko
> Kinesis connector writes wrong Kinesis sequence
snuyanzin commented on code in PR #115:
URL:
https://github.com/apache/flink-connector-aws/pull/115#discussion_r1566124545
##
flink-connector-aws/flink-connector-dynamodb/pom.xml:
##
@@ -34,6 +34,9 @@ under the License.
jar
+
+
Ferenc Csaky created FLINK-35114:
Summary: Remove old Table API implementations
Key: FLINK-35114
URL: https://issues.apache.org/jira/browse/FLINK-35114
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837327#comment-17837327
]
Aleksandr Pilipenko commented on FLINK-35115:
-
[~dannycranmer] Agree, trying to reproduce it
Márton Balassi created FLINK-35116:
--
Summary: Upgrade JOSDK dependency to 4.8.3
Key: FLINK-35116
URL: https://issues.apache.org/jira/browse/FLINK-35116
Project: Flink
Issue Type:
yuxiqian commented on code in PR #3221:
URL: https://github.com/apache/flink-cdc/pull/3221#discussion_r1566596993
##
Zakelly commented on PR #24644:
URL: https://github.com/apache/flink/pull/24644#issuecomment-2058127691
> Thanks for this pr! Overall, LGTM. I have one question:
>
> If a subtask completes its checkpoint but the job's overall checkpoint
fails, the FileMergingSnapshotManager will
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837486#comment-17837486
]
Muhammet Orazov edited comment on FLINK-34508 at 4/16/24 2:51 AM:
--
Hey
[
https://issues.apache.org/jira/browse/FLINK-34127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen reassigned FLINK-34127:
--
Assignee: Mason Chen
> Kafka connector repo runs a duplicate of `IntegrationTests` framework
Jiabao-Sun merged PR #24612:
URL: https://github.com/apache/flink/pull/24612
--
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:
reswqa merged PR #24666:
URL: https://github.com/apache/flink/pull/24666
--
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-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837485#comment-17837485
]
ude commented on FLINK-35111:
-
[~dannycranmer] Thank you for your reply, but I found that has been
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837486#comment-17837486
]
Muhammet Orazov edited comment on FLINK-34508 at 4/16/24 2:49 AM:
--
Hey
Qishang Zhong created FLINK-35119:
-
Summary: UPDATE DataChangeEvent deserialized data is incorrect
Key: FLINK-35119
URL: https://issues.apache.org/jira/browse/FLINK-35119
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen reassigned FLINK-34320:
--
Assignee: (was: Mason Chen)
> Flink Kafka connector tests time out
>
[
https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837471#comment-17837471
]
Jiabao Sun commented on FLINK-25537:
master: 138f1f9d17b7a58b092ee7d9fc4c20d968a7b33b
> [JUnit5
Zakelly commented on code in PR #24644:
URL: https://github.com/apache/flink/pull/24644#discussion_r1566633317
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java:
##
@@ -349,6
[
https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837486#comment-17837486
]
Muhammet Orazov commented on FLINK-34508:
-
Hey all,
I have add changes to remove the
fredia commented on PR #24667:
URL: https://github.com/apache/flink/pull/24667#issuecomment-2058174500
@Zakelly @ljz2051 would 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
URL above to
[
https://issues.apache.org/jira/browse/FLINK-35119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qishang Zhong updated FLINK-35119:
--
Description:
When DebeziumChangelogMode is upsert, the before of DataChangeEvent is null,
zhongqishang opened a new pull request, #3226:
URL: https://github.com/apache/flink-cdc/pull/3226
(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-35119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35119:
---
Labels: pull-request-available (was: )
> UPDATE DataChangeEvent deserialized data is
[
https://issues.apache.org/jira/browse/FLINK-34320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen reassigned FLINK-34320:
--
Assignee: Mason Chen
> Flink Kafka connector tests time out
>
Zakelly commented on code in PR #24663:
URL: https://github.com/apache/flink/pull/24663#discussion_r1566625619
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/AsyncKeyedStateBackend.java:
##
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
roland created FLINK-35118:
--
Summary: StreamingHiveSource cannot track tables that have more
than 32,767 partitions
Key: FLINK-35118
URL: https://issues.apache.org/jira/browse/FLINK-35118
Project: Flink
fredia commented on code in PR #24644:
URL: https://github.com/apache/flink/pull/24644#discussion_r1566649212
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java:
##
@@ -349,6
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r155895
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordProcessorUtils.java:
##
@@ -82,6 +87,10 @@ public static ThrowingConsumer,
yuxiqian commented on code in PR #3221:
URL: https://github.com/apache/flink-cdc/pull/3221#discussion_r1566596993
##
roland created FLINK-35117:
--
Summary: AsyncScalarFunction has a dependency issue.
Key: FLINK-35117
URL: https://issues.apache.org/jira/browse/FLINK-35117
Project: Flink
Issue Type: Bug
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1566645709
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/input/FirstInputOfTwoInput.java:
##
@@ -54,4 +57,17 @@ public
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r154885
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/input/FirstInputOfTwoInput.java:
##
@@ -54,4 +57,17 @@ public
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1566670603
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordProcessorUtils.java:
##
@@ -82,6 +87,10 @@ public static ThrowingConsumer,
[
https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-35028:
---
Summary: Timer firing under async execution model (was: Processing timer
firing under async
[
https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837512#comment-17837512
]
Dian Fu commented on FLINK-35112:
-
Sounds reasonable for me. [~wzorgdrager] Do you want to submit a PR
yunfengzhou-hub commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1566744878
##
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java:
##
@@ -1085,6 +1085,54 @@ public void setUseSnapshotCompression(boolean
masteryhx commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1566625643
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java:
##
@@ -0,0 +1,153 @@
+/*
+ * Licensed to
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r153205
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -0,0 +1,140 @@
+/*
+ *
yunfengzhou-hub commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1566742123
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -181,4 +182,73 @@ public class ExecutionOptions {
fredia merged PR #22973:
URL: https://github.com/apache/flink/pull/22973
--
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:
snuyanzin opened a new pull request, #43:
URL: https://github.com/apache/flink-connector-opensearch/pull/43
The PR will allow to differentiate between Opensearch connector statistics
and others with name ci
--
This is an automated message from the Apache Git Service.
To respond to
snuyanzin merged PR #34:
URL: https://github.com/apache/flink-connector-mongodb/pull/34
--
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-35103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SwathiChandrashekar updated FLINK-35103:
Description:
Currently, whenever we have flink failures, we need to manually do
[
https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen resolved FLINK-34962.
---
Fix Version/s: pulsar-4.2.0
Resolution: Fixed
master via
[
https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-34962:
--
Affects Version/s: (was: pulsar-4.1.1)
> flink-connector-pulsa starts failed due to incorrect use
[
https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-34962:
--
Affects Version/s: (was: pulsar-4.2.0)
> flink-connector-pulsa starts failed due to incorrect use
[
https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-35104:
--
Description:
First collect cdc data in real time and write it to kafka, then write it to
multiple different
[
https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-35104:
--
Description:
There is already a [kafka pipeline data sink
[
https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-35104:
--
Description:
There is already a kafka pipeline data sink connector, and there should also be
a kafka
[
https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-35104:
--
Description:
There is already a kafka pipeline data sink connector, and there should also be
a kafka
[
https://issues.apache.org/jira/browse/FLINK-35104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
melin updated FLINK-35104:
--
Description:
There is already a kafka pipeline data sink connector :
1996fanrui opened a new pull request, #814:
URL: https://github.com/apache/flink-kubernetes-operator/pull/814
## What is the purpose of the change
Currently, autoscaler standalone doesn't support set [autoscaler
[
https://issues.apache.org/jira/browse/FLINK-35105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35105:
---
Labels: pull-request-available (was: )
> Support setting default Autoscaler options at
masteryhx commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1565310323
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java:
##
@@ -0,0 +1,166 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1565225216
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordProcessorUtils.java:
##
@@ -82,6 +87,10 @@ public static ThrowingConsumer,
[
https://issues.apache.org/jira/browse/FLINK-35024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837083#comment-17837083
]
Yanfei Lei commented on FLINK-35024:
Merged 6d139a1 into master
> Implement record order
[
https://issues.apache.org/jira/browse/FLINK-35024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-35024.
Resolution: Resolved
> Implement record order preservation and buffering of
snuyanzin commented on PR #41:
URL:
https://github.com/apache/flink-connector-opensearch/pull/41#issuecomment-2055588592
Closing since it is already 1.26.1 in `pom.xml`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
snuyanzin opened a new pull request, #33:
URL: https://github.com/apache/flink-connector-mongodb/pull/33
The PR will allow to differentiate between MongoDB connector statistics and
others with name ci
--
This is an automated message from the Apache Git Service.
To respond to
1 - 100 of 259 matches
Mail list logo
