[GitHub] [flink] flinkbot edited a comment on pull request #15366: [FLINK-12828][sql-client] Support -f option with a sql script as input

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15366: URL: https://github.com/apache/flink/pull/15366#issuecomment-806388017 ## CI report: * d879f73ab948f4782455d18442095b360c7b8fbc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 0185457ce617de9dbe393680a37681aa1415d9ed Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 * ef3d73a5dfd2c970e38e817e20c7e97041b919be Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15301: [FLINK-21888][hive] Maintain our own ASTNode class

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15301: URL: https://github.com/apache/flink/pull/15301#issuecomment-803353789 ## CI report: * b396325ab19ee75949e87d006c9e17096dbd50a2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15301: [FLINK-21888][hive] Maintain our own ASTNode class

2021-03-26 Thread GitBox
flinkbot edited a comment on pull request #15301: URL: https://github.com/apache/flink/pull/15301#issuecomment-803353789 ## CI report: * b396325ab19ee75949e87d006c9e17096dbd50a2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

[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&focusedCommentId=17309875#comment-17309875 ] Jark Wu commented on FLINK-21997: - Thanks [~yangsanity] > Add back missing jdbc.md zh d

[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 +# +# Licensed

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

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

[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: - 1080a638382676b85b9e739d41775b4dcab7b43

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

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

[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` , shou

[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&focusedCommentId=17309860#comment-17309860 ] jjiey commented on FLINK-21997: --- Hi, [~jark], it's a duplicate issue with  [FLINK-21838|ht

[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 +# +# Licensed

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

[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&focusedCommentId=17309854#comment-17309854 ] Jark Wu edited comment on FLINK-21917 at 3/27/21, 3:56 AM: --- Fi

[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&focusedCommentId=17309854#comment-17309854 ] Jark Wu commented on FLINK-21917: - Fixed in master: - kafka.md: 5b33c79b5dfa1260fa85aff

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

[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&focusedCommentId=17309853#comment-17309853 ] Jark Wu commented on FLINK-21906: - Thanks [~hackergin] for willing contribute. I want to

[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&focusedCommentId=17309852#comment-17309852 ] Kurt Young commented on FLINK-20412: [~sewen] I will ping Caizhi  > Collect Result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17309850#comment-17309850 ] jinfeng commented on FLINK-21978: - [~ykt836] milliseconds > Disable cast conversion bet

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

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

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

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

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17309842#comment-17309842 ] Kurt Young commented on FLINK-21978: [~hackergin] When you cast timestamp to BIGINT,

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-fl

[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&focusedCommentId=17309749#comment-17309749 ] jinfeng commented on FLINK-21906: - [~jark]  I'm interested in this, can you assgin this

[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&focusedCommentId=17309748#comment-17309748 ] jinfeng commented on FLINK-21907: - [~jark]  I'm interested in this, can you assgin this

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17309697#comment-17309697 ] Stephan Ewen commented on FLINK-21996: -- [~trohrmann] What do you think of the propo

[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: [FAILURE](https://dev.azure.com/apache-fl

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

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

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

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17309649#comment-17309649 ] Matthias edited comment on FLINK-21148 at 3/26/21, 7:25 PM:

[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&focusedCommentId=17309649#comment-17309649 ] Matthias edited comment on FLINK-21148 at 3/26/21, 7:25 PM:

[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&focusedCommentId=17309649#comment-17309649 ] Matthias edited comment on FLINK-21148 at 3/26/21, 7:08 PM:

[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&focusedCommentId=17309649#comment-17309649 ] Matthias edited comment on FLINK-21148 at 3/26/21, 7:03 PM:

[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&focusedCommentId=17309649#comment-17309649 ] Matthias edited comment on FLINK-21148 at 3/26/21, 6:59 PM:

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17309649#comment-17309649 ] Matthias commented on FLINK-21148: -- I looked over the issue with [~rmetzger]. The actua

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

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

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17309616#comment-17309616 ] Ricky Burnett commented on FLINK-21980: --- Sure, I'll put together a PR. > ZooKeepe

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

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [CANCELED](https://dev.azure.com/apache-f

[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&focusedCommentId=17309608#comment-17309608 ] Till Rohrmann commented on FLINK-21935: --- +1 for removing this option. I also canno

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17309604#comment-17309604 ] Till Rohrmann commented on FLINK-21980: --- Sounds like a good idea [~rburnett]. We c

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

[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&focusedCommentId=17309440#comment-17309440 ] Till Rohrmann edited comment on FLINK-20412 at 3/26/21, 5:34 PM: -

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

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

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

  1   2   3   4   5   >