[GitHub] [flink] zuston commented on pull request #15653: [FLINK-22329][hive] Inject current ugi credentials into jobconf when getting file split in hive connector

2021-04-19 Thread GitBox
zuston commented on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-822990758 Gentle ping~ @wuchong @wangyang0918 @lirui-apache -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-22327) NPE exception happens if it throws exception in finishBundle during job shutdown

2021-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22327: Fix Version/s: (was: 1.13.1) (was: 1.14.0) 1.13.0 > NPE

[jira] [Updated] (FLINK-22339) Fix some encoding exceptions were not thrown in cython coders

2021-04-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22339: Fix Version/s: (was: 1.13.1) (was: 1.14.0) 1.13.0 > Fix

[GitHub] [flink] zuston commented on pull request #15624: [FLINK-22294][hive] Hive reading fail when getting file numbers on different filesystem nameservices

2021-04-19 Thread GitBox
zuston commented on pull request #15624: URL: https://github.com/apache/flink/pull/15624#issuecomment-822989558 Will merge? @lirui-apache -- 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

[GitHub] [flink] curcur commented on pull request #15636: [FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-19 Thread GitBox
curcur commented on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-822987125 I've done with the tests as well. -- 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

[jira] [Resolved] (FLINK-22160) Test Window TVF based aggregation and TopN

2021-04-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-22160. Resolution: Resolved > Test Window TVF based aggregation and TopN >

[jira] [Commented] (FLINK-22160) Test Window TVF based aggregation and TopN

2021-04-19 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325479#comment-17325479 ] Leonard Xu commented on FLINK-22160: * Tested TUMBLE/HOP/CUMULATE TVF in Sql-Client, the result is

[GitHub] [flink] SteNicholas commented on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

2021-04-19 Thread GitBox
SteNicholas commented on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-822984976 @XComp @wangyang0918 I have followed the detailed review comments. Please help to review the update of the pull request. -- This is an automated message from the Apache

[GitHub] [flink] SteNicholas removed a comment on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

2021-04-19 Thread GitBox
SteNicholas removed a comment on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-819508156 @XComp @wangyang0918 I have followed the detailed review comments. Please help to review the update of the pull request. -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #15595: [FLINK-22171][sql-client][docs] Update the SQL Client doc

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15595: URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408 ## CI report: * b7a82f07683d5a76f6743d68cb4cd174c0453bca UNKNOWN * 0b78a5c66116de0181cc645da264115b4b1ee79c Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #15642: [FLINK-22159][FLINK-22302][docs][table] Restructure SQL "Queries" pages and add docs for the new window TVF based operations

2021-04-19 Thread GitBox
leonardBang commented on a change in pull request #15642: URL: https://github.com/apache/flink/pull/15642#discussion_r616316388 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-tvf.md ## @@ -0,0 +1,264 @@ +--- +title: "窗口函数" +weight: 6 +type: docs +--- + + +#

[GitHub] [flink] flinkbot edited a comment on pull request #15670: [FLINK-22346][sql-client] Remove sql-client-defaults.yaml

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15670: URL: https://github.com/apache/flink/pull/15670#issuecomment-822351871 ## CI report: * 76e54259c49220ecb75209c378d289bfbca6533a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15595: [FLINK-22171][sql-client][docs] Update the SQL Client doc

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15595: URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408 ## CI report: * b7a82f07683d5a76f6743d68cb4cd174c0453bca UNKNOWN * 0b78a5c66116de0181cc645da264115b4b1ee79c Azure:

[GitHub] [flink] dianfu commented on pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

2021-04-19 Thread GitBox
dianfu commented on pull request #15681: URL: https://github.com/apache/flink/pull/15681#issuecomment-822975464 @YikSanChan :) -- 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] [Commented] (FLINK-22365) Images are not displayed in "Data Sources" documentation page

2021-04-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325471#comment-17325471 ] Jark Wu commented on FLINK-22365: - cc [~sjwiesman] > Images are not displayed in "Data Sources"

[jira] [Created] (FLINK-22365) Images are not displayed in "Data Sources" documentation page

2021-04-19 Thread Jark Wu (Jira)
Jark Wu created FLINK-22365: --- Summary: Images are not displayed in "Data Sources" documentation page Key: FLINK-22365 URL: https://issues.apache.org/jira/browse/FLINK-22365 Project: Flink Issue

