[GitHub] [flink] wuchong commented on pull request #15383: [FLINK-21702][sql-client]Support option `sql-client.verbose` to print the exception stack

2021-03-26 Thread GitBox
wuchong commented on pull request #15383: URL: https://github.com/apache/flink/pull/15383#issuecomment-808662551 I have helped to rebase and improve the code. Please have a look. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-21997) Add back missing jdbc.md zh docs

2021-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309875#comment-17309875 ] Jark Wu commented on FLINK-21997: - Thanks [~yangsanity] > Add back missing jdbc.md zh docs >

[jira] [Closed] (FLINK-21997) Add back missing jdbc.md zh docs

2021-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21997. --- Resolution: Duplicate > Add back missing jdbc.md zh docs > > >

[GitHub] [flink] wuchong commented on a change in pull request #15383: [FLINK-21702][sql-client]Support option `sql-client.verbose` to print the exception stack

2021-03-26 Thread GitBox
wuchong commented on a change in pull request #15383: URL: https://github.com/apache/flink/pull/15383#discussion_r602673785 ## File path: flink-table/flink-sql-client/src/test/resources/sql/verbose.q ## @@ -0,0 +1,119 @@ +# function.q - CREATE/DROP/ALTER FUNCTION +# +#

[GitHub] [flink] wuchong commented on a change in pull request #15383: [FLINK-21702][sql-client]Support option `sql-client.verbose` to print the exception stack

2021-03-26 Thread GitBox
wuchong commented on a change in pull request #15383: URL: https://github.com/apache/flink/pull/15383#discussion_r602673701 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStrings.java ## @@ -353,13 +354,19 @@ public static

[GitHub] [flink] flinkbot edited a comment on pull request #15394: [hotfix][format] package format-common to flink-csv and flink-json

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15394: URL: https://github.com/apache/flink/pull/15394#issuecomment-808652774 ## CI report: * d12b0de0aa1b7e7ebd697244f2ee8afdac052d44 Azure:

[GitHub] [flink] flinkbot commented on pull request #15394: [hotfix][format] package format-common to flink-csv and flink-json

2021-03-26 Thread GitBox
flinkbot commented on pull request #15394: URL: https://github.com/apache/flink/pull/15394#issuecomment-808652774 ## CI report: * d12b0de0aa1b7e7ebd697244f2ee8afdac052d44 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15394: [hotfix][format] package format-common to flink-csv and flink-json

2021-03-26 Thread GitBox
flinkbot commented on pull request #15394: URL: https://github.com/apache/flink/pull/15394#issuecomment-808651588 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] leonardBang opened a new pull request #15394: [hotfix][format] package format-common to flink-csv and flink-json

2021-03-26 Thread GitBox
leonardBang opened a new pull request #15394: URL: https://github.com/apache/flink/pull/15394 ## What is the purpose of the change * This pull request fix that flink-csv and flink-json does not packaging the format-common moudule ## Brief change log - update the

[jira] [Closed] (FLINK-21463) Unify SQL Client parser and TableEnvironment parser

2021-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21463. --- Assignee: Shengkai Fang Resolution: Fixed Fixed in master: -

[GitHub] [flink] wuchong closed pull request #15315: [FLINK-21463][sql-client] Unify SQL Client Parser and SQL parser

2021-03-26 Thread GitBox
wuchong closed pull request #15315: URL: https://github.com/apache/flink/pull/15315 -- 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 #15315: [FLINK-21463][sql-client] Unify SQL Client Parser and SQL parser

2021-03-26 Thread GitBox
fsk119 commented on pull request #15315: URL: https://github.com/apache/flink/pull/15315#issuecomment-808649027 Thanks for Jark's help. It looks good to me. -- 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] leonardBang commented on pull request #15356: [FLINK-21947][csv] Support TIMESTAMP_LTZ type in CSV format

