masteryhx commented on code in PR #24766:
URL: https://github.com/apache/flink/pull/24766#discussion_r1597905886
##
docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md:
##
@@ -292,4 +292,25 @@ The final checkpoint would be triggered immediately after
all
yunfengzhou-hub commented on code in PR #24748:
URL: https://github.com/apache/flink/pull/24748#discussion_r1597912452
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/EpochManager.java:
##
@@ -0,0 +1,202 @@
+/*
+ * Licensed to the Apache Software
masteryhx commented on code in PR #24690:
URL: https://github.com/apache/flink/pull/24690#discussion_r1597852929
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AbstractStateIterator.java:
##
@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software
GOODBOY008 opened a new pull request, #3317:
URL: https://github.com/apache/flink-cdc/pull/3317
(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
masteryhx commented on code in PR #24768:
URL: https://github.com/apache/flink/pull/24768#discussion_r1597840604
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackend.java:
##
@@ -147,15 +160,30 @@ public S
[
https://issues.apache.org/jira/browse/FLINK-35237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangdingxin updated FLINK-35237:
-
Fix Version/s: cdc-3.2.0
> Allow Sink to Choose HashFunction in PrePartitionOperator
>
wenbingshen commented on PR #827:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/827#issuecomment-2106527073
> Thanks for the improvement!
>
> LGTM
>
> cc @gyfora
@1996fanrui Can anyone else review this PR? Thanks.
--
This is an automated message from
spoon-lz commented on PR #24461:
URL: https://github.com/apache/flink/pull/24461#issuecomment-2106510219
@Zakelly @masteryhx A new `ExternalizedCheckpointRetention.py` is created,
the old one is marked as deprecated, and a separate commit for the python part
is split.
--
This is an
flinkbot commented on PR #24774:
URL: https://github.com/apache/flink/pull/24774#issuecomment-2106499628
## CI report:
* 93334c7356336561bc6a97c1eb8ceb7509f647a7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33986:
---
Labels: pull-request-available (was: )
> Extend shuffleMaster to support batch snapshot.
>
JunRuiLee opened a new pull request, #24774:
URL: https://github.com/apache/flink/pull/24774
## What is the purpose of the change
Extend ShuffleMaster to support snapshot and restore state.
## Brief change log
Extend shuffleMaster to support batch
[
https://issues.apache.org/jira/browse/FLINK-35197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845761#comment-17845761
]
dalongliu commented on FLINK-35197:
---
Merged in master: e4972c003f68da6dc4066459d4c6e5d981f07e96
>
[
https://issues.apache.org/jira/browse/FLINK-35197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-35197.
---
Resolution: Fixed
> Support the execution of suspend, resume materialized table in continuous
>
lsyldliu closed pull request #24765: [FLINK-35197][table] Support the execution
of supsend materialized table in continuous refresh mode
URL: https://github.com/apache/flink/pull/24765
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
nicusX commented on code in PR #122:
URL:
https://github.com/apache/flink-connector-aws/pull/122#discussion_r1597692785
##
flink-formats-aws/flink-sql-avro-glue-schema-registry/pom.xml:
##
@@ -0,0 +1,163 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
robertkosz commented on PR #41:
URL: https://github.com/apache/flink-playgrounds/pull/41#issuecomment-2106323518
Since all wurstmeister images are gone on docker, this is kind of a must
now, docker compose up fails on operations-playground.
--
This is an automated message from the
superdiaodiao commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2106260978
@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
[
https://issues.apache.org/jira/browse/FLINK-34108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845659#comment-17845659
]
chesterxu edited comment on FLINK-34108 at 5/12/24 1:42 PM:
Hey, there~
If
superdiaodiao commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2106248298
@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
flinkbot commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2106247014
## CI report:
* d7b8727596cda8b1feb6edb3c465043ed764fa4c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845659#comment-17845659
]
chesterxu edited comment on FLINK-34108 at 5/12/24 1:24 PM:
[
https://issues.apache.org/jira/browse/FLINK-34108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34108:
---
Labels: pull-request-available (was: )
> Add URL_ENCODE and URL_DECODE function
>
superdiaodiao opened a new pull request, #24773:
URL: https://github.com/apache/flink/pull/24773
## What is the purpose of the change
This is an implementation of URL_ENCODE and URL_DECODE
1. URL_ENCODE: Translates a string into 'application/x-www-form-urlencoded'
[
https://issues.apache.org/jira/browse/FLINK-35322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845682#comment-17845682
]
Ahmed Hamdy commented on FLINK-35322:
-
[~Sergey Nuyanzin]
yes, let's keep it till after the release
[
https://issues.apache.org/jira/browse/FLINK-35322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845676#comment-17845676
]
Sergey Nuyanzin commented on FLINK-35322:
-
Currently not sure whether we can close this task,
[
https://issues.apache.org/jira/browse/FLINK-35322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845675#comment-17845675
]
Sergey Nuyanzin commented on FLINK-35322:
-
Merged as
boring-cyborg[bot] commented on PR #26:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/26#issuecomment-2106180994
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
snuyanzin merged PR #26:
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/26
--
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-35322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-35322:
---
Assignee: Ahmed Hamdy
> PubSub Connector Weekly build fails
>
vahmed-hamdy commented on PR #26:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/26#issuecomment-2106175939
@snuyanzin yes, I added the rub link to the PR description for the same
vahmed-hamdy commented on code in PR #141:
URL:
https://github.com/apache/flink-connector-aws/pull/141#discussion_r1597507484
##
flink-connector-aws/flink-connector-sqs/src/test/java/org.apache.flink/connector.sqs/sink/testutils/SqsTestUtils.java:
##
@@ -0,0 +1,76 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-33859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33859:
Affects Version/s: (was: opensearch-1.2.0)
> Support OpenSearch v2
>
[
https://issues.apache.org/jira/browse/FLINK-33859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33859:
Affects Version/s: opensearch-1.1.0
> Support OpenSearch v2
> -
>
>
33 matches
Mail list logo
