[jira] [Commented] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-19 Thread Tongtong Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798478#comment-17798478 ] Tongtong Zhu commented on FLINK-33588: -- [~jingge] Yes I can use a Flink Job to test

Re: [PR] [FLINK-33877][streaming] Fix unstable test of CollectSinkFunctionTest.testConfiguredPortIsUsed [flink]

2023-12-19 Thread via GitHub
JingGe commented on code in PR #23955: URL: https://github.com/apache/flink/pull/23955#discussion_r1431057649 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java: ## @@ -129,18 +129,19 @@ void testInvalidVersion() t

Re: [PR] [FLINK-33877][streaming] Fix unstable test of CollectSinkFunctionTest.testConfiguredPortIsUsed [flink]

2023-12-19 Thread via GitHub
Jiabao-Sun commented on code in PR #23955: URL: https://github.com/apache/flink/pull/23955#discussion_r1431064368 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java: ## @@ -129,18 +129,19 @@ void testInvalidVersion

[jira] [Updated] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2023-12-19 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Hamdy updated FLINK-27756: Labels: test-stability (was: pull-request-available stale-assigned test-stability) > Fix intermi

Re: [PR] [FLINK-33872] Retrieve checkpoint history for jobs in completed state [flink]

2023-12-19 Thread via GitHub
hlteoh37 commented on PR #23949: URL: https://github.com/apache/flink/pull/23949#issuecomment-1862406620 Ah... Yes it worked locally but not on CI because I didn't add a wait for future to complete 😅 -- This is an automated message from the Apache Git Service. To respond to the message, p

Re: [PR] [FLINK-33872] Retrieve checkpoint history for jobs in completed state [flink]

2023-12-19 Thread via GitHub
hlteoh37 commented on code in PR #23949: URL: https://github.com/apache/flink/pull/23949#discussion_r1431138471 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java: ## @@ -683,6 +685,129 @@ public void testRetrieveCheckpointStats() throws Exce

Re: [PR] [FLINK-33872] Retrieve checkpoint history for jobs in completed state [flink]

2023-12-19 Thread via GitHub
hlteoh37 commented on code in PR #23949: URL: https://github.com/apache/flink/pull/23949#discussion_r1431138471 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java: ## @@ -683,6 +685,129 @@ public void testRetrieveCheckpointStats() throws Exce

Re: [PR] [FLINK-21949][table] Support ARRAY_AGG aggregate function [flink]

2023-12-19 Thread via GitHub
Jiabao-Sun commented on PR #23411: URL: https://github.com/apache/flink/pull/23411#issuecomment-1862451170 Hi @snuyanzin, could you help take a look again when you have time? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Created] (FLINK-33879) Hybrid Shuffle may hang during redistribution

2023-12-19 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-33879: - Summary: Hybrid Shuffle may hang during redistribution Key: FLINK-33879 URL: https://issues.apache.org/jira/browse/FLINK-33879 Project: Flink Issue Type: Bug

Re: [PR] [FLINK-33823] Make PlannerQueryOperation SQL serializable [flink]

2023-12-19 Thread via GitHub
dawidwys commented on code in PR #23948: URL: https://github.com/apache/flink/pull/23948#discussion_r1431202601 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/PlannerQueryOperation.java: ## @@ -72,6 +75,13 @@ public String asSummaryStr

[PR] [WIP][FLINK-33879] Avoids the potential hang of Hybrid Shuffle during redistribution [flink]

2023-12-19 Thread via GitHub
jiangxin369 opened a new pull request, #23957: URL: https://github.com/apache/flink/pull/23957 ## What is the purpose of the change This PR is to avoid the potential hang of Hybrid Shuffle during redistribution. The details about how a hang happens, please see [issue](https:/

[jira] [Updated] (FLINK-33879) Hybrid Shuffle may hang during redistribution

2023-12-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33879: --- Labels: pull-request-available (was: ) > Hybrid Shuffle may hang during redistribution > --

Re: [PR] [WIP][FLINK-33879] Avoids the potential hang of Hybrid Shuffle during redistribution [flink]