2021-03-26 Thread GitBox
leonardBang commented on pull request #15356: URL: https://github.com/apache/flink/pull/15356#issuecomment-808648608 @KurtYoung Thank for the merging, but the pipeline is still failed, I lookup it a little, we need to add for-common to `format-csv .jar` and `format-csv.sql-jar.jar` ,

[jira] [Commented] (FLINK-21997) Add back missing jdbc.md zh docs

2021-03-26 Thread jjiey (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309860#comment-17309860 ] jjiey commented on FLINK-21997: --- Hi, [~jark], it's a duplicate issue with 

[GitHub] [flink] wuchong commented on a change in pull request #15383: [FLINK-21702][sql-client]Support option `sql-client.verbose` to print the exception stack

2021-03-26 Thread GitBox
wuchong commented on a change in pull request #15383: URL: https://github.com/apache/flink/pull/15383#discussion_r602665885 ## File path: flink-table/flink-sql-client/src/test/resources/sql/verbose.q ## @@ -0,0 +1,119 @@ +# function.q - CREATE/DROP/ALTER FUNCTION +# +#

[jira] [Created] (FLINK-21997) Add back missing jdbc.md zh docs

2021-03-26 Thread Jark Wu (Jira)
Jark Wu created FLINK-21997: --- Summary: Add back missing jdbc.md zh docs Key: FLINK-21997 URL: https://issues.apache.org/jira/browse/FLINK-21997 Project: Flink Issue Type: Task

[jira] [Comment Edited] (FLINK-21917) Add back missing kafka.md zh docs

2021-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309854#comment-17309854 ] Jark Wu edited comment on FLINK-21917 at 3/27/21, 3:56 AM: --- Fixed in master:

[jira] [Closed] (FLINK-21917) Add back missing kafka.md zh docs

2021-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21917. --- Resolution: Fixed > Add back missing kafka.md zh docs > -- > >

[jira] [Updated] (FLINK-21917) Add back missing kafka.md zh docs

2021-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21917: Summary: Add back missing kafka.md zh docs (was: Add back missing zh docs) > Add back missing kafka.md

[jira] [Commented] (FLINK-21917) Add back missing zh docs

2021-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309854#comment-17309854 ] Jark Wu commented on FLINK-21917: - Fixed in master: - kafka.md:

[GitHub] [flink] wuchong merged pull request #15392: [FLINK-21917][docs] Add back missing zh kafka.md doc

2021-03-26 Thread GitBox
wuchong merged pull request #15392: URL: https://github.com/apache/flink/pull/15392 -- 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-21906) Support computed column syntax for Hive DDL dialect

2021-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309853#comment-17309853 ] Jark Wu commented on FLINK-21906: - Thanks [~hackergin] for willing contribute. I want to point out this

[jira] [Commented] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

2021-03-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309852#comment-17309852 ] Kurt Young commented on FLINK-20412: [~sewen] I will ping Caizhi  > Collect Result Fetching

[GitHub] [flink] flinkbot edited a comment on pull request #15391: [FLINK-21630][python] Support Python UDAF in Session Window

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15391: URL: https://github.com/apache/flink/pull/15391#issuecomment-808283258 ## CI report: * d55091ff03d9749e1be6b240d93b8b63a4a2b7b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15393: [FLINK-21980][Runtime/Coordination] ZooKeeperRunningJobsRegistry creates an empty znode

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15393: URL: https://github.com/apache/flink/pull/15393#issuecomment-808510341 ## CI report: * 1dfe04f95e9bfb8ea2f54c647f9643bfa910ab7e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15379: [FLINK-21984][table-planner] Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15379: URL: https://github.com/apache/flink/pull/15379#issuecomment-807932155 ## CI report: * c8228017e07ff5007c61c37b6fcadccf495a6903 Azure:

[jira] [Commented] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

2021-03-26 Thread jinfeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309850#comment-17309850 ] jinfeng commented on FLINK-21978: - [~ykt836] milliseconds > Disable cast conversion between Numeric

[GitHub] [flink] KurtYoung commented on pull request #15379: [FLINK-21984][table-planner] Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

2021-03-26 Thread GitBox
KurtYoung commented on pull request #15379: URL: https://github.com/apache/flink/pull/15379#issuecomment-808636262 @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

[jira] [Closed] (FLINK-21947) Support TIMESTAMP_LTZ type in CSV format

2021-03-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21947. -- Resolution: Fixed fixed: a5aaa0e605eb4966b5d73c987ea4d9d0bc852c6d > Support TIMESTAMP_LTZ type in

[GitHub] [flink] KurtYoung closed pull request #15356: [FLINK-21947][csv] Support TIMESTAMP_LTZ type in CSV format

2021-03-26 Thread GitBox
KurtYoung closed pull request #15356: URL: https://github.com/apache/flink/pull/15356 -- 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] HuangXingBo commented on pull request #15391: [FLINK-21630][python] Support Python UDAF in Session Window

2021-03-26 Thread GitBox
HuangXingBo commented on pull request #15391: URL: https://github.com/apache/flink/pull/15391#issuecomment-808634518 @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

[GitHub] [flink] flinkbot edited a comment on pull request #15306: [FLINK-21623][table-planner] Introduce CURRENT_ROW_TIMESTAMP() function

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15306: URL: https://github.com/apache/flink/pull/15306#issuecomment-803566547 ## CI report: * 3253705075bf797ece2abbf9f10d998a49c3eb32 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15259: URL: https://github.com/apache/flink/pull/15259#issuecomment-801679503 ## CI report: * a141c0e671be4b72b4a0aae4333ac37094aef85a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15306: [FLINK-21623][table-planner] Introduce CURRENT_ROW_TIMESTAMP() function

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15306: URL: https://github.com/apache/flink/pull/15306#issuecomment-803566547 ## CI report: * 3253705075bf797ece2abbf9f10d998a49c3eb32 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15259: URL: https://github.com/apache/flink/pull/15259#issuecomment-801679503 ## CI report: * a141c0e671be4b72b4a0aae4333ac37094aef85a Azure:

[jira] [Commented] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

2021-03-26 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309842#comment-17309842 ] Kurt Young commented on FLINK-21978: [~hackergin] When you cast timestamp to BIGINT, which precision

[GitHub] [flink] hehuiyuan commented on pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

2021-03-26 Thread GitBox
hehuiyuan commented on pull request #15274: URL: https://github.com/apache/flink/pull/15274#issuecomment-808627343 @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 specific

[GitHub] [flink] flinkbot edited a comment on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805219989 ## CI report: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * b15ae8f14a5b8525bdbd040f1305d2029e497f56 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15331: URL: https://github.com/apache/flink/pull/15331#issuecomment-804297575 ## CI report: * 9193da1959634c298969707b0c0aebb167d68318 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805219989 ## CI report: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * d2f555fd8fddb948e2fd4c2f4f96c880a8b22f8b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15383: [FLINK-21702][sql-client]Support option `sql-client.verbose` to print the exception stack

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15383: URL: https://github.com/apache/flink/pull/15383#issuecomment-808001666 ## CI report: * d43ae92d5cf478899c4ba3cdfac4417383dc7701 UNKNOWN * 83ca14682c7a6651d8c8201ad7fbb058373fc17d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805219989 ## CI report: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * d2f555fd8fddb948e2fd4c2f4f96c880a8b22f8b Azure:

[jira] [Commented] (FLINK-21906) Support computed column syntax for Hive DDL dialect

2021-03-26 Thread jinfeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309749#comment-17309749 ] jinfeng commented on FLINK-21906: - [~jark]  I'm interested in this, can you assgin this to me ?  >

[jira] [Commented] (FLINK-21907) Support watermark syntax for Hive DDL dialect

2021-03-26 Thread jinfeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309748#comment-17309748 ] jinfeng commented on FLINK-21907: - [~jark]  I'm interested in this, can you assgin this to me ?  >

[GitHub] [flink] flinkbot edited a comment on pull request #15393: [FLINK-21980][Runtime/Coordination] ZooKeeperRunningJobsRegistry creates an empty znode

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15393: URL: https://github.com/apache/flink/pull/15393#issuecomment-808510341 ## CI report: * 1dfe04f95e9bfb8ea2f54c647f9643bfa910ab7e Azure:

[jira] [Updated] (FLINK-12726) Fix ANY type serialization

2021-03-26 Thread Shannon del Baker (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shannon del Baker updated FLINK-12726: -- Attachment: sa_groups_img_family_grid.png > Fix ANY type serialization >

[GitHub] [flink] austince commented on a change in pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

2021-03-26 Thread GitBox
austince commented on a change in pull request #15348: URL: https://github.com/apache/flink/pull/15348#discussion_r602590455 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java ## @@ -860,6 +902,7 @@ private

[GitHub] [flink] flinkbot commented on pull request #15393: [FLINK-21980][Runtime/Coordination] ZooKeeperRunningJobsRegistry creates an empty znode

2021-03-26 Thread GitBox
flinkbot commented on pull request #15393: URL: https://github.com/apache/flink/pull/15393#issuecomment-808510341 ## CI report: * 1dfe04f95e9bfb8ea2f54c647f9643bfa910ab7e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15393: [FLINK-21980][Runtime/Coordination] ZooKeeperRunningJobsRegistry creates an empty znode

2021-03-26 Thread GitBox
flinkbot commented on pull request #15393: URL: https://github.com/apache/flink/pull/15393#issuecomment-808506972 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] rickyspeak commented on pull request #15393: [FLINK-21980][Runtime/Coordination] ZooKeeperRunningJobsRegistry creates an empty znode

2021-03-26 Thread GitBox
rickyspeak commented on pull request #15393: URL: https://github.com/apache/flink/pull/15393#issuecomment-808506861 Existing tests verify that functionality hasn't changed. If anybody has advise on how best to verify that the race condition no longer exist, I can implement that as well.

[jira] [Updated] (FLINK-21980) ZooKeeperRunningJobsRegistry creates an empty znode

2021-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21980: --- Labels: pull-request-available (was: ) > ZooKeeperRunningJobsRegistry creates an empty

[GitHub] [flink] rickyspeak opened a new pull request #15393: [FLINK-21980][Runtime/Coordination] ZooKeeperRunningJobsRegistry creates an empty znode

2021-03-26 Thread GitBox
rickyspeak opened a new pull request #15393: URL: https://github.com/apache/flink/pull/15393 ## What is the purpose of the change This removes a race condition in which the ZooKeeperRunningJobsRegistry leaves Zookeeper with a znode in the `running_job_registry` with an empty value,

[GitHub] [flink] flinkbot edited a comment on pull request #15375: [FLINK-17012][streaming] Implemented the separated 'restore' method for StreamTask

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15375: URL: https://github.com/apache/flink/pull/15375#issuecomment-807081996 ## CI report: * 78d1730d84e6eaaf74d095fe0f60d90625f1dd23 Azure:

[jira] [Commented] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss

2021-03-26 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309697#comment-17309697 ] Stephan Ewen commented on FLINK-21996: -- [~trohrmann] What do you think of the proposed solution? I

[GitHub] [flink] flinkbot edited a comment on pull request #15356: [FLINK-21947][csv] Support TIMESTAMP_LTZ type in CSV format

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15356: URL: https://github.com/apache/flink/pull/15356#issuecomment-805653657 ## CI report: * 565c4d8bc0c1abd7132fa8540b128b9d08d2240f UNKNOWN * c6267bf845a7a874612bf55f4b92e4b49efed502 Azure:

[jira] [Created] (FLINK-21996) Transient RPC failure without TaskManager failure can lead to split assignment loss

2021-03-26 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-21996: Summary: Transient RPC failure without TaskManager failure can lead to split assignment loss Key: FLINK-21996 URL: https://issues.apache.org/jira/browse/FLINK-21996

[GitHub] [flink] austince commented on a change in pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

2021-03-26 Thread GitBox
austince commented on a change in pull request #15348: URL: https://github.com/apache/flink/pull/15348#discussion_r602555236 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java ## @@ -270,6 +276,42 @@ private static

[GitHub] [flink] austince commented on a change in pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

2021-03-26 Thread GitBox
austince commented on a change in pull request #15348: URL: https://github.com/apache/flink/pull/15348#discussion_r602553141 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java ## @@ -860,6 +902,7 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #15306: [FLINK-21623][table-planner] Introduce CURRENT_ROW_TIMESTAMP() function

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15306: URL: https://github.com/apache/flink/pull/15306#issuecomment-803566547 ## CI report: * 3253705075bf797ece2abbf9f10d998a49c3eb32 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15392: [FLINK-21917][docs] Add back missing zh kafka.md doc

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15392: URL: https://github.com/apache/flink/pull/15392#issuecomment-808407450 ## CI report: * f6f729d7986734b997906f091349f554ec2e6991 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15391: [FLINK-21630][python] Support Python UDAF in Session Window

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15391: URL: https://github.com/apache/flink/pull/15391#issuecomment-808283258 ## CI report: * d55091ff03d9749e1be6b240d93b8b63a4a2b7b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15379: [FLINK-21984][table-planner] Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15379: URL: https://github.com/apache/flink/pull/15379#issuecomment-807932155 ## CI report: * c8228017e07ff5007c61c37b6fcadccf495a6903 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15331: URL: https://github.com/apache/flink/pull/15331#issuecomment-804297575 ## CI report: * 3be12eb2b491b7ad44cfcc9f80d14b6d83994f7a Azure:

[jira] [Comment Edited] (FLINK-21148) YARNSessionFIFOSecuredITCase cannot connect to BlobServer

2021-03-26 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309649#comment-17309649 ] Matthias edited comment on FLINK-21148 at 3/26/21, 7:25 PM: I looked over

[jira] [Comment Edited] (FLINK-21148) YARNSessionFIFOSecuredITCase cannot connect to BlobServer

2021-03-26 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309649#comment-17309649 ] Matthias edited comment on FLINK-21148 at 3/26/21, 7:25 PM: I looked over

[jira] [Comment Edited] (FLINK-21148) YARNSessionFIFOSecuredITCase cannot connect to BlobServer

2021-03-26 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309649#comment-17309649 ] Matthias edited comment on FLINK-21148 at 3/26/21, 7:08 PM: I looked over

[jira] [Comment Edited] (FLINK-21148) YARNSessionFIFOSecuredITCase cannot connect to BlobServer

2021-03-26 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309649#comment-17309649 ] Matthias edited comment on FLINK-21148 at 3/26/21, 7:03 PM: I looked over

[jira] [Comment Edited] (FLINK-21148) YARNSessionFIFOSecuredITCase cannot connect to BlobServer

2021-03-26 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309649#comment-17309649 ] Matthias edited comment on FLINK-21148 at 3/26/21, 6:59 PM: I looked over

[GitHub] [flink] flinkbot edited a comment on pull request #15388: [FLINK-21989][table] Add a SupportsSourceWatermark ability interface

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15388: URL: https://github.com/apache/flink/pull/15388#issuecomment-808143847 ## CI report: * 86af77291d43968516b35185fc08954d4dd3d64f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15313: [FLINK-19682] Actively timeout checkpoint barriers on the inputs

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15313: URL: https://github.com/apache/flink/pull/15313#issuecomment-803870812 ## CI report: * 835c41b325502b8601d28573a760d8703db2c9a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15315: [FLINK-21463][sql-client] Unify SQL Client Parser and SQL parser

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15315: URL: https://github.com/apache/flink/pull/15315#issuecomment-803903558 ## CI report: * ea77b3d703fd8065b829effe7e33edbd900a8cc5 Azure:

[jira] [Commented] (FLINK-21148) YARNSessionFIFOSecuredITCase cannot connect to BlobServer

2021-03-26 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309649#comment-17309649 ] Matthias commented on FLINK-21148: -- I looked over the issue with [~rmetzger]. The actual reason seems

[GitHub] [flink] flinkbot edited a comment on pull request #15390: [FLINK-21985][table-api] Support Explain Query/Modifcation syntax in Calcite Parser

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15390: URL: https://github.com/apache/flink/pull/15390#issuecomment-808191424 ## CI report: * b544d912159cc8109f30b9786466174b7d08e136 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15331: URL: https://github.com/apache/flink/pull/15331#issuecomment-804297575 ## CI report: * 3be12eb2b491b7ad44cfcc9f80d14b6d83994f7a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15311: [FLINK-21189][runtime] Added support for concurrently caught exceptions to exception history

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15311: URL: https://github.com/apache/flink/pull/15311#issuecomment-803836803 ## CI report: * 1d0123ac9a81bee6cdd8c3e75a130ec9fc9ad619 UNKNOWN * 3cacb9f79e21c394254b587554ebf57203dac700 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #15385: [FLINK-21685][k8s] Introduce dedicated thread pool and cache for Kubernetes client

2021-03-26 Thread GitBox
tillrohrmann commented on a change in pull request #15385: URL: https://github.com/apache/flink/pull/15385#discussion_r602492105 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClientFactory.java ## @@ -83,11 +89,19 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #15392: [FLINK-21917][docs] Add back missing zh kafka.md doc

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15392: URL: https://github.com/apache/flink/pull/15392#issuecomment-808407450 ## CI report: * f6f729d7986734b997906f091349f554ec2e6991 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15383: [FLINK-21702][sql-client]Support option `sql-client.verbose` to print the exception stack

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15383: URL: https://github.com/apache/flink/pull/15383#issuecomment-808001666 ## CI report: * d43ae92d5cf478899c4ba3cdfac4417383dc7701 UNKNOWN * db21ff1dec69c7a83a863062830420c95fb3baee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15331: URL: https://github.com/apache/flink/pull/15331#issuecomment-804297575 ## CI report: * 3be12eb2b491b7ad44cfcc9f80d14b6d83994f7a Azure:

[jira] [Commented] (FLINK-21980) ZooKeeperRunningJobsRegistry creates an empty znode

2021-03-26 Thread Ricky Burnett (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309616#comment-17309616 ] Ricky Burnett commented on FLINK-21980: --- Sure, I'll put together a PR. >

[jira] [Updated] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

2021-03-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-19358: -- Component/s: (was: Deployment / YARN) Runtime / Coordination > when

[GitHub] [flink] flinkbot commented on pull request #15392: [FLINK-21917][docs] Add back missing zh kafka.md doc

2021-03-26 Thread GitBox
flinkbot commented on pull request #15392: URL: https://github.com/apache/flink/pull/15392#issuecomment-808407450 ## CI report: * f6f729d7986734b997906f091349f554ec2e6991 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15383: [FLINK-21702][sql-client]Support option `sql-client.verbose` to print the exception stack

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15383: URL: https://github.com/apache/flink/pull/15383#issuecomment-808001666 ## CI report: * d43ae92d5cf478899c4ba3cdfac4417383dc7701 UNKNOWN * db21ff1dec69c7a83a863062830420c95fb3baee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15375: [FLINK-17012][streaming] Implemented the separated 'restore' method for StreamTask

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15375: URL: https://github.com/apache/flink/pull/15375#issuecomment-807081996 ## CI report: * ad391fe5edb9f77fdf3f8cc8bfb8db112178695e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15331: URL: https://github.com/apache/flink/pull/15331#issuecomment-804297575 ## CI report: * 21436b81133864ffebfb2450c4c6094055e7ba43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15311: [FLINK-21189][runtime] Added support for concurrently caught exceptions to exception history

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15311: URL: https://github.com/apache/flink/pull/15311#issuecomment-803836803 ## CI report: * 1d0123ac9a81bee6cdd8c3e75a130ec9fc9ad619 UNKNOWN * 653d616e64d4ccd51d32b950ebe32747eb1bc0eb Azure:

[jira] [Commented] (FLINK-21935) Remove "state.backend.async" option.

2021-03-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309608#comment-17309608 ] Till Rohrmann commented on FLINK-21935: --- +1 for removing this option. I also cannot think of a

[GitHub] [flink] flinkbot edited a comment on pull request #13924: [FLINK-19938][network] Implement shuffle data read scheduling for sort-merge blocking shuffle

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #13924: URL: https://github.com/apache/flink/pull/13924#issuecomment-721619690 ## CI report: * 86aac56ca61e23996f5e0e1b248a7a2f79aae451 Azure:

[jira] [Commented] (FLINK-21980) ZooKeeperRunningJobsRegistry creates an empty znode

2021-03-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309604#comment-17309604 ] Till Rohrmann commented on FLINK-21980: --- Sounds like a good idea [~rburnett]. We could also use

[GitHub] [flink] jjiey commented on pull request #15392: [FLINK-21917][docs] Add back missing zh kafka.md doc

2021-03-26 Thread GitBox
jjiey commented on pull request #15392: URL: https://github.com/apache/flink/pull/15392#issuecomment-808403691 CC. @wuchong -- 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] [Comment Edited] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

2021-03-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309440#comment-17309440 ] Till Rohrmann edited comment on FLINK-20412 at 3/26/21, 5:34 PM: - I will

[GitHub] [flink] dawidwys commented on a change in pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

2021-03-26 Thread GitBox
dawidwys commented on a change in pull request #15331: URL: https://github.com/apache/flink/pull/15331#discussion_r602473545 ## File path: flink-core/src/main/java/org/apache/flink/api/common/functions/util/RuntimeUDFContext.java ## @@ -44,21 +43,24 @@ private final

[GitHub] [flink] flinkbot commented on pull request #15392: [FLINK-21917][docs] Add back missing zh kafka.md doc

2021-03-26 Thread GitBox
flinkbot commented on pull request #15392: URL: https://github.com/apache/flink/pull/15392#issuecomment-808397092 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] dawidwys commented on a change in pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

2021-03-26 Thread GitBox
dawidwys commented on a change in pull request #15331: URL: https://github.com/apache/flink/pull/15331#discussion_r602473545 ## File path: flink-core/src/main/java/org/apache/flink/api/common/functions/util/RuntimeUDFContext.java ## @@ -44,21 +43,24 @@ private final

[jira] [Updated] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

2021-03-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21685: -- Priority: Critical (was: Major) > Flink JobManager failed to restart from checkpoint in

[jira] [Updated] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

2021-03-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21685: -- Labels: k8s-ha pull-request-available (was: pull-request-available) > Flink JobManager

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

2021-03-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309591#comment-17309591 ] Till Rohrmann commented on FLINK-20695: --- The clean up could happen in

[jira] [Updated] (FLINK-21942) KubernetesLeaderRetrievalDriver not closed after terminated which lead to connection leak

2021-03-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21942: -- Labels: k8s-ha (was: ) > KubernetesLeaderRetrievalDriver not closed after terminated which

[jira] [Updated] (FLINK-21917) Add back missing zh docs

2021-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21917: --- Labels: pull-request-available (was: ) > Add back missing zh docs >

[GitHub] [flink] jjiey opened a new pull request #15392: [FLINK-21917][docs] Add back missing zh kafka.md doc

2021-03-26 Thread GitBox
jjiey opened a new pull request #15392: URL: https://github.com/apache/flink/pull/15392 ## What is the purpose of the change [FLINK-21917](https://issues.apache.org/jira/browse/FLINK-21917) Add back missing zh kafka.md doc ## Brief change log * Add back

  1   2   3   4   5   >