[
https://issues.apache.org/jira/browse/FLINK-37435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933736#comment-17933736
]
Gyula Fora edited comment on FLINK-37435 at 3/10/25 6:53 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-37435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933736#comment-17933736
]
Gyula Fora commented on FLINK-37435:
[~kurto] , since only reading seems to be slowe
Shawn-Hx commented on code in PR #3939:
URL: https://github.com/apache/flink-cdc/pull/3939#discussion_r1986690929
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/TransformParser.java:
##
@@ -642,4 +654,16 @@ private static boolean hasAsterisk(SqlNode sqlNo
shameersss1 commented on PR #26162:
URL: https://github.com/apache/flink/pull/26162#issuecomment-2709581017
Thanks @davidradl for the review.
@JunRuiLee - Could you please point to anyone else who knows this flow and
can do the review ?
--
This is an automated message from the Apa
Shawn-Hx commented on code in PR #3939:
URL: https://github.com/apache/flink-cdc/pull/3939#discussion_r1986683512
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilter.java:
##
@@ -41,11 +42,17 @@ public class TransformFilter impleme
[
https://issues.apache.org/jira/browse/FLINK-37443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nil Madhab updated FLINK-37443:
---
Description:
While following the official
[tutorial|https://nightlies.apache.org/flink/flink-docs-m
[
https://issues.apache.org/jira/browse/FLINK-37439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933726#comment-17933726
]
Zakelly Lan commented on FLINK-37439:
-
Merge into master: 67b02e48 ... c7aa1748
2.0:
Zakelly merged PR #26279:
URL: https://github.com/apache/flink/pull/26279
--
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
Zakelly merged PR #26280:
URL: https://github.com/apache/flink/pull/26280
--
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-37265 ]
Hirson Zhang deleted comment on FLINK-37265:
--
was (Author: JIRAUSER308616):
Hello, [~reswqa], could you please help me review this PR or find the person in
charge of it, thank you very much
beliefer commented on code in PR #26277:
URL: https://github.com/apache/flink/pull/26277#discussion_r1986569781
##
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java:
##
@@ -459,7 +459,8 @@ public static String[] mergeListsToArray(List base,
List append)
[
https://issues.apache.org/jira/browse/FLINK-37435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933714#comment-17933714
]
Kurt Ostfeld commented on FLINK-37435:
--
https://github.com/kurtostfeld/kryo2vs5
I
leonardBang commented on PR #3607:
URL: https://github.com/apache/flink-cdc/pull/3607#issuecomment-2709354142
Hey, @gaoyan1998 We have this plan, we're preparing a FLIP for flink
connector general limit rating, after that Flink CDC pipeline can reuse these
feature via bumping flink version.
ctrlaltdilj commented on PR #848:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/848#issuecomment-2709352804
@gyfora does this approach look better?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/FLINK-36806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933703#comment-17933703
]
ouyangwulin commented on FLINK-36806:
-
Not only does this issue occur with Iceberg w
[
https://issues.apache.org/jira/browse/FLINK-36806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933703#comment-17933703
]
ouyangwulin edited comment on FLINK-36806 at 3/10/25 2:52 AM:
1996fanrui commented on code in PR #26277:
URL: https://github.com/apache/flink/pull/26277#discussion_r1986518663
##
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java:
##
@@ -459,7 +459,8 @@ public static String[] mergeListsToArray(List base,
List append)
dserfe closed pull request #23648: [FLINK-33430] Fix `testSerializerTree` test
failures
URL: https://github.com/apache/flink/pull/23648
--
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 c
gaoyan1998 commented on PR #3607:
URL: https://github.com/apache/flink-cdc/pull/3607#issuecomment-2709265687
@lvyanquan @leonardBang hi, Is the cdc community interested in adding this
new feature? If so, I can continue to work to resolve conflict issues
--
This is an automated message fro
beliefer commented on PR #26278:
URL: https://github.com/apache/flink/pull/26278#issuecomment-2709217021
@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.
beliefer commented on PR #26277:
URL: https://github.com/apache/flink/pull/26277#issuecomment-2709216369
@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-37041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-37041.
Resolution: Fixed
> [Release-2.0] Verify that no exclusions were erroneously added to the
> japi
[
https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933676#comment-17933676
]
lajith commented on FLINK-33634:
As mentioned in the FLIP , we will have status.conditio
beliefer commented on code in PR #26277:
URL: https://github.com/apache/flink/pull/26277#discussion_r1986292983
##
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java:
##
@@ -459,7 +459,10 @@ public static String[] mergeListsToArray(List
base, List append)
flinkbot commented on PR #26277:
URL: https://github.com/apache/flink/pull/26277#issuecomment-2708627520
## CI report:
* dd879967d0088d24704844e7000be570e9d5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia commented on code in PR #26279:
URL: https://github.com/apache/flink/pull/26279#discussion_r1986289976
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackendBuilder.java:
##
@@ -298,6 +298,9 @@ public ForStKeyedS
beliefer commented on code in PR #26273:
URL: https://github.com/apache/flink/pull/26273#discussion_r1986297042
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -2218,7 +2218,9 @@ public static LocalStreamEnvironmen
beliefer commented on code in PR #26273:
URL: https://github.com/apache/flink/pull/26273#discussion_r1986297042
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -2218,7 +2218,9 @@ public static LocalStreamEnvironmen
Zakelly commented on code in PR #26279:
URL: https://github.com/apache/flink/pull/26279#discussion_r1986300643
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackendBuilder.java:
##
@@ -298,6 +298,9 @@ public ForStKeyed
Zakelly opened a new pull request, #26279:
URL: https://github.com/apache/flink/pull/26279
## What is the purpose of the change
ForSt may create LOG files twice with overwrite, however, the ForSt wrapped
file system does not support overwriting files. Exception thrown in this case.
beliefer commented on code in PR #26278:
URL: https://github.com/apache/flink/pull/26278#discussion_r1986283555
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java:
##
@@ -1340,16 +1340,15 @@ private TypeInformation
createTypeInfoFromFactory(
beliefer commented on code in PR #26278:
URL: https://github.com/apache/flink/pull/26278#discussion_r1986281578
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java:
##
@@ -1340,16 +1340,15 @@ private TypeInformation
createTypeInfoFromFactory(
Zakelly opened a new pull request, #26280:
URL: https://github.com/apache/flink/pull/26280
## What is the purpose of the change
ForSt may create LOG files twice with overwrite, however, the ForSt wrapped
file system does not support overwriting files. Exception thrown in this case.
davidradl commented on code in PR #26277:
URL: https://github.com/apache/flink/pull/26277#discussion_r1986265859
##
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java:
##
@@ -459,7 +459,10 @@ public static String[] mergeListsToArray(List
base, List append)
flinkbot commented on PR #26280:
URL: https://github.com/apache/flink/pull/26280#issuecomment-2708764905
## CI report:
* 2da30b7ae1a862060a88e40acdda3f9decfe06cc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
davidradl commented on code in PR #26273:
URL: https://github.com/apache/flink/pull/26273#discussion_r1986268403
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java:
##
@@ -2218,7 +2218,9 @@ public static LocalStreamEnvironme
davidradl commented on code in PR #26277:
URL: https://github.com/apache/flink/pull/26277#discussion_r1986265859
##
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java:
##
@@ -459,7 +459,10 @@ public static String[] mergeListsToArray(List
base, List append)
flinkbot commented on PR #26279:
URL: https://github.com/apache/flink/pull/26279#issuecomment-2708759120
## CI report:
* ddb7148c393607a5569d4bd7b0d6052915d0445e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
davidradl commented on code in PR #26278:
URL: https://github.com/apache/flink/pull/26278#discussion_r1986262779
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java:
##
@@ -1340,16 +1340,15 @@ private TypeInformation
createTypeInfoFromFactory(
[
https://issues.apache.org/jira/browse/FLINK-37439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37439:
---
Labels: pull-request-available (was: )
> Missing file creation with overwrite semantic in F
davidradl commented on code in PR #26278:
URL: https://github.com/apache/flink/pull/26278#discussion_r1986262779
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java:
##
@@ -1340,16 +1340,15 @@ private TypeInformation
createTypeInfoFromFactory(
suez1224 commented on code in PR #155:
URL:
https://github.com/apache/flink-connector-kafka/pull/155#discussion_r1986246516
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/enumerator/subscriber/KafkaSubscriberUtils.java:
##
@@ -57,12 +65,42 @@ sta
42 matches
Mail list logo
