[GitHub] [flink] swuferhong commented on pull request #20596: [FLINK-28993][table-planner] Fix adjusting join cost for dpp query pattern error

2022-08-21 Thread GitBox
swuferhong commented on PR #20596: URL: https://github.com/apache/flink/pull/20596#issuecomment-1221874291 @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] flinkbot commented on pull request #20646: [hotfix][docs] Fix ./build_docs.sh error caused by elasticsearch page not exists

2022-08-21 Thread GitBox
flinkbot commented on PR #20646: URL: https://github.com/apache/flink/pull/20646#issuecomment-1221873030 ## CI report: * b50b5bdd209c396756443b0d85007c1ae9992626 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] swuferhong opened a new pull request, #20646: [hotfix][docs] Fix ./build_docs.sh error caused by elasticsearch page not exists

2022-08-21 Thread GitBox
swuferhong opened a new pull request, #20646: URL: https://github.com/apache/flink/pull/20646 ## What is the purpose of the change When I ran `./build_docs.sh` in folder `docs` to build localhost web page as required by `docs/readme.md`. An error that ` page not

[jira] [Closed] (FLINK-29033) Add timestamp to operator resource listener context

2022-08-21 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29033. -- Resolution: Fixed merged to main 964bedefc1e600c5a45ecc007494cd531300 > Add timestamp to

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #350: [FLINK-29033] Expose timestamp in resource listener context

2022-08-21 Thread GitBox
gyfora merged PR #350: URL: https://github.com/apache/flink-kubernetes-operator/pull/350 -- 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] [Created] (FLINK-29052) Support TO_TIMESTAMP built-in function in Table API

2022-08-21 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-29052: - Summary: Support TO_TIMESTAMP built-in function in Table API Key: FLINK-29052 URL: https://issues.apache.org/jira/browse/FLINK-29052 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #20645: [FLINK-29051[Quickstarts] Move dependency-reduced-pom to target folder

2022-08-21 Thread GitBox
flinkbot commented on PR #20645: URL: https://github.com/apache/flink/pull/20645#issuecomment-1221852969 ## CI report: * 6a87ff598207d26cf084cbff478828fff3e3bd2b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29051) Put dependency-reduced pom for quickstart in target folder

2022-08-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29051: --- Labels: pull-request-available (was: ) > Put dependency-reduced pom for quickstart in

[GitHub] [flink] snuyanzin opened a new pull request, #20645: [FLINK-29051[Quickstarts] Move dependency-reduced-pom to target folder

2022-08-21 Thread GitBox
snuyanzin opened a new pull request, #20645: URL: https://github.com/apache/flink/pull/20645 ## What is the purpose of the change This is a trivial PR to move dependecy-reduced poms to target folder to avoid it's appearance in `git diff ` ## Brief change log quickstart pom

[jira] [Created] (FLINK-29051) Put dependency-reduced pom for quickstart in target folder

2022-08-21 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29051: --- Summary: Put dependency-reduced pom for quickstart in target folder Key: FLINK-29051 URL: https://issues.apache.org/jira/browse/FLINK-29051 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #20644: Support TO_TIMESTAMP built-in function in Table API

2022-08-21 Thread GitBox
flinkbot commented on PR #20644: URL: https://github.com/apache/flink/pull/20644#issuecomment-1221834826 ## CI report: * 23b71e3d53003248cb7817c9303e45630181fd1b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] hehuiyuan opened a new pull request, #20644: Support TO_TIMESTAMP built-in function in Table API

2022-08-21 Thread GitBox
hehuiyuan opened a new pull request, #20644: URL: https://github.com/apache/flink/pull/20644 ## What is the purpose of the change Support TO_TIMESTAMP built-in function in Table API. ## Brief change log Support TO_TIMESTAMP built-in functions in Table API. Support

[GitHub] [flink] luoyuxia commented on pull request #18975: [FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant pass