2023-12-19 Thread via GitHub
flinkbot commented on PR #23957: URL: https://github.com/apache/flink/pull/23957#issuecomment-1862513954 ## CI report: * f75788c6a7d2ae6591420915e74239d1e41246cd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [docs] Fix a few docs mistakes [flink-kubernetes-operator]

2023-12-19 Thread via GitHub
mxm commented on PR #736: URL: https://github.com/apache/flink-kubernetes-operator/pull/736#issuecomment-1862520480 Thanks @ryanvanhuuksloot! -- 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

Re: [PR] [docs] Fix a few docs mistakes [flink-kubernetes-operator]

2023-12-19 Thread via GitHub
mxm merged PR #736: URL: https://github.com/apache/flink-kubernetes-operator/pull/736 -- 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...

[jira] [Created] (FLINK-33880) Introducing Retry Mechanism for Listing TaskManager Pods to Prevent API Server Connection Failures

2023-12-19 Thread Yuan Huang (Jira)
Yuan Huang created FLINK-33880: --- Summary: Introducing Retry Mechanism for Listing TaskManager Pods to Prevent API Server Connection Failures Key: FLINK-33880 URL: https://issues.apache.org/jira/browse/FLINK-33880

Re: [PR] [FLINK-33810][Runtime] Propagate RecordAttributes that contains isProcessingBacklog status [flink]

2023-12-19 Thread via GitHub
xintongsong commented on code in PR #23919: URL: https://github.com/apache/flink/pull/23919#discussion_r1431242591 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordAttributesCombiner.java: ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache Softwa

Re: [PR] [FLINK-33810][Runtime] Propagate RecordAttributes that contains isProcessingBacklog status [flink]

2023-12-19 Thread via GitHub
xintongsong closed pull request #23919: [FLINK-33810][Runtime] Propagate RecordAttributes that contains isProcessingBacklog status URL: https://github.com/apache/flink/pull/23919 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[jira] [Assigned] (FLINK-33810) Propagate RecordAttributes that contains isProcessingBacklog status

2023-12-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-33810: Assignee: Xuannan Su > Propagate RecordAttributes that contains isProcessingBacklog statu

[jira] [Closed] (FLINK-33810) Propagate RecordAttributes that contains isProcessingBacklog status

2023-12-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-33810. Fix Version/s: 1.19.0 Resolution: Done master (1.19): f6bbf1cf364a3b4d04e6b6ddc522bad6431b4

Re: [PR] [FLINK-32850][flink-runtime][JUnit5 Migration] The io.network.buffer package of flink-runtime module [flink]

2023-12-19 Thread via GitHub
leonardBang merged PR #23604: URL: https://github.com/apache/flink/pull/23604 -- 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.a

[jira] [Comment Edited] (FLINK-32850) [JUnit5 Migration] The io package of flink-runtime module

2023-12-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798267#comment-17798267 ] Leonard Xu edited comment on FLINK-32850 at 12/19/23 11:13 AM: ---

[jira] [Assigned] (FLINK-33876) [JUnit5 Migration] Introduce methodName method in TableTestBase

2023-12-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-33876: -- Assignee: Jiabao Sun > [JUnit5 Migration] Introduce methodName method in TableTestBase >

Re: [PR] [FLINK-33876][table-planner][JUnit5 Migration] Introduce methodName method in TableTestBase [flink]

2023-12-19 Thread via GitHub
leonardBang merged PR #23952: URL: https://github.com/apache/flink/pull/23952 -- 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.a

[jira] [Updated] (FLINK-33876) [JUnit5 Migration] Introduce methodName method in TableTestBase

2023-12-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-33876: --- Fix Version/s: 1.19.0 > [JUnit5 Migration] Introduce methodName method in TableTestBase > --

[jira] [Resolved] (FLINK-33876) [JUnit5 Migration] Introduce methodName method in TableTestBase