[jira] [Assigned] (FLINK-22364) Translate the page of "Data Sources" to Chinese.

2021-04-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22364: --- Assignee: Senhong Liu > Translate the page of "Data Sources" to Chinese. >

[GitHub] [flink] wuchong commented on a change in pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

2021-04-19 Thread GitBox
wuchong commented on a change in pull request #15658: URL: https://github.com/apache/flink/pull/15658#discussion_r616333796 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java ## @@ -174,27 +209,264 @@ public static void

[GitHub] [flink] flinkbot edited a comment on pull request #15670: [FLINK-22346][sql-client] Remove sql-client-defaults.yaml

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15670: URL: https://github.com/apache/flink/pull/15670#issuecomment-822351871 ## CI report: * 76e54259c49220ecb75209c378d289bfbca6533a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15682: [FLINK-22297][python] Perform early validation for the result of Pand…

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15682: URL: https://github.com/apache/flink/pull/15682#issuecomment-822960773 ## CI report: * 4efbadb337e2779683970225793633a3edb7a4b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15683: [FLINK-22362]Don't appear target address when taskmanager connect to jobmanager error

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15683: URL: https://github.com/apache/flink/pull/15683#issuecomment-822960823 ## CI report: * c31947044463827b662c8239d630b52fdad3eca1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15595: [FLINK-22171][sql-client][docs] Update the SQL Client doc

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15595: URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408 ## CI report: * b7a82f07683d5a76f6743d68cb4cd174c0453bca UNKNOWN * 0b78a5c66116de0181cc645da264115b4b1ee79c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14894: [FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #14894: URL: https://github.com/apache/flink/pull/14894#issuecomment-774905432 ## CI report: * 8b5155d221e948da1d3919162cea2f8cfcb92d19 Azure:

[jira] [Commented] (FLINK-22364) Translate the page of "Data Sources" to Chinese.

2021-04-19 Thread Senhong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325464#comment-17325464 ] Senhong Liu commented on FLINK-22364: - [~jark] Could you please assign this ticket to me? >

[GitHub] [flink] godfreyhe commented on a change in pull request #14484: [FLINK-20722][hive] HiveTableSink should copy the record when convert…

2021-04-19 Thread GitBox
godfreyhe commented on a change in pull request #14484: URL: https://github.com/apache/flink/pull/14484#discussion_r616333752 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/MultipleInputStreamOperatorBase.java

[jira] [Commented] (FLINK-22361) flink run -c not upload udf jar

