[GitHub] [flink] xintongsong closed pull request #23077: [FLINK-32675][doc] Add document for the tiered storage of hybrid shuffle

2023-08-02 Thread via GitHub
xintongsong closed pull request #23077: [FLINK-32675][doc] Add document for the tiered storage of hybrid shuffle URL: https://github.com/apache/flink/pull/23077 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Closed] (FLINK-32675) Add doc for the tiered storage of hybrid shuffle

2023-08-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32675. Fix Version/s: 1.18.0 Resolution: Done master (1.18): b18bde9bb44e94bc2fb7f84c49367c6988aa6

[jira] [Commented] (FLINK-25322) Support no-claim mode in changelog state backend

2023-08-02 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750150#comment-17750150 ] Hangxiang Yu commented on FLINK-25322: -- {quote}But I don't think this adds complexi

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

2023-08-02 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750154#comment-17750154 ] Yao Zhang commented on FLINK-32721: --- Hi community: It seems that Flink does not suppo

[jira] [Commented] (FLINK-32663) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails on AZP

2023-08-02 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750156#comment-17750156 ] Dong Lin commented on FLINK-32663: -- [~mapohl] Thanks for the reminder. Will do it in th

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

2023-08-02 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jacky Lau updated FLINK-32721: -- Summary: agg max/min supports char type (was: agg supports char type) > agg max/min supports char typ

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750162#comment-17750162 ] Matthias Pohl commented on FLINK-32523: --- {quote} I think we should remove @Test(ti

[jira] [Updated] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32523: -- Attachment: failure.log > NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with

[GitHub] [flink] liuyongvs opened a new pull request, #23121: [FLINK-32721] [planner] Support CharType for the MaxAggFunction and M…

2023-08-02 Thread via GitHub
liuyongvs opened a new pull request, #23121: URL: https://github.com/apache/flink/pull/23121 ## What is the purpose of the change *Support CharType for the MaxAggFunction and MinAggFunction.* ## Brief change log *(for example:)* - *The TaskInfo is stored in the b

[GitHub] [flink] xintongsong closed pull request #23113: [FLINK-32559] Deprecate Queryable State

2023-08-02 Thread via GitHub
xintongsong closed pull request #23113: [FLINK-32559] Deprecate Queryable State URL: https://github.com/apache/flink/pull/23113 -- 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.

[jira] [Comment Edited] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750162#comment-17750162 ] Matthias Pohl edited comment on FLINK-32523 at 8/2/23 7:43 AM: ---

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

2023-08-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32721: --- Labels: pull-request-available (was: ) > agg max/min supports char type > -

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

2023-08-02 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750165#comment-17750165 ] Jacky Lau commented on FLINK-32721: --- hi [~libenchao]  do you have time to review it [

[jira] [Closed] (FLINK-32559) Deprecate Queryable State

2023-08-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32559. Release Note: The Queryable State feature is formally deprecated. It will be removed in future maj

[jira] [Updated] (FLINK-31395) AbstractPartitionDiscoverer.discoverPartitions calls remove on immutable collection

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31395: -- Affects Version/s: 1.17.1 > AbstractPartitionDiscoverer.discoverPartitions calls remove on imm

[jira] [Commented] (FLINK-31395) AbstractPartitionDiscoverer.discoverPartitions calls remove on immutable collection

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750168#comment-17750168 ] Matthias Pohl commented on FLINK-31395: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-31395) AbstractPartitionDiscoverer.discoverPartitions calls remove on immutable collection

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750170#comment-17750170 ] Matthias Pohl commented on FLINK-31395: --- [~xzw0223] did you continue looking into

[GitHub] [flink] flinkbot commented on pull request #23121: [FLINK-32721] [planner] Support CharType for the MaxAggFunction and M…

2023-08-02 Thread via GitHub
flinkbot commented on PR #23121: URL: https://github.com/apache/flink/pull/23121#issuecomment-1661688661 ## CI report: * 05a56a0ef42d50f743e2885f3866fc31bfac6f9c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-32732) auto offset reset should be exposed to user

