[
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 th
SwathiChandrashekar created FLINK-35103:
---
Summary: [Plugin] Enhancing Flink Failure Management in Kubernetes
with Dynamic Termination Log Integration
Key: FLINK-35103
URL: https://issues.apache.org/jira/brow
[
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 th
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: issues-unsubscr.
[
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 th
[
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://github.com/apache/flink-con
[
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
melin created FLINK-35104:
-
Summary: Add kafka pipeline data source connector
Key: FLINK-35104
URL: https://issues.apache.org/jira/browse/FLINK-35104
Project: Flink
Issue Type: New Feature
[
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 d
[
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|[https://github.com/apache/flink-cdc/pull
[
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 :
[https://github.com/apache/flink-cdc/pul
masteryhx commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1565293565
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java:
##
@@ -0,0 +1,167 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) u
Rui Fan created FLINK-35105:
---
Summary: Support setting default Autoscaler options at autoscaler
standalone level
Key: FLINK-35105
URL: https://issues.apache.org/jira/browse/FLINK-35105
Project: Flink
[
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 :
[https://github.com/apache/flink-cdc/pul
[
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 pipeline
[
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 pipeline
[
https://issues.apache.org/jira/browse/FLINK-35037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837095#comment-17837095
]
yisha zhou commented on FLINK-35037:
[~libenchao] The PR has been submitted. Please
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
options](https://nightlies.apache.org/flink/flink-kubernetes-operator-doc
[
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 auto
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) u
reswqa commented on PR #24662:
URL: https://github.com/apache/flink/pull/24662#issuecomment-2055922902
Wait a minute, you shouldn't only change the title of github pull request.
Commit message should be aligned with this also.
--
This is an automated message from the Apache Git Service.
masteryhx commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1565315084
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalKeyedState.java:
##
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
fredia commented on code in PR #24644:
URL: https://github.com/apache/flink/pull/24644#discussion_r1565310108
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java:
##
@@ -349,6 +3
Mate Czagany created FLINK-35106:
Summary: Kubernetes Operator ignores checkpoint type configuration
Key: FLINK-35106
URL: https://issues.apache.org/jira/browse/FLINK-35106
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-35064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837107#comment-17837107
]
Yufan Sheng commented on FLINK-35064:
-
AFAICS, the {{pulsar-client-all}} should be r
snuyanzin commented on PR #2:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/2#issuecomment-2056067269
@dchristle thanks for the review
May I ask you to have another iteration review for this PR?
--
This is an automated message from the Apache Git Service.
To respond to
boring-cyborg[bot] commented on PR #24:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/24#issuecomment-2056080694
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This
fredia commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1565352484
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java:
##
@@ -0,0 +1,166 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
xleoken created FLINK-35107:
---
Summary: rename flink-connector-datagen-test module folder to
flink-connector-datagen-tests
Key: FLINK-35107
URL: https://issues.apache.org/jira/browse/FLINK-35107
Project: Fli
fredia commented on code in PR #24651:
URL: https://github.com/apache/flink/pull/24651#discussion_r1565354167
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalKeyedState.java:
##
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
xleoken opened a new pull request, #24665:
URL: https://github.com/apache/flink/pull/24665
## What is the purpose of the change
Rename flink-connector-datagen-test module folder to
flink-connector-datagen-tests.
## Brief change log
*(for example:)*
- *Th
[
https://issues.apache.org/jira/browse/FLINK-35107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35107:
---
Labels: pull-request-available (was: )
> rename flink-connector-datagen-test module folder
chenyu-opensource commented on PR #24662:
URL: https://github.com/apache/flink/pull/24662#issuecomment-2056154528
> Wait a minute, you shouldn't only change the title of github pull request.
Commit message should be aligned with this also.
Sorry about that. May I close the current PR
flinkbot commented on PR #24665:
URL: https://github.com/apache/flink/pull/24665#issuecomment-2056169433
## CI report:
* fedce03e26e8f925d2fa5297f8fda9ca6c06d151 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
masteryhx commented on code in PR #24663:
URL: https://github.com/apache/flink/pull/24663#discussion_r1565377484
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java:
##
@@ -104,6 +104,25 @@ default String getName() {
CheckpointableKeyedStateBack
chenyu-opensource closed pull request #24662: [hotfix][runtime]Fix the missing
methed parameter annotation problem
URL: https://github.com/apache/flink/pull/24662
--
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
Gyula Fora created FLINK-35108:
--
Summary: Deployment recovery is triggered on terminal jobs after
jm shutdown ttl
Key: FLINK-35108
URL: https://issues.apache.org/jira/browse/FLINK-35108
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SwathiChandrashekar updated FLINK-35103:
Labels: pull-request-available (was: )
> [Plugin] Enhancing Flink Failure Managem
chenyu-opensource opened a new pull request, #24666:
URL: https://github.com/apache/flink/pull/24666
## What is the purpose of the change
This pull request fixs the problem of missing methed parameter annotation.
## Brief change log
Add the parameter annotatio
chenyu-opensource commented on PR #24662:
URL: https://github.com/apache/flink/pull/24662#issuecomment-2056223652
> Wait a minute, you shouldn't only change the title of github pull request.
Commit message should be aligned with this also.
I had close this pr and create a new one.
ht
ljz2051 commented on code in PR #24644:
URL: https://github.com/apache/flink/pull/24644#discussion_r1562362549
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerBase.java:
##
@@ -70,6 +72,9 @@ public abstract class FileMergi
snuyanzin commented on PR #38:
URL:
https://github.com/apache/flink-connector-opensearch/pull/38#issuecomment-2056231334
this is in my todo list for today/tomorrow
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
reswqa commented on PR #24666:
URL: https://github.com/apache/flink/pull/24666#issuecomment-2056235051
You could just force push it, github can take care of this. But you've
opened a new PR, let's move our eyes here. 😉
--
This is an automated message from the Apache Git Service.
To respo
reswqa commented on PR #24666:
URL: https://github.com/apache/flink/pull/24666#issuecomment-2056237176
I will merge this after CI passed.
--
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 speci
flinkbot commented on PR #24666:
URL: https://github.com/apache/flink/pull/24666#issuecomment-2056241215
## CI report:
* b0404b8f421f5920d958ff4ad3fdad170d4f56e4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Boyko updated FLINK-34694:
Attachment: image-2024-04-15-15-45-51-027.png
> Delete num of associations for streaming outer joi
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Boyko updated FLINK-34694:
Attachment: image-2024-04-15-15-46-17-671.png
> Delete num of associations for streaming outer joi
[
https://issues.apache.org/jira/browse/FLINK-35022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35022:
-
Assignee: Ahmed Hamdy
> Add TypeInformed Element Converter for DynamoDbSink
> -
chenyu-opensource commented on PR #24666:
URL: https://github.com/apache/flink/pull/24666#issuecomment-2056282707
> I will merge this after CI passed.
This is my first time contributing to this project. Thank you so much for
your patience. I will continue to pay attention to the commu
reswqa commented on PR #24666:
URL: https://github.com/apache/flink/pull/24666#issuecomment-2056324276
welcome to on board 👍
--
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.
[
https://issues.apache.org/jira/browse/FLINK-35022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837132#comment-17837132
]
Danny Cranmer commented on FLINK-35022:
---
Hey [~chalixar], thanks for the contribut
[
https://issues.apache.org/jira/browse/FLINK-35022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837132#comment-17837132
]
Danny Cranmer edited comment on FLINK-35022 at 4/15/24 9:19 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-35109:
---
Summary: Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and
drop support for 1
dannycranmer commented on PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#issuecomment-2056352344
Please change commit message to include the component:
`[FLINK-35022][Connectors/DynamoDB]`
--
This is an automated message from the Apache Git Service.
To respond to th
Martijn Visser created FLINK-35109:
--
Summary: Drop support for Flink 1.17 and 1.18 in Flink Kafka
connector
Key: FLINK-35109
URL: https://issues.apache.org/jira/browse/FLINK-35109
Project: Flink
PatrickRen commented on code in PR #3186:
URL: https://github.com/apache/flink-cdc/pull/3186#discussion_r1565458476
##
docs/content.zh/docs/connectors/mysql.md:
##
@@ -107,6 +107,14 @@ pipeline:
需要注意的是，点号（.）被视为数据库和表名的分隔符。
如果需要在正则表达式中使用点（.）来匹配任何字符，必须使用反斜杠对点进行转义。
MartijnVisser closed pull request #43: [FLINK-32732][Connectors/Kafka] auto
offset reset should be exposed t…
URL: https://github.com/apache/flink-connector-kafka/pull/43
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
MartijnVisser commented on PR #43:
URL:
https://github.com/apache/flink-connector-kafka/pull/43#issuecomment-2056370919
No activity on the PR, closing as invalid
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-32732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32732.
--
Resolution: Invalid
> auto offset reset should be exposed to user
> --
[
https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34470:
---
Affects Version/s: kafka-3.1.0
(was: 1.17.1)
> Transactional mess
dannycranmer commented on code in PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#discussion_r1565419487
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java:
##
@@
dannycranmer commented on PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#issuecomment-2056383239
I have left a comment regarding the need for this on the Jira:
https://issues.apache.org/jira/browse/FLINK-35022
--
This is an automated message from the Apache Git Serv
fredia opened a new pull request, #24667:
URL: https://github.com/apache/flink/pull/24667
## What is the purpose of the change
As part of the async execution model of disaggregated state management, this
PR introduce async execution configurations.
## Brief change l
[
https://issues.apache.org/jira/browse/FLINK-35026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35026:
---
Labels: pull-request-available (was: )
> Introduce async execution configurations
> ---
liuyongvs commented on PR #24650:
URL: https://github.com/apache/flink/pull/24650#issuecomment-2056391409
hi @snuyanzin will you help review it?
--
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 th
[
https://issues.apache.org/jira/browse/FLINK-30388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-30388:
-
Assignee: Ahmed Hamdy
> Add support for ElementConverted open() method for KDS/KDF/DDB
[
https://issues.apache.org/jira/browse/FLINK-35022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837140#comment-17837140
]
Ahmed Hamdy commented on FLINK-35022:
-
Hi [~dannycranmer]
Thanks for the reply, I a
[
https://issues.apache.org/jira/browse/FLINK-30388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30388:
--
Fix Version/s: aws-connector-4.3.0
> Add support for ElementConverted open() method for KDS/KD
liuyongvs commented on PR #24648:
URL: https://github.com/apache/flink/pull/24648#issuecomment-2056392924
hi @snuyanzin will you help review it?
--
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 th
flinkbot commented on PR #24667:
URL: https://github.com/apache/flink/pull/24667#issuecomment-2056402383
## CI report:
* aea56668e33e7062e6b18dac4086a2f05dc36fc1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30388:
---
Labels: pull-request-available (was: )
> Add support for ElementConverted open() method for
[
https://issues.apache.org/jira/browse/FLINK-35075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837146#comment-17837146
]
Jacky Lau commented on FLINK-35075:
---
hi [~snuyanzin] will you help review this?
> Mig
[
https://issues.apache.org/jira/browse/FLINK-34436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837148#comment-17837148
]
Yufan Sheng commented on FLINK-34436:
-
If you want to consume all the messages with
[
https://issues.apache.org/jira/browse/FLINK-34091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837152#comment-17837152
]
Yufan Sheng commented on FLINK-34091:
-
Since this is a requirement from Pulsar side.
vahmed-hamdy commented on code in PR #136:
URL:
https://github.com/apache/flink-connector-aws/pull/136#discussion_r1565513965
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbTypeInformedElementConverter.java:
##
@@
[
https://issues.apache.org/jira/browse/FLINK-33729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837157#comment-17837157
]
Yufan Sheng commented on FLINK-33729:
-
[~Weijie Guo] Yep, this is a valid ticket. Bu
[
https://issues.apache.org/jira/browse/FLINK-33486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837160#comment-17837160
]
Yufan Sheng commented on FLINK-33486:
-
The retry logic is internally provided by the
ude created FLINK-35110:
---
Summary: Modify the spelling mistakes in the taskmanager html
Key: FLINK-35110
URL: https://issues.apache.org/jira/browse/FLINK-35110
Project: Flink
Issue Type: Improv
ude created FLINK-35111:
---
Summary: Modify the spelling mistakes in the taskmanager html
Key: FLINK-35111
URL: https://issues.apache.org/jira/browse/FLINK-35111
Project: Flink
Issue Type: Improv
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1565516972
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -0,0 +1,134 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-33136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837161#comment-17837161
]
Yufan Sheng commented on FLINK-33136:
-
Yep, I think you are right. We should use mor
Wouter Zorgdrager created FLINK-35112:
-
Summary: Membership for Row class does not include field names
Key: FLINK-35112
URL: https://issues.apache.org/jira/browse/FLINK-35112
Project: Flink
snuyanzin merged PR #43:
URL: https://github.com/apache/flink-connector-opensearch/pull/43
--
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-unsubs
[
https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837162#comment-17837162
]
Yufan Sheng commented on FLINK-32645:
-
[~tison] I think we can close this issue now.
[
https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen resolved FLINK-32645.
---
Resolution: Fixed
> Flink pulsar sink is having poor performance
> -
Jiabao-Sun commented on code in PR #24612:
URL: https://github.com/apache/flink/pull/24612#discussion_r1565548513
##
flink-core/src/test/java/org/apache/flink/configuration/MemorySizePrettyPrintingTest.java:
##
@@ -45,13 +46,13 @@ public static Object[][] parameters() {
snuyanzin commented on PR #23:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/23#issuecomment-2056554166
ci fails because of dependency convergence issue which is going to be fixed
within
https://github.com/apache/flink-connector-gcp-pubsub/pull/24
--
This is an autom
snuyanzin merged PR #44:
URL: https://github.com/apache/flink-connector-opensearch/pull/44
--
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-unsubs
GOODBOY008 commented on code in PR #24612:
URL: https://github.com/apache/flink/pull/24612#discussion_r1565637869
##
flink-core/src/test/java/org/apache/flink/configuration/ReadableWritableConfigurationTest.java:
##
@@ -169,7 +170,7 @@ void testGetOptionalFromObject() {
GOODBOY008 commented on code in PR #24612:
URL: https://github.com/apache/flink/pull/24612#discussion_r1565642234
##
flink-core/src/test/java/org/apache/flink/configuration/GlobalConfigurationTest.java:
##
@@ -42,57 +42,48 @@ class GlobalConfigurationTest {
@TempDir private
GOODBOY008 commented on code in PR #24612:
URL: https://github.com/apache/flink/pull/24612#discussion_r1565637869
##
flink-core/src/test/java/org/apache/flink/configuration/ReadableWritableConfigurationTest.java:
##
@@ -169,7 +170,7 @@ void testGetOptionalFromObject() {
snuyanzin opened a new pull request, #89:
URL: https://github.com/apache/flink-connector-pulsar/pull/89
## Purpose of the change
The PR will allow to differentiate between Pulsar connector statistics and
others with name ci
## Brief change log
GHA name change
gyfora opened a new pull request, #815:
URL: https://github.com/apache/flink-kubernetes-operator/pull/815
## What is the purpose of the change
The deployment recovery mechanism is incorrectly triggered for terminal jobs
once the JM deployment is deleted after the TTL period.
Th
[
https://issues.apache.org/jira/browse/FLINK-35108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35108:
---
Labels: pull-request-available (was: )
> Deployment recovery is triggered on terminal jobs
gyfora merged PR #806:
URL: https://github.com/apache/flink-kubernetes-operator/pull/806
--
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
dannycranmer merged PR #135:
URL: https://github.com/apache/flink-connector-aws/pull/135
--
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
[
https://issues.apache.org/jira/browse/FLINK-30388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-30388.
---
Resolution: Fixed
> Add support for ElementConverted open() method for KDS/KDF/DDB
> ---
[
https://issues.apache.org/jira/browse/FLINK-30388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837204#comment-17837204
]
Danny Cranmer commented on FLINK-30388:
---
Merged commit
[{{8cafbbc}}|https://githu
[
https://issues.apache.org/jira/browse/FLINK-35113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35113:
--
Fix Version/s: aws-connector-4.3.0
(was: kafka-4.0.0)
1 - 100 of 253 matches
Mail list logo
