[GitHub] [flink-kubernetes-operator] Aitozi commented on pull request #164: [FLINK-26871] Handle session job spec change

2022-04-10 Thread GitBox
Aitozi commented on PR #164: URL: https://github.com/apache/flink-kubernetes-operator/pull/164#issuecomment-1094581810 cc @gyfora @wangyang0918 Please take a look when you are free. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Created] (FLINK-27161) Support user jar from different type of filesystems

2022-04-10 Thread Aitozi (Jira)
Aitozi created FLINK-27161: -- Summary: Support user jar from different type of filesystems Key: FLINK-27161 URL: https://issues.apache.org/jira/browse/FLINK-27161 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27160) Add e2e tests for FlinkSessionJob type

2022-04-10 Thread Aitozi (Jira)
Aitozi created FLINK-27160: -- Summary: Add e2e tests for FlinkSessionJob type Key: FLINK-27160 URL: https://issues.apache.org/jira/browse/FLINK-27160 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-26871) Handle Session job spec change

2022-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26871: --- Labels: pull-request-available (was: ) > Handle Session job spec change >

[GitHub] [flink-kubernetes-operator] Aitozi opened a new pull request, #164: [FLINK-26871] Handle session job spec change

2022-04-10 Thread GitBox
Aitozi opened a new pull request, #164: URL: https://github.com/apache/flink-kubernetes-operator/pull/164 This PR is meant to support the upgrade/trigger savepoint for the session job. The brief change as below: - Complete the `FlinkSessionJobReconciler` to handle spec change -

[GitHub] [flink] flinkbot commented on pull request #19417: [FLINK-20060][Connectors / Kinesis] Add a Collector to KinsesisDeserializationSchema

2022-04-10 Thread GitBox
flinkbot commented on PR #19417: URL: https://github.com/apache/flink/pull/19417#issuecomment-1094569830 ## CI report: * 90ae89ff5e1d9e66e0a1e898da3fc85ad50cf04e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-20060) Add a Collector to KinsesisDeserializationSchema

2022-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20060: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

[GitHub] [flink] blake-wilson opened a new pull request, #19417: [FLINK-20060][Connectors / Kinesis] Add a Collector to KinsesisDeserializationSchema

2022-04-10 Thread GitBox
blake-wilson opened a new pull request, #19417: URL: https://github.com/apache/flink/pull/19417 https://issues.apache.org/jira/browse/FLINK-20060 ## What is the purpose of the change Enables specifying a `DeserializationSchema` for the `KinesisConsumer` which uses a

[GitHub] [flink-table-store] tsreaper opened a new pull request, #88: [hotfix] Add logs to file store compact for better tunning

2022-04-10 Thread GitBox
tsreaper opened a new pull request, #88: URL: https://github.com/apache/flink-table-store/pull/88 Currently there is not enough log in `CompactManager`, for example what files are being compacted, what are their sizes, etc. This PR adds logs to file store compact for better tunning. --

[jira] [Commented] (FLINK-27151) Group By Aggregation With Sorted Data