2023-08-02 Thread xiaogang zhou (Jira)
xiaogang zhou created FLINK-32732: - Summary: auto offset reset should be exposed to user Key: FLINK-32732 URL: https://issues.apache.org/jira/browse/FLINK-32732 Project: Flink Issue Type: Imp

[jira] [Updated] (FLINK-32732) auto offset reset should be exposed to user

2023-08-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-32732: -- Description: {code:java} // code placeholder maybeOverride( ConsumerConfig.AUTO_OFFSET

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #248: [FLINK-32704] Supports spilling to disk when feedback channel memory buffer is full

2023-08-02 Thread via GitHub
Fanoid commented on code in PR #248: URL: https://github.com/apache/flink-ml/pull/248#discussion_r1280468831 ## flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/feedback/SpillableQueue.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to t

[jira] [Updated] (FLINK-32713) Cascade deprecation to non-private methods that reference SourceFunction

2023-08-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32713: --- Labels: pull-request-available (was: ) > Cascade deprecation to non-private methods that re

[jira] [Updated] (FLINK-32732) auto offset reset should be exposed to user

2023-08-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-32732: -- Description: {code:java} // code placeholder maybeOverride( ConsumerConfig.AUTO_OFFSET

[jira] [Commented] (FLINK-32223) Add Hive delegation token support

2023-08-02 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750182#comment-17750182 ] Gabor Somogyi commented on FLINK-32223: --- Thanks for the detailed step-by-step! Sou

[jira] [Commented] (FLINK-32732) auto offset reset should be exposed to user

2023-08-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750183#comment-17750183 ] xiaogang zhou commented on FLINK-32732: --- [~libenchao] [~renqs]  let me know your t

[jira] [Commented] (FLINK-32607) Kafka table source and json format support projection pushdown

2023-08-02 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750184#comment-17750184 ] xiaogang zhou commented on FLINK-32607: --- [~libenchao] Not sure if someone has take

[jira] [Updated] (FLINK-32587) The results returned from the CDC sql query are null or the value was changed unexpectly

2023-08-02 Thread jasonliangyc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jasonliangyc updated FLINK-32587: - Attachment: image-2023-08-02-16-40-32-476.png > The results returned from the CDC sql query are

[jira] [Commented] (FLINK-32223) Add Hive delegation token support

2023-08-02 Thread qingbo jiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750193#comment-17750193 ] qingbo jiao commented on FLINK-32223: - Ok, I'll see on my environment why it failed

[jira] [Updated] (FLINK-32587) The results returned from the CDC sql query are null or the value was changed unexpectly

2023-08-02 Thread jasonliangyc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jasonliangyc updated FLINK-32587: - Attachment: image-2023-08-02-16-43-25-458.png > The results returned from the CDC sql query are

[GitHub] [flink] lindong28 commented on a diff in pull request #22931: [FLINK-32514] Support configuring checkpointing interval during process backlog

2023-08-02 Thread via GitHub
lindong28 commented on code in PR #22931: URL: https://github.com/apache/flink/pull/22931#discussion_r1281616827 ## flink-tests/src/test/java/org/apache/flink/test/util/NumberSequenceSourceBlockableByCheckpoint.java: ## @@ -0,0 +1,152 @@ +/* + * Licensed to the Apache Software F

[jira] [Updated] (FLINK-32587) The results returned from the CDC sql query are null or the value was changed unexpectly

2023-08-02 Thread jasonliangyc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jasonliangyc updated FLINK-32587: - Attachment: image-2023-08-02-17-03-05-932.png > The results returned from the CDC sql query are

[jira] [Updated] (FLINK-32587) The results returned from the CDC sql query are null or the value was changed unexpectly

2023-08-02 Thread jasonliangyc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jasonliangyc updated FLINK-32587: - Attachment: image-2023-08-02-17-07-19-295.png > The results returned from the CDC sql query are

