[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

2021-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346693#comment-17346693 ] Robert Metzger commented on FLINK-22613: Disabled on master in

[jira] [Assigned] (FLINK-22656) Fix spelling mistakes

2021-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-22656: - Assignee: LeeJiangchuan > Fix spelling mistakes > - > >

[jira] [Closed] (FLINK-22656) Fix spelling mistakes

2021-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22656. - Fix Version/s: 1.14.0 Resolution: Fixed Fixed via

[jira] [Updated] (FLINK-22587) Support aggregations in batch mode with DataStream API

2021-05-18 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22587: - Issue Type: Bug (was: Improvement) > Support aggregations in batch mode with

[jira] [Updated] (FLINK-22587) Support aggregations in batch mode with DataStream API

2021-05-18 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22587: - Affects Version/s: 1.12.0 1.13.0 > Support aggregations in batch

[GitHub] [flink] dannycranmer merged pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

2021-05-18 Thread GitBox
dannycranmer merged pull request #15830: URL: https://github.com/apache/flink/pull/15830 -- 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-docker] zentol merged pull request #80: [FLINK-22648] Only set number of slots if env variable is set

2021-05-18 Thread GitBox
zentol merged pull request #80: URL: https://github.com/apache/flink-docker/pull/80 -- 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] lqjack commented on a change in pull request #15812: remove slotpoolImpl

2021-05-18 Thread GitBox
lqjack commented on a change in pull request #15812: URL: https://github.com/apache/flink/pull/15812#discussion_r634202437 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImplWithSpreadOutStrategyTest.java ## @@ -90,6

[jira] [Created] (FLINK-22694) Refactor TPCH end to end tests

2021-05-18 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-22694: - Summary: Refactor TPCH end to end tests Key: FLINK-22694 URL: https://issues.apache.org/jira/browse/FLINK-22694 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-22494) Avoid discarding checkpoints in case of failure

2021-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22494. - Resolution: Fixed Fixed via 1.14.0: 9d2e2d980e cc59ad5e62 417cf78fd0 e632591623 fa0d1dc3d5

[jira] [Updated] (FLINK-22688) Root Exception can not be shown on Web UI in Flink 1.13.0

2021-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22688: --- Labels: pull-request-available (was: ) > Root Exception can not be shown on Web UI in

[jira] [Updated] (FLINK-22688) Root Exception can not be shown on Web UI in Flink 1.13.0

2021-05-18 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-22688: - Affects Version/s: (was: 1.13.0) 1.13.1 > Root Exception can not be shown on

[jira] [Updated] (FLINK-22688) Root Exception can not be shown on Web UI in Flink 1.13.0

2021-05-18 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-22688: - Affects Version/s: 1.13.0 > Root Exception can not be shown on Web UI in Flink 1.13.0 >

[jira] [Updated] (FLINK-22688) Root Exception can not be shown on Web UI in Flink 1.13.0

2021-05-18 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-22688: - Component/s: Runtime / Coordination > Root Exception can not be shown on Web UI in Flink 1.13.0 >

[GitHub] [flink] XComp opened a new pull request #15945: [FLINK-22688][runtime] Eases assertion on ExceptionHistoryEntry

2021-05-18 Thread GitBox
XComp opened a new pull request #15945: URL: https://github.com/apache/flink/pull/15945 Additionally, I added a few Preconditions to the ExceptionHistoryEntry creation to make the code more robust. ## What is the purpose of the change An

[jira] [Updated] (FLINK-22696) Enable Confluent Schema Registry e2e Test on jdk 11

2021-05-18 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-22696: Summary: Enable Confluent Schema Registry e2e Test on jdk 11 (was: Enable Confluent Schema

[GitHub] [flink] flinkbot commented on pull request #15947: [FLINK-22696] Enable Confluent Schema Registry e2e Test on jdk 11

2021-05-18 Thread GitBox
flinkbot commented on pull request #15947: URL: https://github.com/apache/flink/pull/15947#issuecomment-843140545 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] tillrohrmann closed pull request #14172: [FLINK-19545][e2e] Add e2e test for native Kubernetes HA

2021-05-18 Thread GitBox
tillrohrmann closed pull request #14172: URL: https://github.com/apache/flink/pull/14172 -- 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] [Closed] (FLINK-19316) FLIP-134: Batch execution for the DataStream API

2021-05-18 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-19316. Resolution: Implemented > FLIP-134: Batch execution for the DataStream API >

[jira] [Commented] (FLINK-19316) FLIP-134: Batch execution for the DataStream API

2021-05-18 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346726#comment-17346726 ] Dawid Wysakowicz commented on FLINK-19316: -- Hi [~echauchot] I think the reported issue is a

[jira] [Resolved] (FLINK-22515) Add Documentation for Flink Glue Schema Registry Integration

2021-05-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-22515. --- Resolution: Done > Add Documentation for Flink Glue Schema Registry Integration >

[GitHub] [flink] fsk119 opened a new pull request #15944: [FLINK-22694][e2e] Use sql file in TPCH end to end tests

2021-05-18 Thread GitBox
fsk119 opened a new pull request #15944: URL: https://github.com/apache/flink/pull/15944 ## What is the purpose of the change *Use sql files to init environment in TPCH tests.* -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used

2021-05-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346755#comment-17346755 ] Yang Wang commented on FLINK-22585: --- [~rainieli] Thanks for volunteering to take this ticket. I have

[jira] [Updated] (FLINK-22694) Refactor TPCH end to end tests

2021-05-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22694: Component/s: Table SQL / Client > Refactor TPCH end to end tests > -- > >

[GitHub] [flink] flinkbot commented on pull request #15945: [FLINK-22688][runtime] Eases assertion on ExceptionHistoryEntry

2021-05-18 Thread GitBox
flinkbot commented on pull request #15945: URL: https://github.com/apache/flink/pull/15945#issuecomment-843082121 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] lqjack commented on pull request #15812: remove slotpoolImpl

2021-05-18 Thread GitBox
lqjack commented on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-843143564 @tillrohrmann Thanks to review. When I have a problem, I will ask for your help. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-22631) Metrics are incorrect when task finished

2021-05-18 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346876#comment-17346876 ] Konstantin Knauf commented on FLINK-22631: -- Hi [~kanata163], thank you for you patience. As

[jira] [Assigned] (FLINK-22570) Reduce #notifications of Flink Jira Bot by combining API requests

2021-05-18 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-22570: Assignee: Konstantin Knauf > Reduce #notifications of Flink Jira Bot by

[jira] [Commented] (FLINK-22682) Checkpoint interval too large for higher DOP

2021-05-18 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346691#comment-17346691 ] Till Rohrmann commented on FLINK-22682: --- The {{DefaultCompletedCheckpointStore}} should log

[jira] [Commented] (FLINK-22631) Metrics are incorrect when task finished

2021-05-18 Thread Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346718#comment-17346718 ] Li commented on FLINK-22631: cc [~knaufk] > Metrics are incorrect when task finished >

[GitHub] [flink] PatrickRen opened a new pull request #15943: [FLINK-20655][e2e] Add E2E test for new KafkaSource based on FLIP-27

2021-05-18 Thread GitBox
PatrickRen opened a new pull request #15943: URL: https://github.com/apache/flink/pull/15943 ## What is the purpose of the change This pull request adds E2E test case for the new KafkaSource based on FLIP-27. ## Brief change log - Add command line argument in

[GitHub] [flink] flinkbot edited a comment on pull request #15907: [BP-1.12][FLINK-22494][runtime] Introduce PossibleInconsistentStateException

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15907: URL: https://github.com/apache/flink/pull/15907#issuecomment-839913984 ## CI report: * a0bfff801337de40a41fe919a7cc3a83ab909028 Azure:

[GitHub] [flink] lqjack commented on a change in pull request #15812: remove slotpoolImpl

2021-05-18 Thread GitBox
lqjack commented on a change in pull request #15812: URL: https://github.com/apache/flink/pull/15812#discussion_r634203296 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolInteractionsTest.java ## @@ -178,34 +159,34 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #15942: [BP-1.13][FLINK-19545][e2e] Add e2e test for native Kubernetes HA

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15942: URL: https://github.com/apache/flink/pull/15942#issuecomment-842991448 ## CI report: * 829bb063f2932a0ad4f0d1586977c6b69bdff9d6 Azure:

[GitHub] [flink] lqjack commented on a change in pull request #15812: remove slotpoolImpl

2021-05-18 Thread GitBox
lqjack commented on a change in pull request #15812: URL: https://github.com/apache/flink/pull/15812#discussion_r634202976 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImplWithSpreadOutStrategyTest.java ## @@

[jira] [Commented] (FLINK-22540) Remove YAML environment file support in SQL Client

2021-05-18 Thread liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346753#comment-17346753 ] liu commented on FLINK-22540: - Hi,[~jark], I understand about "make the construtor arguments to be

[jira] [Assigned] (FLINK-22585) Add deprecated message when "-m yarn-cluster" is used

2021-05-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-22585: - Assignee: Rainie Li > Add deprecated message when "-m yarn-cluster" is used >

[GitHub] [flink] zentol commented on pull request #15945: [FLINK-22688][runtime] Eases assertion on ExceptionHistoryEntry

2021-05-18 Thread GitBox
zentol commented on pull request #15945: URL: https://github.com/apache/flink/pull/15945#issuecomment-843096197 While the change itself is fine I would like to understand why the exception reported in the ticket could result in the TM location not being set. Under what circumstances can

[GitHub] [flink] flinkbot commented on pull request #15945: [FLINK-22688][runtime] Eases assertion on ExceptionHistoryEntry

2021-05-18 Thread GitBox
flinkbot commented on pull request #15945: URL: https://github.com/apache/flink/pull/15945#issuecomment-843096661 ## CI report: * a8d0dec7152ab961154a57f146c8aafb4167a2a1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-22693) EXPLAIN cannot be used on Hbase table when useing ROW type

2021-05-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346844#comment-17346844 ] Jark Wu commented on FLINK-22693: - [~sadf] could you share the program code above, so that we can

[GitHub] [flink] Airblader opened a new pull request #15946: [FLINK-22645][sql-parser] "ALTER VIEW" DDL for Flink dialect

2021-05-18 Thread GitBox
Airblader opened a new pull request #15946: URL: https://github.com/apache/flink/pull/15946 This introduces the DDL ALTER VIEW … RENAME TO … ALTER VIEW … AS … for the Flink dialect. These already exist for the Hive dialect, but should be supported in the Flink dialect as

[jira] [Commented] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

2021-05-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346863#comment-17346863 ] Timo Walther commented on FLINK-19973: -- The SQL Client is not tested for different execution

[GitHub] [flink] flinkbot edited a comment on pull request #15941: [FLINK-22659]Adding execution.checkpointing.interval to Flink Doccc

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15941: URL: https://github.com/apache/flink/pull/15941#issuecomment-842958650 ## CI report: * 5c3eb4a45ace79436f9dcb2406022bb12c1f4205 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15938: [FLINK-11103][runtime] Set a configurable default uncaught exception handler for all entrypoints

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15938: URL: https://github.com/apache/flink/pull/15938#issuecomment-842314070 ## CI report: * 355d00278c2e225d26be37bb6e1db5eb6a8a1147 Azure:

[GitHub] [flink] flinkbot commented on pull request #15942: [BP-1.13][FLINK-19545][e2e] Add e2e test for native Kubernetes HA

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

[jira] [Comment Edited] (FLINK-22631) Metrics are incorrect when task finished

2021-05-18 Thread Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346718#comment-17346718 ] Li edited comment on FLINK-22631 at 5/18/21, 9:10 AM: -- This is indeed a serious

[GitHub] [flink] flinkbot commented on pull request #15944: [FLINK-22694][e2e] Use sql file in TPCH end to end tests

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

[GitHub] [flink] flinkbot commented on pull request #15944: [FLINK-22694][e2e] Use sql file in TPCH end to end tests

2021-05-18 Thread GitBox
flinkbot commented on pull request #15944: URL: https://github.com/apache/flink/pull/15944#issuecomment-843049332 ## CI report: * b64a13c6b1f1c16817a40ca21a20574f51eabcfb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15941: [FLINK-22659]Adding execution.checkpointing.interval to Flink Doccc

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15941: URL: https://github.com/apache/flink/pull/15941#issuecomment-842958650 ## CI report: * 5c3eb4a45ace79436f9dcb2406022bb12c1f4205 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15905: [FLINK-22623][hbase] Drop BatchTableSource HBaseTableSource/Sink and related classes

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15905: URL: https://github.com/apache/flink/pull/15905#issuecomment-839723747 ## CI report: * 41d487e74631600cb58096fff107af55c36dc243 Azure:

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

2021-05-18 Thread GitBox
yittg commented on pull request #15561: URL: https://github.com/apache/flink/pull/15561#issuecomment-843049598 haha, sounds good :). Thanks -- 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

[GitHub] [flink] lqjack commented on a change in pull request #15812: remove slotpoolImpl

2021-05-18 Thread GitBox
lqjack commented on a change in pull request #15812: URL: https://github.com/apache/flink/pull/15812#discussion_r634266267 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImplWithDefaultSlotSelectionStrategyTest.java

[GitHub] [flink] flinkbot edited a comment on pull request #14830: [FLINK-20487][table-planner-blink] Remove restriction on StreamPhysicalGroupWindowAggregate which only supports insert-only input nod

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #14830: URL: https://github.com/apache/flink/pull/14830#issuecomment-770878871 ## CI report: * 1178237083493c3420184beb7047e4c57f023885 Azure:

[GitHub] [flink] movesan commented on a change in pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

2021-05-18 Thread GitBox
movesan commented on a change in pull request #15866: URL: https://github.com/apache/flink/pull/15866#discussion_r634264653 ## File path: docs/content.zh/docs/ops/monitoring/back_pressure.md ## @@ -28,62 +28,51 @@ under the License. # 监控反压 -Flink Web 界面提供了一个选项卡来监控正在运行 Job

[jira] [Updated] (FLINK-22623) Drop BatchTableSource/Sink HBaseTableSource/Sink and related classes

2021-05-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-22623: - Summary: Drop BatchTableSource/Sink HBaseTableSource/Sink and related classes (was: Drop

[GitHub] [flink] flinkbot edited a comment on pull request #15943: [FLINK-20655][e2e] Add E2E test for new KafkaSource based on FLIP-27

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15943: URL: https://github.com/apache/flink/pull/15943#issuecomment-843009282 ## CI report: * e34dbb3c99269e57b3056c912d5127eaddccb89a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15947: [FLINK-22696] Enable Confluent Schema Registry e2e Test on jdk 11

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15947: URL: https://github.com/apache/flink/pull/15947#issuecomment-843151200 ## CI report: * 29dbbbc55bf216894e05ed293551cf090740da63 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15812: remove slotpoolImpl

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15812: URL: https://github.com/apache/flink/pull/15812#issuecomment-829441551 ## CI report: * fb9f54a13d3f63e93c1088c72acfd6de86eff36c Azure:

[GitHub] [flink] tillrohrmann closed pull request #15912: [FLINK-22656] FIX TYPO

2021-05-18 Thread GitBox
tillrohrmann closed pull request #15912: URL: https://github.com/apache/flink/pull/15912 -- 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] tillrohrmann closed pull request #15832: [FLINK-22494][ha] Introduce PossibleInconsistentStateException

2021-05-18 Thread GitBox
tillrohrmann closed pull request #15832: URL: https://github.com/apache/flink/pull/15832 -- 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] [Updated] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

2021-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20655: --- Labels: pull-request-available stale-assigned (was: stale-assigned) > Add E2E tests to the

[jira] [Reopened] (FLINK-19316) FLIP-134: Batch execution for the DataStream API

2021-05-18 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot reopened FLINK-19316: -- I took the liberty to reopen this ticket because of

[jira] [Updated] (FLINK-22694) Refactor TPCH end to end tests

2021-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22694: --- Labels: pull-request-available (was: ) > Refactor TPCH end to end tests >

[GitHub] [flink] 95chenjz commented on a change in pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

2021-05-18 Thread GitBox
95chenjz commented on a change in pull request #15866: URL: https://github.com/apache/flink/pull/15866#discussion_r634293204 ## File path: docs/content.zh/docs/ops/monitoring/back_pressure.md ## @@ -28,62 +28,51 @@ under the License. # 监控反压 -Flink Web 界面提供了一个选项卡来监控正在运行

[jira] [Created] (FLINK-22695) Update Flink's Code Style and Quality Guide to match the Google Java Format style introduced

2021-05-18 Thread Matthias (Jira)
Matthias created FLINK-22695: Summary: Update Flink's Code Style and Quality Guide to match the Google Java Format style introduced Key: FLINK-22695 URL: https://issues.apache.org/jira/browse/FLINK-22695

[GitHub] [flink] twalthr closed pull request #15905: [FLINK-22623][hbase] Drop BatchTableSource HBaseTableSource/Sink and related classes

2021-05-18 Thread GitBox
twalthr closed pull request #15905: URL: https://github.com/apache/flink/pull/15905 -- 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] lqjack commented on a change in pull request #15812: remove slotpoolImpl

2021-05-18 Thread GitBox
lqjack commented on a change in pull request #15812: URL: https://github.com/apache/flink/pull/15812#discussion_r634333209 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java ## @@ -144,9 +144,9 @@ void start( Collection

[jira] [Updated] (FLINK-22696) Enable Confluent Schema Registry e2e Test on jdk 11

2021-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22696: --- Labels: pull-request-available (was: ) > Enable Confluent Schema Registry e2e Test on jdk

[GitHub] [flink] fapaul opened a new pull request #15947: [FLINK-22696] Enable Confluent Schema Registry e2e Test on jdk 11

2021-05-18 Thread GitBox
fapaul opened a new pull request #15947: URL: https://github.com/apache/flink/pull/15947 ## What is the purpose of the change Enable Confluent Schema Registry e2e Test on jdk 11 nightly run ## Verifying this change I ran the change on private azure with jdk11 enabled

[jira] [Commented] (FLINK-19316) FLIP-134: Batch execution for the DataStream API

2021-05-18 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346884#comment-17346884 ] Etienne Chauchot commented on FLINK-19316: -- [~dwysakowicz] thanks for commenting. Ok fair

[GitHub] [flink] flinkbot commented on pull request #15943: [FLINK-20655][e2e] Add E2E test for new KafkaSource based on FLIP-27

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

[jira] [Closed] (FLINK-22515) Add Documentation for Flink Glue Schema Registry Integration

2021-05-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer closed FLINK-22515. - > Add Documentation for Flink Glue Schema Registry Integration >

[GitHub] [flink] lqjack commented on a change in pull request #15812: remove slotpoolImpl

2021-05-18 Thread GitBox
lqjack commented on a change in pull request #15812: URL: https://github.com/apache/flink/pull/15812#discussion_r634201138 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolPendingRequestFailureTest.java ## @@ -68,114 +52,6 @@

[GitHub] [flink] lqjack commented on a change in pull request #15812: remove slotpoolImpl

2021-05-18 Thread GitBox
lqjack commented on a change in pull request #15812: URL: https://github.com/apache/flink/pull/15812#discussion_r634201763 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImplWithSpreadOutStrategyTest.java ## @@ -48,19

[GitHub] [flink] flinkbot commented on pull request #15943: [FLINK-20655][e2e] Add E2E test for new KafkaSource based on FLIP-27

2021-05-18 Thread GitBox
flinkbot commented on pull request #15943: URL: https://github.com/apache/flink/pull/15943#issuecomment-843009282 ## CI report: * e34dbb3c99269e57b3056c912d5127eaddccb89a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15943: [FLINK-20655][e2e] Add E2E test for new KafkaSource based on FLIP-27

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15943: URL: https://github.com/apache/flink/pull/15943#issuecomment-843009282 ## CI report: * e34dbb3c99269e57b3056c912d5127eaddccb89a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15907: [BP-1.12][FLINK-22494][runtime] Introduce PossibleInconsistentStateException

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15907: URL: https://github.com/apache/flink/pull/15907#issuecomment-839913984 ## CI report: * a0bfff801337de40a41fe919a7cc3a83ab909028 Azure:

[GitHub] [flink] 95chenjz commented on a change in pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

2021-05-18 Thread GitBox
95chenjz commented on a change in pull request #15866: URL: https://github.com/apache/flink/pull/15866#discussion_r634292109 ## File path: docs/content.zh/docs/ops/monitoring/back_pressure.md ## @@ -28,62 +28,51 @@ under the License. # 监控反压 -Flink Web 界面提供了一个选项卡来监控正在运行

[GitHub] [flink] 95chenjz commented on a change in pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

2021-05-18 Thread GitBox
95chenjz commented on a change in pull request #15866: URL: https://github.com/apache/flink/pull/15866#discussion_r634292577 ## File path: docs/content.zh/docs/ops/monitoring/back_pressure.md ## @@ -28,62 +28,51 @@ under the License. # 监控反压 -Flink Web 界面提供了一个选项卡来监控正在运行

[GitHub] [flink] 95chenjz commented on a change in pull request #15866: [FLINK-22562][docs-zh]Translate recent updates to backpressure and ch…

2021-05-18 Thread GitBox
95chenjz commented on a change in pull request #15866: URL: https://github.com/apache/flink/pull/15866#discussion_r634292403 ## File path: docs/content.zh/docs/ops/monitoring/back_pressure.md ## @@ -28,62 +28,51 @@ under the License. # 监控反压 -Flink Web 界面提供了一个选项卡来监控正在运行

[jira] [Closed] (FLINK-22623) Drop BatchTableSource/Sink HBaseTableSource/Sink and related classes

2021-05-18 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-22623. Fix Version/s: 1.14.0 Release Note: The HBaseTableSource/Sink and related classes including

[jira] [Updated] (FLINK-22645) "ALTER VIEW" DDL is not supported for Flink dialect

2021-05-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22645: --- Labels: pull-request-available (was: ) > "ALTER VIEW" DDL is not supported for Flink

[GitHub] [flink] lqjack commented on a change in pull request #15812: remove slotpoolImpl

2021-05-18 Thread GitBox
lqjack commented on a change in pull request #15812: URL: https://github.com/apache/flink/pull/15812#discussion_r634331684 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphRestartTest.java ## @@ -272,8 +272,8 @@ public void

[GitHub] [flink] flinkbot commented on pull request #15947: [FLINK-22696] Enable Confluent Schema Registry e2e Test on jdk 11

2021-05-18 Thread GitBox
flinkbot commented on pull request #15947: URL: https://github.com/apache/flink/pull/15947#issuecomment-843151200 ## CI report: * 29dbbbc55bf216894e05ed293551cf090740da63 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15946: [FLINK-22645][sql-parser] "ALTER VIEW" DDL for Flink dialect

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15946: URL: https://github.com/apache/flink/pull/15946#issuecomment-843135843 ## CI report: * 77f74a0287db9399e8b32106232d5eedaef2c576 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15942: [BP-1.13][FLINK-19545][e2e] Add e2e test for native Kubernetes HA

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15942: URL: https://github.com/apache/flink/pull/15942#issuecomment-842991448 ## CI report: * 829bb063f2932a0ad4f0d1586977c6b69bdff9d6 Azure:

[jira] [Commented] (FLINK-19379) Submitting job to running YARN session fails

2021-05-18 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346700#comment-17346700 ] Robert Metzger commented on FLINK-19379: I discussed with Yang Wang offline that he'll deprecate

[GitHub] [flink] flinkbot edited a comment on pull request #15905: [FLINK-22623][hbase] Drop BatchTableSource HBaseTableSource/Sink and related classes

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15905: URL: https://github.com/apache/flink/pull/15905#issuecomment-839723747 ## CI report: * 41d487e74631600cb58096fff107af55c36dc243 Azure:

[GitHub] [flink] tillrohrmann commented on pull request #15832: [FLINK-22494][ha] Introduce PossibleInconsistentStateException

2021-05-18 Thread GitBox
tillrohrmann commented on pull request #15832: URL: https://github.com/apache/flink/pull/15832#issuecomment-842989916 Thanks for updating the PR @XComp. Merging it now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot edited a comment on pull request #15780: [FLINK-22487][python] Support `print` to print logs in PyFlink

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15780: URL: https://github.com/apache/flink/pull/15780#issuecomment-827444976 ## CI report: * 859149a5224d05589dcae87b7a384b7c223fce17 Azure:

[GitHub] [flink] tillrohrmann merged pull request #15907: [BP-1.12][FLINK-22494][runtime] Introduce PossibleInconsistentStateException

2021-05-18 Thread GitBox
tillrohrmann merged pull request #15907: URL: https://github.com/apache/flink/pull/15907 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15944: [FLINK-22694][e2e] Use sql file in TPCH end to end tests

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15944: URL: https://github.com/apache/flink/pull/15944#issuecomment-843049332 ## CI report: * b64a13c6b1f1c16817a40ca21a20574f51eabcfb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15905: [FLINK-22623][hbase] Drop BatchTableSource HBaseTableSource/Sink and related classes

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15905: URL: https://github.com/apache/flink/pull/15905#issuecomment-839723747 ## CI report: * 41d487e74631600cb58096fff107af55c36dc243 Azure:

[jira] [Updated] (FLINK-22688) Root Exception can not be shown on Web UI in Flink 1.13.0

2021-05-18 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-22688: - Fix Version/s: 1.13.1 > Root Exception can not be shown on Web UI in Flink 1.13.0 >

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

2021-05-18 Thread GitBox
zuston commented on a change in pull request #15653: URL: https://github.com/apache/flink/pull/15653#discussion_r634308061 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/util/JobConfUtilsTest.java ## @@ -0,0 +1,60 @@ +/* + *

[jira] [Commented] (FLINK-22688) Root Exception can not be shown on Web UI in Flink 1.13.0

2021-05-18 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17346855#comment-17346855 ] Matthias commented on FLINK-22688: -- [~gary.wu] could you share your JobManager and TaskManager logs

[jira] [Created] (FLINK-22696) Enable Confluent Schema Registry Test on jdk 11

2021-05-18 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-22696: --- Summary: Enable Confluent Schema Registry Test on jdk 11 Key: FLINK-22696 URL: https://issues.apache.org/jira/browse/FLINK-22696 Project: Flink Issue Type:

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

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-821801891 ## CI report: * 3e9b9c76bddbc2e1c58959ae1a59edf00f28f016 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15905: [FLINK-22623][hbase] Drop BatchTableSource HBaseTableSource/Sink and related classes

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15905: URL: https://github.com/apache/flink/pull/15905#issuecomment-839723747 ## CI report: * 41d487e74631600cb58096fff107af55c36dc243 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15893: [FLINK-22636] Group job specific zNodes under /jobs zNode

2021-05-18 Thread GitBox
flinkbot edited a comment on pull request #15893: URL: https://github.com/apache/flink/pull/15893#issuecomment-838372611 ## CI report: * 30eda18286e58548247ae87974650d3ebb1219b1 UNKNOWN * b65b3eb86c266a58433fc99f99c76ade7cb02d61 Azure:

  1   2   3   4   >