2022-04-10 Thread Karthik (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520304#comment-17520304 ] Karthik commented on FLINK-27151: - yes, when I send data to agg_udf  it is not processed in the order.

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #87: [FLINK-27123] Introduce filter predicate for 'LIKE'

2022-04-10 Thread GitBox
JingsongLi commented on code in PR #87: URL: https://github.com/apache/flink-table-store/pull/87#discussion_r846932171 ## flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ReadWriteTableITCase.java: ## @@ -211,7 +212,7 @@ public void

[jira] [Commented] (FLINK-27145) The code generated for agg function accepts empty parameters can't be compiled

2022-04-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520293#comment-17520293 ] Jingsong Lee commented on FLINK-27145: -- [~luoyuxia] Thanks > The code generated for agg function

[jira] [Assigned] (FLINK-27145) The code generated for agg function accepts empty parameters can't be compiled

2022-04-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-27145: Assignee: luoyuxia > The code generated for agg function accepts empty parameters can't

[jira] [Assigned] (FLINK-26465) Optimize SortMergeReader: use loser tree to reduce comparisons

2022-04-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26465: Assignee: Aiden Gong > Optimize SortMergeReader: use loser tree to reduce comparisons >

[jira] [Commented] (FLINK-26465) Optimize SortMergeReader: use loser tree to reduce comparisons

2022-04-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520292#comment-17520292 ] Jingsong Lee commented on FLINK-26465: -- [~Aiden Gong] Thanks, assigned to u, maybe this one is not

[jira] [Updated] (FLINK-27123) Introduce filter predicate for 'LIKE'

2022-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27123: --- Labels: pull-request-available (was: ) > Introduce filter predicate for 'LIKE' >

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #87: [FLINK-27123] Introduce filter predicate for 'LIKE'

2022-04-10 Thread GitBox
JingsongLi commented on code in PR #87: URL: https://github.com/apache/flink-table-store/pull/87#discussion_r846922818 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/Like.java: ## @@ -0,0 +1,90 @@ +/* + * Licensed to the Apache Software

[jira] [Created] (FLINK-27159) Support first_value/last_value in the Table API

2022-04-10 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-27159: Summary: Support first_value/last_value in the Table API Key: FLINK-27159 URL: https://issues.apache.org/jira/browse/FLINK-27159 Project: Flink Issue Type:

[jira] [Commented] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

2022-04-10 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520289#comment-17520289 ] Yi Tang commented on FLINK-25238: - Thanks [~martijnvisser], i'll close the PR for 1.13. > flink iceberg

[GitHub] [flink] yittg closed pull request #19385: [FLINK-25238][BP-1.13][table-runtime] Fix ArrayDataSerializer#copy for customi…

2022-04-10 Thread GitBox
yittg closed pull request #19385: [FLINK-25238][BP-1.13][table-runtime] Fix ArrayDataSerializer#copy for customi… URL: https://github.com/apache/flink/pull/19385 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-27130) unable to pass custom System properties through command line

2022-04-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520285#comment-17520285 ] Yang Wang commented on FLINK-27130: --- The "-m yarn-cluster" should be used along with "-yD xxx=yyy".

[jira] [Comment Edited] (FLINK-25867) [ZH] Add ChangelogBackend documentation

2022-04-10 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520284#comment-17520284 ] Feifan Wang edited comment on FLINK-25867 at 4/11/22 3:08 AM: -- Thanks

[jira] [Commented] (FLINK-25867) [ZH] Add ChangelogBackend documentation

2022-04-10 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520284#comment-17520284 ] Feifan Wang commented on FLINK-25867: - Thanks [~masteryhx] , and note that I just updated the pr to

[jira] [Closed] (FLINK-27157) Add version field to manifest entries

2022-04-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27157. Resolution: Fixed master: 7e1fa387474a4a2983d5c46422f53636e64aa478 > Add version field to

[GitHub] [flink-table-store] JingsongLi merged pull request #85: [FLINK-27157] Add version field to manifest entries

2022-04-10 Thread GitBox
JingsongLi merged PR #85: URL: https://github.com/apache/flink-table-store/pull/85 -- 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:

[jira] [Commented] (FLINK-27153) Allow optional last-state fallback for savepoint upgrade mode

2022-04-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520277#comment-17520277 ] Yang Wang commented on FLINK-27153: --- Do you think we could reuse the {{savepointTriggerNonce}} to

[jira] [Closed] (FLINK-26897) Provide an additional way to add dependency files to k8s

2022-04-10 Thread liuzhuo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhuo closed FLINK-26897. --- Resolution: Not A Problem > Provide an additional way to add dependency files to k8s >

[jira] [Closed] (FLINK-27139) FileStoreCommitImpl#filterCommitted should exit when faced with expired files

2022-04-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27139. Resolution: Fixed master: 9d9b38ef5fa0a09f3dd396fb6a718b467900ce22 >

[GitHub] [flink-table-store] JingsongLi merged pull request #84: [FLINK-27139] FileStoreCommitImpl#filterCommitted should exit when faced with expired files

2022-04-10 Thread GitBox
JingsongLi merged PR #84: URL: https://github.com/apache/flink-table-store/pull/84 -- 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:

[jira] [Closed] (FLINK-27158) Adjust default value of compaction and compress

2022-04-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27158. Resolution: Fixed master: de66c5c1177d16ccbc47ac519adee437627d9e1d > Adjust default value of

[GitHub] [flink-table-store] JingsongLi merged pull request #86: [FLINK-27158] Adjust default value of compaction and compress

2022-04-10 Thread GitBox
JingsongLi merged PR #86: URL: https://github.com/apache/flink-table-store/pull/86 -- 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:

[jira] [Updated] (FLINK-27130) unable to pass custom System properties through command line

2022-04-10 Thread Adrian Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian Zhong updated FLINK-27130: - Description: I'm using Flink YARN-PER-JOB mode to submit a job. I'm wondering what is wrong,

[jira] [Updated] (FLINK-27130) unable to pass custom System properties through command line

2022-04-10 Thread Adrian Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian Zhong updated FLINK-27130: - Summary: unable to pass custom System properties through command line (was: unable to read

[jira] [Updated] (FLINK-27130) unable to read custom System properties in job class

2022-04-10 Thread Adrian Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian Zhong updated FLINK-27130: - Description: I'm using Flink YARN-PER-JOB mode to submit a job. I'm wondering what is wrong,

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #86: [FLINK-27158] Adjust default value of compaction and compress

2022-04-10 Thread GitBox
JingsongLi commented on code in PR #86: URL: https://github.com/apache/flink-table-store/pull/86#discussion_r846903121 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/orc/OrcFileFormatFactory.java: ## @@ -31,7 +32,19 @@ public String identifier() {

[jira] [Updated] (FLINK-27158) Adjust default value of compaction and compress

2022-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27158: --- Labels: pull-request-available (was: ) > Adjust default value of compaction and compress >

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #86: [FLINK-27158] Adjust default value of compaction and compress

2022-04-10 Thread GitBox
JingsongLi opened a new pull request, #86: URL: https://github.com/apache/flink-table-store/pull/86 - By default, numLevels = numSortedRunMax + 1, this ensures that the compaction does not fall to level 0, but at least to level 1 - orc default compress is lz4, zlib is too slow -- This

[jira] [Created] (FLINK-27158) Adjust default value of compaction and compress

2022-04-10 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27158: Summary: Adjust default value of compaction and compress Key: FLINK-27158 URL: https://issues.apache.org/jira/browse/FLINK-27158 Project: Flink Issue Type:

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a diff in pull request #160: [FLINK-27124] Flink Kubernetes operator prints starting logs with wrong version

2022-04-10 Thread GitBox
wangyang0918 commented on code in PR #160: URL: https://github.com/apache/flink-kubernetes-operator/pull/160#discussion_r846895737 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EnvUtils.java: ## @@ -68,4 +97,113 @@ public static String

[jira] [Commented] (FLINK-27151) Group By Aggregation With Sorted Data

2022-04-10 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520268#comment-17520268 ] zoucao commented on FLINK-27151: Do you mean ’agg_udf(field) WITHIN GROUP (ORDER BY field [ASC | DESC])‘

[jira] [Commented] (FLINK-25470) Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization size

2022-04-10 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520267#comment-17520267 ] Hangxiang Yu commented on FLINK-25470: -- I think we may don't need to expose these changelog metics

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-10 Thread GitBox
yunfengzhou-hub commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r846885979 ## flink-ml-lib/src/test/java/org/apache/flink/ml/feature/VectorAssemblerTest.java: ## @@ -141,10 +140,11 @@ public void testErrorInvalid() { Table

[jira] [Commented] (FLINK-25867) [ZH] Add ChangelogBackend documentation

2022-04-10 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520265#comment-17520265 ] Hangxiang Yu commented on FLINK-25867: -- [~ym] Of course not. I will take a look soon. > [ZH] Add

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-10 Thread GitBox
zhipeng93 commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r846892103 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/bucketizer/Bucketizer.java: ## @@ -0,0 +1,179 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-10 Thread GitBox
zhipeng93 commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r846892103 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/bucketizer/Bucketizer.java: ## @@ -0,0 +1,179 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Updated] (FLINK-27157) Add version field to manifest entries

2022-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27157: --- Labels: pull-request-available (was: ) > Add version field to manifest entries >

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #85: [FLINK-27157] Add version field to manifest entries

2022-04-10 Thread GitBox
JingsongLi opened a new pull request, #85: URL: https://github.com/apache/flink-table-store/pull/85 Metadata related format should be added to the version field for better forward compatibility in the future. -- This is an automated message from the Apache Git Service. To respond

[jira] [Created] (FLINK-27157) Add version field to manifest entries

2022-04-10 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27157: Summary: Add version field to manifest entries Key: FLINK-27157 URL: https://issues.apache.org/jira/browse/FLINK-27157 Project: Flink Issue Type: Sub-task

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-10 Thread GitBox
zhipeng93 commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r846890813 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoderParams.java: ## @@ -27,6 +27,8 @@ /** * Params of OneHotEncoderModel. * + * The

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-10 Thread GitBox
zhipeng93 commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r846890706 ## flink-ml-core/src/main/java/org/apache/flink/ml/param/ArrayArrayParam.java: ## @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + *

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-10 Thread GitBox
yunfengzhou-hub commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r846884071 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/bucketizer/Bucketizer.java: ## @@ -0,0 +1,179 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-10 Thread GitBox
yunfengzhou-hub commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r846883248 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/bucketizer/Bucketizer.java: ## @@ -0,0 +1,179 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-10 Thread GitBox
yunfengzhou-hub commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r846882710 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoderParams.java: ## @@ -27,6 +27,8 @@ /** * Params of OneHotEncoderModel. * +

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-10 Thread GitBox
yunfengzhou-hub commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r846882100 ## flink-ml-core/src/main/java/org/apache/flink/ml/param/ArrayArrayParam.java: ## @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink] yittg commented on pull request #19385: [FLINK-25238][BP-1.13][table-runtime] Fix ArrayDataSerializer#copy for customi…

2022-04-10 Thread GitBox
yittg commented on PR #19385: URL: https://github.com/apache/flink/pull/19385#issuecomment-1094441246 @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.

[GitHub] [flink-kubernetes-operator] SteNicholas commented on a diff in pull request #161: [FLINK-27141] Improve FlinkService#waitForClusterShutdown logic

2022-04-10 Thread GitBox
SteNicholas commented on code in PR #161: URL: https://github.com/apache/flink-kubernetes-operator/pull/161#discussion_r846865468 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -207,7 +213,10 @@ public static void

[GitHub] [flink-kubernetes-operator] SteNicholas commented on a diff in pull request #161: [FLINK-27141] Improve FlinkService#waitForClusterShutdown logic

2022-04-10 Thread GitBox
SteNicholas commented on code in PR #161: URL: https://github.com/apache/flink-kubernetes-operator/pull/161#discussion_r846865468 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -207,7 +213,10 @@ public static void

[jira] [Updated] (FLINK-26048) Yarn access should be separated by semicolon

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26048: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-25884) PulsarSourceITCase.testTaskManagerFailure failed on azure

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25884: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-5601) Window operator does not checkpoint watermarks

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5601: -- Labels: auto-deprioritized-critical auto-deprioritized-major auto-unassigned