2022-08-21 Thread GitBox
luoyuxia commented on PR #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1221777826 @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 #20549: [FLINK-28883][hive] Fix HiveTableSink failed to report statistic to hive metastore in batch mode

2022-08-21 Thread GitBox
luoyuxia commented on PR #20549: URL: https://github.com/apache/flink/pull/20549#issuecomment-1221777112 @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 #20549: [FLINK-28883][hive] Fix HiveTableSink failed to report statistic to hive metastore in batch mode

2022-08-21 Thread GitBox
luoyuxia commented on PR #20549: URL: https://github.com/apache/flink/pull/20549#issuecomment-1221776939 @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] bzhaoopenstack commented on pull request #20642: [FLINK-29047][k8s] Shade fabric8 kubernetes with org.apache.flink.shaded prefix in flink-kubernetes

2022-08-21 Thread GitBox
bzhaoopenstack commented on PR #20642: URL: https://github.com/apache/flink/pull/20642#issuecomment-1221774647 @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] bzhaoopenstack commented on pull request #20636: [FLINK-28831][k8s]Support pluginable decorators mechanism - part 1st

2022-08-21 Thread GitBox
bzhaoopenstack commented on PR #20636: URL: https://github.com/apache/flink/pull/20636#issuecomment-1221774507 @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-ml] zhipeng93 commented on a diff in pull request #142: [FLINK-28943] Add Transformer and Estimator for MaxAbsScaler

2022-08-21 Thread GitBox
zhipeng93 commented on code in PR #142: URL: https://github.com/apache/flink-ml/pull/142#discussion_r950988727 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/maxabsscaler/MaxAbsScalerModel.java: ## @@ -0,0 +1,169 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] bzhaoopenstack commented on pull request #20193: [WIP][FLINK-28433][connector/jdbc]Add mariadb jdbc connection validation

2022-08-21 Thread GitBox
bzhaoopenstack commented on PR #20193: URL: https://github.com/apache/flink/pull/20193#issuecomment-1221772980 Sorry for late update. ;-) . Let's wait the azure test result. I got pass on my local env. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on pull request #20643: [FLINK-29013][hive] Fix fail to use BinaryRecordReader in "transform using" syntax with Hive dialect

2022-08-21 Thread GitBox
flinkbot commented on PR #20643: URL: https://github.com/apache/flink/pull/20643#issuecomment-1221769686 ## CI report: * b49504483a7936132ef72a368e57ec442ebde659 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29013) Fail to use "transform using" when record reader is binary record reader in Hive dialect

2022-08-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29013: --- Labels: pull-request-available (was: ) > Fail to use "transform using" when record reader

[GitHub] [flink] luoyuxia opened a new pull request, #20643: [FLINK-29013][hive] Fix fail to use BinaryRecordReader in "transform using" syntax with Hive dialect

2022-08-21 Thread GitBox
luoyuxia opened a new pull request, #20643: URL: https://github.com/apache/flink/pull/20643 ## What is the purpose of the change To fix fail to use BinaryRecordReader in "transform using" syntax with Hive dialect. ## Brief change log - While reading the data

[GitHub] [flink] swuferhong commented on a diff in pull request #20506: [FLINK-28493][docs] Add document to describe "ANALYZE TABLE" syntax

2022-08-21 Thread GitBox
swuferhong commented on code in PR #20506: URL: https://github.com/apache/flink/pull/20506#discussion_r950988794 ## docs/content/docs/dev/table/sql/analyze.md: ## @@ -0,0 +1,371 @@ +--- +title: "ANALYZE Statements" +weight: 8 +type: docs +aliases: + -

[jira] [Commented] (FLINK-29038) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed with AssertionError

2022-08-21 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582716#comment-17582716 ] lincoln lee commented on FLINK-29038: - The failure record is the last input record of test data, it

[jira] [Commented] (FLINK-29013) Fail to use "transform using" when record reader is binary record reader in Hive dialect