[jira] [Updated] (FLINK-32587) The results returned from the CDC sql query are null or the value was changed unexpectly

2023-08-02 Thread jasonliangyc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jasonliangyc updated FLINK-32587: - Attachment: image-2023-08-02-17-09-14-671.png > The results returned from the CDC sql query are

[jira] [Updated] (FLINK-32587) The results returned from the CDC sql query are null or the value was changed unexpectly

2023-08-02 Thread jasonliangyc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jasonliangyc updated FLINK-32587: - Attachment: image-2023-08-02-17-10-03-889.png > The results returned from the CDC sql query are

[jira] [Commented] (FLINK-32587) The results returned from the CDC sql query are null or the value was changed unexpectly

2023-08-02 Thread jasonliangyc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750208#comment-17750208 ] jasonliangyc commented on FLINK-32587: -- Hi [~jiabao.sun] , thanks for your advices

[jira] [Updated] (FLINK-32587) The results returned from the CDC sql query are null or the value was changed unexpectly

2023-08-02 Thread jasonliangyc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jasonliangyc updated FLINK-32587: - Attachment: image-2023-08-02-17-18-06-375.png > The results returned from the CDC sql query are

[jira] [Comment Edited] (FLINK-32587) The results returned from the CDC sql query are null or the value was changed unexpectly

2023-08-02 Thread jasonliangyc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750208#comment-17750208 ] jasonliangyc edited comment on FLINK-32587 at 8/2/23 9:28 AM:

[GitHub] [flink-connector-hbase] YesOrNo828 commented on pull request #17: [FLINK-28013] Shade all netty dependencies in sql jar

2023-08-02 Thread via GitHub
YesOrNo828 commented on PR #17: URL: https://github.com/apache/flink-connector-hbase/pull/17#issuecomment-1661865824 I tested this patch locally which resolves this NoClassDefFoundError exception; ```java.lang.NoClassDefFoundError: org/apache/flink/hbase/shaded/io/netty/channel/EventLoo

[GitHub] [flink] WencongLiu commented on pull request #23026: [FLINK-32558][flink-java] Deprecate all DataSet API

2023-08-02 Thread via GitHub
WencongLiu commented on PR #23026: URL: https://github.com/apache/flink/pull/23026#issuecomment-1661879343 > * PENDING `ParameterTool` is still used by the`DataStreamAllroundTestJobFactory`, `HistoryServer` and the DataStream e2e test classes. `MultipleParameterTool ` is also used by t

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #248: [FLINK-32704] Supports spilling to disk when feedback channel memory buffer is full

2023-08-02 Thread via GitHub
jiangxin369 commented on code in PR #248: URL: https://github.com/apache/flink-ml/pull/248#discussion_r1281676904 ## flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/datacache/nonkeyed/ListStateWithCache.java: ## @@ -82,11 +82,13 @@ public Li

[GitHub] [flink] xintongsong commented on pull request #23026: [FLINK-32558][flink-java] Deprecate all DataSet API

2023-08-02 Thread via GitHub
xintongsong commented on PR #23026: URL: https://github.com/apache/flink/pull/23026#issuecomment-1661938754 I think being used in test cases probably should not block the deprecation of the classes. In this specific case, I don't it's necessary to move them to another module. There are many

[jira] [Commented] (FLINK-15736) Support Java 17 (LTS)

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750250#comment-17750250 ] Matthias Pohl commented on FLINK-15736: --- I guess, having it part of the release no

[jira] [Updated] (FLINK-15736) Support Java 17 (LTS)

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-15736: -- Release Note: Apache Flink was made ready to compile and run with Java 17 (LTS). > Support Ja

[jira] [Created] (FLINK-32733) Add Transformer for FpGrowth

2023-08-02 Thread Yindi Wang (Jira)
Yindi Wang created FLINK-32733: -- Summary: Add Transformer for FpGrowth Key: FLINK-32733 URL: https://issues.apache.org/jira/browse/FLINK-32733 Project: Flink Issue Type: New Feature Co

