[GitHub] [flink] flinkbot commented on pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-10 Thread GitBox
flinkbot commented on pull request #15134: URL: https://github.com/apache/flink/pull/15134#issuecomment-795048956 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] flinkbot edited a comment on pull request #15068: [FLINK-21523][Connectors / Hive] Bug fix: ArrayIndexOutOfBoundsException occurs while run a hive strea…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15089: [FLINK-21614][sql-client] Introduce a new integration test framework for SQL Client

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15089: URL: https://github.com/apache/flink/pull/15089#issuecomment-791143216 ## CI report: * b63fd15854d2c90c545c6368b2e19b59ba798d08 UNKNOWN * 89d33ee6e7ca0a41121e0e2ba8c04c3d1b9a3520 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15133: URL: https://github.com/apache/flink/pull/15133#issuecomment-795031750 ## CI report: * 3ff8f4a973c368ff82f56414abe7d53f825beb2e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] rmetzger commented on a change in pull request #15071: [FLINK-21135][coord] Adjust parallelism of job for reactive mode

2021-03-10 Thread GitBox
rmetzger commented on a change in pull request #15071: URL: https://github.com/apache/flink/pull/15071#discussion_r587505749 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/DefaultSlotPoolServiceSchedulerFactory.java ## @@ -78,6 +83,11 @@ public Sl

[GitHub] [flink] LadyForest opened a new pull request #15135: [hotfix][docs] Fix broken links to Java and Python Docs

2021-03-10 Thread GitBox
LadyForest opened a new pull request #15135: URL: https://github.com/apache/flink/pull/15135 ## What is the purpose of the change This PR is to fix the broken links to Java/Python docs since after migrating to Hugo, the old references became unreachable. ## Brief change lo

[jira] [Commented] (FLINK-21597) testMapAfterRepartitionHasCorrectParallelism2 Fail because of "NoResourceAvailableException"

2021-03-10 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298623#comment-17298623 ] Matthias commented on FLINK-21597: -- [~maguowei] Could you provide the link to the faile

[GitHub] [flink] rmetzger commented on a change in pull request #15071: [FLINK-21135][coord] Adjust parallelism of job for reactive mode

2021-03-10 Thread GitBox
rmetzger commented on a change in pull request #15071: URL: https://github.com/apache/flink/pull/15071#discussion_r591186994 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ## @@ -287,6 +291,23 @@ public void onUnknownDeploymentsOf(

[GitHub] [flink] flinkbot commented on pull request #15135: [hotfix][docs] Fix broken links to Java and Python Docs

2021-03-10 Thread GitBox
flinkbot commented on pull request #15135: URL: https://github.com/apache/flink/pull/15135#issuecomment-795057715 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] rmetzger commented on pull request #15071: [FLINK-21135][coord] Adjust parallelism of job for reactive mode

2021-03-10 Thread GitBox
rmetzger commented on pull request #15071: URL: https://github.com/apache/flink/pull/15071#issuecomment-795057930 This is ready to review. This is an automated message from the Apache Git Service. To respond to the message, p

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

2021-03-10 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: -- Description: We use Flink K8S session cluster with HA mode (1 JobManager and 4 TaskManagers).

[GitHub] [flink] JingsongLi commented on a change in pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-03-10 Thread GitBox
JingsongLi commented on a change in pull request #14977: URL: https://github.com/apache/flink/pull/14977#discussion_r591191743 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/PreValidateReWriter.scala ## @@ -191,41 +267

[jira] [Updated] (FLINK-21696) scala code in "Writing WatermarkGenerators" documentation missing/deprecated

2021-03-10 Thread giackgamba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] giackgamba updated FLINK-21696: --- Description: Hi all, I belive the scala code in the "Writing a Periodic WatermarkGenerator" and "W

[jira] [Created] (FLINK-21708) CloserCleaner warning

2021-03-10 Thread Avi Levi (Jira)
Avi Levi created FLINK-21708: Summary: CloserCleaner warning Key: FLINK-21708 URL: https://issues.apache.org/jira/browse/FLINK-21708 Project: Flink Issue Type: Bug Reporter: Avi Levi

[jira] [Updated] (FLINK-21696) scala code in "Writing WatermarkGenerators" documentation missing/deprecated

2021-03-10 Thread giackgamba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] giackgamba updated FLINK-21696: --- Description: Hi all, I belive the scala code in the "Writing a Periodic WatermarkGenerator" and "W