[jira] [Updated] (FLINK-10886) Event time synchronization across sources

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10886: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-10896) Extend state schema evolution support for more types

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10896: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-11852) Improve Processing function example

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11852: --- Labels: auto-unassigned pull-request-available stale-minor (was: auto-unassigned

[jira] [Updated] (FLINK-25416) Build unified Parquet BulkFormat for both Table API and DataStream API

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25416: --- Labels: Umbrella stale-assigned (was: Umbrella) I am the [Flink Jira

[jira] [Updated] (FLINK-22955) lookup join filter push down result to mismatch function signature

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22955: --- Labels: auto-deprioritized-critical auto-deprioritized-major (was:

[jira] [Updated] (FLINK-11746) Add thrift format support in Flink

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11746: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor

[jira] [Updated] (FLINK-7958) Allow reporters to override the default delimiter

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7958: -- Labels: auto-unassigned pull-request-available stale-minor (was: auto-unassigned

[jira] [Updated] (FLINK-12256) Implement Confluent Schema Registry Catalog

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12256: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-11747) Elasticsearch 6 connector - Expose RestHighLevelClient to allow for custom sniffing

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11747: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-12395) Add more detailed javadoc for getDescription() and getDetailedDescription() in catalog object interfaces

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12395: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15550: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #161: [FLINK-27141] Improve FlinkService#waitForClusterShutdown logic

2022-04-10 Thread GitBox
gyfora commented on code in PR #161: URL: https://github.com/apache/flink-kubernetes-operator/pull/161#discussion_r846827058 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -207,7 +213,10 @@ public static void

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #162: [FLINK-27029] DeploymentValidator should take default flink config into account during validation

2022-04-10 Thread GitBox
gyfora commented on code in PR #162: URL: https://github.com/apache/flink-kubernetes-operator/pull/162#discussion_r846826594 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilder.java: ## @@ -241,7 +244,9 @@ private static

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #163: [FLINK-27154] Disable web.cancel.enable for application clusters

2022-04-10 Thread GitBox
gyfora commented on code in PR #163: URL: https://github.com/apache/flink-kubernetes-operator/pull/163#discussion_r846826436 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilder.java: ## @@ -100,16 +101,22 @@ public

[GitHub] [flink-statefun] mans2singh opened a new pull request, #311: [hotfix][statefun][function-type] Updated parameter description

2022-04-10 Thread GitBox
mans2singh opened a new pull request, #311: URL: https://github.com/apache/flink-statefun/pull/311 The javadoc param description is ...namespace the function type's **namepsace**... Changed it to ...namespace the function type's **namespace**... -- This is an automated message from the

[jira] [Commented] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-10 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520195#comment-17520195 ] Feifan Wang commented on FLINK-27155: - Thanks for further clarification [~ym] , I also agree to

[GitHub] [flink] RocMarshal commented on pull request #19403: [FLINK-27120][docs-zh] Translate "Gradle" tab of development > conf > overview

2022-04-10 Thread GitBox
RocMarshal commented on PR #19403: URL: https://github.com/apache/flink/pull/19403#issuecomment-1094300997 > Thanks for your guide @RocMarshal ! I hive committed all of your suggestion. Need I squash those commit into one ? Cool~ @zoltar9264 . Please let me have a final check

[jira] [Commented] (FLINK-25867) [ZH] Add ChangelogBackend documentation

2022-04-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520190#comment-17520190 ] Yuan Mei commented on FLINK-25867: -- [~masteryhx]  Would you mind help reviewing this? > [ZH] Add

[jira] [Comment Edited] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520188#comment-17520188 ] Yuan Mei edited comment on FLINK-27155 at 4/10/22 3:29 PM: --- Hey [~Feifan Wang]

[jira] [Commented] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520188#comment-17520188 ] Yuan Mei commented on FLINK-27155: -- Hey [~Feifan Wang] , by "{+}Indeed, downloading the same files

[jira] [Commented] (FLINK-27156) [FLIP-171] MongoDB implementation of Async Sink

2022-04-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520176#comment-17520176 ] Martijn Visser commented on FLINK-27156: [~almogtavor] Thanks for opening the ticket. Please be

[GitHub] [flink] zoltar9264 commented on pull request #19403: [FLINK-27120][docs-zh] Translate "Gradle" tab of development > conf > overview

2022-04-10 Thread GitBox
zoltar9264 commented on PR #19403: URL: https://github.com/apache/flink/pull/19403#issuecomment-1094286030 Thanks for your guide @RocMarshal ! I hive committed all of your suggestion. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] RocMarshal commented on a diff in pull request #19403: [FLINK-27120][docs-zh] Translate "Gradle" tab of development > conf > overview

2022-04-10 Thread GitBox
RocMarshal commented on code in PR #19403: URL: https://github.com/apache/flink/pull/19403#discussion_r846785106 ## docs/content.zh/docs/dev/configuration/overview.md: ## @@ -36,39 +36,44 @@ specific language governing permissions and limitations under the License. --> +

[jira] [Commented] (FLINK-26465) Optimize SortMergeReader: use loser tree to reduce comparisons

2022-04-10 Thread Aiden Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520170#comment-17520170 ] Aiden Gong commented on FLINK-26465: Hi,[~lzljs3620320] .I have interest in this issue,May I try?

[jira] [Updated] (FLINK-12770) Make number of bulk concurrentRequests configurable

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12770: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-14116) Translate changes on Getting Started Overview to Chinese

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14116: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-13611) Introduce analyze statistic utility to generate table & column statistics

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13611: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-12499) JDBCAppendTableSink support retry

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12499: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-14079) Full data type support in planner

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14079: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-12470) FLIP39: Flink ML pipeline and ML libs

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12470: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-14184) Provide a stage listener API to be invoked per task manager

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14184: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14364: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-14625) Eliminate cross join in multi join to reduce cost

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14625: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-13194) Add explicit clarification about thread-safety of state in document

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13194: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-14521) CoLocationGroup is not set into JobVertex if the stream node is chained with others

2022-04-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14521: --- Labels: auto-deprioritized-major pull-request-available stale-minor (was:

[jira] [Commented] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-10 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520132#comment-17520132 ] Feifan Wang commented on FLINK-27155: - [~ym] , I'm a little confused about "{+}Indeed, downloading

[jira] [Commented] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-10 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520129#comment-17520129 ] Feifan Wang commented on FLINK-27155: - Thanks for reply [~ym] , I've also noticed that local

[jira] [Comment Edited] (FLINK-27155) Reduce multiple reads to the same Changelog file in the same taskmanager during restore

2022-04-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520127#comment-17520127 ] Yuan Mei edited comment on FLINK-27155 at 4/10/22 9:41 AM: --- Hey [~Feifan Wang]

[GitHub] [flink] Thesharing commented on pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-04-10 Thread GitBox
Thesharing commented on PR #19275: URL: https://github.com/apache/flink/pull/19275#issuecomment-1094229021 @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

[GitHub] [flink] zoltar9264 commented on a diff in pull request #19403: [FLINK-27120][docs-zh] Translate "Gradle" tab of development > conf > overview

2022-04-10 Thread GitBox
zoltar9264 commented on code in PR #19403: URL: https://github.com/apache/flink/pull/19403#discussion_r846747681 ## docs/content.zh/docs/dev/configuration/overview.md: ## @@ -85,25 +86,31 @@ plugins { // artifact properties group = 'org.quickstart' version = '0.1-SNAPSHOT'

  1   2   >