2023-12-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-33876. Resolution: Implemented master (1.19): 945c5062c28c3feee94703e88fe6ef797e3760b3 > [JUnit5 Migrati

[jira] [Commented] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798545#comment-17798545 ] Jing Ge commented on FLINK-33588: - [~zhutong66] Thanks for the feedback. Could you pleas

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-12-19 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798548#comment-17798548 ] Sergey Nuyanzin commented on FLINK-33365: - glad that the issue is solved and tha

[jira] [Commented] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-19 Thread Tongtong Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798549#comment-17798549 ] Tongtong Zhu commented on FLINK-33588: -- [~jingge] My testing steps are as follows:

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-12-19 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798552#comment-17798552 ] david radley commented on FLINK-33365: -- [~Sergey Nuyanzin] sounds great! Thank you

[jira] [Commented] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798553#comment-17798553 ] Jing Ge commented on FLINK-33588: - [~zhutong66] It is great that you tested the change m

Re: [PR] [FLINK-33490][table-planner] Validate the column name conflicts in view when creating view [flink]

2023-12-19 Thread via GitHub
xuyangzhong commented on code in PR #23760: URL: https://github.com/apache/flink/pull/23760#discussion_r1431313795 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlDdlToOperationConverterTest.java: ## @@ -2210,6 +2211,32 @@ public voi

[jira] [Commented] (FLINK-32721) agg max/min supports char type

2023-12-19 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798560#comment-17798560 ] dalongliu commented on FLINK-32721: --- Sorry for responding later, I found this issue is

[jira] [Commented] (FLINK-32721) agg max/min supports char type

2023-12-19 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798561#comment-17798561 ] dalongliu commented on FLINK-32721: --- [~xuyangzhong] opened the PR Jan 17, 2022 for iss

Re: [PR] [FLINK-25476][table-planner] support CHAR type in function MAX and MIN [flink]

2023-12-19 Thread via GitHub
lsyldliu commented on code in PR #18375: URL: https://github.com/apache/flink/pull/18375#discussion_r1431348856 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/aggfunctions/MaxWithRetractAggFunctionTest.java: ## @@ -317,6 +318,31 @@ prot

[jira] [Assigned] (FLINK-25476) CharType lost in the creation of MaxAggFunction & MinAggFunction

2023-12-19 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-25476: - Assignee: Xu Yang > CharType lost in the creation of MaxAggFunction & MinAggFunction >

Re: [PR] [FLINK-32721][table-planner] Fix SQL MAX aggregation function does no… [flink]

2023-12-19 Thread via GitHub
lsyldliu commented on PR #23671: URL: https://github.com/apache/flink/pull/23671#issuecomment-1862685758 @paul8263 Thanks for your contribution, this will be fixed by https://github.com/apache/flink/pull/18375, this pr will be closed later. -- This is an automated message from the Apache

Re: [PR] [FLINK-32721] [planner] Support CharType for the MaxAggFunction [flink]

2023-12-19 Thread via GitHub
lsyldliu commented on PR #23943: URL: https://github.com/apache/flink/pull/23943#issuecomment-1862686262 @liuyongvs Thanks for your contribution, this will be fixed by https://github.com/apache/flink/pull/18375, this pr will be closed later. -- This is an automated message from the Apache

Re: [PR] [FLINK-32721] [planner] Support CharType for the MaxAggFunction and M… [flink]

2023-12-19 Thread via GitHub
lsyldliu commented on PR #23121: URL: https://github.com/apache/flink/pull/23121#issuecomment-1862686645 @liuyongvs Thanks for your contribution, this will be fixed by https://github.com/apache/flink/pull/18375, this pr will be closed later. -- This is an automated message from the Apache

Re: [PR] [FLINK-31650][metrics][rest] Remove transient metrics for subtasks in terminal state [flink]

2023-12-19 Thread via GitHub
wanglijie95 closed pull request #23447: [FLINK-31650][metrics][rest] Remove transient metrics for subtasks in terminal state URL: https://github.com/apache/flink/pull/23447 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Closed] (FLINK-32721) agg max/min supports char type

2023-12-19 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu closed FLINK-32721. - Resolution: Duplicate > agg max/min supports char type > -- > >

Re: [PR] [FLINK-31650][metrics][rest] Remove transient metrics for subtasks in terminal state [flink]

2023-12-19 Thread via GitHub
wanglijie95 commented on PR #23447: URL: https://github.com/apache/flink/pull/23447#issuecomment-1862700155 @X-czh Could you prepare a backport PR for branch release-1.17 ? It has conflicts when I cherry-pick the changes here to release-1.17 -- This is an automated message from the Apache

[jira] [Created] (FLINK-33881) [TtlListState]Avoid copy and update value when TtlListState don‘t have expired element

2023-12-19 Thread Jinzhong Li (Jira)
Jinzhong Li created FLINK-33881: --- Summary: [TtlListState]Avoid copy and update value when TtlListState don‘t have expired element Key: FLINK-33881 URL: https://issues.apache.org/jira/browse/FLINK-33881

[jira] [Updated] (FLINK-33881) [TtlListState]Avoid copy and update value in TtlListState#getUnexpiredOrNull

2023-12-19 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jinzhong Li updated FLINK-33881: Summary: [TtlListState]Avoid copy and update value in TtlListState#getUnexpiredOrNull (was: [TtlL

[jira] [Commented] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798579#comment-17798579 ] Jing Ge commented on FLINK-33588: - 1.18: c53493ecc45a02b3db595bdd28ac145482703322 > Fix

Re: [PR] [BP-1.18][FLINK-33588]Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics [flink]

2023-12-19 Thread via GitHub
JingGe merged PR #23947: URL: https://github.com/apache/flink/pull/23947 -- 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

[jira] [Updated] (FLINK-33881) [TtlListState]Avoid copy and update value in TtlListState#getUnexpiredOrNull

2023-12-19 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jinzhong Li updated FLINK-33881: Description: In some scenarios, 'TtlListState#getUnexpiredOrNull -> elementSerializer.copy(ttlVal

[jira] [Updated] (FLINK-33881) [TtlListState]Avoid copy and update value in TtlListState#getUnexpiredOrNull

2023-12-19 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jinzhong Li updated FLINK-33881: Description: In some scenarios, 'TtlListState#getUnexpiredOrNull -> elementSerializer.copy(ttlVal

[jira] [Created] (FLINK-33882) UT/IT for checkpointing statistics

2023-12-19 Thread Jing Ge (Jira)
Jing Ge created FLINK-33882: --- Summary: UT/IT for checkpointing statistics Key: FLINK-33882 URL: https://issues.apache.org/jira/browse/FLINK-33882 Project: Flink Issue Type: Improvement Co

[jira] [Commented] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798583#comment-17798583 ] Jing Ge commented on FLINK-33588: - created a follow-up ticket for test: https://issues.

[jira] [Commented] (FLINK-33882) UT/IT for checkpointing statistics

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798584#comment-17798584 ] Jing Ge commented on FLINK-33882: - [~zhutong66] would you like to work on this task?  >

[jira] [Resolved] (FLINK-33588) Fix Flink Checkpointing Statistics Bug

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33588. - Resolution: Fixed > Fix Flink Checkpointing Statistics Bug > -- > >

[jira] [Updated] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33872: Fix Version/s: 1.18.1 (was: 1.18.2) > Checkpoint history does not display for compl

Re: [PR] [FLINK-33872] Retrieve checkpoint history for jobs in completed state [flink]

2023-12-19 Thread via GitHub
JingGe merged PR #23951: URL: https://github.com/apache/flink/pull/23951 -- 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

[jira] [Commented] (FLINK-33882) UT/IT for checkpointing statistics

2023-12-19 Thread Tongtong Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798602#comment-17798602 ] Tongtong Zhu commented on FLINK-33882: -- [~jingge] Yes I would like > UT/IT for che

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

2023-12-19 Thread via GitHub
flashJd commented on PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#issuecomment-1862843009 @mxm can you approval the workflow again, I've fixed the ci failure, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Commented] (FLINK-33877) CollectSinkFunctionTest.testConfiguredPortIsUsed fails due to BindException

2023-12-19 Thread Jim Hughes (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798614#comment-17798614 ] Jim Hughes commented on FLINK-33877: https://dev.azure.com/apache-flink/apache-flink

[jira] [Created] (FLINK-33883) Bump CI flink version on flink-connector-jdbc

2023-12-19 Thread Jiabao Sun (Jira)
Jiabao Sun created FLINK-33883: -- Summary: Bump CI flink version on flink-connector-jdbc Key: FLINK-33883 URL: https://issues.apache.org/jira/browse/FLINK-33883 Project: Flink Issue Type: Improve

[PR] [FLINK-33883][jdbc] Bump CI flink version on flink-connector-jdbc to support flink 1.19 [flink-connector-jdbc]

2023-12-19 Thread via GitHub
Jiabao-Sun opened a new pull request, #85: URL: https://github.com/apache/flink-connector-jdbc/pull/85 [FLINK-33883][jdbc] Bump CI flink version on flink-connector-jdbc to support flink 1.19. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Updated] (FLINK-33883) Bump CI flink version on flink-connector-jdbc

2023-12-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33883: --- Labels: pull-request-available (was: ) > Bump CI flink version on flink-connector-jdbc > --

[jira] [Commented] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798634#comment-17798634 ] Hong Liang Teoh commented on FLINK-33872: - merged commit  [{{1e89e2f}}|https://g

Re: [PR] [FLINK-33872] Retrieve checkpoint history for jobs in completed state [flink]

2023-12-19 Thread via GitHub
hlteoh37 merged PR #23949: URL: https://github.com/apache/flink/pull/23949 -- 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.apac

[jira] [Commented] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798635#comment-17798635 ] Hong Liang Teoh commented on FLINK-33872: - merged commit  [{{54fd94a}}|https://g

[jira] [Resolved] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33872. - Resolution: Fixed > Checkpoint history does not display for completed jobs > ---

[jira] [Commented] (FLINK-16505) Document how to use the FlinkKinesisConsumer to read a CDC stream from DynamoDB

2023-12-19 Thread Ethan Hedden (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798638#comment-17798638 ] Ethan Hedden commented on FLINK-16505: -- Hi everyone, I see this issue is a few year

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

2023-12-19 Thread via GitHub
mxm commented on PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#issuecomment-1863023384 @gyfora Any more 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 to the

[jira] [Commented] (FLINK-33881) [TtlListState]Avoid copy and update value in TtlListState#getUnexpiredOrNull

2023-12-19 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798648#comment-17798648 ] Zakelly Lan commented on FLINK-33881: - Thanks [~lijinzhong]  for reporting this! How

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

2023-12-19 Thread via GitHub
gyfora commented on code in PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1431635885 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java: ## @@ -147,7 +149,13 @@ public CollectedMetricHistory updateM

Re: [PR] [FLINK-30593][autoscaler] Improve restart time tracking [flink-kubernetes-operator]

2023-12-19 Thread via GitHub
gyfora commented on code in PR #735: URL: https://github.com/apache/flink-kubernetes-operator/pull/735#discussion_r1431637325 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -182,22 +182,22 @@ private void runScalingLogic(Context ctx,

Re: [PR] [FLINK-30593][autoscaler] Improve restart time tracking [flink-kubernetes-operator]

2023-12-19 Thread via GitHub
gyfora commented on code in PR #735: URL: https://github.com/apache/flink-kubernetes-operator/pull/735#discussion_r1431638371 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -182,22 +182,22 @@ private void runScalingLogic(Context ctx,

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

2023-12-19 Thread via GitHub
mxm commented on code in PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1431648293 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java: ## @@ -147,7 +149,13 @@ public CollectedMetricHistory updateMetr

Re: [PR] [FLINK-30593][autoscaler] Improve restart time tracking [flink-kubernetes-operator]

2023-12-19 Thread via GitHub
mxm commented on code in PR #735: URL: https://github.com/apache/flink-kubernetes-operator/pull/735#discussion_r1431686776 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -182,22 +182,22 @@ private void runScalingLogic(Context ctx, A

Re: [PR] [FLINK-33883][jdbc] Bump CI flink version on flink-connector-jdbc to support flink 1.19 [flink-connector-jdbc]

2023-12-19 Thread via GitHub
snuyanzin commented on code in PR #85: URL: https://github.com/apache/flink-connector-jdbc/pull/85#discussion_r1431723034 ## .github/workflows/push_pr.yml: ## @@ -30,6 +30,8 @@ jobs: include: - flink: 1.18-SNAPSHOT jdk: '8, 11, 17' + -

Re: [PR] [FLINK-33883][jdbc] Bump CI flink version on flink-connector-jdbc to support flink 1.19 [flink-connector-jdbc]

2023-12-19 Thread via GitHub
snuyanzin commented on code in PR #85: URL: https://github.com/apache/flink-connector-jdbc/pull/85#discussion_r1431723394 ## .github/workflows/weekly.yml: ## @@ -36,6 +36,10 @@ jobs: flink: 1.18-SNAPSHOT, jdk: '8, 11, 17', branch: main +

Re: [PR] [FLINK-33883][jdbc] Bump CI flink version on flink-connector-jdbc to support flink 1.19 [flink-connector-jdbc]

2023-12-19 Thread via GitHub
snuyanzin commented on code in PR #85: URL: https://github.com/apache/flink-connector-jdbc/pull/85#discussion_r1431724158 ## flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java: ## @@ -64,4 +69,14 @@ public void testFilterPushdown() {

Re: [PR] [FLINK-33883][jdbc] Bump CI flink version on flink-connector-jdbc to support flink 1.19 [flink-connector-jdbc]

2023-12-19 Thread via GitHub
snuyanzin commented on code in PR #85: URL: https://github.com/apache/flink-connector-jdbc/pull/85#discussion_r1431724158 ## flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java: ## @@ -64,4 +69,14 @@ public void testFilterPushdown() {

[jira] [Commented] (FLINK-33486) Pulsar Client Send Timeout Terminates TaskManager

2023-12-19 Thread David Christle (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798684#comment-17798684 ] David Christle commented on FLINK-33486: We also observe this issue, typically a

[jira] [Created] (FLINK-33884) Update Pulsar dependency to 3.0.2 in Pulsar Connector

2023-12-19 Thread David Christle (Jira)
David Christle created FLINK-33884: -- Summary: Update Pulsar dependency to 3.0.2 in Pulsar Connector Key: FLINK-33884 URL: https://issues.apache.org/jira/browse/FLINK-33884 Project: Flink Iss

Re: [PR] [FLINK-33884] Update Pulsar dependency to 3.0.2 in Pulsar Connector [flink-connector-pulsar]

2023-12-19 Thread via GitHub
boring-cyborg[bot] commented on PR #72: URL: https://github.com/apache/flink-connector-pulsar/pull/72#issuecomment-1863247716 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[PR] [FLINK-33884] Update Pulsar dependency to 3.0.2 in Pulsar Connector [flink-connector-pulsar]

2023-12-19 Thread via GitHub
dchristle opened a new pull request, #72: URL: https://github.com/apache/flink-connector-pulsar/pull/72 ## Purpose of the change Update the Pulsar dependency version to pick up patch fixes. ## Brief change log - Update `pulsar.version` to `3.0.2` in pom.xml.

[jira] [Updated] (FLINK-33884) Update Pulsar dependency to 3.0.2 in Pulsar Connector

2023-12-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33884: --- Labels: pull-request-available (was: ) > Update Pulsar dependency to 3.0.2 in Pulsar Connec

Re: [PR] [FLINK-33365] include filters with Lookup joins [flink-connector-jdbc]

2023-12-19 Thread via GitHub
davidradl commented on code in PR #79: URL: https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1431856416 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java: ## @@ -96,28 +98,70 @@ public JdbcDynamicTableSourc

Re: [PR] [FLINK-33365] include filters with Lookup joins [flink-connector-jdbc]

2023-12-19 Thread via GitHub
davidradl commented on code in PR #79: URL: https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1431857437 ## flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSourceITCase.java: ## @@ -356,6 +356,152 @@ void testLookupJoin(

[jira] [Commented] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-12-19 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798719#comment-17798719 ] david radley commented on FLINK-33365: -- [~Sergey Nuyanzin] I have pushed up my late

[jira] [Comment Edited] (FLINK-33365) Missing filter condition in execution plan containing lookup join with mysql jdbc connector

2023-12-19 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798719#comment-17798719 ] david radley edited comment on FLINK-33365 at 12/19/23 7:36 PM: --

Re: [PR] [FLINK-33611] [flink-protobuf] Support Large Protobuf Schemas [flink]

2023-12-19 Thread via GitHub
sharath1709 commented on PR #23937: URL: https://github.com/apache/flink/pull/23937#issuecomment-1863449372 @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 co

Re: [PR] [FLINK-33877][streaming] Fix unstable test of CollectSinkFunctionTest.testConfiguredPortIsUsed [flink]

2023-12-19 Thread via GitHub
JingGe merged PR #23955: URL: https://github.com/apache/flink/pull/23955 -- 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

[jira] [Updated] (FLINK-33362) Document Externalized Declarative Resource Management With Chinese

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33362: Fix Version/s: 1.18.2 (was: 1.18.1) > Document Externalized Declarative Resource Ma

[jira] [Created] (FLINK-33887) CLONE - Stage source and binary releases on dist.apache.org

2023-12-19 Thread Jing Ge (Jira)
Jing Ge created FLINK-33887: --- Summary: CLONE - Stage source and binary releases on dist.apache.org Key: FLINK-33887 URL: https://issues.apache.org/jira/browse/FLINK-33887 Project: Flink Issue Type

[jira] [Created] (FLINK-33889) CLONE - Vote on the release candidate

2023-12-19 Thread Jing Ge (Jira)
Jing Ge created FLINK-33889: --- Summary: CLONE - Vote on the release candidate Key: FLINK-33889 URL: https://issues.apache.org/jira/browse/FLINK-33889 Project: Flink Issue Type: Sub-task Affects

[jira] [Created] (FLINK-33885) Build Release Candidate: 1.18.1-rc2

2023-12-19 Thread Jing Ge (Jira)
Jing Ge created FLINK-33885: --- Summary: Build Release Candidate: 1.18.1-rc2 Key: FLINK-33885 URL: https://issues.apache.org/jira/browse/FLINK-33885 Project: Flink Issue Type: New Feature Affects

[jira] [Created] (FLINK-33888) CLONE - Propose a pull request for website updates

2023-12-19 Thread Jing Ge (Jira)
Jing Ge created FLINK-33888: --- Summary: CLONE - Propose a pull request for website updates Key: FLINK-33888 URL: https://issues.apache.org/jira/browse/FLINK-33888 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33886) CLONE - Build and stage Java and Python artifacts

2023-12-19 Thread Jing Ge (Jira)
Jing Ge created FLINK-33886: --- Summary: CLONE - Build and stage Java and Python artifacts Key: FLINK-33886 URL: https://issues.apache.org/jira/browse/FLINK-33886 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-33887) Stage source and binary releases on dist.apache.org

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33887: Summary: Stage source and binary releases on dist.apache.org (was: CLONE - Stage source and binary releas

[jira] [Resolved] (FLINK-33886) Build and stage Java and Python artifacts

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33886. - Resolution: Fixed > Build and stage Java and Python artifacts >

[jira] [Resolved] (FLINK-33887) Stage source and binary releases on dist.apache.org

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33887. - Resolution: Fixed > Stage source and binary releases on dist.apache.org > --

[jira] [Updated] (FLINK-33886) Build and stage Java and Python artifacts

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33886: Summary: Build and stage Java and Python artifacts (was: CLONE - Build and stage Java and Python artifact

[jira] [Updated] (FLINK-33888) Propose a pull request for website updates

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33888: Summary: Propose a pull request for website updates (was: CLONE - Propose a pull request for website upda

[jira] [Updated] (FLINK-33889) Vote on the release candidate

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33889: Summary: Vote on the release candidate (was: CLONE - Vote on the release candidate) > Vote on the releas

[jira] [Assigned] (FLINK-33840) Deploy artifacts to Maven Central Repository

2023-12-19 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-33840: --- Assignee: Jing Ge (was: Qingsheng Ren) > Deploy artifacts to Maven Central Repository > --

  1   2   >