[jira] [Assigned] (FLINK-20557) Support statement set in SQL CLI

2021-03-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20557: --- Assignee: Nicholas Jiang > Support statement set in SQL CLI > > >

[GitHub] [flink] mobuchowski commented on a change in pull request #15066: [FLINK-21488] [connectors/jdbc] Embed JobID into XID's global transaction ID

2021-03-10 Thread GitBox
mobuchowski commented on a change in pull request #15066: URL: https://github.com/apache/flink/pull/15066#discussion_r591197914 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/SemanticXidGenerator.java ## @@ -46,20 +50,29 @@

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

2021-03-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298040#comment-17298040 ] Yang Wang edited comment on FLINK-21685 at 3/10/21, 8:20 AM: -

[jira] [Commented] (FLINK-21515) SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing

2021-03-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298629#comment-17298629 ] Roman Khachatryan commented on FLINK-21515: --- Yes, it should be fine, I don't t

[GitHub] [flink] mobuchowski commented on a change in pull request #15066: [FLINK-21488] [connectors/jdbc] Embed JobID into XID's global transaction ID

2021-03-10 Thread GitBox
mobuchowski commented on a change in pull request #15066: URL: https://github.com/apache/flink/pull/15066#discussion_r591198312 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/xa/SemanticXidGeneratorTest.java ## @@ -40,21 +40,2

[GitHub] [flink] flinkbot edited a comment on pull request #15071: [FLINK-21135][coord] Adjust parallelism of job for reactive mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #15089: [FLINK-21614][sql-client] Introduce a new integration test framework for SQL Client

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15089: URL: https://github.com/apache/flink/pull/15089#issuecomment-791143216 ## CI report: * b63fd15854d2c90c545c6368b2e19b59ba798d08 UNKNOWN * 89d33ee6e7ca0a41121e0e2ba8c04c3d1b9a3520 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-10 Thread GitBox
flinkbot commented on pull request #15134: URL: https://github.com/apache/flink/pull/15134#issuecomment-795077470 ## CI report: * 2fc38441318d123267cee7d14f16cfa7a42f8a6e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

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

[GitHub] [flink] flinkbot commented on pull request #15135: [hotfix][docs] Fix broken links to Java and Python Docs

2021-03-10 Thread GitBox
flinkbot commented on pull request #15135: URL: https://github.com/apache/flink/pull/15135#issuecomment-795077645 ## CI report: * eaa2ed41fc87a9ef605022a7c7cf44ca4aafebf6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] wuchong commented on a change in pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-03-10 Thread GitBox
wuchong commented on a change in pull request #14977: URL: https://github.com/apache/flink/pull/14977#discussion_r591206961 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/PreValidateReWriter.scala ## @@ -191,41 +267,40

[GitHub] [flink] rmetzger commented on pull request #15086: [FLINK-21561] Predownload/Cache large E2E test artifacts

2021-03-10 Thread GitBox
rmetzger commented on pull request #15086: URL: https://github.com/apache/flink/pull/15086#issuecomment-795079890 pushing (even an empty commit) is a much more reliable way of triggering azure builds This is an automated mes

[GitHub] [flink] wuchong commented on a change in pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-03-10 Thread GitBox
wuchong commented on a change in pull request #14977: URL: https://github.com/apache/flink/pull/14977#discussion_r591206961 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/PreValidateReWriter.scala ## @@ -191,41 +267,40

[GitHub] [flink] lirui-apache commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-03-10 Thread GitBox
lirui-apache commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-795082975 Hi @JackWangCS , I guess it's not worth the efforts to implement something like the TableFactory in flink runtime. Perhaps we can just support configurations in yaml file l

[jira] [Assigned] (FLINK-13030) add more test case for blink planner

2021-03-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-13030: Assignee: (was: godfrey he) > add more test case for blink planner >

[jira] [Closed] (FLINK-13030) add more test case for blink planner

2021-03-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-13030. Resolution: Won't Fix This issue is very unspecific and probably outdated. I will close it. > add

[GitHub] [flink] JingsongLi commented on a change in pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-03-10 Thread GitBox
JingsongLi commented on a change in pull request #14977: URL: https://github.com/apache/flink/pull/14977#discussion_r591213360 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/PreValidateReWriter.scala ## @@ -191,41 +267

