davidradl commented on PR #26075:
URL: https://github.com/apache/flink/pull/26075#issuecomment-2613053101
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
Zakelly Lan created FLINK-37222:
---
Summary: Table planner exception when sql client submit job
Key: FLINK-37222
URL: https://issues.apache.org/jira/browse/FLINK-37222
Project: Flink
Issue Type:
davidradl commented on PR #26040:
URL: https://github.com/apache/flink/pull/26040#issuecomment-2612994754
Reviewed by Chi on 23/01/2025 Need a committer to review. Requested minor
change has been made.
--
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot commented on PR #26078:
URL: https://github.com/apache/flink/pull/26078#issuecomment-2612994089
## CI report:
* 882ddcbbe3e4c3492903a35f4c4845eb4775ff54 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
davidradl commented on PR #26058:
URL: https://github.com/apache/flink/pull/26058#issuecomment-2613013814
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916796#comment-17916796
]
Zakelly Lan commented on FLINK-37222:
-
[~dwysakowicz] [~twalthr] Would you please ta
davidradl commented on PR #26048:
URL: https://github.com/apache/flink/pull/26048#issuecomment-2613005954
Reviewed by Chi on 23/01/2025 Need a committer to review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-37222:
Attachment: flink-root-sql-client-master-1-1.c-76646bdbb8bdab89.log
> Table planner exception when
sharath1709 commented on PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#issuecomment-2613385337
That sounds great, let me remove the test. I'm not the expert on this
situation either and ChatGPT originally suggested starting and stopping the
container to simulat
davidradl commented on PR #26047:
URL: https://github.com/apache/flink/pull/26047#issuecomment-2613004071
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
davidradl commented on PR #26064:
URL: https://github.com/apache/flink/pull/26064#issuecomment-2613023525
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
davidradl commented on PR #26062:
URL: https://github.com/apache/flink/pull/26062#issuecomment-2613021765
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/FLINK-37220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-37220:
--
Affects Version/s: 2.0-preview
1.19.1
1.20.0
> G
davidradl commented on PR #26055:
URL: https://github.com/apache/flink/pull/26055#issuecomment-2613010175
I have suggested that #26022 may not be required in the review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
davidradl commented on PR #26055:
URL: https://github.com/apache/flink/pull/26055#issuecomment-2613010680
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
davidradl commented on PR #26060:
URL: https://github.com/apache/flink/pull/26060#issuecomment-2613019399
this looks like a back port to 1.19 - please add that to the title - I see
titles with BP 1.19 and description
Reviewed by Chi on 23/01/2025 Go back to the submitter with review c
JoeryH commented on PR #26029:
URL: https://github.com/apache/flink/pull/26029#issuecomment-2613008820
@davidradl Thanks for looking at my PR. I'll add some sort of unit test
tomorrow, if you have anything specific in mind, please let me know.
On the documentation I wholeheartedly agr
davidradl commented on PR #26059:
URL: https://github.com/apache/flink/pull/26059#issuecomment-2613017174
this looks like a back port to 1.19 - please add that to the title - I see
titles with BP 1.19 and description
Reviewed by Chi on 23/01/2025 Go back to the submitter with review c
davidradl commented on code in PR #26073:
URL: https://github.com/apache/flink/pull/26073#discussion_r1929019154
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -619,6 +619,65 @@ After execution, SQL Client will print the cluster id on
the terminal. The scrip
Attention When
[
https://issues.apache.org/jira/browse/FLINK-37200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916657#comment-17916657
]
qinghuan wang commented on FLINK-37200:
---
hi, are you working on it? if not, I w
potterhe commented on PR #3093:
URL: https://github.com/apache/flink-cdc/pull/3093#issuecomment-2612143404
> Is there any information on how to use this? It seems to be part of the
3.2.0 release but I couldn't find any documentation for it.
https://nightlies.apache.org/flink/flink-cd
snuyanzin commented on code in PR #26076:
URL: https://github.com/apache/flink/pull/26076#discussion_r1928574617
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/test/program/TableTestProgram.java:
##
@@ -177,6 +177,14 @@ public List getSetupFunctionTestS
snuyanzin commented on code in PR #26076:
URL: https://github.com/apache/flink/pull/26076#discussion_r1928588289
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/SystemTypeInference.java:
##
@@ -135,6 +142,25 @@ private static void checkRese
flinkbot commented on PR #26076:
URL: https://github.com/apache/flink/pull/26076#issuecomment-2612248449
## CI report:
* 799d81532fc4c2f752e97b8aeef09b5007f96f5d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-37208.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> Properly notify a new key is selected for async
flinkbot commented on PR #26075:
URL: https://github.com/apache/flink/pull/26075#issuecomment-2612248209
## CI report:
* 1c6dbc8dc91a437006740a98cf216db21dd6d86e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916725#comment-17916725
]
Zakelly Lan commented on FLINK-37208:
-
1.20: 6a5fab8036f534409d774e8724f2cd01ca5d24f
davidradl commented on PR #26075:
URL: https://github.com/apache/flink/pull/26075#issuecomment-2613052759
CI failing for spotless
--
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 comm
davidradl commented on code in PR #26075:
URL: https://github.com/apache/flink/pull/26075#discussion_r1929021562
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##
@@ -554,6 +554,16 @@ public class ExecutionConfigO
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luís Costa updated FLINK-37193:
---
Description:
Greetings team,
I'm using flink-operator v1.7.0.
After performed somes changes on CR F
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luís Costa updated FLINK-37193:
---
Affects Version/s: 1.8.0
> [flink-operator] Ingress recreated after perform a change to CR
> FlinkD
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luís Costa updated FLINK-37193:
---
Description:
Greetings team,
I'm using flink-operator v1.8.0.
After performed somes changes on CR F
[
https://issues.apache.org/jira/browse/FLINK-37193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luís Costa updated FLINK-37193:
---
Affects Version/s: (was: 1.8.0)
> [flink-operator] Ingress recreated after perform a change to C
sehajsandhu123 commented on PR #26037:
URL: https://github.com/apache/flink/pull/26037#issuecomment-2613073546
@davidradl
The reason for tolerating strings is that
ConfigurationParserUtils.loadAndModifyConfiguration inherently processes all
YAML configuration values as strings due to ho
davidradl commented on PR #26039:
URL: https://github.com/apache/flink/pull/26039#issuecomment-2612984291
Reviewed by Chi on 23/01/2025 Approve - looking for committer to merge
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
davidradl commented on code in PR #26075:
URL: https://github.com/apache/flink/pull/26075#discussion_r1929023525
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##
@@ -554,6 +554,16 @@ public class ExecutionConfigO
[
https://issues.apache.org/jira/browse/FLINK-36866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-36866.
---
Resolution: Fixed
> Support more CDC YAML numeric casting paths
> --
[
https://issues.apache.org/jira/browse/FLINK-36900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mika Naylor updated FLINK-36900:
Priority: Minor (was: Major)
> Migrate away from Anaconda for managing Python environments for Fl
ChaomingZhangCN commented on PR #3892:
URL: https://github.com/apache/flink-cdc/pull/3892#issuecomment-2612016169
@huyuanfeng2018 This PR looks good, renaming `findNotFoundTable` to
`extractNotFoundTableId` seems better.
--
This is an automated message from the Apache Git Service.
To resp
[
https://issues.apache.org/jira/browse/FLINK-36852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang reassigned FLINK-36852:
-
Assignee: Yanquan Lv
> Avoid StackOverflowError in Paimon Pipeline sink
> -
[
https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang closed FLINK-34595.
-
Resolution: Fixed
> Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils
> ---
[
https://issues.apache.org/jira/browse/FLINK-36549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-36549:
--
Assignee: (was: Yu Xiao)
> Using the ignore-parse-errors parameter in Debezium/Canal/Maxw
[
https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916644#comment-17916644
]
Ruan Hang commented on FLINK-34595:
---
[~kunni] This has been fixed via
master(26eb6a99
[
https://issues.apache.org/jira/browse/FLINK-34595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang updated FLINK-34595:
--
Affects Version/s: cdc-3.2.1
> Fix ClassNotFoundException: com.ververica.cdc.common.utils.StringUtils
[
https://issues.apache.org/jira/browse/FLINK-36549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-36549:
--
Assignee: Yu Xiao
> Using the ignore-parse-errors parameter in Debezium/Canal/Maxwell/Ogg JSO
flinkbot commented on PR #26073:
URL: https://github.com/apache/flink/pull/26073#issuecomment-2612038902
## CI report:
* 4158587fbfc2147778ac85ef8ec95a95fb3e9f02 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fsk119 merged PR #26050:
URL: https://github.com/apache/flink/pull/26050
--
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-37138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-37138.
-
Resolution: Fixed
> testDeployScriptViaSqlClient failed on AZP
> ---
davidradl commented on code in PR #26008:
URL: https://github.com/apache/flink/pull/26008#discussion_r1928944185
##
flink-python/setup.py:
##
@@ -318,7 +318,7 @@ def extracted_output_files(base_dir, file_path,
output_directory):
install_requires = ['py4j==0.10.9.7', 'pyt
davidradl commented on PR #26008:
URL: https://github.com/apache/flink/pull/26008#issuecomment-2612923867
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
davidradl commented on PR #25999:
URL: https://github.com/apache/flink/pull/25999#issuecomment-2612860451
Reviewed by Chi on 23/01/2025 Need a committer to review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
davidradl commented on PR #25997:
URL: https://github.com/apache/flink/pull/25997#issuecomment-2612858746
Reviewed by Chi on 23/01/2025 Need a committer to review. From the WebUI area
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/FLINK-37214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-37214.
---
Fix Version/s: 2.0.0
Resolution: Fixed
master:
[3b7d3d6e513a94f504423fa1d4dcdb3b77ad
XComp merged PR #26066:
URL: https://github.com/apache/flink/pull/26066
--
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.
davidradl commented on PR #26000:
URL: https://github.com/apache/flink/pull/26000#issuecomment-2612874649
Reviewed by Chi on 23/01/2025 Need a committer to review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[ https://issues.apache.org/jira/browse/FLINK-37214 ]
Matthias Pohl deleted comment on FLINK-37214:
---
was (Author: mapohl):
master:
[3b7d3d6e513a94f504423fa1d4dcdb3b77adf273|https://github.com/apache/flink/commit/3b7d3d6e513a94f504423fa1d4dcdb
davidradl commented on PR #26003:
URL: https://github.com/apache/flink/pull/26003#issuecomment-2612877680
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/FLINK-37215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-37215.
---
Fix Version/s: 2.0.0
Resolution: Fixed
master:
[3b7d3d6e513a94f504423fa1d4dcdb3b77ad
[
https://issues.apache.org/jira/browse/FLINK-37214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reopened FLINK-37214:
---
> Refactor TaskSlotTableImplTest away from using the test thread as the main
> thread
> ---
[
https://issues.apache.org/jira/browse/FLINK-37214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-37214:
--
Fix Version/s: (was: 2.0.0)
> Refactor TaskSlotTableImplTest away from using the test thre
[
https://issues.apache.org/jira/browse/FLINK-37218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee closed FLINK-37218.
--
Fix Version/s: 2.0.0
2.1.0
Resolution: Fixed
master 8b6a608490322d7eb1056120
Matthias Pohl created FLINK-37220:
-
Summary: GuavaRateLimiter creates an ExecutorService without
shutting it down properly leaking threads
Key: FLINK-37220
URL: https://issues.apache.org/jira/browse/FLINK-37220
JunRuiLee opened a new pull request, #26078:
URL: https://github.com/apache/flink/pull/26078
mina-asham commented on PR #26008:
URL: https://github.com/apache/flink/pull/26008#issuecomment-2612937573
> Reviewed by Chi on 23/01/2025 Go back to the submitter with review
comments.
@davidradl thanks for reviewing, responded and re-requested review.
--
This is an automated mess
mina-asham commented on code in PR #26008:
URL: https://github.com/apache/flink/pull/26008#discussion_r1928952489
##
flink-python/setup.py:
##
@@ -318,7 +318,7 @@ def extracted_output_files(base_dir, file_path,
output_directory):
install_requires = ['py4j==0.10.9.7', 'py
davidradl commented on code in PR #26013:
URL: https://github.com/apache/flink/pull/26013#discussion_r1928963713
##
docs/content.zh/docs/dev/datastream/sinks.md:
##
@@ -0,0 +1,122 @@
+---
+title: "Data Sinks"
+weight: 12
+type: docs
+aliases:
+ - /dev/stream/sinks.html
+---
+
+
gustavodemorais commented on PR #26055:
URL: https://github.com/apache/flink/pull/26055#issuecomment-2612678688
Thanks 👍 let's first wait https://github.com/apache/flink/pull/26022 to be
merged
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
XComp commented on PR #26066:
URL: https://github.com/apache/flink/pull/26066#issuecomment-2612671984
@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.
To
dawidwys commented on PR #26065:
URL: https://github.com/apache/flink/pull/26065#issuecomment-2612662959
@autophagy Have you seen the CI failure?
--
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 t
gustavodemorais commented on code in PR #26022:
URL: https://github.com/apache/flink/pull/26022#discussion_r1928799919
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Expressions.java:
##
@@ -861,9 +862,13 @@ public static ApiExpression withoutColumn
gustavodemorais commented on code in PR #26022:
URL: https://github.com/apache/flink/pull/26022#discussion_r1928817518
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -2819,6 +2819,15 @@ ANY, and(logical(Log
[
https://issues.apache.org/jira/browse/FLINK-36782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916686#comment-17916686
]
qinghuan wang commented on FLINK-36782:
---
[~calelinflink] hi, I create a PR to fix.
wangqinghuan opened a new pull request, #26077:
URL: https://github.com/apache/flink/pull/26077
(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 unsubscribe,
flinkbot commented on PR #26077:
URL: https://github.com/apache/flink/pull/26077#issuecomment-2612298085
## CI report:
* 654de985999ec1778d7c8e2d6287c36399a9bc0a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
twalthr commented on code in PR #26076:
URL: https://github.com/apache/flink/pull/26076#discussion_r1928537953
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/SystemTypeInference.java:
##
@@ -57,10 +56,15 @@
@Internal
public class SystemT
[
https://issues.apache.org/jira/browse/FLINK-37138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916653#comment-17916653
]
Shengkai Fang commented on FLINK-37138:
---
Merged at:
release-2.0: 19e868f10ae4994d
libenchao commented on code in PR #25919:
URL: https://github.com/apache/flink/pull/25919#discussion_r1928378346
##
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java:
##
@@ -214,6 +215,7 @@ public void deserialize(@Nul
[
https://issues.apache.org/jira/browse/FLINK-37213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37213:
---
Labels: pull-request-available (was: )
> Improve performance of unbounded OVER aggregations
[
https://issues.apache.org/jira/browse/FLINK-37180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37180:
---
Labels: pull-request-available (was: )
> Implement StreamOperator for PTF
> ---
davidradl commented on PR #26022:
URL: https://github.com/apache/flink/pull/26022#issuecomment-2612963787
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
davidradl commented on PR #26021:
URL: https://github.com/apache/flink/pull/26021#issuecomment-2612962887
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
davidradl commented on code in PR #26021:
URL: https://github.com/apache/flink/pull/26021#discussion_r1928968943
##
docs/content/docs/dev/datastream/operators/full_window_partition.md:
##
@@ -98,7 +98,7 @@ An example is as follows:
```java
DataStream> dataStream = //...
Parti
davidradl commented on PR #26020:
URL: https://github.com/apache/flink/pull/26020#issuecomment-2612960505
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
CI failing
--
This is an automated message from the Apache Git Service.
To respond to the message, please
davidradl commented on PR #26013:
URL: https://github.com/apache/flink/pull/26013#issuecomment-2612958949
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
davidradl commented on PR #26029:
URL: https://github.com/apache/flink/pull/26029#issuecomment-2612969745
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
Ben Brandt created FLINK-37221:
--
Summary: Apply FLIP-406 to Kubernetes Operator
Key: FLINK-37221
URL: https://issues.apache.org/jira/browse/FLINK-37221
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-37221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ben Brandt updated FLINK-37221:
---
Description:
References:
* FLINK-34482 Rename options for checkpointing - ASF JIRA
* [FLINK-34482[
[
https://issues.apache.org/jira/browse/FLINK-37221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ben Brandt updated FLINK-37221:
---
Description:
References:
* FLINK-34482 Rename options for checkpointing - ASF JIRA
* [FLINK-34482[
[
https://issues.apache.org/jira/browse/FLINK-37221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ben Brandt updated FLINK-37221:
---
Description:
References:
* FLINK-34482 Rename options for checkpointing - ASF JIRA
* [FLINK-34482[
davidradl commented on PR #26037:
URL: https://github.com/apache/flink/pull/26037#issuecomment-2612980628
Reviewed by Chi on 23/01/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
nacisimsek commented on PR #26020:
URL: https://github.com/apache/flink/pull/26020#issuecomment-2612988506
@davidradl @JunRuiLee A Correction on the requested line 170 of the Chinese
version has been made. An overall check was also performed. No occurrences were
spotted. Please review the c
JunRuiLee merged PR #26020:
URL: https://github.com/apache/flink/pull/26020
--
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
JunRuiLee opened a new pull request, #26079:
URL: https://github.com/apache/flink/pull/26079
Reverts apache/flink#26020
--
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 u
JunRuiLee merged PR #26079:
URL: https://github.com/apache/flink/pull/26079
--
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
lvyanquan commented on PR #3891:
URL: https://github.com/apache/flink-cdc/pull/3891#issuecomment-2613819620
Please update the doc of [Elasticsearch Pipeline
Connector](https://nightlies.apache.org/flink/flink-cdc-docs-release-3.3/docs/connectors/pipeline-connectors/elasticsearch/#pipeline-co
Yanquan Lv created FLINK-37223:
--
Summary: Add the missing content of MySQL CDC to the Chinese
document.
Key: FLINK-37223
URL: https://issues.apache.org/jira/browse/FLINK-37223
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-37223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17916896#comment-17916896
]
Yanquan Lv commented on FLINK-37223:
Please assign to me, I'm willing to take this.
[
https://issues.apache.org/jira/browse/FLINK-37154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37154:
---
Labels: pull-request-available (was: )
> Support reading binary data from Kafka in Python D
lvyanquan opened a new pull request, #3894:
URL: https://github.com/apache/flink-cdc/pull/3894
Align with the doc in English.
--
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.
christeoh opened a new pull request, #26080:
URL: https://github.com/apache/flink/pull/26080
## What is the purpose of the change
This pull request enables PyFlink to consume Byte arrays from Kafka enabling
consumption of binary formatted data. It is intended to be used similar to the
1 - 100 of 118 matches
Mail list logo