2022-08-21 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582715#comment-17582715 ] luoyuxia commented on FLINK-29013: -- To fix it, we should first call RecordReader#createRow just like

[GitHub] [flink] swuferhong commented on a diff in pull request #20506: [FLINK-28493][docs] Add document to describe "ANALYZE TABLE" syntax

2022-08-21 Thread GitBox
swuferhong commented on code in PR #20506: URL: https://github.com/apache/flink/pull/20506#discussion_r950985483 ## docs/content/docs/dev/table/sql/analyze.md: ## @@ -0,0 +1,365 @@ +--- +title: "ANALYZE TABLE Statements" +weight: 8 +type: docs +aliases: + -

[GitHub] [flink] swuferhong commented on a diff in pull request #20506: [FLINK-28493][docs] Add document to describe "ANALYZE TABLE" syntax

2022-08-21 Thread GitBox
swuferhong commented on code in PR #20506: URL: https://github.com/apache/flink/pull/20506#discussion_r950985564 ## docs/content/docs/dev/table/sql/analyze.md: ## @@ -0,0 +1,365 @@ +--- +title: "ANALYZE TABLE Statements" +weight: 8 +type: docs +aliases: + -

[GitHub] [flink] swuferhong commented on a diff in pull request #20506: [FLINK-28493][docs] Add document to describe "ANALYZE TABLE" syntax

2022-08-21 Thread GitBox
swuferhong commented on code in PR #20506: URL: https://github.com/apache/flink/pull/20506#discussion_r950985388 ## docs/content/docs/dev/table/sql/analyze.md: ## @@ -0,0 +1,371 @@ +--- +title: "ANALYZE Statements" +weight: 8 +type: docs +aliases: + -

[jira] [Updated] (FLINK-28988) Incorrect result for filter after temporal join

