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`
Zakelly merged PR #26237:
URL: https://github.com/apache/flink/pull/26237
--
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
[
https://issues.apache.org/jira/browse/FLINK-37379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932290#comment-17932290
]
Zakelly Lan commented on FLINK-37379:
-
Merged into master :
9f5f13ba9d4f1175d06ccc9
Zakelly merged PR #24247:
URL: https://github.com/apache/flink/pull/24247
--
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
[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-33734.
-
Fix Version/s: 2.1.0
Resolution: Fixed
> Merge unaligned checkpoint state handle
> --
[
https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932293#comment-17932293
]
Zakelly Lan commented on FLINK-33734:
-
Merged into master via be91c9f2...0d1b5aa1
>
Zakelly commented on code in PR #26202:
URL: https://github.com/apache/flink/pull/26202#discussion_r1979288504
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackendBuilder.java:
##
@@ -259,10 +259,14 @@ public ForStKey
[
https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-3154.
-
Fix Version/s: 2.1.0
Resolution: Fixed
merged:
master - ef09e1716924d1e6ed64bfc273859f2de979b027
r
gyfora merged PR #26243:
URL: https://github.com/apache/flink/pull/26243
--
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
flinkbot commented on PR #26246:
URL: https://github.com/apache/flink/pull/26246#issuecomment-2697640544
## CI report:
* 9d20743a1e0f52e33b75eb0ffac46fdd0cd0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
afedulov closed pull request #135: Bump org.apache.zookeeper:zookeeper from
3.5.10 to 3.7.2 in /flink-shaded-zookeeper-parent/flink-shaded-zookeeper-35
URL: https://github.com/apache/flink-shaded/pull/135
--
This is an automated message from the Apache Git Service.
To respond to the message,
dependabot[bot] commented on PR #134:
URL: https://github.com/apache/flink-shaded/pull/134#issuecomment-2697460996
OK, I won't notify you again about this release, but will get in touch when
a new version is available. If you'd rather skip all updates until the next
major or minor version,
dependabot[bot] commented on PR #135:
URL: https://github.com/apache/flink-shaded/pull/135#issuecomment-2697458845
OK, I won't notify you again about this release, but will get in touch when
a new version is available. If you'd rather skip all updates until the next
major or minor version,
afedulov commented on PR #134:
URL: https://github.com/apache/flink-shaded/pull/134#issuecomment-2697460863
Already on 3.8.4
https://github.com/apache/flink-shaded/commit/ed2ec9a73cd416014214801e81ba7f626946a65d
--
This is an automated message from the Apache Git Service.
To respond to
afedulov closed pull request #134: Bump org.apache.zookeeper:zookeeper from
3.6.4 to 3.7.2 in /flink-shaded-zookeeper-parent/flink-shaded-zookeeper-36
URL: https://github.com/apache/flink-shaded/pull/134
--
This is an automated message from the Apache Git Service.
To respond to the message, p
trompa commented on PR #133:
URL:
https://github.com/apache/flink-connector-kafka/pull/133#issuecomment-2698004133
TBH, I think the code is just about adding a missing wrapper on the position
call to make it consistent with the rest of the usages on the file, but didnt
liked to create a PR
fapaul commented on PR #133:
URL:
https://github.com/apache/flink-connector-kafka/pull/133#issuecomment-2698041282
> I never liked it much, But I was not able to deterministically make it
throw within a thread.
Any help is welcome.
I agree with that the current code structure make
nilmadhab commented on PR #26246:
URL: https://github.com/apache/flink/pull/26246#issuecomment-2697956609
can this bug be reproduced and a test case be added?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
[
https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932348#comment-17932348
]
Nishita Pattanayak edited comment on FLINK-35145 at 3/4/25 3:17 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932348#comment-17932348
]
Nishita Pattanayak commented on FLINK-35145:
Is this being worked upon? I wo
[
https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932348#comment-17932348
]
Nishita Pattanayak edited comment on FLINK-35145 at 3/4/25 3:18 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-27641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932349#comment-17932349
]
Grzegorz Kołakowski commented on FLINK-27641:
-
For missing *PROCTIME* attrib
[
https://issues.apache.org/jira/browse/FLINK-37418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob updated FLINK-37418:
--
Description:
Test RowData's arity is 10. the 5th column is an array structure. then I called
rowData.
afedulov commented on PR #135:
URL: https://github.com/apache/flink-shaded/pull/135#issuecomment-2697458788
Already on 3.8.4
https://github.com/apache/flink-shaded/commit/ed2ec9a73cd416014214801e81ba7f626946a65d
--
This is an automated message from the Apache Git Service.
To respond to
flinkbot commented on PR #26245:
URL: https://github.com/apache/flink/pull/26245#issuecomment-2697544462
## CI report:
* cf25f30b4e18a217c953b1814d30399e1e2a9573 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
]
ASF GitHub Bot updated FLINK-37419:
---
Labels: pull-request-available (was: )
> ForStMapState serializeValue may get wrong result
mayuehappy opened a new pull request, #26245:
URL: https://github.com/apache/flink/pull/26245
…et wrong result
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we av
hlteoh37 commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1979552202
##
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_r1979565026
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java:
#
pchoudhury22 commented on PR #952:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/952#issuecomment-2697507125
There is another evaluated metric, EXPECTED_PROCESSING_RATE, which gets
computed at JobVertexScaler.computeScaleTargetParallelism .
Since we calculate this first a
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1979566056
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReader.java:
#
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1979569780
##
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_r1979571088
##
flink-connector-aws/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReaderTest.java:
#
Zakelly commented on PR #25837:
URL: https://github.com/apache/flink/pull/25837#issuecomment-2697453076
@hejufang Sure. Sorry for the late response. I'm busy preparing the Flink
2.0.0 release. It's on a pretty tight schedule and may take few more days. I'll
check this after the release.
mayuehappy opened a new pull request, #26246:
URL: https://github.com/apache/flink/pull/26246
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
fdc-ntflx commented on PR #26204:
URL: https://github.com/apache/flink/pull/26204#issuecomment-2697766555
Thanks for the review, everyone! I got caught up with work and wasn't able
to address the comments before the PR was merged. I agree that more unit tests
could have been added, but I fe
[
https://issues.apache.org/jira/browse/FLINK-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932333#comment-17932333
]
Seung Eun Choi commented on FLINK-8929:
---
In my case, it was OOM Killed in K8S.
> "
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
Spongebob created FLINK-37418:
-
Summary: caugth array out of index exception while using
RowData.getArray method
Key: FLINK-37418
URL: https://issues.apache.org/jira/browse/FLINK-37418
Project: Flink
pnowojski commented on code in PR #154:
URL:
https://github.com/apache/flink-connector-kafka/pull/154#discussion_r1979381461
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionAbortStrategyImpl.java:
##
@@ -107,6 +119,64 @@ private
Yue Ma created FLINK-37419:
--
Summary: ForStMapState serializeValue may get wrong result
Key: FLINK-37419
URL: https://issues.apache.org/jira/browse/FLINK-37419
Project: Flink
Issue Type: Bug
Yue Ma created FLINK-37420:
--
Summary: AbstractAggregatingState add may return wrong result
Key: FLINK-37420
URL: https://issues.apache.org/jira/browse/FLINK-37420
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-37420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37420:
---
Labels: pull-request-available (was: )
> AbstractAggregatingState add may return wrong resu
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1979887307
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed to
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1979991125
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed to
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1979991560
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/utils/KuduSplitGenerator.java:
##
@@ -0,0 +1,109 @@
+/*
+ * Licensed to the Ap
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1979989809
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed to
KevDi commented on PR #75:
URL:
https://github.com/apache/flink-connector-jdbc/pull/75#issuecomment-2698552638
Ok but how should the connection leak beeing fixed then?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1979568486
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/config/DynamodbStreamsSourceConfigConstants.java:
##
hlteoh37 commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1979590842
##
flink-connector-aws/flink-connector-dynamodb/src/test/java/org/apache/flink/connector/dynamodb/source/reader/PollingDynamoDbStreamsShardSplitReaderTest.java:
###
autophagy opened a new pull request, #26247:
URL: https://github.com/apache/flink/pull/26247
## What is the purpose of the change
Currently, the Java APIs use annotations like `@PublicEvolving` and
`@Experimental` to clearly indicate the stability status of API components.
This is su
martongreber commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1979988711
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed to
gguptp commented on code in PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#discussion_r1980023788
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/config/DynamodbStreamsSourceConfigConstants.java:
##
gguptp commented on PR #190:
URL:
https://github.com/apache/flink-connector-aws/pull/190#issuecomment-2698575556
> Added some questions. Thanks @gguptp
Thanks @hlteoh37 . I have updated the PR with the requested changes
--
This is an automated message from the Apache Git Service.
T
ferenc-csaky commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1979790813
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-37421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932440#comment-17932440
]
Yaroslav Tkachenko commented on FLINK-37421:
[~jklaw90] you can add labels a
ferenc-csaky commented on code in PR #8:
URL:
https://github.com/apache/flink-connector-kudu/pull/8#discussion_r1979799806
##
flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumerator.java:
##
@@ -0,0 +1,264 @@
+/*
+ * Licensed to
Zakelly commented on PR #26246:
URL: https://github.com/apache/flink/pull/26246#issuecomment-2698399338
I know it's easy to add UT covering this alone, but it would be great if
implementing a mocked `StateRequestHandler` and verifying those methods of
'abstract' classes via that.
--
This
[
https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-3154:
---
Assignee: Kurt Ostfeld
> Update Kryo version from 2.24.0 to latest Kryo LTS version
> --
albert597 commented on PR #25410:
URL: https://github.com/apache/flink/pull/25410#issuecomment-2699957640
Hey thanks for working on this - just checking in if we can merge this soon?
This bug is causing very annoying bugs on our side and I think others are
facing the same issue.
--
This
[
https://issues.apache.org/jira/browse/FLINK-37418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Spongebob closed FLINK-37418.
-
Resolution: Not A Problem
> caugth array out of index exception while using RowData.getArray method
> --
MOBIN-F commented on code in PR #3791:
URL: https://github.com/apache/flink-cdc/pull/3791#discussion_r1980832960
##
docs/content/docs/connectors/pipeline-connectors/kafka.md:
##
@@ -202,79 +266,100 @@ An output example is:
Data Type Mapping
+[Literal
type](
MOBIN-F commented on PR #3791:
URL: https://github.com/apache/flink-cdc/pull/3791#issuecomment-2700090679
> Thanks @MOBIN-F for this update. Overall, This modification is good for
me, left some comments about the code structure.
>
> Additionally, you can manually test the data types i
[
https://issues.apache.org/jira/browse/FLINK-37302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37302:
---
Labels: pull-request-available (was: )
> Support timers in PTFs
> --
>
1 - 100 of 146 matches
Mail list logo
