zoltar9264 commented on code in PR #24247:
URL: https://github.com/apache/flink/pull/24247#discussion_r1979001874
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV6Serializer.java:
##
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Apache Software Fo
davidradl commented on code in PR #26223:
URL: https://github.com/apache/flink/pull/26223#discussion_r1979001732
##
docs/content/docs/dev/datastream/sinks.md:
##
@@ -93,36 +93,36 @@ The `Sink` needs to be serializable. All configuration
should be validated eager
### Custom s
davidradl commented on code in PR #26223:
URL: https://github.com/apache/flink/pull/26223#discussion_r1979000101
##
docs/content/docs/dev/datastream/sinks.md:
##
@@ -93,36 +93,36 @@ The `Sink` needs to be serializable. All configuration
should be validated eager
### Custom s
davidradl commented on code in PR #26223:
URL: https://github.com/apache/flink/pull/26223#discussion_r1979005956
##
docs/content.zh/docs/dev/datastream/sinks.md:
##
@@ -93,36 +93,36 @@ The `Sink` needs to be serializable. All configuration
should be validated eager
### Custo
davidradl commented on code in PR #26223:
URL: https://github.com/apache/flink/pull/26223#discussion_r1979006634
##
docs/content.zh/docs/dev/datastream/sinks.md:
##
@@ -93,36 +93,36 @@ The `Sink` needs to be serializable. All configuration
should be validated eager
### Custo
[
https://issues.apache.org/jira/browse/FLINK-35724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-35724:
---
Fix Version/s: 2.1.0
(was: 2.0.1)
> javax.xml.bind.JAXBException not found wi
pchoudhury22 opened a new pull request, #952:
URL: https://github.com/apache/flink-kubernetes-operator/pull/952
Draft PR for plugin based approach for evalution hook for scaling metric
evaluation
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
Zakelly commented on code in PR #26202:
URL: https://github.com/apache/flink/pull/26202#discussion_r1979295031
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackendBuilder.java:
##
@@ -259,10 +259,14 @@ public ForStKey
Zakelly commented on code in PR #26202:
URL: https://github.com/apache/flink/pull/26202#discussion_r1979297416
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackendBuilder.java:
##
@@ -259,10 +259,14 @@ public ForStKey
Zakelly commented on PR #26246:
URL: https://github.com/apache/flink/pull/26246#issuecomment-2700142576
Ah, the CI fails due to the
`AbstractAggregatingStateTest.AggregatingStateExecutor.hashMap` is static,
which is problematic.
--
This is an automated message from the Apache Git Service
[
https://issues.apache.org/jira/browse/FLINK-35343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932382#comment-17932382
]
Nil Madhab commented on FLINK-35343:
There is an upgrade in doris, 24.0.1. Does the
[
https://issues.apache.org/jira/browse/FLINK-37420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-37420:
---
Assignee: Yue Ma
> AbstractAggregatingState add may return wrong result
> -
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1980009840
##
flink-connector-aws/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReaderTest.java:
#
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1980022377
##
flink-connector-aws/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReaderTest.java:
#
Julian created FLINK-37421:
--
Summary: [flink-operator][FlinkDeployment] Doesn't provide a
mechanism to label the deployment
Key: FLINK-37421
URL: https://issues.apache.org/jira/browse/FLINK-37421
Project: Fl
ferenc-csaky commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1980080222
##
flink-connector-kudu/src/test/java/org/apache/flink/connector/kudu/source/KuduSourceITCase.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-37421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julian updated FLINK-37421:
---
Description:
I don't see a way to add labels to the Deployment created by the
FlinkDeployment.
My organizat
[
https://issues.apache.org/jira/browse/FLINK-37421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julian updated FLINK-37421:
---
Description:
I don't see a way to add labels to the Deployment created by the
FlinkDeployment.
My organizat
JunRuiLee merged PR #26244:
URL: https://github.com/apache/flink/pull/26244
--
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.apa
Zakelly commented on code in PR #26245:
URL: https://github.com/apache/flink/pull/26245#discussion_r1980602627
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStMapState.java:
##
@@ -139,6 +140,7 @@ public byte[] serializeValue(UV v
mayuehappy commented on PR #26246:
URL: https://github.com/apache/flink/pull/26246#issuecomment-2699693803
> can this bug be reproduced and a test cabe added?
@nilmadhab @Zakelly Thanks for the reivew. This can be reproduced and I've
add related Unit Test (`testAggregatingStateAddWi
mayuehappy commented on PR #26246:
URL: https://github.com/apache/flink/pull/26246#issuecomment-2699708741
@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
[
https://issues.apache.org/jira/browse/FLINK-37411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932494#comment-17932494
]
Rui Fan commented on FLINK-37411:
-
Thanks [~gyfora] for the quick feedback! :)
{quote}It
leonardBang merged PR #3925:
URL: https://github.com/apache/flink-cdc/pull/3925
--
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-37348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-37348:
---
Fix Version/s: cdc-3.4.0
> [pipeline-paimon]fix paimon ArrayIndexOutOfBoundsException when add colum
[
https://issues.apache.org/jira/browse/FLINK-37348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37348.
Resolution: Fixed
Fixed via master: 8019fd3fc07f3b3d4288347302b65b32860410f5
> [pipeline-paimon]f
[
https://issues.apache.org/jira/browse/FLINK-37265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932480#comment-17932480
]
Hirson Zhang commented on FLINK-37265:
--
Hello, [~reswqa], could you please help me
reswqa merged PR #26242:
URL: https://github.com/apache/flink/pull/26242
--
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-37119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37119.
Resolution: Fixed
Implemented via master: ba282700cc4b481033df5af1591b6307cd9c41f7
> Bump the ver
[
https://issues.apache.org/jira/browse/FLINK-37119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37119:
--
Assignee: Yanquan Lv
> Bump the version of Paimon flink to 1.0.0
> --
leonardBang merged PR #3857:
URL: https://github.com/apache/flink-cdc/pull/3857
--
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-37119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932498#comment-17932498
]
Leonard Xu commented on FLINK-37119:
Hey [~911432], you can find the version mapping
ronghangye created FLINK-37422:
--
Summary: Typo in streaming analytics zh document
Key: FLINK-37422
URL: https://issues.apache.org/jira/browse/FLINK-37422
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-37348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37348:
--
Assignee: MOBIN
> [pipeline-paimon]fix paimon ArrayIndexOutOfBoundsException when add column
[
https://issues.apache.org/jira/browse/FLINK-37119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-37119:
---
Fix Version/s: cdc-3.4.0
> Bump the version of Paimon flink to 1.0.0
> -
ranko-aha opened a new pull request, #26249:
URL: https://github.com/apache/flink/pull/26249
## What is the purpose of the change
Fix a typo in streaming analytics zh document.
Typo here
https://nightlies.apache.org/flink/flink-docs-release-1.20/zh/docs/learn-flink/streaming_analytics/
reswqa merged PR #26241:
URL: https://github.com/apache/flink/pull/26241
--
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-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-35810.
Fix Version/s: 2.1.0
Resolution: Fixed
master(2.1) via 49466aa995861ab529f11936dcf2b5522573
[
https://issues.apache.org/jira/browse/FLINK-37387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932485#comment-17932485
]
Junrui Lee commented on FLINK-37387:
release-2.0 315046b171b13b4e02c0ad1a4e4529305fd
Zakelly opened a new pull request, #26248:
URL: https://github.com/apache/flink/pull/26248
## What is the purpose of the change
Currently, the file-based LRU cache lacks of loading files from the
disaggregated DFS. Meaning that after the job recovery, there will be no cache
available
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932491#comment-17932491
]
Weijie Guo commented on FLINK-33555:
[~dmvk] Could you please take a look at this? T
flinkbot commented on PR #26248:
URL: https://github.com/apache/flink/pull/26248#issuecomment-2699624712
## CI report:
* 4a52cdda3d959825dd714b8359035b36478d00ab UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-37419:
---
Assignee: Yue Ma
> ForStMapState serializeValue may get wrong result
>
[
https://issues.apache.org/jira/browse/FLINK-37119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-37119:
---
Summary: Bump the version of Paimon flink to 1.0.1 (was: Bump the version
of Paimon flink to 1.0.0)
[
https://issues.apache.org/jira/browse/FLINK-37422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37422:
---
Labels: pull-request-available (was: )
> Typo in streaming analytics zh document
>
flinkbot commented on PR #26249:
URL: https://github.com/apache/flink/pull/26249#issuecomment-2699787445
## CI report:
* b05c7a59c1754db8de1f116bcb5a525873db78b7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
101 - 146 of 146 matches
Mail list logo