2021-04-19 Thread todd (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325462#comment-17325462 ] todd commented on FLINK-22361: -- yarn.ship-files is a parameter of version 1.12. In addition,

[jira] [Created] (FLINK-22364) Translate the page of "Data Sources" to Chinese.

2021-04-19 Thread Senhong Liu (Jira)
Senhong Liu created FLINK-22364: --- Summary: Translate the page of "Data Sources" to Chinese. Key: FLINK-22364 URL: https://issues.apache.org/jira/browse/FLINK-22364 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #15683: [FLINK-22362]Don't appear target address when taskmanager connect to jobmanager error

2021-04-19 Thread GitBox
flinkbot commented on pull request #15683: URL: https://github.com/apache/flink/pull/15683#issuecomment-822960823 ## CI report: * c31947044463827b662c8239d630b52fdad3eca1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15682: [FLINK-22297][python] Perform early validation for the result of Pand…

2021-04-19 Thread GitBox
flinkbot commented on pull request #15682: URL: https://github.com/apache/flink/pull/15682#issuecomment-822960773 ## CI report: * 4efbadb337e2779683970225793633a3edb7a4b5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15680: [FLINK-22359][python] Reset version to 1.13-SNAPSHOT

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15680: URL: https://github.com/apache/flink/pull/15680#issuecomment-822928365 ## CI report: * 71c256a205b987a867e86e47505968db9fccc81f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15681: URL: https://github.com/apache/flink/pull/15681#issuecomment-822948644 ## CI report: * cb7fcc6d2c4a66793756112e9d2c83eb83d222e2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15657: [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler.

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15657: URL: https://github.com/apache/flink/pull/15657#issuecomment-822150567 ## CI report: * 16939921d94de5421c6cb8453c5a9158a40bee4a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14894: [FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #14894: URL: https://github.com/apache/flink/pull/14894#issuecomment-774905432 ## CI report: * 8b5155d221e948da1d3919162cea2f8cfcb92d19 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14880: [FLINK-21302][table-planner-blink] Fix NPE when use row_number() in over agg

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #14880: URL: https://github.com/apache/flink/pull/14880#issuecomment-774029330 ## CI report: * 4b1a437943dbf05b91590eed252f8ba83f14cdb9 Azure:

[jira] [Closed] (FLINK-22363) Python test pipeline failed because of failure of downloading deps.

2021-04-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-22363. - Fix Version/s: 1.13.0 Resolution: Duplicate > Python test pipeline failed because of failure of

[jira] [Commented] (FLINK-22363) Python test pipeline failed because of failure of downloading deps.

2021-04-19 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325457#comment-17325457 ] Guowei Ma commented on FLINK-22363: ---

[jira] [Created] (FLINK-22363) Python test pipeline failed because of failure of downloading deps.

2021-04-19 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22363: - Summary: Python test pipeline failed because of failure of downloading deps. Key: FLINK-22363 URL: https://issues.apache.org/jira/browse/FLINK-22363 Project: Flink

[GitHub] [flink] 1996fanrui commented on a change in pull request #15667: Reduce the delete file api when the checkpoint is completed. [FLINK-…

2021-04-19 Thread GitBox
1996fanrui commented on a change in pull request #15667: URL: https://github.com/apache/flink/pull/15667#discussion_r616324659 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java ## @@ -291,6 +306,33 @@ public boolean

[jira] [Updated] (FLINK-20896) Support SupportsAggregatePushDown for JDBC TableSource

2021-04-19 Thread Sebastian Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Liu updated FLINK-20896: -- Labels: (was: stale-assigned) > Support SupportsAggregatePushDown for JDBC TableSource >

[jira] [Commented] (FLINK-20896) Support SupportsAggregatePushDown for JDBC TableSource

2021-04-19 Thread Sebastian Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325455#comment-17325455 ] Sebastian Liu commented on FLINK-20896: --- Still working on this, pending in other subtasks. >

[jira] [Updated] (FLINK-20895) Support LocalAggregatePushDown in Blink planner

2021-04-19 Thread Sebastian Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Liu updated FLINK-20895: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > Support

[jira] [Commented] (FLINK-20895) Support LocalAggregatePushDown in Blink planner

2021-04-19 Thread Sebastian Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325453#comment-17325453 ] Sebastian Liu commented on FLINK-20895: --- Updated the PR, still working on this. > Support

[GitHub] [flink] sebastianliu commented on pull request #14894: [FLINK-20895][flink-table-planner-blink] support local aggregate push down in blink planner

2021-04-19 Thread GitBox
sebastianliu commented on pull request #14894: URL: https://github.com/apache/flink/pull/14894#issuecomment-822950848 @godfreyhe @wuchong Hi, sorry that the push of this feature is delayed for some reasons. I will follow up this ASAP. I have introduced an `AggregatePushDownSpec `. Hope

[jira] [Commented] (FLINK-22361) flink run -c not upload udf jar

2021-04-19 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325452#comment-17325452 ] Yang Wang commented on FLINK-22361: --- If you want to ship jars/files, then you should use 

[jira] [Updated] (FLINK-22361) flink run -c not upload udf jar

2021-04-19 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-22361: -- Priority: Minor (was: Blocker) > flink run -c not upload udf jar > --- >

[jira] [Updated] (FLINK-22362) Don't appear target address when taskmanager connect to jobmanager error

2021-04-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22362: --- Labels: pull-request-available (was: ) > Don't appear target address when taskmanager

[GitHub] [flink] YikSanChan commented on pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

2021-04-19 Thread GitBox
YikSanChan commented on pull request #15681: URL: https://github.com/apache/flink/pull/15681#issuecomment-822948988 @dianfu This is great! -- 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

[GitHub] [flink] flinkbot commented on pull request #15683: [FLINK-22362]Don't appear target address when taskmanager connect to jobmanager error

2021-04-19 Thread GitBox
flinkbot commented on pull request #15683: URL: https://github.com/apache/flink/pull/15683#issuecomment-822948893 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

2021-04-19 Thread GitBox
flinkbot commented on pull request #15681: URL: https://github.com/apache/flink/pull/15681#issuecomment-822948644 ## CI report: * cb7fcc6d2c4a66793756112e9d2c83eb83d222e2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15680: [FLINK-22359][python] Reset version to 1.13-SNAPSHOT

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15680: URL: https://github.com/apache/flink/pull/15680#issuecomment-822928365 ## CI report: * 71c256a205b987a867e86e47505968db9fccc81f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15657: [FLINK-22335][runtime][config] Increase default resource wait timeout for the adaptive scheduler.

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15657: URL: https://github.com/apache/flink/pull/15657#issuecomment-822150567 ## CI report: * 16939921d94de5421c6cb8453c5a9158a40bee4a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15636: [FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-820725807 ## CI report: * f9e372fc6d647b67af6c8ce1c4962c46e9bcf785 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN *

[GitHub] [flink] gentlewangyu opened a new pull request #15683: Don't appear target address when taskmanager connect to jobmanager error

2021-04-19 Thread GitBox
gentlewangyu opened a new pull request #15683: URL: https://github.com/apache/flink/pull/15683 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[GitHub] [flink] flinkbot commented on pull request #15682: [FLINK-22297][python] Perform early validation for the result of Pand…

2021-04-19 Thread GitBox
flinkbot commented on pull request #15682: URL: https://github.com/apache/flink/pull/15682#issuecomment-822947649 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #14880: [FLINK-21302][table-planner-blink] Fix NPE when use row_number() in over agg

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #14880: URL: https://github.com/apache/flink/pull/14880#issuecomment-774029330 ## CI report: * 4b1a437943dbf05b91590eed252f8ba83f14cdb9 Azure:

[GitHub] [flink] dianfu opened a new pull request #15682: [FLINK-22297][python] Perform early validation for the result of Pand…

2021-04-19 Thread GitBox
dianfu opened a new pull request #15682: URL: https://github.com/apache/flink/pull/15682 ## What is the purpose of the change *This pull request performs early validation for the result of Pandas UDF, e.g. ensure the result length is equal to the input length, validates the result

[GitHub] [flink] flinkbot commented on pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

2021-04-19 Thread GitBox
flinkbot commented on pull request #15681: URL: https://github.com/apache/flink/pull/15681#issuecomment-822945162 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

2021-04-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22297: --- Labels: pull-request-available (was: ) > Perform early check to ensure that the length of

[GitHub] [flink] dianfu opened a new pull request #15681: [FLINK-22297][python] Perform early validation for the result of Pandas UDF

2021-04-19 Thread GitBox
dianfu opened a new pull request #15681: URL: https://github.com/apache/flink/pull/15681 ## What is the purpose of the change *This pull request performs early validation for the result of Pandas UDF, e.g. ensure the result length is equal to the input length, validates the

[GitHub] [flink] flinkbot edited a comment on pull request #15680: [FLINK-22359][python] Reset version to 1.13-SNAPSHOT

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15680: URL: https://github.com/apache/flink/pull/15680#issuecomment-822928365 ## CI report: * 71c256a205b987a867e86e47505968db9fccc81f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15658: URL: https://github.com/apache/flink/pull/15658#issuecomment-822156568 ## CI report: * 3fb642a0baf02d20af8ed2fcccae8493205f1e66 Azure:

[jira] [Created] (FLINK-22362) Don't appear target address when taskmanager connect to jobmanager error

2021-04-19 Thread Yu Wang (Jira)
Yu Wang created FLINK-22362: --- Summary: Don't appear target address when taskmanager connect to jobmanager error Key: FLINK-22362 URL: https://issues.apache.org/jira/browse/FLINK-22362 Project: Flink

[jira] [Closed] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

2021-04-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22338. Resolution: Fixed release-1.13: 5d4b451c6146a8a0470f4c17c76caa0411dbeffd > Clear watermark

[jira] [Assigned] (FLINK-22338) Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

2021-04-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22338: Assignee: Shengkai Fang > Clear watermark output when test finished for >

[GitHub] [flink] JingsongLi merged pull request #15672: [FLINK-22338][table-planner] Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

2021-04-19 Thread GitBox
JingsongLi merged pull request #15672: URL: https://github.com/apache/flink/pull/15672 -- 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. For queries about this service,

[jira] [Commented] (FLINK-22021) PushFilterIntoLegacyTableSourceScanRule fails to deal with INTERVAL types

2021-04-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325436#comment-17325436 ] Jingsong Lee commented on FLINK-22021: -- release-1.12: 8c146a5610a6438326789cf57390154e8f749329 >

[GitHub] [flink] JingsongLi merged pull request #15615: [FLINK-22021][table-planner-blink] Fix exception when PushFilterIntoLegacyTableSourceScanRule is faced with INTERVAL types

2021-04-19 Thread GitBox
JingsongLi merged pull request #15615: URL: https://github.com/apache/flink/pull/15615 -- 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. For queries about this service,

[GitHub] [flink] fsk119 commented on pull request #15672: [FLINK-22338][table-planner] Clear watermark output when test finished for FromElementSourceFunctionWithWatermark

2021-04-19 Thread GitBox
fsk119 commented on pull request #15672: URL: https://github.com/apache/flink/pull/15672#issuecomment-822937383 The failed test is not related to the PR. -- 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] [Updated] (FLINK-22092) HiveConf can cache hiveSiteURL from classpath and cause FileNotFoundException

2021-04-19 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-22092: --- Summary: HiveConf can cache hiveSiteURL from classpath and cause FileNotFoundException (was: Prevent

[GitHub] [flink] JingsongLi merged pull request #15483: [FLINK-22092][hive] Ignore static conf file URLs in HiveConf

2021-04-19 Thread GitBox
JingsongLi merged pull request #15483: URL: https://github.com/apache/flink/pull/15483 -- 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. For queries about this service,

[jira] [Commented] (FLINK-21073) Mention that RocksDB ignores equals/hashCode because it works on binary data

2021-04-19 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325429#comment-17325429 ] Yun Tang commented on FLINK-21073: -- Merged in master: 653811c70895f13f04b8c86fbd9b80d0c0c9a69e

[jira] [Resolved] (FLINK-21073) Mention that RocksDB ignores equals/hashCode because it works on binary data

2021-04-19 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-21073. -- Resolution: Fixed > Mention that RocksDB ignores equals/hashCode because it works on binary data >

[jira] [Created] (FLINK-22361) flink run -c not upload udf jar

2021-04-19 Thread todd (Jira)
todd created FLINK-22361: Summary: flink run -c not upload udf jar Key: FLINK-22361 URL: https://issues.apache.org/jira/browse/FLINK-22361 Project: Flink Issue Type: Bug Components:

[GitHub] [flink] Myasuka merged pull request #15527: [FLINK-21073][docs] Mention that RocksDB would ignore java's equals/hashCode during comparing objects

2021-04-19 Thread GitBox
Myasuka merged pull request #15527: URL: https://github.com/apache/flink/pull/15527 -- 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. For queries about this service,

[GitHub] [flink] flinkbot commented on pull request #15680: [FLINK-22359][python] Reset version to 1.13-SNAPSHOT

2021-04-19 Thread GitBox
flinkbot commented on pull request #15680: URL: https://github.com/apache/flink/pull/15680#issuecomment-822928365 ## CI report: * 71c256a205b987a867e86e47505968db9fccc81f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15658: [FLINK-18206][table-api / sql-client] Fix the incorrect timestamp display

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15658: URL: https://github.com/apache/flink/pull/15658#issuecomment-822156568 ## CI report: * 3fb642a0baf02d20af8ed2fcccae8493205f1e66 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-817508957 ## CI report: * 85afc0e14a28cdf84f44a2013306e3257421 Azure:

[jira] [Assigned] (FLINK-22359) Python tests do not pass on 1.x branch if it has not been released

2021-04-19 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-22359: Assignee: Huang Xingbo > Python tests do not pass on 1.x branch if it has not been

[jira] [Commented] (FLINK-22359) Python tests do not pass on 1.x branch if it has not been released

2021-04-19 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325421#comment-17325421 ] Huang Xingbo commented on FLINK-22359: -- The problem comes in updating the version in version.py

[GitHub] [flink] wuchong commented on a change in pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

2021-04-19 Thread GitBox
wuchong commented on a change in pull request #13011: URL: https://github.com/apache/flink/pull/13011#discussion_r616298791 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java ## @@ -1293,6 +1328,121 @@

[GitHub] [flink] flinkbot commented on pull request #15680: [FLINK-22359][python] Reset version to 1.13-SNAPSHOT

2021-04-19 Thread GitBox
flinkbot commented on pull request #15680: URL: https://github.com/apache/flink/pull/15680#issuecomment-822922791 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22359) Python tests do not pass on 1.x branch if it has not been released

2021-04-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22359: --- Labels: pull-request-available (was: ) > Python tests do not pass on 1.x branch if it has

[GitHub] [flink] HuangXingBo opened a new pull request #15680: [FLINK-22359][python] Reset version to 1.13-SNAPSHOT

2021-04-19 Thread GitBox
HuangXingBo opened a new pull request #15680: URL: https://github.com/apache/flink/pull/15680 ## What is the purpose of the change *This pull request will reset version to 1.13-SNAPSHOT in `version.py`* ## Brief change log - *Remove the logic of updating

[GitHub] [flink] flinkbot edited a comment on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

2021-04-19 Thread GitBox
flinkbot edited a comment on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-817508957 ## CI report: * 85afc0e14a28cdf84f44a2013306e3257421 Azure:

[jira] [Commented] (FLINK-20695) Zookeeper node under leader and leaderlatch is not deleted after job finished

2021-04-19 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325415#comment-17325415 ] Yi Tang commented on FLINK-20695: - [~trohrmann] how to remove the stale label ? I added a github

[jira] [Updated] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN

2021-04-19 Thread Andy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-22038: - Labels: (was: stale-assigned) > Update TopN node to be without rowNumber if rowNumber field is projected out

[jira] [Closed] (FLINK-22351) Promote the log level of the resource declaration to INFO in FineGrainedSlotManager

2021-04-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-22351. Fix Version/s: (was: 1.14.0) 1.13.0 Resolution: Fixed Merged via -

[GitHub] [flink] xintongsong commented on pull request #15669: [FLINK-22351][coordination] Promote resource declaration log to INFO …

2021-04-19 Thread GitBox
xintongsong commented on pull request #15669: URL: https://github.com/apache/flink/pull/15669#issuecomment-822913511 Merged via - master (1.14): 98019fd622f1ed9459e49c88a9f16d43927a895e - release-1.13: 123c1c4d1ea97c9614f838523ad7757e00dff359 -- This is an automated message from

[GitHub] [flink] xintongsong closed pull request #15669: [FLINK-22351][coordination] Promote resource declaration log to INFO …

2021-04-19 Thread GitBox
xintongsong closed pull request #15669: URL: https://github.com/apache/flink/pull/15669 -- 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. For queries about this service,

[GitHub] [flink] yittg commented on pull request #15561: [FLINK-20695][ha] Clean up ha data for job if globally terminated

2021-04-19 Thread GitBox
yittg commented on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-822911265 @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] [Updated] (FLINK-22098) Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

2021-04-19 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22098: --- Fix Version/s: 1.14.0 > Fix bug for window join: plan is wrong if join condition contain 'IS NOT >

[GitHub] [flink] fsk119 commented on pull request #15670: [FLINK-22346][sql-client] Remove sql-client-defaults.yaml

2021-04-19 Thread GitBox
fsk119 commented on pull request #15670: URL: https://github.com/apache/flink/pull/15670#issuecomment-822910587 The failed reason is ``` Apr 19 15:44:35 Warning Failed 16s (x3 over 59s) kubelet Failed to pull image "test_kubernetes_pyflink_application": rpc

[jira] [Commented] (FLINK-18199) Translate "Filesystem SQL Connector" page into Chinese

2021-04-19 Thread michaelli (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325410#comment-17325410 ] michaelli commented on FLINK-18199: --- Actually there is already a pull request available on this issue.

[jira] [Updated] (FLINK-17117) There are an useless cast operation for sql on blink when generate code

2021-04-19 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17117: --- Component/s: (was: Table SQL / Planner) Table SQL / Runtime > There are an

[jira] [Commented] (FLINK-8513) Add documentation for connecting to non-AWS S3 endpoints

2021-04-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325378#comment-17325378 ] Flink Jira Bot commented on FLINK-8513: --- This issue is assigned but has not received an update in 7

[jira] [Updated] (FLINK-22029) Remove "Task", "Wish" and "Test" Issue Types

2021-04-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22029: --- Labels: stale-assigned (was: ) > Remove "Task", "Wish" and "Test" Issue Types >

[jira] [Commented] (FLINK-1939) Add Parquet Documentation to Wiki

2021-04-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325385#comment-17325385 ] Flink Jira Bot commented on FLINK-1939: --- This issue is assigned but has not received an update in 7

[jira] [Commented] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties

2021-04-19 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325384#comment-17325384 ] Flink Jira Bot commented on FLINK-4627: --- This issue is assigned but has not received an update in 7

  1   2   3   4   5   6   7   >