[GitHub] [flink] JingsongLi commented on a change in pull request #14977: [FLINK-18726][table-planner-blink] Support INSERT INTO specific colum…

2021-03-10 Thread GitBox
JingsongLi commented on a change in pull request #14977: URL: https://github.com/apache/flink/pull/14977#discussion_r591213970 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/PreValidateReWriter.scala ## @@ -191,41 +267

[GitHub] [flink] dannycranmer commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-03-10 Thread GitBox
dannycranmer commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-795087810 I have setup my pipeline, running master to verify it works, then I will run your GSR branch: - https://dev.azure.com/dannycranmer/Flink/_build/results?buildId=4&view=re

[jira] [Closed] (FLINK-11492) Support the full Blink SQL runtime

2021-03-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11492. Fix Version/s: 1.13.0 Resolution: Fixed [~ykt836] correct me if I'm wrong but I think we ac

[jira] [Commented] (FLINK-11493) Finalize the Blink SQL merging efforts

2021-03-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298638#comment-17298638 ] Timo Walther commented on FLINK-11493: -- [~ykt836] [~jark] could somebody take care

[GitHub] [flink] leonardBang opened a new pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-10 Thread GitBox
leonardBang opened a new pull request #15136: URL: https://github.com/apache/flink/pull/15136 ## What is the purpose of the change * This pull request supports TO_TIMESTAMP_LTZ(epochSeconds , 0), TO_TIMESTAMP_LTZ(epochMilliseconds , 3) ## Brief change log - Hotfix integr

[GitHub] [flink] wuchong merged pull request #15116: [FLINK-21656][hive] Add antlr parser for hive dialect

2021-03-10 Thread GitBox
wuchong merged pull request #15116: URL: https://github.com/apache/flink/pull/15116 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