2022-08-21 Thread Xuannan Su (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuannan Su updated FLINK-28988: --- Description: The following code can reproduce the case   {code:java} public class

[GitHub] [flink] luoyuxia commented on pull request #18975: [FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant pass

2022-08-21 Thread GitBox
luoyuxia commented on PR #18975: URL: https://github.com/apache/flink/pull/18975#issuecomment-1221743113 @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 #20549: [FLINK-28883][hive] Fix HiveTableSink failed to report statistic to hive metastore in batch mode

2022-08-21 Thread GitBox
luoyuxia commented on PR #20549: URL: https://github.com/apache/flink/pull/20549#issuecomment-1221742080 @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] godfreyhe commented on pull request #20596: [FLINK-28993][table-planner] Fix adjusting join cost for dpp query pattern error

2022-08-21 Thread GitBox
godfreyhe commented on PR #20596: URL: https://github.com/apache/flink/pull/20596#issuecomment-1221736274 @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] godfreyhe commented on a diff in pull request #20506: [FLINK-28493][docs] Add document to describe "ANALYZE TABLE" syntax

2022-08-21 Thread GitBox
godfreyhe commented on code in PR #20506: URL: https://github.com/apache/flink/pull/20506#discussion_r950973426 ## docs/content/docs/dev/table/sql/analyze.md: ## @@ -0,0 +1,371 @@ +--- +title: "ANALYZE Statements" +weight: 8 +type: docs +aliases: + -

[jira] [Closed] (FLINK-28992) Change Ndv takes the max value instead of sum of all partitions when getting partition table column stats

2022-08-21 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-28992. -- Resolution: Fixed Fixed in master: 10e4c82902164f2651d73f018393f930dcef55a8 > Change Ndv takes the

[jira] [Assigned] (FLINK-28992) Change Ndv takes the max value instead of sum of all partitions when getting partition table column stats

2022-08-21 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-28992: -- Assignee: Yunhong Zheng > Change Ndv takes the max value instead of sum of all partitions

[GitHub] [flink] godfreyhe closed pull request #20595: [FLINK-28992][table-planner] fix: Change Ndv takes the max value instead of sum of all partitions when getting partition table column stats

2022-08-21 Thread GitBox
godfreyhe closed pull request #20595: [FLINK-28992][table-planner] fix: Change Ndv takes the max value instead of sum of all partitions when getting partition table column stats URL: https://github.com/apache/flink/pull/20595 -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] link3280 commented on pull request #20159: [FLINK-28360][SQL Client] Support stop job statement in SQL client

2022-08-21 Thread GitBox
link3280 commented on PR #20159: URL: https://github.com/apache/flink/pull/20159#issuecomment-1221708160 ping @fsk119 -- 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

[jira] [Closed] (FLINK-29049) Remove the deprecated classes in the flink-java module.

2022-08-21 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal closed FLINK-29049. -- Resolution: Duplicate > Remove the deprecated classes in the flink-java module. >

[jira] [Commented] (FLINK-28985) support create table like view

2022-08-21 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582684#comment-17582684 ] waywtdcc commented on FLINK-28985: -- 嗨,[~jark]   > support create table like view >

[GitHub] [flink] RocMarshal commented on pull request #20641: [FLINK-29049] Remove the deprecated classes in the flink-java module.

2022-08-21 Thread GitBox
RocMarshal commented on PR #20641: URL: https://github.com/apache/flink/pull/20641#issuecomment-1221703403 Closed it. @snuyanzin -- 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] RocMarshal closed pull request #20641: [FLINK-29049] Remove the deprecated classes in the flink-java module.

2022-08-21 Thread GitBox
RocMarshal closed pull request #20641: [FLINK-29049] Remove the deprecated classes in the flink-java module. URL: https://github.com/apache/flink/pull/20641 -- 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

[jira] [Commented] (FLINK-29046) HiveTableSourceStatisticsReportTest fails with Hadoop 3

2022-08-21 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582682#comment-17582682 ] Huang Xingbo commented on FLINK-29046: --

[jira] [Commented] (FLINK-29046) HiveTableSourceStatisticsReportTest fails with Hadoop 3

2022-08-21 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582683#comment-17582683 ] Huang Xingbo commented on FLINK-29046: -- [~337361...@qq.com] Could you help take a look? Thx. >

[GitHub] [flink] dianfu commented on pull request #20638: [FLINK-28439][table][python] [backport]Support SUBSTR and REGEXP built-in function in Table API

2022-08-21 Thread GitBox
dianfu commented on PR #20638: URL: https://github.com/apache/flink/pull/20638#issuecomment-1221702532 @hehuiyuan Hey, per my understanding, we don't necessary to backport this to Flink 1.15 as it's not a bug. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-29046) HiveTableSourceStatisticsReportTest fails with Hadoop 3

2022-08-21 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-29046: - Description: {code:java} 2022-08-19T13:35:56.1882498Z Aug 19 13:35:56 [ERROR]

[jira] [Updated] (FLINK-29046) HiveTableSourceStatisticsReportTest fails with Hadoop 3

2022-08-21 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-29046: - Priority: Critical (was: Major) > HiveTableSourceStatisticsReportTest fails with Hadoop 3 >

[jira] [Updated] (FLINK-29028) Add the missing cache api in Python DataStream API

2022-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29028: Component/s: (was: Documentation) > Add the missing cache api in Python DataStream API >

[jira] [Closed] (FLINK-29028) Add the missing cache api in Python DataStream API

2022-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-29028. --- Resolution: Fixed Merged to master via 97519d1683f3f5f086ce613d59aa5ba46cf38a30 > Add the missing cache

[GitHub] [flink] dianfu closed pull request #20618: [FLINK-29028][python][doc] Add the missing cache api in Python DataStream API

2022-08-21 Thread GitBox
dianfu closed pull request #20618: [FLINK-29028][python][doc] Add the missing cache api in Python DataStream API URL: https://github.com/apache/flink/pull/20618 -- 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-28972) Add methods of StartCursor and StopCursor to align the Java

2022-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582680#comment-17582680 ] Dian Fu commented on FLINK-28972: - Merged to master via 77ea6638f150d1e261e6bd703a06282ebd2e9176 > Add

[jira] [Closed] (FLINK-28972) Add methods of StartCursor and StopCursor to align the Java

2022-08-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28972. --- Fix Version/s: (was: 1.14.6) (was: 1.15.3) Assignee: Luning Wang

[GitHub] [flink] dianfu closed pull request #20589: [FLINK-28972][python][connector/pulsar] Align Start/StopCursor method to java

2022-08-21 Thread GitBox
dianfu closed pull request #20589: [FLINK-28972][python][connector/pulsar] Align Start/StopCursor method to java URL: https://github.com/apache/flink/pull/20589 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] bzhaoopenstack commented on pull request #20642: [FLINK-29047][k8s] Shade fabric8 kubernetes with org.apache.flink.shaded prefix in flink-kubernetes

2022-08-21 Thread GitBox
bzhaoopenstack commented on PR #20642: URL: https://github.com/apache/flink/pull/20642#issuecomment-1221672835 @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] bzhaoopenstack commented on pull request #20636: [FLINK-28831][k8s]Support pluginable decorators mechanism - part 1st

2022-08-21 Thread GitBox
bzhaoopenstack commented on PR #20636: URL: https://github.com/apache/flink/pull/20636#issuecomment-1221672379 @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] swuferhong commented on pull request #20596: [FLINK-28993][table-planner] Fix adjusting join cost for dpp query pattern error

2022-08-21 Thread GitBox
swuferhong commented on PR #20596: URL: https://github.com/apache/flink/pull/20596#issuecomment-1221671919 @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-ml] lindong28 merged pull request #144: [FLINK-29043] Reduce HeadOperator overhead

2022-08-21 Thread GitBox
lindong28 merged PR #144: URL: https://github.com/apache/flink-ml/pull/144 -- 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:

[GitHub] [flink-ml] lindong28 commented on pull request #144: [FLINK-29043] Reduce HeadOperator overhead

2022-08-21 Thread GitBox
lindong28 commented on PR #144: URL: https://github.com/apache/flink-ml/pull/144#issuecomment-1221660910 Thanks for the update. LGTM. -- 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

[jira] [Updated] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

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

[jira] [Updated] (FLINK-25469) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown fails on AZP

2022-08-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25469: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-27741) Fix NPE when use dense_rank() and rank() in over aggregation

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