[jira] [Commented] (FLINK-28199) Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750260#comment-17750260 ] Matthias Pohl commented on FLINK-28199: --- https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-28199) Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-28199: -- Affects Version/s: 1.17.1 > Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval

[GitHub] [flink] XComp merged pull request #23103: [FLINK-31168] Fix JobManagerHAProcessFailureRecoveryITCase

2023-08-02 Thread via GitHub
XComp merged PR #23103: URL: https://github.com/apache/flink/pull/23103 -- 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] [Resolved] (FLINK-31168) JobManagerHAProcessFailureRecoveryITCase failed due to job not being found

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-31168. --- Resolution: Fixed master: 476d68814ab606a86e376b1649713a7661fb12e4 > JobManagerHAProcessFai

[jira] [Resolved] (FLINK-32715) ProcessFailureCancelingITCase.testCancelingOnProcessFailure

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-32715. --- Fix Version/s: 1.18.0 Resolution: Fixed master: 99b98338266e32c08284ccac3ac49229ec29b

[GitHub] [flink] XComp commented on pull request #23117: [FLINK-32662][test] Fixes JobMasterTest#testRetrievingCheckpointStats with the AdaptiveScheduler

2023-08-02 Thread via GitHub
XComp commented on PR #23117: URL: https://github.com/apache/flink/pull/23117#issuecomment-1662033881 Thanks for the approval. I removed the debug commit and squashed the other two into a single commit (see [the comparision of the force push](https://github.com/apache/flink/compare/850e4a46

[GitHub] [flink] XComp merged pull request #23117: [FLINK-32662][test] Fixes JobMasterTest#testRetrievingCheckpointStats with the AdaptiveScheduler

2023-08-02 Thread via GitHub
XComp merged PR #23117: URL: https://github.com/apache/flink/pull/23117 -- 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] [Resolved] (FLINK-32662) JobMasterTest.testRetrievingCheckpointStats fails with NPE on AZP

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-32662. --- Fix Version/s: 1.18.0 Resolution: Fixed master: 74babdab7fd5b72d5eec5bff4070532a9621b

[jira] [Commented] (FLINK-32717) Change of topic list from KafkaSource not works