[jira] [Updated] (FLINK-21622) Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21622: --- Labels: pull-request-available (was: ) > Introduce function TO_TIMESTAMP_LTZ(numeric [, pr

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

2021-03-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298640#comment-17298640 ] Till Rohrmann commented on FLINK-21685: --- Could you share a bit more details about

[jira] [Closed] (FLINK-21656) Add antlr parser for hive dialect

2021-03-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21656. --- Assignee: Rui Li Resolution: Fixed Fixed in master: 7b822ee8ef0850e8e37ea4bce27ffadf891bef79 > Add an

[GitHub] [flink] leonardBang commented on pull request #15125: [FLINK-21624][table-planner] Correct FLOOR/CEIL (TIMESTAMP/DATE TO WEEK) functions

2021-03-10 Thread GitBox
leonardBang commented on pull request #15125: URL: https://github.com/apache/flink/pull/15125#issuecomment-795094726 cc @KurtYoung Could you help review this? thanks This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot commented on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-10 Thread GitBox
flinkbot commented on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795094958 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 commented on pull request #15132: [FLINK-21698][table-planner] Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

2021-03-10 Thread GitBox
leonardBang commented on pull request #15132: URL: https://github.com/apache/flink/pull/15132#issuecomment-795095340 cc @KurtYoung Could you help review this? thanks This is an automated message from the Apache Git Se

[GitHub] [flink] leonardBang commented on pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

2021-03-10 Thread GitBox
leonardBang commented on pull request #15133: URL: https://github.com/apache/flink/pull/15133#issuecomment-795095783 cc @KurtYoung Could you help review this? thanks This is an automated message from the Apache Git Service. T

[jira] [Created] (FLINK-21709) Officially deprecate the legacy planner

2021-03-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-21709: Summary: Officially deprecate the legacy planner Key: FLINK-21709 URL: https://issues.apache.org/jira/browse/FLINK-21709 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-14437) Drop the legacy planner

2021-03-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-14437: Assignee: Timo Walther > Drop the legacy planner > --- > >

[GitHub] [flink] leonardBang commented on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-10 Thread GitBox
leonardBang commented on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795096936 cc @KurtYoung Could you have a look this one ? This is an automated message from the Apache Git Ser

[GitHub] [flink] lirui-apache commented on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-10 Thread GitBox
lirui-apache commented on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-795097232 > But other streaming sink options will also work in batch mode once we migrate to the unified FileSink API. Hi @wuchong , how about we update the doc when that happe

[GitHub] [flink] flinkbot edited a comment on pull request #15071: [FLINK-21135][coord] Adjust parallelism of job for reactive mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #15089: [FLINK-21614][sql-client] Introduce a new integration test framework for SQL Client

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15089: URL: https://github.com/apache/flink/pull/15089#issuecomment-791143216 ## CI report: * b63fd15854d2c90c545c6368b2e19b59ba798d08 UNKNOWN * f10eb8f78b585ac52fc040a5a8a206ef34fb42e0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15134: [FLINK-21654][test] Added @throws information to tests

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15134: URL: https://github.com/apache/flink/pull/15134#issuecomment-795077470 ## CI report: * 2fc38441318d123267cee7d14f16cfa7a42f8a6e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-14437) Drop the legacy planner

2021-03-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-14437: - Description: This is an umbrella issue for all tasks that are related to dropping the legacy pl

[GitHub] [flink] flinkbot edited a comment on pull request #15135: [hotfix][docs] Fix broken links to Java and Python Docs

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

[GitHub] [flink] wuchong commented on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

2021-03-10 Thread GitBox
wuchong commented on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-795102885 I'm fine with that. This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-21300) Update module documentation

2021-03-10 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298646#comment-17298646 ] Jane Chan commented on FLINK-21300: --- Will open a PR once [https://github.com/apache/fl

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

2021-03-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298647#comment-17298647 ] Till Rohrmann commented on FLINK-20695: --- This should be the same problem [~yittg].

[jira] [Commented] (FLINK-21667) Standby RM might remove resources from Kubernetes

2021-03-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298658#comment-17298658 ] Till Rohrmann commented on FLINK-21667: --- Yes, sorry I meant {{JobMaster}} instead

[jira] [Commented] (FLINK-16829) Pass PrometheusReporter arguments via constructor

2021-03-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298660#comment-17298660 ] Till Rohrmann commented on FLINK-16829: --- [~chesnay] could [~rionmonster] help you

[jira] [Commented] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

2021-03-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298654#comment-17298654 ] Till Rohrmann commented on FLINK-19142: --- You are right [~zhuzh], for batch jobs th

[jira] [Commented] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers

2021-03-10 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298666#comment-17298666 ] Matthias commented on FLINK-21707: -- Thanks for bringing this up, [~zhuzh]. This is rela

[GitHub] [flink] twalthr opened a new pull request #15137: [FLINK-21396][table] Resolve tables when calling Catalog.createTable/alterTable

2021-03-10 Thread GitBox
twalthr opened a new pull request #15137: URL: https://github.com/apache/flink/pull/15137 ## What is the purpose of the change This ensures that the framework always resolves CatalogTable or CatalogView before calling `Catalog.createTable/alterTable`. It is still possible to pass u

[jira] [Commented] (FLINK-21597) testMapAfterRepartitionHasCorrectParallelism2 Fail because of "NoResourceAvailableException"

2021-03-10 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298669#comment-17298669 ] Guowei Ma commented on FLINK-21597: --- sorry I forgot the link https://dev.azure.com/apa

[jira] [Comment Edited] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers

2021-03-10 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298666#comment-17298666 ] Matthias edited comment on FLINK-21707 at 3/10/21, 9:13 AM:

[GitHub] [flink] rkhachatryan commented on a change in pull request #14943: [FLINK-21354][statebackend] Introduce ChangelogStateBackend to delegate state access

2021-03-10 Thread GitBox
rkhachatryan commented on a change in pull request #14943: URL: https://github.com/apache/flink/pull/14943#discussion_r591252261 ## File path: flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java ## @@ -96,6 +96,16 @@

[jira] [Commented] (FLINK-21694) Increase default value of "state.backend.rocksdb.checkpoint.transfer.thread.num"

2021-03-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298672#comment-17298672 ] Yun Tang commented on FLINK-21694: -- I think increasing the default value is a good idea

[GitHub] [flink] flinkbot edited a comment on pull request #15128: [FLINK-21433][runtime] Pass number of slots as dynamic properties to TMs.

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

[GitHub] [flink] flinkbot commented on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-10 Thread GitBox
flinkbot commented on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795141489 ## CI report: * 8f82c86bb26581417320b2588b44b33a3956bec4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15137: [FLINK-21396][table] Resolve tables when calling Catalog.createTable/alterTable

2021-03-10 Thread GitBox
flinkbot commented on pull request #15137: URL: https://github.com/apache/flink/pull/15137#issuecomment-795141967 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

[jira] [Commented] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

2021-03-10 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298692#comment-17298692 ] Yuan Mei commented on FLINK-21317: -- Hey [~kezhuw], thanks very much for reporting the b

[GitHub] [flink] xintongsong commented on pull request #15128: [FLINK-21433][runtime] Pass number of slots as dynamic properties to TMs.

2021-03-10 Thread GitBox
xintongsong commented on pull request #15128: URL: https://github.com/apache/flink/pull/15128#issuecomment-795145332 Thanks for the review, @KarmaGYZ. Comments addressed. Merging this. This is an automated message from the Ap

[GitHub] [flink] xintongsong closed pull request #15128: [FLINK-21433][runtime] Pass number of slots as dynamic properties to TMs.

2021-03-10 Thread GitBox
xintongsong closed pull request #15128: URL: https://github.com/apache/flink/pull/15128 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] [Closed] (FLINK-21433) Default slot resource is calculated inconsistently for pending / registered TMs

2021-03-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-21433. Resolution: Fixed Fixed via * master (1.13): fa02b09734ad4efc8987f427acb9e7a0d713d5b3 > Default s

[jira] [Created] (FLINK-21710) FlinkRelMdUniqueKeys get incorrect result on TableScan after project push-down

2021-03-10 Thread godfrey he (Jira)
godfrey he created FLINK-21710: -- Summary: FlinkRelMdUniqueKeys get incorrect result on TableScan after project push-down Key: FLINK-21710 URL: https://issues.apache.org/jira/browse/FLINK-21710 Project: F

[jira] [Updated] (FLINK-21710) FlinkRelMdUniqueKeys gets incorrect result on TableScan after project push-down

2021-03-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21710: --- Description: FlinkRelMdUniqueKeys#getTableUniqueKeys uses the original columns to find the index of

[jira] [Updated] (FLINK-21710) FlinkRelMdUniqueKeys gets incorrect result on TableScan after project push-down

2021-03-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21710: --- Summary: FlinkRelMdUniqueKeys gets incorrect result on TableScan after project push-down (was: Flin

[jira] [Updated] (FLINK-21710) FlinkRelMdUniqueKeys get incorrect result on TableScan after project push-down

2021-03-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21710: --- Description: FlinkRelMdUniqueKeys#getTableUniqueKeys uses the original columns to find the index of

[jira] [Commented] (FLINK-8031) Provide configuration to enable/disable ability to cancel jobs in Web Frontend

2021-03-10 Thread fangyue (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298704#comment-17298704 ] fangyue commented on FLINK-8031: We can control the ability to cancel a task by using a n

[GitHub] [flink] flinkbot edited a comment on pull request #14800: [FLINK-21192][python] Support setting namespace in RemoteKeyedStateBackend

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

[GitHub] [flink] flinkbot edited a comment on pull request #15086: [FLINK-21561] Predownload/Cache large E2E test artifacts

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15086: URL: https://github.com/apache/flink/pull/15086#issuecomment-790506153 ## CI report: * 3f85a1bad5fb751a05590c7acfaae898549f9a21 UNKNOWN * 2394febfc54a6db9e1c5aac8896cc2b508c227dc UNKNOWN * ed55dd1a011ce5af7b25e11003772f78072c

[GitHub] [flink] twalthr commented on a change in pull request #15124: [FLINK-21620][table-api / sql-parser ] Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE

2021-03-10 Thread GitBox
twalthr commented on a change in pull request #15124: URL: https://github.com/apache/flink/pull/15124#discussion_r591259973 ## File path: docs/content.zh/docs/dev/table/types.md ## @@ -895,17 +899,20 @@ DataTypes.TIMESTAMP_WITH_LOCAL_TIME_ZONE(p) {{< /tab >}} {{< tab "Python"

[GitHub] [flink] flinkbot edited a comment on pull request #15089: [FLINK-21614][sql-client] Introduce a new integration test framework for SQL Client

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15089: URL: https://github.com/apache/flink/pull/15089#issuecomment-791143216 ## CI report: * b63fd15854d2c90c545c6368b2e19b59ba798d08 UNKNOWN * f10eb8f78b585ac52fc040a5a8a206ef34fb42e0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

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

[GitHub] [flink] flinkbot commented on pull request #15137: [FLINK-21396][table] Resolve tables when calling Catalog.createTable/alterTable

2021-03-10 Thread GitBox
flinkbot commented on pull request #15137: URL: https://github.com/apache/flink/pull/15137#issuecomment-795162549 ## CI report: * a66b0e7f8e7d3c8432b7b06b7d9ed92e0e991608 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Assigned] (FLINK-16829) Pass PrometheusReporter arguments via constructor

2021-03-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-16829: Assignee: Rion Williams (was: Chesnay Schepler) > Pass PrometheusReporter argume

[jira] [Commented] (FLINK-16829) Pass PrometheusReporter arguments via constructor

2021-03-10 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298705#comment-17298705 ] Chesnay Schepler commented on FLINK-16829: -- [~rionmonster] There are 2 Promethe

[GitHub] [flink] godfreyhe opened a new pull request #15138: [FLINK-21710][table-planner-blink] FlinkRelMdUniqueKeys gets incorrect result on TableScan after project push-down

2021-03-10 Thread GitBox
godfreyhe opened a new pull request #15138: URL: https://github.com/apache/flink/pull/15138 ## What is the purpose of the change *FlinkRelMdUniqueKeys#getTableUniqueKeys uses the original columns to find the index of primary keys. But after project push-down, the indexes is inco

[jira] [Updated] (FLINK-21710) FlinkRelMdUniqueKeys gets incorrect result on TableScan after project push-down

2021-03-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21710: --- Labels: pull-request-available (was: ) > FlinkRelMdUniqueKeys gets incorrect result on Tabl

[jira] [Commented] (FLINK-21695) Increase default value for number of KeyGroups

2021-03-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298708#comment-17298708 ] Yun Tang commented on FLINK-21695: -- I think the max parallelism is the most important f

[GitHub] [flink] flinkbot commented on pull request #15138: [FLINK-21710][table-planner-blink] FlinkRelMdUniqueKeys gets incorrect result on TableScan after project push-down

2021-03-10 Thread GitBox
flinkbot commented on pull request #15138: URL: https://github.com/apache/flink/pull/15138#issuecomment-795173536 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

[jira] [Commented] (FLINK-21690) remove redundant tolerableCheckpointFailureNumber setting in CheckpointConfig

2021-03-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298710#comment-17298710 ] Yun Tang commented on FLINK-21690: -- Why do you think this setting is redundant? This is

[jira] [Commented] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers

2021-03-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298711#comment-17298711 ] Till Rohrmann commented on FLINK-21707: --- Thanks for reporting this issue [~zhuzh].

[jira] [Comment Edited] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers

2021-03-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17298711#comment-17298711 ] Till Rohrmann edited comment on FLINK-21707 at 3/10/21, 9:58 AM: -

[GitHub] [flink] LinyuYao1021 commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

2021-03-10 Thread GitBox
LinyuYao1021 commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-795179693 This is my pipeline, directly to run my commit to see what's the problem: - https://dev.azure.com/yaolinyu3547/yaoliny.flink/_build/results?buildId=1&view=results -

[GitHub] [flink] flinkbot edited a comment on pull request #15086: [FLINK-21561] Predownload/Cache large E2E test artifacts

2021-03-10 Thread GitBox
flinkbot edited a comment on pull request #15086: URL: https://github.com/apache/flink/pull/15086#issuecomment-790506153 ## CI report: * 3f85a1bad5fb751a05590c7acfaae898549f9a21 UNKNOWN * 2394febfc54a6db9e1c5aac8896cc2b508c227dc UNKNOWN * ed55dd1a011ce5af7b25e11003772f78072c

[GitHub] [flink] AHeise commented on a change in pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

2021-03-10 Thread GitBox
AHeise commented on a change in pull request #13845: URL: https://github.com/apache/flink/pull/13845#discussion_r591301746 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/recovery/RecordFilter.java ## @@ -0,0 +1,64 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

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

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

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

[GitHub] [flink] flinkbot edited a comment on pull request #15137: [FLINK-21396][table] Resolve tables when calling Catalog.createTable/alterTable

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

[GitHub] [flink] flinkbot commented on pull request #15138: [FLINK-21710][table-planner-blink] FlinkRelMdUniqueKeys gets incorrect result on TableScan after project push-down

2021-03-10 Thread GitBox
flinkbot commented on pull request #15138: URL: https://github.com/apache/flink/pull/15138#issuecomment-795184471 ## CI report: * caf54acb3e974ecf4d6bb7b396c0fe4dad1b5592 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

  1   2   3   4   5   >