snuyanzin commented on PR #25186:
URL: https://github.com/apache/flink/pull/25186#issuecomment-2283234486
Added `[hotfix]` commit making use the fact that `asJsonString` gives
pretty json
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/FLINK-34510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34510:
---
Labels: pull-request-available (was: )
> Flink 2.0: Rename RestoreMode to RecoveryClaimMode
spoon-lz opened a new pull request, #25192:
URL: https://github.com/apache/flink/pull/25192
## What is the purpose of the change
As a subitem of FLIP-406,Rename RestoreMode to RecoveryClaimMode
## Brief change log
Change the `RestoreMode` class name and variable n
reswqa merged PR #25183:
URL: https://github.com/apache/flink/pull/25183
--
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 #25191:
URL: https://github.com/apache/flink/pull/25191#issuecomment-2283226514
## CI report:
* a99b0a0d5a40cea0b916976ab2151e22b4ca6b06 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36035:
---
Labels: pull-request-available (was: )
> Remove zipped dependency files from flink-python
>
gracegrimwood opened a new pull request, #25191:
URL: https://github.com/apache/flink/pull/25191
## What is the purpose of the change
This PR removes the zipped `py4j` and `cloudpickle` dependency files from
the `flink-python` sources, and moves dependency resolution part (alo
flinkbot commented on PR #25190:
URL: https://github.com/apache/flink/pull/25190#issuecomment-2283220170
## CI report:
* 9d546737abc95b34deb6e09d2967a37b2c17e17c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35891.
Resolution: Implemented
master via: 64f996b504fe9b5b250e1806c9b98de8df8bd01d
> Support writing dy
leonardBang merged PR #3499:
URL: https://github.com/apache/flink-cdc/pull/3499
--
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-35891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35891:
---
Fix Version/s: cdc-3.2.0
> Support writing dynamic bucket table of Paimon
> ---
[
https://issues.apache.org/jira/browse/FLINK-35891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35891:
---
Affects Version/s: cdc-3.1.1
(was: cdc-3.2.0)
> Support writing dynamic b
[
https://issues.apache.org/jira/browse/FLINK-35891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35891:
--
Assignee: LvYanquan
> Support writing dynamic bucket table of Paimon
> -
[
https://issues.apache.org/jira/browse/FLINK-35891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35891:
---
Issue Type: Improvement (was: Technical Debt)
> Support writing dynamic bucket table of Paimon
> -
codenohup opened a new pull request, #25190:
URL: https://github.com/apache/flink/pull/25190
master branch PR: https://github.com/apache/flink/pull/25164.
Close the TieredStorageMasterClient when NettyShuffleMaster close.
--
This is an automated message from the Apache Git Service.
leonardBang commented on PR #3499:
URL: https://github.com/apache/flink-cdc/pull/3499#issuecomment-2283215311
Merging... The failed case is not related current PR，I‘ll file a issue
ticket to track it
--
This is an automated message from the Apache Git Service.
To respond to the message, p
[
https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872783#comment-17872783
]
Gyula Fora commented on FLINK-36018:
Based on your proposals how about simply `job.a
leonardBang commented on PR #3524:
URL: https://github.com/apache/flink-cdc/pull/3524#issuecomment-2283204122
@ruanhang1993 @PatrickRen Would you like to take a look this PR when you
have time?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-35984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35984.
Resolution: Fixed
master : 17d21a957a4e73648788c5abe493bf7be6b63a5b
> Job crashes when metadata c
[
https://issues.apache.org/jira/browse/FLINK-35984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35984:
---
Affects Version/s: cdc-3.1.1
> Job crashes when metadata column names present in transform rules
> -
[
https://issues.apache.org/jira/browse/FLINK-35984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35984:
---
Fix Version/s: cdc-3.2.0
> Job crashes when metadata column names present in transform rules
> -
leonardBang merged PR #3528:
URL: https://github.com/apache/flink-cdc/pull/3528
--
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
Grace Grimwood created FLINK-36035:
--
Summary: Remove zipped dependency files from flink-python
Key: FLINK-36035
URL: https://issues.apache.org/jira/browse/FLINK-36035
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-35984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-35984:
--
Assignee: MOBIN
> Job crashes when metadata column names present in transform rules
> ---
snuyanzin commented on PR #25186:
URL: https://github.com/apache/flink/pull/25186#issuecomment-2283199307
@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-34397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872775#comment-17872775
]
Matthias Pohl commented on FLINK-34397:
---
I agree with [~roman]: Currently, it's in
[
https://issues.apache.org/jira/browse/FLINK-36034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-36034:
---
Issue Type: Technical Debt (was: Bug)
> Remove dependencies of Flink table planner in Transform mod
[
https://issues.apache.org/jira/browse/FLINK-36034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872774#comment-17872774
]
Leonard Xu commented on FLINK-36034:
Thanks [~xiqian_yu] , assigned to you!
> Remov
[
https://issues.apache.org/jira/browse/FLINK-36034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36034:
--
Assignee: yux
> Remove dependencies of Flink table planner in Transform module
>
[
https://issues.apache.org/jira/browse/FLINK-27519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872773#comment-17872773
]
lincoln lee commented on FLINK-27519:
-
Some updates: after debugged with code, the n
lvyanquan commented on PR #3499:
URL: https://github.com/apache/flink-cdc/pull/3499#issuecomment-2283159963
The failed case in mysql is unrelated to the change of this pr.
Error message:
```
Caused by: java.lang.IllegalStateException: Invalid assigner status {}
[NEWLY_ADDED_ASSIGNIN
[
https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872769#comment-17872769
]
Rui Fan commented on FLINK-36018:
-
Hey [~gyfora]
{quote}It makes sense to introduce a n
[
https://issues.apache.org/jira/browse/FLINK-36034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872765#comment-17872765
]
yux commented on FLINK-36034:
-
[~Leonard] I'm willing to investigate this.
> Remove depende
yux created FLINK-36034:
---
Summary: Remove dependencies of Flink table planner in Transform
module
Key: FLINK-36034
URL: https://issues.apache.org/jira/browse/FLINK-36034
Project: Flink
Issue Type: Bug
Samrat002 commented on PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#issuecomment-2283081714
@foxus Please review whenever time
--
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
beryllw commented on PR #3490:
URL: https://github.com/apache/flink-cdc/pull/3490#issuecomment-2283075516
```
2024-08-12T03:56:34.3999892Z [WARNING] Tests run: 20, Failures: 0, Errors:
0, Skipped: 1, Time elapsed: 624.39 s - in
org.apache.flink.cdc.connectors.oracle.table.OracleConnector
lvyanquan commented on code in PR #3499:
URL: https://github.com/apache/flink-cdc/pull/3499#discussion_r1713144650
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonHashFunctionTest.java
lvyanquan commented on PR #3499:
URL: https://github.com/apache/flink-cdc/pull/3499#issuecomment-2283065434
Thanks @yuxiqian, addressed your comments.
--
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
PatrickRen merged PR #3523:
URL: https://github.com/apache/flink-cdc/pull/3523
--
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.
yuxiqian commented on code in PR #3499:
URL: https://github.com/apache/flink-cdc/pull/3499#discussion_r1713130419
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonHashFunctionTest.java:
[
https://issues.apache.org/jira/browse/FLINK-35891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35891:
---
Labels: pull-request-available (was: )
> Support writing dynamic bucket table of Paimon
>
yuxiqian commented on code in PR #3499:
URL: https://github.com/apache/flink-cdc/pull/3499#discussion_r1713116670
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DataSink.java:
##
@@ -38,7 +38,8 @@ public interface DataSink {
* Get the {@code HashFunctio
[
https://issues.apache.org/jira/browse/FLINK-34510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872758#comment-17872758
]
Zakelly Lan commented on FLINK-34510:
-
[~spoon-lz] I'd suggest keeping any user opti
[
https://issues.apache.org/jira/browse/FLINK-34510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872755#comment-17872755
]
liuzhuo commented on FLINK-34510:
-
Hi [~zakelly] , I found in the change "[FLINK-34454][
[
https://issues.apache.org/jira/browse/FLINK-35938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35938:
---
Labels: pull-request-available (was: )
> Avoid commit the same datafile again in Paimon Sin
[
https://issues.apache.org/jira/browse/FLINK-35938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35938.
Resolution: Fixed
via master: 3bb1f3ca45e58e4489cc7a03ef928de40895d138
> Avoid commit the same da
leonardBang merged PR #3504:
URL: https://github.com/apache/flink-cdc/pull/3504
--
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-35938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-35938:
---
Issue Type: Bug (was: Technical Debt)
> Avoid commit the same datafile again in Paimon Sink.
>
Junrui Li created FLINK-36033:
-
Summary: FLIP-469: Supports Adaptive Optimization of StreamGraph
Key: FLINK-36033
URL: https://issues.apache.org/jira/browse/FLINK-36033
Project: Flink
Issue Type:
Junrui Li created FLINK-36032:
-
Summary: FLIP-468: Introducing StreamGraph-Based Job Submission
Key: FLINK-36032
URL: https://issues.apache.org/jira/browse/FLINK-36032
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872750#comment-17872750
]
Weijie Guo edited comment on FLINK-33555 at 8/12/24 1:56 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872750#comment-17872750
]
Weijie Guo commented on FLINK-33555:
https://issues.apache.org/jira/browse/FLINK-335
yuxiqian commented on code in PR #3495:
URL: https://github.com/apache/flink-cdc/pull/3495#discussion_r1713104432
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/test/resources/testcontainers.properties:
##
Review Comment:
W
[
https://issues.apache.org/jira/browse/FLINK-36031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36031:
---
Labels: pull-request-available (was: )
> Migrate kubernetes operator metrics from OKHttp In
SamBarker opened a new pull request, #863:
URL: https://github.com/apache/flink-kubernetes-operator/pull/863
## What is the purpose of the change
Migrate to the Fabric8 kubernetes-client interceptor API so that metrics are
captured regardless of which HTTP client is used.
yuxiqian commented on PR #3495:
URL: https://github.com/apache/flink-cdc/pull/3495#issuecomment-2282976584
Hi @proletarians,
Seems license check failed since it detects questionable licenses, which
isn't strictly forbidden to use but requires manual verify and confirmation.
By
Sam Barker created FLINK-36031:
--
Summary: Migrate kubernetes operator metrics from OKHttp
Interceptor API to Fabric8 Interceptor API
Key: FLINK-36031
URL: https://issues.apache.org/jira/browse/FLINK-36031
[
https://issues.apache.org/jira/browse/FLINK-36029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LEE SOMANG updated FLINK-36029:
---
Description:
The current ValueState#value method has the following description
{code:java}
/**
*
github-actions[bot] commented on PR #3036:
URL: https://github.com/apache/flink-cdc/pull/3036#issuecomment-2282934867
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
snuyanzin commented on code in PR #25186:
URL: https://github.com/apache/flink/pull/25186#discussion_r1713084757
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/api/CompiledPlanITCase.java:
##
@@ -83,14 +83,25 @@ void testCompilePlanSql() throws IOExcepti
[
https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872743#comment-17872743
]
Sergey Nuyanzin commented on FLINK-34446:
-
Finally was fixed in Calcite within
[
https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-34446.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> SqlValidatorException with LATERAL TABLE
[
https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872744#comment-17872744
]
Sergey Nuyanzin commented on FLINK-34446:
-
Merged as
[11b1fdfc7cffb74c7515a522b
[
https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-34446:
---
Assignee: Sergey Nuyanzin (was: Jeyhun Karimov)
> SqlValidatorException with LATER
[
https://issues.apache.org/jira/browse/FLINK-34111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-34111.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> Add JSON_QUOTE and JSON_UNQUOTE function
snuyanzin commented on PR #24156:
URL: https://github.com/apache/flink/pull/24156#issuecomment-2282912942
superseded by https://github.com/apache/flink/pull/24967
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
snuyanzin closed pull request #24156: [FLINK-34111][table] Add JSON_QUOTE and
JSON_UNQUOTE function
URL: https://github.com/apache/flink/pull/24156
--
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 th
[
https://issues.apache.org/jira/browse/FLINK-34111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872742#comment-17872742
]
Sergey Nuyanzin commented on FLINK-34111:
-
Merged as
[9457b8792fa285ecd42576a8f
snuyanzin closed pull request #24967: [FLINK-34111][table] Add support for
json_quote, json_unquote, address PR feedback #24156
URL: https://github.com/apache/flink/pull/24967
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
flinkbot commented on PR #25189:
URL: https://github.com/apache/flink/pull/25189#issuecomment-2282894855
## CI report:
* 8c50457a2bc87658b84e21e2027fbf1303fd16aa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36030:
---
Labels: pull-request-available (was: )
> Don't use negative values for changelog recovery t
rkhachatryan opened a new pull request, #25189:
URL: https://github.com/apache/flink/pull/25189
## What is the purpose of the change
FLINK-34030 introduced a new option that allows to explicitly disable
materialization instead of using a negative values.
Negative values might c
Roman Khachatryan created FLINK-36030:
-
Summary: Don't use negative values for changelog recovery tests
Key: FLINK-36030
URL: https://issues.apache.org/jira/browse/FLINK-36030
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan closed FLINK-35576.
-
Resolution: Fixed
Merged into FRocksDB-8.10.0 as ed46268ea99b85370e9a8098be16806860aa620
[
https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872727#comment-17872727
]
Roman Khachatryan commented on FLINK-35576:
---
Thanks [~mayuehappy] !
All the PR
flinkbot commented on PR #25188:
URL: https://github.com/apache/flink/pull/25188#issuecomment-2282728413
## CI report:
* 47bd7375ea1c9920fe04842f85228227bea77105 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
huhuan1898 opened a new pull request, #25188:
URL: https://github.com/apache/flink/pull/25188
## What is the purpose of the change
- Fix typo of json format zh docs
- Fix docs of json format test util class
- Fix some test cases that were not working properly
- Add serializati
lvyanquan commented on PR #3495:
URL: https://github.com/apache/flink-cdc/pull/3495#issuecomment-2282712484
hi @leonardBang, could you please help to
trige CI check?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
SML0127 commented on PR #3529:
URL: https://github.com/apache/flink-cdc/pull/3529#issuecomment-2282685027
All check passed here
(https://github.com/SML0127/flink-cdc-connectors/actions/runs/10334300400)
--
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/FLINK-36027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872664#comment-17872664
]
Leonard Xu commented on FLINK-36027:
Assigned the ticket to you [~seung-min]
> [cd
[
https://issues.apache.org/jira/browse/FLINK-36027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36027:
--
Assignee: Lee SeungMin
> [cdc-connector][MySQL] added metrics numRecordsOut/numRecordsOutRate
81 matches
Mail list logo