[jira] [Updated] (FLINK-25814) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond failed due to stop-with-savepoint failed

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

[jira] [Updated] (FLINK-25877) Update the copyright year in NOTICE files

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

[jira] [Updated] (FLINK-25211) Elasticsearch connector version compatibility

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

[jira] [Updated] (FLINK-25164) DogStatsD Metrics Reporter

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

[jira] [Updated] (FLINK-27241) Support DROP PARTITION statement for partitioned table

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

[jira] [Updated] (FLINK-27164) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper failed on azure

2022-08-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27164: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-27240) Support ADD PARTITION statement for partitioned table

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

[jira] [Updated] (FLINK-27603) Hive dialect supports "reload function"

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

[jira] [Updated] (FLINK-27850) Hive dialect supports "add file xxx"

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

[jira] [Updated] (FLINK-28399) Refactor CheckedThread to accept runnable via constructor

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

[jira] [Updated] (FLINK-27291) Translate the "List of Data Types" section of "Data Types" in to Chinese

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

[jira] [Updated] (FLINK-27242) Support RENAME PARTITION statement for partitioned table

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

[jira] [Updated] (FLINK-27859) Hive dialect should support create table whose name begins with digits

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

[jira] [Updated] (FLINK-27243) Support SHOW PARTITIONS statement for partitioned table

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