2023-08-02 Thread Kwangin (Dennis) Jung (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750276#comment-17750276 ] Kwangin (Dennis) Jung commented on FLINK-32717: --- [~martijnvisser] thanks f

[jira] [Comment Edited] (FLINK-32717) Change of topic list from KafkaSource not works

2023-08-02 Thread Kwangin (Dennis) Jung (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750276#comment-17750276 ] Kwangin (Dennis) Jung edited comment on FLINK-32717 at 8/2/23 11:55 AM: --

[jira] [Commented] (FLINK-32607) Kafka table source and json format support projection pushdown

2023-08-02 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750281#comment-17750281 ] Benchao Li commented on FLINK-32607: [~zhoujira86] Feel free to add a subtask for pb

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

2023-08-02 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750284#comment-17750284 ] Benchao Li commented on FLINK-32721: [~paul8263] Seems Jacky has proposed a PR alrea

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

2023-08-02 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li reassigned FLINK-32721: -- Assignee: Jacky Lau > agg max/min supports char type > -- > >

[jira] [Created] (FLINK-32734) Add .mvn/maven.config to .gitignore

2023-08-02 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32734: - Summary: Add .mvn/maven.config to .gitignore Key: FLINK-32734 URL: https://issues.apache.org/jira/browse/FLINK-32734 Project: Flink Issue Type: Improvement

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #637: [FLINK-29634] Support periodic checkpoint triggering

2023-08-02 Thread via GitHub
gyfora merged PR #637: URL: https://github.com/apache/flink-kubernetes-operator/pull/637 -- 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] [Assigned] (FLINK-32734) Add .mvn/maven.config to .gitignore

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-32734: - Assignee: Matthias Pohl > Add .mvn/maven.config to .gitignore > ---

[jira] [Closed] (FLINK-29634) Support periodic checkpoint triggering

2023-08-02 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29634. -- Fix Version/s: kubernetes-operator-1.7.0 Resolution: Fixed merged to main c09671c5c51277c266b8c

[GitHub] [flink] XComp opened a new pull request, #23122: [FLINK-32734][build] Adds .mvn/maven.config to .gitignore

2023-08-02 Thread via GitHub
XComp opened a new pull request, #23122: URL: https://github.com/apache/flink/pull/23122 ## What is the purpose of the change This allows the checkout-specific customization of the Maven build (e.g. setting a different local repository). ## Brief change log * Add

[jira] [Updated] (FLINK-32734) Add .mvn/maven.config to .gitignore

2023-08-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32734: --- Labels: pull-request-available (was: ) > Add .mvn/maven.config to .gitignore >

[GitHub] [flink] flinkbot commented on pull request #23122: [FLINK-32734][build] Adds .mvn/maven.config to .gitignore

2023-08-02 Thread via GitHub
flinkbot commented on PR #23122: URL: https://github.com/apache/flink/pull/23122#issuecomment-1662208981 ## CI report: * 2dbbb0c1782c0489a172dae4b03f96be44d9a455 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

2023-08-02 Thread LEONID ILYEVSKY (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750331#comment-17750331 ] LEONID ILYEVSKY commented on FLINK-30998: - [~reta] [~martijnvisser]  Thanks for

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

2023-08-02 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750368#comment-17750368 ] Hangxiang Yu commented on FLINK-32523: -- >From the exception stack and attached logs

[jira] [Commented] (FLINK-30719) flink-runtime-web failed due to a corrupted

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750376#comment-17750376 ] Matthias Pohl commented on FLINK-30719: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-30719) flink-runtime-web failed due to a corrupted

2023-08-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750375#comment-17750375 ] Matthias Pohl commented on FLINK-30719: --- https://dev.azure.com/apache-flink/apache

[jira] [Created] (FLINK-32735) Flink SQL Gateway for Native Kubernetes Application Mode

2023-08-02 Thread Junyao Huang (Jira)
Junyao Huang created FLINK-32735: Summary: Flink SQL Gateway for Native Kubernetes Application Mode Key: FLINK-32735 URL: https://issues.apache.org/jira/browse/FLINK-32735 Project: Flink Iss

[jira] [Updated] (FLINK-32102) Aggregate multiple pendingRecords metric per source if present

2023-08-02 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-32102: --- Fix Version/s: (was: kubernetes-operator-1.5.1) > Aggregate multiple pendingReco

[jira] [Updated] (FLINK-31684) Autoscaler metrics are only visible after metric window is full

2023-08-02 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-31684: --- Fix Version/s: (was: kubernetes-operator-1.5.1) > Autoscaler metrics are only vi

[jira] [Updated] (FLINK-32100) Max parallelism is incorrectly calculated with multiple topics

2023-08-02 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-32100: --- Fix Version/s: (was: kubernetes-operator-1.5.1) > Max parallelism is incorrectly

[jira] [Updated] (FLINK-32120) Add autoscaler config option to disable parallelism key group alignment

2023-08-02 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-32120: --- Fix Version/s: kubernetes-operator-1.6.0 (was: kubernetes-oper

[jira] [Updated] (FLINK-32119) Revise source partition skew logic

2023-08-02 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-32119: --- Fix Version/s: kubernetes-operator-1.6.0 (was: kubernetes-oper

[jira] [Assigned] (FLINK-32729) allow create an initial deployment with suspend state

2023-08-02 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-32729: -- Assignee: Zhenqiu Huang > allow create an initial deployment with suspend state > ---

[jira] [Updated] (FLINK-32729) allow create an initial deployment with suspend state

2023-08-02 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-32729: -- Description: With this feature, Users could create an application in suspend status as a backu

[jira] [Created] (FLINK-32736) Add a post to announce new connectors and connector externalisation

2023-08-02 Thread Elphas Toringepi (Jira)
Elphas Toringepi created FLINK-32736: Summary: Add a post to announce new connectors and connector externalisation Key: FLINK-32736 URL: https://issues.apache.org/jira/browse/FLINK-32736 Project:

[jira] [Commented] (FLINK-32736) Add a post to announce new connectors and connector externalisation

2023-08-02 Thread Elphas Toringepi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750417#comment-17750417 ] Elphas Toringepi commented on FLINK-32736: -- [~danny.cranmer] Could you please a

[jira] [Assigned] (FLINK-32736) Add a post to announce new connectors and connector externalisation

2023-08-02 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-32736: - Assignee: Elphas Toringepi > Add a post to announce new connectors and connector extern

[GitHub] [flink-connector-aws] dannycranmer commented on pull request #90: [Connectors/Kinesis] Fixed typo in the Kinesis connector documentation

2023-08-02 Thread via GitHub
dannycranmer commented on PR #90: URL: https://github.com/apache/flink-connector-aws/pull/90#issuecomment-1662941934 > the bot said i have a wrong commit title on my PR, but i don't know what's wrong with my commit title. Can anyone help me? It is missing the Jira ID `[FLINK-12345]`

[jira] [Created] (FLINK-32737) Add support for Snowflake sink connector

2023-08-02 Thread Mohsen Rezaei (Jira)
Mohsen Rezaei created FLINK-32737: - Summary: Add support for Snowflake sink connector Key: FLINK-32737 URL: https://issues.apache.org/jira/browse/FLINK-32737 Project: Flink Issue Type: New Fe

[jira] [Commented] (FLINK-32736) Add a post to announce new connectors and connector externalisation

2023-08-02 Thread Elphas Toringepi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750492#comment-17750492 ] Elphas Toringepi commented on FLINK-32736: -- https://github.com/apache/flink-web

[GitHub] [flink] snuyanzin commented on pull request #23122: [FLINK-32734][build] Adds .mvn/maven.config to .gitignore

2023-08-02 Thread via GitHub
snuyanzin commented on PR #23122: URL: https://github.com/apache/flink/pull/23122#issuecomment-1663065963 LGTM P.S. In theory support of user properties should help here however it was added in 4.0.0 only https://issues.apache.org/jira/browse/MNG-6303 -- This is an automated mes

[GitHub] [flink] yunfengzhou-hub commented on a diff in pull request #22931: [FLINK-32514] Support configuring checkpointing interval during process backlog

2023-08-02 Thread via GitHub
yunfengzhou-hub commented on code in PR #22931: URL: https://github.com/apache/flink/pull/22931#discussion_r1282534739 ## flink-tests/src/test/java/org/apache/flink/test/util/NumberSequenceSourceBlockableByCheckpoint.java: ## @@ -0,0 +1,152 @@ +/* + * Licensed to the Apache Soft

[GitHub] [flink] yunfengzhou-hub commented on a diff in pull request #22931: [FLINK-32514] Support configuring checkpointing interval during process backlog

2023-08-02 Thread via GitHub
yunfengzhou-hub commented on code in PR #22931: URL: https://github.com/apache/flink/pull/22931#discussion_r1282534739 ## flink-tests/src/test/java/org/apache/flink/test/util/NumberSequenceSourceBlockableByCheckpoint.java: ## @@ -0,0 +1,152 @@ +/* + * Licensed to the Apache Soft

[jira] [Commented] (FLINK-32716) Give 'None' option for 'scheduler-mode'

2023-08-02 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750514#comment-17750514 ] Yao Zhang commented on FLINK-32716: --- Hi [~kination], I got the same problem. Currentl

[GitHub] [flink-connector-aws] MRKKmrkk commented on pull request #90: [Connectors/Kinesis] Fixed typo in the Kinesis connector documentation

2023-08-02 Thread via GitHub
MRKKmrkk commented on PR #90: URL: https://github.com/apache/flink-connector-aws/pull/90#issuecomment-1663156681 > > the bot said i have a wrong commit title on my PR, but i don't know what's wrong with my commit title. Can anyone help me? > > It is missing the Jira ID `[FLINK-12345]

[jira] [Comment Edited] (FLINK-32716) Give 'None' option for 'scheduler-mode'

2023-08-02 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750514#comment-17750514 ] Yao Zhang edited comment on FLINK-32716 at 8/3/23 1:09 AM: --- Hi

[jira] [Commented] (FLINK-32716) Give 'None' option for 'scheduler-mode'

2023-08-02 Thread Kwangin (Dennis) Jung (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750517#comment-17750517 ] Kwangin (Dennis) Jung commented on FLINK-32716: --- [~paul8263] thanks for co

[GitHub] [flink] xintongsong closed pull request #23006: [FLINK-32560][Scala] Deprecate all Scala API

2023-08-02 Thread via GitHub
xintongsong closed pull request #23006: [FLINK-32560][Scala] Deprecate all Scala API URL: https://github.com/apache/flink/pull/23006 -- 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

[GitHub] [flink] liuyongvs commented on pull request #23121: [FLINK-32721] [planner] Support CharType for the MaxAggFunction and M…

2023-08-02 Thread via GitHub
liuyongvs commented on PR #23121: URL: https://github.com/apache/flink/pull/23121#issuecomment-166318 @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.

[jira] [Closed] (FLINK-32560) Properly deprecate all Scala APIs

2023-08-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32560. Resolution: Done master (1.18): 255d83087c6a6432270e6886ffdcf85dae00c241 > Properly deprecate all

[GitHub] [flink] wanglijie95 opened a new pull request, #23125: [FLINK-32144][connector/filesystem][test] Create a new minicluser instead of using MiniClusterExtension in tests that would kill JM/TM

2023-08-02 Thread via GitHub
wanglijie95 opened a new pull request, #23125: URL: https://github.com/apache/flink/pull/23125 ## What is the purpose of the change Fix FLINK-32144, fix the unstable tests in `FileSourceTextLinesITCase` ## Does this pull request potentially affect one of the following parts:

[jira] [Updated] (FLINK-32144) FileSourceTextLinesITCase times out on AZP

2023-08-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32144: --- Labels: pull-request-available test-stability (was: test-stability) > FileSourceTextLinesIT

[GitHub] [flink] flinkbot commented on pull request #23125: [FLINK-32144][connector/filesystem][test] Create a new minicluser instead of using MiniClusterExtension in tests that would kill JM/TM

2023-08-02 Thread via GitHub
flinkbot commented on PR #23125: URL: https://github.com/apache/flink/pull/23125#issuecomment-1663198618 ## CI report: * 179d15c703d4e5a2a9a3ec410d9aefeacdb61b81 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32223) Add Hive delegation token support

2023-08-02 Thread qingbo jiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qingbo jiao updated FLINK-32223: Attachment: image-2023-08-03-10-18-56-029.png > Add Hive delegation token support > -

[jira] [Created] (FLINK-32738) PROTOBUF format supports projection push down

2023-08-02 Thread xiaogang zhou (Jira)
xiaogang zhou created FLINK-32738: - Summary: PROTOBUF format supports projection push down Key: FLINK-32738 URL: https://issues.apache.org/jira/browse/FLINK-32738 Project: Flink Issue Type: S

[jira] [Updated] (FLINK-32223) Add Hive delegation token support

2023-08-02 Thread qingbo jiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qingbo jiao updated FLINK-32223: Attachment: screenshot-1.png > Add Hive delegation token support > --

[jira] [Commented] (FLINK-32223) Add Hive delegation token support

2023-08-02 Thread qingbo jiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750526#comment-17750526 ] qingbo jiao commented on FLINK-32223: - !image-2023-08-03-10-18-56-029.png! I use th

[jira] [Assigned] (FLINK-32738) PROTOBUF format supports projection push down

2023-08-02 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li reassigned FLINK-32738: -- Assignee: xiaogang zhou > PROTOBUF format supports projection push down > ---

  1   2   >