[
https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suxing Lee updated FLINK-35396:
---
Affects Version/s: 1.16.2
> DynamoDB Streams Consumer consumption data is out of order
>
[
https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suxing Lee updated FLINK-35396:
---
Affects Version/s: aws-connector-4.2.0
> DynamoDB Streams Consumer consumption data is out of order
[
https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suxing Lee updated FLINK-35396:
---
Affects Version/s: (was: 1.16.2)
> DynamoDB Streams Consumer consumption data is out of order
>
Suxing Lee created FLINK-35396:
--
Summary: DynamoDB Streams Consumer consumption data is out of order
Key: FLINK-35396
URL: https://issues.apache.org/jira/browse/FLINK-35396
Project: Flink
Issue
chenyuzhi459 commented on code in PR #825:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/825#discussion_r1605937715
##
docker-entrypoint.sh:
##
@@ -22,6 +22,27 @@ args=("$@")
cd /flink-kubernetes-operator || exit
+maybe_enable_jemalloc() {
+if [
chenyuzhi459 commented on code in PR #825:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/825#discussion_r1605937715
##
docker-entrypoint.sh:
##
@@ -22,6 +22,27 @@ args=("$@")
cd /flink-kubernetes-operator || exit
+maybe_enable_jemalloc() {
+if [
chenyuzhi459 commented on code in PR #825:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/825#discussion_r1605937475
##
docker-entrypoint.sh:
##
@@ -22,6 +22,27 @@ args=("$@")
cd /flink-kubernetes-operator || exit
+maybe_enable_jemalloc() {
+if [
whhe commented on PR #109:
URL:
https://github.com/apache/flink-connector-jdbc/pull/109#issuecomment-2119061257
> I left some minor comments
Hi @eskabetxe, I updated these files, please take a look again.
--
This is an automated message from the Apache Git Service.
To respond to
flinkbot commented on PR #24809:
URL: https://github.com/apache/flink/pull/24809#issuecomment-2118862642
## CI report:
* 8d7ee00f3b8cfe49afbce3aa80070e8ea24abb7c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35355:
---
Labels: pull-request-available (was: )
> Async aggregating state
> ---
jectpro7 opened a new pull request, #24809:
URL: https://github.com/apache/flink/pull/24809
This PR defines the V2 `AggreatingState` and its `StateDescriptor`. And
provides the default `InternalAggregatingState` implementation which delegates
all aycn request to AEC.
## What
morazow commented on PR #24426:
URL: https://github.com/apache/flink/pull/24426#issuecomment-2118852480
@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.
flinkbot commented on PR #24808:
URL: https://github.com/apache/flink/pull/24808#issuecomment-2118775672
## CI report:
* 671fbbda0860f86d585656e6b030782910dd9a3b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35395:
---
Labels: pull-request-available (was: )
> Fix KeyedStateStore class annotation error
>
usberkeley opened a new pull request, #24808:
URL: https://github.com/apache/flink/pull/24808
## What is the purpose of the change
[FLINK-35395][core] Fix KeyedStateStore class annotation error
## Brief change log
There is an error in the annotation of the getState
bradley created FLINK-35395:
---
Summary: Fix KeyedStateStore class annotation error
Key: FLINK-35395
URL: https://issues.apache.org/jira/browse/FLINK-35395
Project: Flink
Issue Type: Improvement
melin created FLINK-35394:
-
Summary: paimon pipeline support dynamic bucket
Key: FLINK-35394
URL: https://issues.apache.org/jira/browse/FLINK-35394
Project: Flink
Issue Type: New Feature
melin created FLINK-35393:
-
Summary: Support flink kafka catalog
Key: FLINK-35393
URL: https://issues.apache.org/jira/browse/FLINK-35393
Project: Flink
Issue Type: New Feature
Components:
18 matches
Mail list logo
