LadyForest commented on PR #24510:
URL: https://github.com/apache/flink/pull/24510#issuecomment-2058380570
> Thanks for your review @LadyForest. I rebased and addressed your comments.
Could you please re-check the PR in your available time? Thanks
Apologies for the delayed response, a
yuxiqian opened a new pull request, #3227:
URL: https://github.com/apache/flink-cdc/pull/3227
This closes [FLINK-35120](https://issues.apache.org/jira/browse/FLINK-35120).
Currently, Flink CDC Doris pipeline connector has very limited test cases
(which only covers row convertion). Thi
[
https://issues.apache.org/jira/browse/FLINK-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35120:
---
Labels: pull-request-available (was: )
> Add Doris Pipeline connector integration test case
yuxiqian commented on PR #3227:
URL: https://github.com/apache/flink-cdc/pull/3227#issuecomment-2058385113
cc @PatrickRen
--
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-35103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837541#comment-17837541
]
SwathiChandrashekar commented on FLINK-35103:
-
Thanks [~martijnvisser] . Hav
caicancai commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1566828007
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837538#comment-17837538
]
Wouter Zorgdrager commented on FLINK-35112:
---
[~dianfu] sure, I can submit a PR
1996fanrui commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1566834001
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,65 @@ specific language governing permissions and limitations
under the License.
zhongqishang commented on code in PR #3226:
URL: https://github.com/apache/flink-cdc/pull/3226#discussion_r1566843014
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/test/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSourceITCase
snuyanzin commented on PR #91:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/91#issuecomment-2058403397
@liuml07 thanks for the contribution
it seems the ci failed because of `spotless`
could you please apply spotless to the PR?
--
This is an automated message f
mas-chen commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1566845916
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref: '#/compo
1996fanrui commented on code in PR #809:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/809#discussion_r1566848357
##
docs/content.zh/docs/concepts/architecture.md:
##
@@ -24,57 +24,66 @@ specific language governing permissions and limitations
under the License.
ljz2051 commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1566847884
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferWritableFSDataOutputStream.java:
##
@@ -0,0 +1,102 @@
+/*
+ * L
LadyForest commented on code in PR #24510:
URL: https://github.com/apache/flink/pull/24510#discussion_r1566868181
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/UncollectToTableFunctionScanRule.scala:
##
@@ -0,0 +1,100 @@
+/*
Hongshun Wang created FLINK-35121:
-
Summary: CDC pipeline connector should verify requiredOptions and
optionalOptions
Key: FLINK-35121
URL: https://issues.apache.org/jira/browse/FLINK-35121
Project: F
[
https://issues.apache.org/jira/browse/FLINK-35121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837552#comment-17837552
]
Hongshun Wang commented on FLINK-35121:
---
[~renqs] , CC
> CDC pipeline connector s
[
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,
des
1996fanrui commented on PR #801:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/801#issuecomment-2058446456
Hi @mxm , I merge this PR first, feel free to ping me if you have any
comment in the future, thanks~
--
This is an automated message from the Apache Git Service.
To
1996fanrui merged PR #801:
URL: https://github.com/apache/flink-kubernetes-operator/pull/801
--
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-unsu
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837562#comment-17837562
]
Aleksandr Pilipenko commented on FLINK-35115:
-
[~vadim.vararu] are you able
[
https://issues.apache.org/jira/browse/FLINK-35122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen updated FLINK-35122:
---
Component/s: Connectors / Kafka
> Implement Watermark Alignment for DynamicKafkaSource
> ---
Mason Chen created FLINK-35122:
--
Summary: Implement Watermark Alignment for DynamicKafkaSource
Key: FLINK-35122
URL: https://issues.apache.org/jira/browse/FLINK-35122
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-35111.
---
Fix Version/s: 1.20.0
Resolution: Fixed
> Modify the spelling mistakes in the taskman
[
https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837569#comment-17837569
]
Mason Chen commented on FLINK-35088:
Watermark alignment was moved out of beta du
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35111:
--
Component/s: Documentation
(was: Runtime / Web Frontend)
> Modify the spe
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837570#comment-17837570
]
Ahmed Hamdy commented on FLINK-31472:
-
Is there a reason why the issue is not Resolv
[
https://issues.apache.org/jira/browse/FLINK-34906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837557#comment-17837557
]
Rui Fan commented on FLINK-34906:
-
Merged to main(1.9.0) via : 75eb206e863993727b62bd737
[
https://issues.apache.org/jira/browse/FLINK-34906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-34906.
-
Resolution: Fixed
> Don't start autoscaling when some tasks are not running
> --
[
https://issues.apache.org/jira/browse/FLINK-34735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837571#comment-17837571
]
牛一凡 commented on FLINK-34735:
-
I am willing to do this.Can it be assigned to me?:)
> "Devel
[
https://issues.apache.org/jira/browse/FLINK-34747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837575#comment-17837575
]
牛一凡 commented on FLINK-34747:
-
I am willing to do this.Can it be assigned to me?:)
> "legac
[
https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837576#comment-17837576
]
牛一凡 commented on FLINK-34748:
-
I am willing to do this.Can it be assigned to me?:)
> "legac
[
https://issues.apache.org/jira/browse/FLINK-31400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen reassigned FLINK-31400:
--
Assignee: Mason Chen (was: Mason Chen)
> Add autoscaler integration for Iceberg source
> ---
dannycranmer merged PR #24669:
URL: https://github.com/apache/flink/pull/24669
--
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.
[
https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837578#comment-17837578
]
牛一凡 commented on FLINK-34749:
-
I am willing to do this.Can it be assigned to me?:)
> "legac
[
https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837579#comment-17837579
]
牛一凡 commented on FLINK-34752:
-
I am willing to do this.Can it be assigned to me?:)
> "legac
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31472:
--
Fix Version/s: 1.18.2
1.19.1
> AsyncSinkWriterThrottlingTest failed with Il
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35111:
--
Fix Version/s: (was: 1.19.0)
> Modify the spelling mistakes in the taskmanager html
>
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837568#comment-17837568
]
Danny Cranmer commented on FLINK-35111:
---
Ok great, thanks for the update [~wczhu]
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35111:
--
Fix Version/s: (was: 1.20.0)
> Modify the spelling mistakes in the taskmanager html
>
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35111:
--
Fix Version/s: 1.20.0
> Modify the spelling mistakes in the taskmanager html
> ---
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-35111:
--
Component/s: Runtime / Web Frontend
(was: Documentation)
> Modify the spe
dannycranmer commented on PR #24276:
URL: https://github.com/apache/flink/pull/24276#issuecomment-2058472281
In parallel, a Jira was created for this. Referencing here
https://issues.apache.org/jira/browse/FLINK-35111
--
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35111:
-
Assignee: Yun Tang
> Modify the spelling mistakes in the taskmanager html
> ---
[
https://issues.apache.org/jira/browse/FLINK-34748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837576#comment-17837576
]
牛一凡 edited comment on FLINK-34748 at 4/16/24 8:10 AM:
--
Hi [~kunni]
[ https://issues.apache.org/jira/browse/FLINK-34749 ]
牛一凡 deleted comment on FLINK-34749:
-
was (Author: JIRAUSER304780):
I am willing to do this.Can it be assigned to me?:)
> "legacy-flink-cdc-sources" Page of SQLServer for Flink CDC Chinese
> Documen
[
https://issues.apache.org/jira/browse/FLINK-34749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837582#comment-17837582
]
牛一凡 commented on FLINK-34749:
-
Hi [~kunni] ，I am a Chinese Speaker and glad to take this wo
[
https://issues.apache.org/jira/browse/FLINK-32892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mason Chen reassigned FLINK-32892:
--
Assignee: Mason Chen
> Handle Kafka clients JMX mBean errors by disabling JMX metrics
> -
[ https://issues.apache.org/jira/browse/FLINK-34735 ]
牛一凡 deleted comment on FLINK-34735:
-
was (Author: JIRAUSER304780):
I am willing to do this.Can it be assigned to me?:)
> "Developer Guide - Understanding Flink CDC API" Page for Flink CDC Chinese
>
dannycranmer merged PR #24668:
URL: https://github.com/apache/flink/pull/24668
--
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.
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837580#comment-17837580
]
Danny Cranmer commented on FLINK-31472:
---
I was waiting for the backports to be mer
[
https://issues.apache.org/jira/browse/FLINK-31472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-31472.
---
Resolution: Fixed
> AsyncSinkWriterThrottlingTest failed with Illegal mailbox thread
> -
[ https://issues.apache.org/jira/browse/FLINK-34747 ]
牛一凡 deleted comment on FLINK-34747:
-
was (Author: JIRAUSER304780):
I am willing to do this.Can it be assigned to me?:)
> "legacy-flink-cdc-sources" Page of DB2 for Flink CDC Chinese Documentation.
>
[
https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837579#comment-17837579
]
牛一凡 edited comment on FLINK-34752 at 4/16/24 8:09 AM:
--
Hi [~kunni]
Fei Feng created FLINK-35123:
Summary: Flink Kubernetes Operator should not do deleteHAData
Key: FLINK-35123
URL: https://issues.apache.org/jira/browse/FLINK-35123
Project: Flink
Issue Type: Tec
snuyanzin commented on PR #23:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/23#issuecomment-2058526774
@joaquinfernandez131 could you please rebase to be sure that ci passes?
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
[
https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834758#comment-17834758
]
ude edited comment on FLINK-35039 at 4/16/24 8:36 AM:
--
[~Yu
reswqa commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1566976014
##
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/context/ProcessingTimeManager.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Fou
RocMarshal commented on code in PR #810:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/810#discussion_r1566975727
##
docs/content.zh/docs/concepts/overview.md:
##
@@ -24,86 +24,93 @@ specific language governing permissions and limitations
under the License.
--
reswqa commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1566978504
##
flink-datastream/src/main/java/org/apache/flink/datastream/impl/stream/ProcessConfigurableDataStream.java:
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software
reswqa commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1566988135
##
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/context/StateManager.java:
##
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundation (
reswqa commented on code in PR #24541:
URL: https://github.com/apache/flink/pull/24541#discussion_r1566991099
##
flink-datastream-api/src/main/java/org/apache/flink/datastream/api/context/TimestampManager.java:
##
@@ -0,0 +1,35 @@
+/*
+ * Licensed to the Apache Software Foundati
GOODBOY008 commented on PR #24670:
URL: https://github.com/apache/flink/pull/24670#issuecomment-2058579166
@Jiabao-Sun @1996fanrui PTAL
--
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 specif
snuyanzin commented on PR #89:
URL:
https://github.com/apache/flink-connector-pulsar/pull/89#issuecomment-2058580128
yep, thanks for noticing it
however i guess it is worth discussion first to change it
thanks for taking a look
--
This is an automated message from the Apache Git Ser
[
https://issues.apache.org/jira/browse/FLINK-35123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837610#comment-17837610
]
Gyula Fora commented on FLINK-35123:
I agree that if the rest api is accessible we c
snuyanzin merged PR #89:
URL: https://github.com/apache/flink-connector-pulsar/pull/89
--
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..
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567004818
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordProcessorUtils.java:
##
@@ -82,6 +87,10 @@ public static ThrowingConsumer,
Exception>
flinkbot commented on PR #24670:
URL: https://github.com/apache/flink/pull/24670#issuecomment-2058604771
## CI report:
* aae449392b8ce075a2413679ed2a0c42eaa52c68 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837641#comment-17837641
]
Ryan Skraba commented on FLINK-35002:
-
1.20 AdaptiveScheduler: Compile
https://gith
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567096409
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequestBuffer.java:
##
@@ -59,6 +60,9 @@ public StateRequestBuffer() {
}
void en
[
https://issues.apache.org/jira/browse/FLINK-34919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837643#comment-17837643
]
Ryan Skraba commented on FLINK-34919:
-
1.19 Java 21: Test (module: core)
https://gi
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837642#comment-17837642
]
Ryan Skraba commented on FLINK-35041:
-
* 1.20 Java 11: Test (module: core)
https://
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837647#comment-17837647
]
Ryan Skraba commented on FLINK-35041:
-
1.20 test_ci core
https://dev.azure.com/apac
Danny Cranmer created FLINK-35124:
-
Summary: Connector Release Fails to run Checkstyle
Key: FLINK-35124
URL: https://issues.apache.org/jira/browse/FLINK-35124
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837654#comment-17837654
]
Danny Cranmer commented on FLINK-35124:
---
[~echauchot] do you recall why the tools
[
https://issues.apache.org/jira/browse/FLINK-31872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31872:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Add Sup
[
https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25779:
--
Affects Version/s: aws-connector-4.3.0
> Define ConfigOption for aws, scan and sink map in Kin
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-24379:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Support
[
https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32116:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> FlinkKi
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-24379:
--
Affects Version/s: (was: aws-connector-4.2.0)
> Support AWS Glue Schema Registry Avro for
[
https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31922:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Port ov
[
https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31922:
--
Affects Version/s: aws-connector-4.3.0
> Port over Kinesis Client configurations for retry and
[
https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25779:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Define
[
https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32116:
--
Affects Version/s: aws-connector-4.3.0
> FlinkKinesisConsumer cannot stop-with-savepoint when
[
https://issues.apache.org/jira/browse/FLINK-31872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31872:
--
Affects Version/s: (was: aws-connector-4.2.0)
> Add Support for Configuring AIMD Ratelimit
[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33991:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Custom
[
https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33259:
--
Affects Version/s: aws-connector-4.3.0
> flink-connector-aws should use/extend the common conn
[
https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33259:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> flink-c
[
https://issues.apache.org/jira/browse/FLINK-32007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32007:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Impleme
[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33991:
--
Affects Version/s: (was: aws-connector-4.2.0)
> Custom Error Handling for Kinesis Polling
Zakelly commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1567124524
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java:
##
@@ -0,0 +1,195 @@
+/*
+ * Li
dannycranmer opened a new pull request, #733:
URL: https://github.com/apache/flink-web/pull/733
(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,
mbalassi opened a new pull request, #816:
URL: https://github.com/apache/flink-kubernetes-operator/pull/816
Also bumps fabric8 client 6.11.0 to harmonize it with JOSDK.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
[
https://issues.apache.org/jira/browse/FLINK-35116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35116:
---
Labels: pull-request-available (was: )
> Upgrade JOSDK dependency to 4.8.3
> --
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567158767
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequestBuffer.java:
##
@@ -59,6 +60,9 @@ public StateRequestBuffer() {
}
void e
ferenc-csaky commented on PR #35:
URL:
https://github.com/apache/flink-connector-hbase/pull/35#issuecomment-2058924269
@snuyanzin I fixed the dep convergence for 1.19 the last CI run failed on,
also had to change `HBaseTablePlanTest` as the JUnit5 migration for
`TableTestBase` in the core
Jinzhong Li created FLINK-35125:
---
Summary: Implement ValueState for ForStStateBackend
Key: FLINK-35125
URL: https://issues.apache.org/jira/browse/FLINK-35125
Project: Flink
Issue Type: Sub-task
ljz2051 opened a new pull request, #24671:
URL: https://github.com/apache/flink/pull/24671
## What is the purpose of the change
This pull request implements the ValueState for ForStStateBackend.
## Brief change log
- Define the InternalSyncState interfaces in flink-run
[
https://issues.apache.org/jira/browse/FLINK-35125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35125:
---
Labels: pull-request-available (was: )
> Implement ValueState for ForStStateBackend
> -
flinkbot commented on PR #24671:
URL: https://github.com/apache/flink/pull/24671#issuecomment-2058974205
## CI report:
* f4b1a4374cc6c579ff50e5b09bb5715b386645d2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dfontana commented on PR #23226:
URL: https://github.com/apache/flink/pull/23226#issuecomment-2058978531
Hi @singhravidutt thank you for your efforts; are you actively working on
this PR? I am also interested in seeing this land; am happy to help where needed
--
This is an automated messa
1 - 100 of 163 matches
Mail list logo
