Zakelly commented on code in PR #25308:
URL: https://github.com/apache/flink/pull/25308#discussion_r1758282666
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalMergingState.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
yuxiqian opened a new pull request, #3605:
URL: https://github.com/apache/flink-cdc/pull/3605
This closes FLINK-35634.
* implemented an cli utility to simplify cdc playground environment
configuration
* added corresponding docs in quickstart guide
--
This is an automated message
flinkbot commented on PR #25323:
URL: https://github.com/apache/flink/pull/25323#issuecomment-2348161085
## CI report:
* 3121e6c6fd73a5ef7b62785efb5defdd15cb9875 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on code in PR #25308:
URL: https://github.com/apache/flink/pull/25308#discussion_r1758275098
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalReducingState.java:
##
@@ -58,6 +72,107 @@ public V get() {
@Override
public void a
[
https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35634:
---
Labels: pull-request-available (was: )
> Add a CDC quickstart utility
> ---
[
https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36275:
---
Labels: pull-request-available (was: )
> Remove deprecated ProgramArgsQueryParameter
>
reswqa opened a new pull request, #25323:
URL: https://github.com/apache/flink/pull/25323
## What is the purpose of the change
*ProgramArgsQueryParameter has been deprecated in Flink 1.7(see
https://issues.apache.org/jira/browse/FLINK-10295). We can remove this(Breaking
compatibility
[
https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36275:
---
Priority: Blocker (was: Major)
> Remove deprecated ProgramArgsQueryParameter
>
[
https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36275:
---
Parent: FLINK-3957
Issue Type: Sub-task (was: Technical Debt)
> Remove deprecated ProgramAr
[ https://issues.apache.org/jira/browse/FLINK-36275 ]
Weijie Guo deleted comment on FLINK-36275:
was (Author: weijie guo):
ProgramArgsQueryParameter has been deprecated in Flink 1.7(see
https://issues.apache.org/jira/browse/FLINK-10295). We can
fredia commented on code in PR #25308:
URL: https://github.com/apache/flink/pull/25308#discussion_r1758244383
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalMergingState.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881474#comment-17881474
]
Weijie Guo commented on FLINK-36275:
ProgramArgsQueryParameter has been deprecated i
[
https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36275:
---
Description: ProgramArgsQueryParameter has been deprecated in Flink 1.7(see
https://issues.apache.or
Weijie Guo created FLINK-36275:
--
Summary: Remove deprecated ProgramArgsQueryParameter
Key: FLINK-36275
URL: https://issues.apache.org/jira/browse/FLINK-36275
Project: Flink
Issue Type: Technical
zhuzhurk commented on code in PR #25256:
URL: https://github.com/apache/flink/pull/25256#discussion_r1758217831
##
flink-python/docs/reference/pyflink.datastream/stream_execution_environment.rst:
##
@@ -132,4 +130,4 @@ SlotSharingGroup
:toctree: api/
SlotSharingGroup
1996fanrui commented on code in PR #879:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/879#discussion_r1758222419
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -389,15 +407,61 @@ protected static int scale(
ztison commented on PR #25319:
URL: https://github.com/apache/flink/pull/25319#issuecomment-2348090458
@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.
T
fredia commented on code in PR #25308:
URL: https://github.com/apache/flink/pull/25308#discussion_r1758159745
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalReducingState.java:
##
@@ -58,6 +72,108 @@ public V get() {
@Override
public void ad
Zakelly commented on code in PR #25308:
URL: https://github.com/apache/flink/pull/25308#discussion_r1758160241
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalMergingState.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/FLINK-36258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36258:
---
Component/s: Deployment / YARN
Tests
(was: Build System / CI)
[
https://issues.apache.org/jira/browse/FLINK-36258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-36258:
---
Labels: test-stability (was: )
> testRecursiveUploadForYarnS3n failed due to no AWS Credentials pro
[
https://issues.apache.org/jira/browse/FLINK-36225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-36225.
--
Resolution: Done
master(2.0) via 8d4e98503fd36faa6046731d329e42cd95d5e507.
> Remove deprecated method
[
https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-5336.
-
Resolution: Done
master(2.0) via eb19716fd1fffc5425556fbb93311daeff077682.
> Make Path immutable
> -
Zakelly commented on code in PR #25310:
URL: https://github.com/apache/flink/pull/25310#discussion_r1758146251
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java:
##
@@ -101,6 +156,13 @@ public boolean rename(
Zakelly Lan created FLINK-36274:
---
Summary: Remove legacy ExternalizedCheckpointCleanup
Key: FLINK-36274
URL: https://issues.apache.org/jira/browse/FLINK-36274
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-36274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881461#comment-17881461
]
Zakelly Lan commented on FLINK-36274:
-
[~spoon-lz] Would you spare some time working
fredia commented on code in PR #25310:
URL: https://github.com/apache/flink/pull/25310#discussion_r1758136623
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java:
##
@@ -125,29 +187,111 @@ public URI getUri() {
fredia commented on code in PR #25310:
URL: https://github.com/apache/flink/pull/25310#discussion_r1758133695
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java:
##
@@ -160,4 +304,16 @@ public boolean isDistri
fredia commented on code in PR #25310:
URL: https://github.com/apache/flink/pull/25310#discussion_r1758132493
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java:
##
@@ -101,6 +156,13 @@ public boolean rename(P
xuyang created FLINK-36273:
--
Summary: Remove deprecated Table/SQL configuration in 2.0
Key: FLINK-36273
URL: https://issues.apache.org/jira/browse/FLINK-36273
Project: Flink
Issue Type: Sub-task
reswqa merged PR #25311:
URL: https://github.com/apache/flink/pull/25311
--
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
reswqa merged PR #25318:
URL: https://github.com/apache/flink/pull/25318
--
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
Zakelly commented on code in PR #25310:
URL: https://github.com/apache/flink/pull/25310#discussion_r1758099239
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java:
##
@@ -125,29 +187,111 @@ public URI getUri()
[
https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881448#comment-17881448
]
Zakelly Lan commented on FLINK-35027:
-
Merged into master via e94d433dd0b242e68eb2eb
Zakelly merged PR #25317:
URL: https://github.com/apache/flink/pull/25317
--
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.apach
hackergin commented on PR #25315:
URL: https://github.com/apache/flink/pull/25315#issuecomment-2347907388
@lsyldliu I think both need to be fixed, including master and release 1.20.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/FLINK-36147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-36147.
---
Fix Version/s: 2.0-preview
(was: 2.0.0)
Resolution: Fixed
mast
XComp merged PR #25249:
URL: https://github.com/apache/flink/pull/25249
--
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-36239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhi Gupta closed FLINK-36239.
--
> DDB Streams Connector reprocessing due to DescribeStream inconsistencies for
> trimmed shards
> ---
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757533937
##
flink-connector-prometheus/src/main/java/org/apache/flink/connector/prometheus/sink/http/RemoteWriteRetryStrategy.java:
##
@@ -0,0 +1,129 @@
+/*
+ *
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757533031
##
flink-connector-prometheus/src/main/java/org/apache/flink/connector/prometheus/sink/http/RemoteWriteResponseClassifier.java:
##
@@ -0,0 +1,38 @@
+/*
+
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757531627
##
flink-connector-prometheus/src/main/java/org/apache/flink/connector/prometheus/sink/PrometheusSinkException.java:
##
@@ -0,0 +1,33 @@
+/*
+ * Licensed
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757532715
##
flink-connector-prometheus/src/main/java/org/apache/flink/connector/prometheus/sink/RequestEntrySizeUtils.java:
##
@@ -0,0 +1,63 @@
+/*
+ * Licensed
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757532179
##
flink-connector-prometheus/src/main/java/org/apache/flink/connector/prometheus/sink/PrometheusStateSerializer.java:
##
@@ -0,0 +1,154 @@
+/*
+ * Lice
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757531446
##
flink-connector-prometheus/src/main/java/org/apache/flink/connector/prometheus/sink/PrometheusSinkConfiguration.java:
##
@@ -0,0 +1,165 @@
+package or
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757530475
##
flink-connector-prometheus/src/main/java/org/apache/flink/connector/prometheus/sink/PrometheusSinkConfiguration.java:
##
@@ -0,0 +1,165 @@
+package or
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757530223
##
flink-connector-prometheus/src/main/java/org/apache/flink/connector/prometheus/sink/PrometheusSinkBuilder.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757529466
##
flink-connector-prometheus-request-signer-amp/src/test/java/org/apache/flink/connector/prometheus/sink/aws/RequestHeaderTestUtil.java:
##
@@ -0,0 +1,2
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757529253
##
flink-connector-prometheus-request-signer-amp/src/test/java/org/apache/flink/connector/prometheus/sink/aws/DummAwsSessionCredentialProvider.java:
##
@
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757528729
##
flink-connector-prometheus-request-signer-amp/src/test/java/org/apache/flink/connector/prometheus/sink/aws/AWS4SignerForAMPTest.java:
##
@@ -0,0 +1,73
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757527855
##
flink-connector-prometheus-request-signer-amp/src/test/java/org/apache/flink/connector/prometheus/sink/aws/RequestHeaderTestUtil.java:
##
@@ -0,0 +1,2
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757526897
##
flink-connector-prometheus/README.md:
##
@@ -0,0 +1,259 @@
+## Flink Prometheus connector (sink)
+
+Implementation of the Prometheus sink connector fo
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757525987
##
flink-connector-prometheus-request-signer-amp/src/main/java/org/apache/flink/connector/prometheus/sink/aws/AmazonManagedPrometheusWriteRequestSigner.java:
###
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757525787
##
flink-connector-prometheus-request-signer-amp/src/main/java/org/apache/flink/connector/prometheus/sink/aws/AWS4SignerForAMP.java:
##
@@ -0,0 +1,347 @@
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757525575
##
flink-connector-prometheus-request-signer-amp/src/main/java/org/apache/flink/connector/prometheus/sink/aws/AWS4SignerForAMP.java:
##
@@ -0,0 +1,347 @@
hlteoh37 commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#discussion_r1757525231
##
flink-connector-prometheus-request-signer-amp/src/test/java/org/apache/flink/connector/prometheus/sink/aws/DummAwsSessionCredentialProvider.java:
##
@
gguptp commented on PR #164:
URL:
https://github.com/apache/flink-connector-aws/pull/164#issuecomment-2347138069
Thanks for the review @hlteoh37! The review comments have been addressed now
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
dzikosc commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-aws/pull/152#discussion_r1757390907
##
docs/content/docs/connectors/table/dynamodb.md:
##
@@ -303,6 +303,46 @@ WITH (
);
```
+## Specifying Primary Key For Deletes
+
+The DynamoDB sink supp
dzikosc commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-aws/pull/152#discussion_r1757368121
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactory.java:
##
@@ -58,6 +58,17 @
dzikosc commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-aws/pull/152#discussion_r1757386924
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactory.java:
##
@@ -58,6 +58,17 @
dzikosc commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-aws/pull/152#discussion_r1757386924
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactory.java:
##
@@ -58,6 +58,17 @
dzikosc commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-aws/pull/152#discussion_r1757386924
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactory.java:
##
@@ -58,6 +58,17 @
dzikosc commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-aws/pull/152#discussion_r1757368121
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSinkFactory.java:
##
@@ -58,6 +58,17 @
dzikosc commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-aws/pull/152#discussion_r1757365286
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/DynamoDbDynamicSink.java:
##
@@ -62,7 +63,8 @@ protec
Matthias Pohl created FLINK-36272:
-
Summary: YarnFileStageTestS3ITCase fails on master
Key: FLINK-36272
URL: https://issues.apache.org/jira/browse/FLINK-36272
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-36272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36272:
--
Priority: Blocker (was: Major)
> YarnFileStageTestS3ITCase fails on master
>
[
https://issues.apache.org/jira/browse/FLINK-36272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881391#comment-17881391
]
Matthias Pohl commented on FLINK-36272:
---
[~xuannan] may you have a look at this?
XComp commented on PR #25302:
URL: https://github.com/apache/flink/pull/25302#issuecomment-2346944451
This PR causes a constant test failure in `master`:
[YarnFileStageTestS3ITCase](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=61979&view=logs&j=fc5181b0-e452-5c8f-68
[
https://issues.apache.org/jira/browse/FLINK-32688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-32688.
---
Resolution: Fixed
master:
[8dc40ab70c991d67949d3498b26dd6661e816312|https://github.com/apac
XComp merged PR #25248:
URL: https://github.com/apache/flink/pull/25248
--
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.
XComp commented on PR #25249:
URL: https://github.com/apache/flink/pull/25249#issuecomment-2346847083
Squashed commits together ([no
diff](https://github.com/apache/flink/compare/9e9f00e3b9edf55bd128859729194f9d93a19433..721c6a25763e4a9936cbd1d06b95da60eabd0f36))
--
This is an automated m
[
https://issues.apache.org/jira/browse/FLINK-36207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-36207.
---
Fix Version/s: 2.0-preview
Resolution: Fixed
master:
[625c6774fc187aed9f875abb421dd8
XComp merged PR #25285:
URL: https://github.com/apache/flink/pull/25285
--
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.
dzikosc commented on code in PR #157:
URL:
https://github.com/apache/flink-connector-aws/pull/157#discussion_r1757263194
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java:
##
@@ -149,7 +150,7 @@ public
gguptp commented on code in PR #164:
URL:
https://github.com/apache/flink-connector-aws/pull/164#discussion_r1757216895
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -159,12 +
gguptp commented on code in PR #164:
URL:
https://github.com/apache/flink-connector-aws/pull/164#discussion_r1757216391
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -86,17 +8
gguptp commented on code in PR #164:
URL:
https://github.com/apache/flink-connector-aws/pull/164#discussion_r1757215863
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java:
##
@
nicusX commented on PR #1:
URL:
https://github.com/apache/flink-connector-prometheus/pull/1#issuecomment-2346741773
@hlteoh37 I should have addressed all comments.
The configuration classes have been moved into a top-level
`PrometheusSinkConfiguration` class
--
This is an automated m
[
https://issues.apache.org/jira/browse/FLINK-36168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877742#comment-17877742
]
Matthias Pohl edited comment on FLINK-36168 at 9/12/24 3:45 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-36073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881352#comment-17881352
]
Ferenc Csaky commented on FLINK-36073:
--
Hey [~rmetzger],
Finally had some time to
XComp merged PR #25305:
URL: https://github.com/apache/flink/pull/25305
--
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.
gaborgsomogyi commented on code in PR #25267:
URL: https://github.com/apache/flink/pull/25267#discussion_r1757068022
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV5Serializer.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache Softwar
gaborgsomogyi commented on code in PR #25267:
URL: https://github.com/apache/flink/pull/25267#discussion_r1757059964
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV5Serializer.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache Softwar
mxm commented on code in PR #879:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/879#discussion_r1757006171
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -389,15 +413,51 @@ protected static int scale(
retur
mxm commented on code in PR #879:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/879#discussion_r1757005246
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -389,15 +413,51 @@ protected static int scale(
retur
mxm commented on code in PR #879:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/879#discussion_r1756999617
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -378,28 +405,70 @@ protected static int scale(
// Cap
[
https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-31986:
---
Assignee: Elphas Toringepi
> Implement Integration test for FLIP-27 DataStreams API
gyfora commented on code in PR #25267:
URL: https://github.com/apache/flink/pull/25267#discussion_r1756963082
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV5Serializer.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache Software Found
mxm commented on code in PR #879:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/879#discussion_r1756940171
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobVertexScaler.java:
##
@@ -378,28 +405,70 @@ protected static int scale(
// Cap
gaborgsomogyi commented on code in PR #25267:
URL: https://github.com/apache/flink/pull/25267#discussion_r1756924303
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV5Serializer.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache Softwar
hlteoh37 commented on code in PR #164:
URL:
https://github.com/apache/flink-connector-aws/pull/164#discussion_r1756892805
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -159,12
hlteoh37 commented on code in PR #164:
URL:
https://github.com/apache/flink-connector-aws/pull/164#discussion_r1756874586
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -86,17
[
https://issues.apache.org/jira/browse/FLINK-36270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-36270:
---
Assignee: Abhi Gupta
> DDB Streams Connector performance issue due to splitsAvailab
flinkbot commented on PR #25322:
URL: https://github.com/apache/flink/pull/25322#issuecomment-2346243164
## CI report:
* 706da1369385e5e708fecb3c54a9bf5e98343161 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp commented on PR #25285:
URL: https://github.com/apache/flink/pull/25285#issuecomment-2346176611
@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.
To
XComp commented on PR #25305:
URL: https://github.com/apache/flink/pull/25305#issuecomment-2346171277
@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.
To
ztison commented on PR #25319:
URL: https://github.com/apache/flink/pull/25319#issuecomment-2346163318
@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.
T
Grzegorz KoĊakowski created FLINK-36271:
---
Summary: Support json and jsonb type in PostgreSQL JDBC Dialect
Key: FLINK-36271
URL: https://issues.apache.org/jira/browse/FLINK-36271
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36270:
---
Labels: pull-request-available (was: )
> DDB Streams Connector performance issue due to spl
gguptp opened a new pull request, #164:
URL: https://github.com/apache/flink-connector-aws/pull/164
## Purpose of the change
When a split is marked as finished, we are iterating over all splits and
assigning available splits to readers. On a large enough stream with en
1 - 100 of 162 matches
Mail list logo