[jira] [Updated] (FLINK-27857) Hive source support filter push down for orc format

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

[jira] [Updated] (FLINK-28515) The files in local recovery directory hasn't be clean up properly after checkpoint abort

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

[jira] [Commented] (FLINK-28915) Flink Native k8s mode jar localtion support s3 schema

2022-08-21 Thread hjw (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582588#comment-17582588 ] hjw commented on FLINK-28915: - [~wangyang0918] Could you tell more about how to use the credential for

[GitHub] [flink] atris commented on pull request #20187: [FLINK-27473] Introduce Generic Metrics For Job States

2022-08-21 Thread GitBox
atris commented on PR #20187: URL: https://github.com/apache/flink/pull/20187#issuecomment-1221583085 @zentol Ping. Please let me know your thoughts and comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

2022-08-21 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582569#comment-17582569 ] João Boto commented on FLINK-25421: --- Hi [~RocMarshal], sorry for late response... I don't have the

[GitHub] [flink] flinkbot commented on pull request #20642: [FLINK-29047][k8s] Shade fabric8 kubernetes with org.apache.flink.shaded prefix in flink-kubernetes

2022-08-21 Thread GitBox
flinkbot commented on PR #20642: URL: https://github.com/apache/flink/pull/20642#issuecomment-1221562438 ## CI report: * 78eb40c702450a389ccae05f9cab415344f707bc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Resolved] (FLINK-28832) [4] Upgrade Fabric8 to the latest version

2022-08-21 Thread bo zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bo zhao resolved FLINK-28832. - Resolution: Fixed > [4] Upgrade Fabric8 to the latest version >

[jira] [Updated] (FLINK-29047) [3.1] Shade the Flink-Kubernetes Fabric8 Kubernetes dependency with org.apache.flink.shaded prefix

2022-08-21 Thread bo zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bo zhao updated FLINK-29047: Summary: [3.1] Shade the Flink-Kubernetes Fabric8 Kubernetes dependency with org.apache.flink.shaded

[jira] [Updated] (FLINK-29047) [4.1] Shade the Flink-Kubernetes Fabric8 Kubernetes dependency with org.apache.flink.shaded prefix

2022-08-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29047: --- Labels: pull-request-available (was: ) > [4.1] Shade the Flink-Kubernetes Fabric8

[GitHub] [flink] bzhaoopenstack opened a new pull request, #20642: [FLINK-29047][k8s] Shade fabric8 kubernetes with org.apache.flink.shaded prefix in flink-kubernetes

2022-08-21 Thread GitBox
bzhaoopenstack opened a new pull request, #20642: URL: https://github.com/apache/flink/pull/20642 Shade the fabric8 kubernetes deps with `org.apache.flink.shaded` prefix in flink-kubernetes ## What is the purpose of the change For supporting stepDecorators SPI(pluginable

[GitHub] [flink-table-store] HannanKan opened a new pull request, #270: [FLINK-27626] Introduce pre-aggregated merge to table store

2022-08-21 Thread GitBox
HannanKan opened a new pull request, #270: URL: https://github.com/apache/flink-table-store/pull/270 https://issues.apache.org/jira/browse/FLINK-27626 -- 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

[jira] [Updated] (FLINK-29047) [4.1] Shade the Flink-Kubernetes Fabric8 Kubernetes dependency with org.apache.flink.shaded prefix

2022-08-21 Thread bo zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bo zhao updated FLINK-29047: Summary: [4.1] Shade the Flink-Kubernetes Fabric8 Kubernetes dependency with org.apache.flink.shaded

[jira] [Commented] (FLINK-29049) Remove the deprecated classes in the flink-java module.

2022-08-21 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17582565#comment-17582565 ] Sergey Nuyanzin commented on FLINK-29049: - this is a duplicate of 

[GitHub] [flink] snuyanzin commented on pull request #20641: [FLINK-29049] Remove the deprecated classes in the flink-java module.

2022-08-21 Thread GitBox
snuyanzin commented on PR #20641: URL: https://github.com/apache/flink/pull/20641#issuecomment-1221557793 this is a duplicate of https://github.com/apache/flink/pull/18440 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] RocMarshal commented on pull request #20641: [FLINK-29049] Remove the deprecated classes in the flink-java module.

2022-08-21 Thread GitBox
RocMarshal commented on PR #20641: URL: https://github.com/apache/flink/pull/20641#issuecomment-1221556554 @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

[jira] [Created] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility

2022-08-21 Thread RocMarshal (Jira)
RocMarshal created FLINK-29050: -- Summary: [JUnit5 Migration] Module: flink-hadoop-compatibility Key: FLINK-29050 URL: https://issues.apache.org/jira/browse/FLINK-29050 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #20641: [FLINK-29049] Remove the deprecated classes in the flink-java module.

2022-08-21 Thread GitBox
flinkbot commented on PR #20641: URL: https://github.com/apache/flink/pull/20641#issuecomment-1221549335 ## CI report: * bf966fe40ed853f73738f0eaf42d2c91f83f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29049) Remove the deprecated classes in the flink-java module.

2022-08-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29049: --- Labels: pull-request-available (was: ) > Remove the deprecated classes in the flink-java

[GitHub] [flink] RocMarshal opened a new pull request, #20641: [FLINK-29049] Remove the deprecated classes in the flink-java module.

2022-08-21 Thread GitBox
RocMarshal opened a new pull request, #20641: URL: https://github.com/apache/flink/pull/20641 ## What is the purpose of the change *Remove the deprecated classes in the flink-java module.* ## Brief change log Remove -

[jira] [Created] (FLINK-29049) Remove the deprecated classes in the flink-java module.

2022-08-21 Thread RocMarshal (Jira)
RocMarshal created FLINK-29049: -- Summary: Remove the deprecated classes in the flink-java module. Key: FLINK-29049 URL: https://issues.apache.org/jira/browse/FLINK-29049 Project: Flink Issue

[GitHub] [flink] liuzhuang2017 commented on pull request #20640: [hotfix][docs] Fix some formatting errors in Chinese documents.

2022-08-21 Thread GitBox
liuzhuang2017 commented on PR #20640: URL: https://github.com/apache/flink/pull/20640#issuecomment-1221508104 @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] flinkbot commented on pull request #20640: [hotfix][docs] Fix some formatting errors in Chinese documents.

2022-08-21 Thread GitBox
flinkbot commented on PR #20640: URL: https://github.com/apache/flink/pull/20640#issuecomment-1221500202 ## CI report: * 1e1a059cb6d50ba1e72e199a28d119798109e108 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20640: [hotfix][docs] Fix some formatting errors in Chinese documents.

2022-08-21 Thread GitBox
liuzhuang2017 opened a new pull request, #20640: URL: https://github.com/apache/flink/pull/20640 ## What is the purpose of the change - **In english document:** ![image](https://user-images.githubusercontent.com/95120044/185782776-13544e12-f1c5-4510-8a1f-02b4b0c1b3ab.png)

[jira] [Closed] (FLINK-29048) WatermarksWithIdleness does not work with FLIP-27 sources

2022-08-21 Thread Lee Y S (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Y S closed FLINK-29048. --- Resolution: Duplicate > WatermarksWithIdleness does not work with FLIP-27 sources >

[jira] [Created] (FLINK-29048) WatermarksWithIdleness does not work with FLIP-27 sources

2022-08-21 Thread Lee Y S (Jira)
Lee Y S created FLINK-29048: --- Summary: WatermarksWithIdleness does not work with FLIP-27 sources Key: FLINK-29048 URL: https://issues.apache.org/jira/browse/FLINK-29048 Project: Flink Issue Type: