[jira] [Created] (FLINK-27162) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure

2022-04-10 Thread Yun Gao (Jira)
Yun Gao created FLINK-27162: --- Summary: RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure Key: FLINK-27162 URL: https://issues.apache.org/jira/browse/FLINK-27162 Project: F

[GitHub] [flink] yangjunhan commented on pull request #18868: [FLINK-26206][runtime-web] add service layer abstraction and refactor config service

2022-04-10 Thread GitBox
yangjunhan commented on PR #18868: URL: https://github.com/apache/flink/pull/18868#issuecomment-1094622744 @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] luoyuxia commented on pull request #19416: FlinkSQL中创建的表结构信息在SparkSQL中不可见

2022-04-10 Thread GitBox
luoyuxia commented on PR #19416: URL: https://github.com/apache/flink/pull/19416#issuecomment-1094622697 @whitecloud6688 Are you using Hive metastore to store these table? For such case, unfortunately, for the tables other than Hive, the table schema won't store as columns in Hive metastor

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

2022-04-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520333#comment-17520333 ] Gyula Fora commented on FLINK-27153: [~wangyang0918] previously I felt that if the u

[jira] [Commented] (FLINK-27138) flink1.14.0-sql-job submit failed:Flink doesn't support individual window table-valued function TUMBLE

2022-04-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520332#comment-17520332 ] Martijn Visser commented on FLINK-27138: [~shubiao] This is not a bug, that feat

[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_r846993644 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -207,7 +213,10 @@ public static void waitFor

[jira] [Comment Edited] (FLINK-27133) Performance regression in serializerHeavyString

2022-04-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520327#comment-17520327 ] Matthias Pohl edited comment on FLINK-27133 at 4/11/22 6:44 AM: --

[GitHub] [flink] KarmaGYZ commented on a diff in pull request #19380: [FLINK-25055][runtime] Support listen and notify mechanism for partition request

2022-04-10 Thread GitBox
KarmaGYZ commented on code in PR #19380: URL: https://github.com/apache/flink/pull/19380#discussion_r846987716 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionManager.java: ## @@ -104,12 +192,40 @@ public void shutdown() {

[jira] [Comment Edited] (FLINK-27133) Performance regression in serializerHeavyString

2022-04-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520327#comment-17520327 ] Matthias Pohl edited comment on FLINK-27133 at 4/11/22 6:43 AM: --

[jira] [Comment Edited] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520331#comment-17520331 ] Yun Gao edited comment on FLINK-27148 at 4/11/22 6:43 AM: -- With

[jira] [Updated] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-27148: Fix Version/s: (was: 1.15.0) > UnalignedCheckpointITCase fails on AZP > --

[jira] [Commented] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520331#comment-17520331 ] Yun Gao commented on FLINK-27148: - With some checks I think this issue is caused by the

[jira] [Updated] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-27148: Affects Version/s: (was: 1.15.0) > UnalignedCheckpointITCase fails on AZP > --

[GitHub] [flink] luoyuxia commented on pull request #19388: [FLINK-27116][hive] Support reading Hive table partitioned by decimal type

2022-04-10 Thread GitBox
luoyuxia commented on PR #19388: URL: https://github.com/apache/flink/pull/19388#issuecomment-1094610987 @beyond1920 @wuchong @lsyldliu Could you please help review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot commented on pull request #19418: [FLINK-27145][table] Support code gen for aggregate function with empty parameter

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

[jira] [Comment Edited] (FLINK-27133) Performance regression in serializerHeavyString

2022-04-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520327#comment-17520327 ] Matthias Pohl edited comment on FLINK-27133 at 4/11/22 6:37 AM: --

[jira] [Commented] (FLINK-27133) Performance regression in serializerHeavyString

2022-04-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520327#comment-17520327 ] Matthias Pohl commented on FLINK-27133: --- I focused on the following commits in my

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

2022-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27145: --- Labels: pull-request-available (was: ) > The code generated for agg function accepts empty

[GitHub] [flink] luoyuxia commented on pull request #19418: [FLINK-27145][table] Support code gen for aggregate function with empty parameter

2022-04-10 Thread GitBox
luoyuxia commented on PR #19418: URL: https://github.com/apache/flink/pull/19418#issuecomment-1094607480 @JingsongLi Could you please help review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] luoyuxia opened a new pull request, #19418: [FLINK-27145][table] Support code gen for aggregate function with empty parameter

2022-04-10 Thread GitBox
luoyuxia opened a new pull request, #19418: URL: https://github.com/apache/flink/pull/19418 ## What is the purpose of the change Support code gen for aggregate function with empty parameter. Currently, if the aggregate function doesn't have any parameter, the code generated can't

[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_r846977954 ## flink-ml-lib/src/test/java/org/apache/flink/ml/feature/BucketizerTest.java: ## @@ -0,0 +1,190 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under o

[jira] [Commented] (FLINK-27138) flink1.14.0-sql-job submit failed:Flink doesn't support individual window table-valued function TUMBLE

2022-04-10 Thread yanbiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520323#comment-17520323 ] yanbiao commented on FLINK-27138: - hi [~martijnvisser] i have translated it ,other devel

[jira] [Updated] (FLINK-27138) flink1.14.0-sql-job submit failed:Flink doesn't support individual window table-valued function TUMBLE

2022-04-10 Thread yanbiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanbiao updated FLINK-27138: Description: I am working with a standalone deployment of flink-1.14.0-bin-scala_2.11 the package is down

[jira] [Updated] (FLINK-27138) flink1.14.0-sql-job submit failed:Flink doesn't support individual window table-valued function TUMBLE

2022-04-10 Thread yanbiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanbiao updated FLINK-27138: Description: I am working with a standalone deployment of flink-1.14.0-bin-scala_2.11 the package is down

[jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

2022-04-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520317#comment-17520317 ] Dian Fu commented on FLINK-26644: - cc [~hxbks2ks] > python > StreamExecutionEnvironmen

[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_r846975117 ## 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 on

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

2022-04-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-27161: - Assignee: Aitozi > Support user jar from different type of filesystems > --

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

2022-04-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-26871: - Assignee: Aitozi > Handle Session job spec change > --- > >

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

2022-04-10 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520316#comment-17520316 ] Aitozi commented on FLINK-27161: I'm working on this now. > Support user jar from diffe

[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 Gi

[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 Com

[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 - Com

[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: auto

[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 `Collec

[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. -- T

[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&focusedCommentId=17520304#comment-17520304 ] Karthik commented on FLINK-27151: - yes, when I send data to agg_udf  it is not processe

[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 testBatchWrite

[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&focusedCommentId=17520293#comment-17520293 ] Jingsong Lee commented on FLINK-27145: -- [~luoyuxia] Thanks > The code generated fo

[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 b

[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&focusedCommentId=17520292#comment-17520292 ] Jingsong Lee commented on FLINK-26465: -- [~Aiden Gong] Thanks, assigned to u, maybe

[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 Found

[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: S

[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&focusedCommentId=17520289#comment-17520289 ] Yi Tang commented on FLINK-25238: - Thanks [~martijnvisser], i'll close the PR for 1.13.

[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 abo

[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&focusedCommentId=17520285#comment-17520285 ] Yang Wang commented on FLINK-27130: --- The "-m yarn-cluster" should be used along with "

[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&focusedCommentId=17520284#comment-17520284 ] Feifan Wang edited comment on FLINK-25867 at 4/11/22 3:08 AM:

[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&focusedCommentId=17520284#comment-17520284 ] Feifan Wang commented on FLINK-25867: - Thanks [~masteryhx] , and note that I just up

[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 manifes

[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: issues-unsubscr...@fl

[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&focusedCommentId=17520277#comment-17520277 ] Yang Wang commented on FLINK-27153: --- Do you think we could reuse the {{savepointTrigge

[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 > FileStoreCommitImpl#filterCo

[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: issues-unsubscr...@fl

[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 comp

[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: issues-unsubscr...@fl

[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, an

[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 cust

[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, an

[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: S

[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 ge

[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&focusedCommentId=17520268#comment-17520268 ] zoucao commented on FLINK-27151: Do you mean ’agg_udf(field) WITHIN GROUP (ORDER BY fiel

[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&focusedCommentId=17520267#comment-17520267 ] Hangxiang Yu commented on FLINK-25470: -- I think we may don't need to expose these c

[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 out

[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&focusedCommentId=17520265#comment-17520265 ] Hangxiang Yu commented on FLINK-25867: -- [~ym] Of course not. I will take a look soo

[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 on

[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. To

[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 wa

[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 wa

[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 Ji

[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 Bot|https://g

[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 pull-request-avail

[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: auto-deprioritized-major

[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 [Fli

[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 usabilit

[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 pull-reque

[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 Bot|https://github.com

[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: auto-deprioritized-cri

[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 pull-request-

[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: auto-deprioritized-major

[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: a

[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: auto-deprioritize

[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 [Flink

  1   2   >