[GitHub] [flink] zentol commented on a change in pull request #8820: [FLINK-12916][tests] Retry cancelWithSavepoint on cancellation barrier in AbstractOperatorRestoreTestBase

zentol commented on a change in pull request #8820: [FLINK-12916][tests] Retry cancelWithSavepoint on cancellation barrier in AbstractOperatorRestoreTestBase URL: https://github.com/apache/flink/pull/8820#discussion_r303422653 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8820: [FLINK-12916][tests] Retry cancelWithSavepoint on cancellation barrier in AbstractOperatorRestoreTestBase

zentol commented on a change in pull request #8820: [FLINK-12916][tests] Retry cancelWithSavepoint on cancellation barrier in AbstractOperatorRestoreTestBase URL: https://github.com/apache/flink/pull/8820#discussion_r303423389 ## File path:

[GitHub] [flink] flinkbot commented on issue #9117: [FLINK-13223][dist] Enable fine-grained recovery by default in distribution

flinkbot commented on issue #9117: [FLINK-13223][dist] Enable fine-grained recovery by default in distribution URL: https://github.com/apache/flink/pull/9117#issuecomment-511392531 ## CI report: * c75968cc5631c40d54ee0f79dbc84f5b1098768f : PENDING

[GitHub] [flink] flinkbot commented on issue #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser

flinkbot commented on issue #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser URL: https://github.com/apache/flink/pull/9118#issuecomment-511392553 ## CI report: * f1da2b8c756a0af3e923aeee451e857c4d1728b7 : PENDING

[GitHub] [flink] asfgit closed pull request #7932: [FLINK-11727][formats] Fixed JSON format issues after serialization

asfgit closed pull request #7932: [FLINK-11727][formats] Fixed JSON format issues after serialization URL: https://github.com/apache/flink/pull/7932 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot commented on issue #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser

flinkbot commented on issue #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser URL: https://github.com/apache/flink/pull/9118#issuecomment-511389589 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

flinkbot edited a comment on issue #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101#issuecomment-510770597 ## CI report: *

[jira] [Updated] (FLINK-13206) modify 'use database' syntax in SQL CLI to be consistant with standard sql

[ https://issues.apache.org/jira/browse/FLINK-13206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13206: --- Labels: pull-request-available (was: ) > modify 'use database' syntax in SQL CLI to be

[GitHub] [flink] zjuwangg commented on issue #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser

zjuwangg commented on issue #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser URL: https://github.com/apache/flink/pull/9118#issuecomment-511389116 cc @bowenli86 @xuefuz @lirui-apache to review.

[GitHub] [flink] zjuwangg opened a new pull request #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser

zjuwangg opened a new pull request #9118: [FLINK-13206][sql client]replace `use database xxx` with `use xxx` in sql client parser URL: https://github.com/apache/flink/pull/9118 ## What is the purpose of the change *Replace `use database xxx` with `use xxx` in sql client parser *

[GitHub] [flink] flinkbot commented on issue #9117: [FLINK-13223][dist] Enable fine-grained recovery by default in distribution

flinkbot commented on issue #9117: [FLINK-13223][dist] Enable fine-grained recovery by default in distribution URL: https://github.com/apache/flink/pull/9117#issuecomment-511388296 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-13273) Allow switching planners in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-13273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-13273: - Priority: Blocker (was: Major) > Allow switching planners in SQL Client >

[jira] [Updated] (FLINK-13223) Set jobmanager.execution.failover-strategy to region in default flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13223: --- Labels: pull-request-available (was: ) > Set jobmanager.execution.failover-strategy to

[jira] [Updated] (FLINK-13273) Allow switching planners in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-13273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-13273: - Affects Version/s: 1.9.0 > Allow switching planners in SQL Client >

[GitHub] [flink] zentol opened a new pull request #9117: [FLINK-13223][dist] Enable fine-grained recovery by default in distribution

zentol opened a new pull request #9117: [FLINK-13223][dist] Enable fine-grained recovery by default in distribution URL: https://github.com/apache/flink/pull/9117 Enables fine-grained recovery by default in the flink distribution. We don't enable it by default for all tests since too many

[jira] [Created] (FLINK-13273) Allow switching planners in SQL Client

Timo Walther created FLINK-13273: Summary: Allow switching planners in SQL Client Key: FLINK-13273 URL: https://issues.apache.org/jira/browse/FLINK-13273 Project: Flink Issue Type: New

[GitHub] [flink] flinkbot edited a comment on issue #8820: [FLINK-12916][tests] Retry cancelWithSavepoint on cancellation barrier in AbstractOperatorRestoreTestBase

flinkbot edited a comment on issue #8820: [FLINK-12916][tests] Retry cancelWithSavepoint on cancellation barrier in AbstractOperatorRestoreTestBase URL: https://github.com/apache/flink/pull/8820#issuecomment-511336236 ## CI report: * 4b0f85fab76048b96500745b7aff8105e079401c :

[jira] [Updated] (FLINK-13205) Checkpoints/savepoints injection has loose ordering properties when a stop-with-savepoint is triggered

[ https://issues.apache.org/jira/browse/FLINK-13205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13205: --- Labels: pull-request-available (was: ) > Checkpoints/savepoints injection has loose

[GitHub] [flink] kl0u closed pull request #9021: [FLINK-13205][runtime] Make checkpoints injection ordered with stop-with-savepoint

kl0u closed pull request #9021: [FLINK-13205][runtime] Make checkpoints injection ordered with stop-with-savepoint URL: https://github.com/apache/flink/pull/9021 This is an automated message from the Apache Git Service. To

[GitHub] [flink] kl0u commented on issue #9021: [FLINK-13205][runtime] Make checkpoints injection ordered with stop-with-savepoint

kl0u commented on issue #9021: [FLINK-13205][runtime] Make checkpoints injection ordered with stop-with-savepoint URL: https://github.com/apache/flink/pull/9021#issuecomment-511385434 Merged on master and release-1.9 This is

[jira] [Closed] (FLINK-13205) Checkpoints/savepoints injection has loose ordering properties when a stop-with-savepoint is triggered

[ https://issues.apache.org/jira/browse/FLINK-13205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-13205. -- Resolution: Fixed Merged on master with 0c8c1d4b827700d788f5b4ddbd8a21192165d039 and on

[jira] [Updated] (FLINK-13205) Checkpoints/savepoints injection has loose ordering properties when a stop-with-savepoint is triggered

[ https://issues.apache.org/jira/browse/FLINK-13205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-13205: --- Fix Version/s: 1.9.0 > Checkpoints/savepoints injection has loose ordering properties when

[GitHub] [flink] flinkbot edited a comment on issue #8820: [FLINK-12916][tests] Retry cancelWithSavepoint on cancellation barrier in AbstractOperatorRestoreTestBase

flinkbot edited a comment on issue #8820: [FLINK-12916][tests] Retry cancelWithSavepoint on cancellation barrier in AbstractOperatorRestoreTestBase URL: https://github.com/apache/flink/pull/8820#issuecomment-511336236 ## CI report: * 4b0f85fab76048b96500745b7aff8105e079401c :

[GitHub] [flink] twalthr commented on issue #9116: [FLINK-13264][table] Let the planner supply its type inference util

twalthr commented on issue #9116: [FLINK-13264][table] Let the planner supply its type inference util URL: https://github.com/apache/flink/pull/9116#issuecomment-511383942 Thanks @godfreyhe. Will address you comment and merge this. Once the build is green.

[jira] [Created] (FLINK-13272) Local recovery and sticky scheduling end-to-end test fails on Travis

Chesnay Schepler created FLINK-13272: Summary: Local recovery and sticky scheduling end-to-end test fails on Travis Key: FLINK-13272 URL: https://issues.apache.org/jira/browse/FLINK-13272

[GitHub] [flink] flinkbot edited a comment on issue #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager

flinkbot edited a comment on issue #8471: [FLINK-12529][runtime] Release record-deserializer buffers timely to improve the efficiency of heap usage on taskmanager URL: https://github.com/apache/flink/pull/8471#issuecomment-510870797 ## CI report: *

[jira] [Commented] (FLINK-13264) Remove planner class clashes for planner type inference lookups

[ https://issues.apache.org/jira/browse/FLINK-13264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885161#comment-16885161 ] Timo Walther commented on FLINK-13264: -- Makes sense to me. Thanks. > Remove planner class clashes

[jira] [Comment Edited] (FLINK-13266) Relocate blink planner classes to avoid class clashes

[ https://issues.apache.org/jira/browse/FLINK-13266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885156#comment-16885156 ] Timo Walther edited comment on FLINK-13266 at 7/15/19 12:18 PM: I would

[jira] [Commented] (FLINK-13266) Relocate blink planner classes to avoid class clashes

[ https://issues.apache.org/jira/browse/FLINK-13266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885156#comment-16885156 ] Timo Walther commented on FLINK-13266: -- I would not use {{org.apache.flink.table.blink}} in any

[jira] [Closed] (FLINK-13270) CheckpointCoordinator abort the checkpoint

[ https://issues.apache.org/jira/browse/FLINK-13270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13270. Resolution: Duplicate > CheckpointCoordinator abort the checkpoint >

[GitHub] [flink] flinkbot edited a comment on issue #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter

flinkbot edited a comment on issue #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter URL: https://github.com/apache/flink/pull/8621#issuecomment-511183092 ## CI report: * e21d12fa2c9b6305d90502ae05a9d574ce712fd1 : PENDING

[GitHub] [flink] godfreyhe commented on a change in pull request #9116: [FLINK-13264][table] Let the planner supply its type inference util

godfreyhe commented on a change in pull request #9116: [FLINK-13264][table] Let the planner supply its type inference util URL: https://github.com/apache/flink/pull/9116#discussion_r303398132 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter

flinkbot edited a comment on issue #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter URL: https://github.com/apache/flink/pull/8621#issuecomment-511183092 ## CI report: * e21d12fa2c9b6305d90502ae05a9d574ce712fd1 : FAILURE

[jira] [Created] (FLINK-13271) Add documentation for all the new features of blink planner

Jark Wu created FLINK-13271: --- Summary: Add documentation for all the new features of blink planner Key: FLINK-13271 URL: https://issues.apache.org/jira/browse/FLINK-13271 Project: Flink Issue

[jira] [Assigned] (FLINK-13267) Package Flink planner and Blink planner into an uber jar

[ https://issues.apache.org/jira/browse/FLINK-13267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13267: --- Assignee: Jark Wu > Package Flink planner and Blink planner into an uber jar >

[jira] [Updated] (FLINK-13270) CheckpointCoordinator abort the checkpoint

[ https://issues.apache.org/jira/browse/FLINK-13270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] molsion updated FLINK-13270: Description: # Submitting a job that source is Kafka, and Kafka partition is 1 , if set source

[jira] [Updated] (FLINK-13270) CheckpointCoordinator abort the checkpoint

[ https://issues.apache.org/jira/browse/FLINK-13270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] molsion updated FLINK-13270: Description: # Submitting a job that source is Kafka, and Kafka partition is 1 , if set source

[jira] [Updated] (FLINK-13269) copy RelDecorrelator to flink planner to fix CALCITE-3169 & CALCITE-3170

[ https://issues.apache.org/jira/browse/FLINK-13269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-13269: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-13267 > copy RelDecorrelator to

[jira] [Updated] (FLINK-13269) copy RelDecorrelator to flink planner to fix CALCITE-3169 & CALCITE-3170

[ https://issues.apache.org/jira/browse/FLINK-13269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-13269: --- Summary: copy RelDecorrelator to flink planner to fix CALCITE-3169 & CALCITE-3170 (was: copy

[jira] [Created] (FLINK-13269) copy RelDecorrelator from blink planner to flink planner to fix CALCITE-3169 & CALCITE-3170

godfrey he created FLINK-13269: -- Summary: copy RelDecorrelator from blink planner to flink planner to fix CALCITE-3169 & CALCITE-3170 Key: FLINK-13269 URL: https://issues.apache.org/jira/browse/FLINK-13269

[GitHub] [flink] zentol commented on issue #9071: FLINK-13044 [BuildSystem / Shaded] Fix for wrong shading of AWS SDK in flink-s3-fs-hadoop

zentol commented on issue #9071: FLINK-13044 [BuildSystem / Shaded] Fix for wrong shading of AWS SDK in flink-s3-fs-hadoop URL: https://github.com/apache/flink/pull/9071#issuecomment-511368590 OK, let's see if I got this correctly: There are 2 issues here: 1) The shade-plugin

[jira] [Created] (FLINK-13270) CheckpointCoordinator abort the checkpoint

molsion created FLINK-13270: --- Summary: CheckpointCoordinator abort the checkpoint Key: FLINK-13270 URL: https://issues.apache.org/jira/browse/FLINK-13270 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on issue #7932: [FLINK-11727][formats] Fixed JSON format issues after serialization

flinkbot commented on issue #7932: [FLINK-11727][formats] Fixed JSON format issues after serialization URL: https://github.com/apache/flink/pull/7932#issuecomment-511368557 ## CI report: * 08ffc23688712438dde2b18a187853e165402bae : PENDING

[jira] [Updated] (FLINK-13268) Revert SqlSplittableAggFunction to make two planners available in one jar

[ https://issues.apache.org/jira/browse/FLINK-13268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13268: Issue Type: Sub-task (was: Improvement) Parent: FLINK-13267 > Revert SqlSplittableAggFunction to

[jira] [Updated] (FLINK-13268) Revert SqlSplittableAggFunction to make two planners available in one jar

[ https://issues.apache.org/jira/browse/FLINK-13268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13268: Summary: Revert SqlSplittableAggFunction to make two planners available in one jar (was: revert

[jira] [Updated] (FLINK-13266) Relocate blink planner classes to avoid class clashes

[ https://issues.apache.org/jira/browse/FLINK-13266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13266: Issue Type: Sub-task (was: Task) Parent: FLINK-13267 > Relocate blink planner classes to avoid

[jira] [Created] (FLINK-13268) revert SqlSplittableAggFunction to make two planners available in one jar

godfrey he created FLINK-13268: -- Summary: revert SqlSplittableAggFunction to make two planners available in one jar Key: FLINK-13268 URL: https://issues.apache.org/jira/browse/FLINK-13268 Project: Flink

[jira] [Commented] (FLINK-13264) Remove planner class clashes for planner type inference lookups

[ https://issues.apache.org/jira/browse/FLINK-13264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885108#comment-16885108 ] Jark Wu commented on FLINK-13264: - Hi [~twalthr], I changed this issue into a sub-task of FLINK-13267 to

[jira] [Updated] (FLINK-13264) Remove planner class clashes for planner type inference lookups

[ https://issues.apache.org/jira/browse/FLINK-13264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13264: Issue Type: Sub-task (was: Task) Parent: FLINK-13267 > Remove planner class clashes for planner

[jira] [Updated] (FLINK-13264) Remove planner class clashes for planner type inference lookups

[ https://issues.apache.org/jira/browse/FLINK-13264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13264: Issue Type: Task (was: Sub-task) Parent: (was: FLINK-12251) > Remove planner class clashes

[GitHub] [flink] flinkbot commented on issue #9116: [FLINK-13264][table] Let the planner supply its type inference util

flinkbot commented on issue #9116: [FLINK-13264][table] Let the planner supply its type inference util URL: https://github.com/apache/flink/pull/9116#issuecomment-511366494 ## CI report: * ae71d7dafcd5aa2ada79a8198be1811337501222 : PENDING

[jira] [Closed] (FLINK-13124) Stop fails with Universal Kafka Consumer

[ https://issues.apache.org/jira/browse/FLINK-13124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-13124. -- Resolution: Fixed Merged on master with 2e2f67ed348c334402a5d0af76b0fd47cedcf5a7 and on

[jira] [Created] (FLINK-13267) Package Flink planner and Blink planner into an uber jar

Jark Wu created FLINK-13267: --- Summary: Package Flink planner and Blink planner into an uber jar Key: FLINK-13267 URL: https://issues.apache.org/jira/browse/FLINK-13267 Project: Flink Issue Type:

[GitHub] [flink] kl0u commented on issue #9115: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

kl0u commented on issue #9115: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9115#issuecomment-511365458 Merge on 1.9. This is an automated message from the

[GitHub] [flink] kl0u closed pull request #9115: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

kl0u closed pull request #9115: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9115 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] twalthr commented on issue #7932: [FLINK-11727][formats] Fixed JSON format issues after serialization

twalthr commented on issue #7932: [FLINK-11727][formats] Fixed JSON format issues after serialization URL: https://github.com/apache/flink/pull/7932#issuecomment-511365164 Thank you @dawidwys. I will go through the changes again and merge this.

[GitHub] [flink] flinkbot commented on issue #9116: [FLINK-13264][table] Let the planner supply its type inference util

flinkbot commented on issue #9116: [FLINK-13264][table] Let the planner supply its type inference util URL: https://github.com/apache/flink/pull/9116#issuecomment-511363908 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-13266) Relocate blink planner classes to avoid class clashes

[ https://issues.apache.org/jira/browse/FLINK-13266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13266: Priority: Blocker (was: Major) > Relocate blink planner classes to avoid class clashes >

[jira] [Created] (FLINK-13266) Relocate blink planner classes to avoid class clashes

Jark Wu created FLINK-13266: --- Summary: Relocate blink planner classes to avoid class clashes Key: FLINK-13266 URL: https://issues.apache.org/jira/browse/FLINK-13266 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-13264) Remove planner class clashes for planner type inference lookups

[ https://issues.apache.org/jira/browse/FLINK-13264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13264: --- Labels: pull-request-available (was: ) > Remove planner class clashes for planner type

[GitHub] [flink] twalthr opened a new pull request #9116: [FLINK-13264][table] Let the planner supply its type inference util

twalthr opened a new pull request #9116: [FLINK-13264][table] Let the planner supply its type inference util URL: https://github.com/apache/flink/pull/9116 ## What is the purpose of the change This PR makes it possible that

[GitHub] [flink] dianfu commented on issue #9114: [FLINK-13263] [python] Supports explain DAG plan in flink-python

dianfu commented on issue #9114: [FLINK-13263] [python] Supports explain DAG plan in flink-python URL: https://github.com/apache/flink/pull/9114#issuecomment-511363327 @godfreyhe Thanks a lot for the PR. LGTM. +1 from my side.

[GitHub] [flink] flinkbot commented on issue #9115: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

flinkbot commented on issue #9115: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9115#issuecomment-511362235 ## CI report: * a7f8c3ed0b8bb958e8aafc36cbd206dcb1cc984d : PENDING

[GitHub] [flink] flinkbot commented on issue #9114: [FLINK-13263] [python] Supports explain DAG plan in flink-python

flinkbot commented on issue #9114: [FLINK-13263] [python] Supports explain DAG plan in flink-python URL: https://github.com/apache/flink/pull/9114#issuecomment-511362229 ## CI report: * abc251f1802e984bc79ce073cef82f6382f50359 : PENDING

[jira] [Updated] (FLINK-13262) Add documentation for the new Table & SQL API type system

[ https://issues.apache.org/jira/browse/FLINK-13262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13262: Fix Version/s: 1.9.0 > Add documentation for the new Table & SQL API type system >

[jira] [Updated] (FLINK-13264) Remove planner class clashes for planner type inference lookups

[ https://issues.apache.org/jira/browse/FLINK-13264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13264: Fix Version/s: 1.9.0 > Remove planner class clashes for planner type inference lookups >

[GitHub] [flink] flinkbot edited a comment on issue #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner

flinkbot edited a comment on issue #9035: [FLINK-13168] [table] clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner URL: https://github.com/apache/flink/pull/9035#issuecomment-510801620 ## CI report: * dac226605ba8018c4c18c27624260c9e3d1f9eaf : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

flinkbot edited a comment on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#issuecomment-511260167 ## CI report: * e290f6b65758fc7d199277e4345a75335de981b2 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9110: [FLINK-13258] Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator

flinkbot edited a comment on issue #9110: [FLINK-13258] Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator URL: https://github.com/apache/flink/pull/9110#issuecomment-511305693 ## CI report: * 26f95bfde851137cb71fa6060df7587535340afe : PENDING

[GitHub] [flink] flinkbot commented on issue #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

flinkbot commented on issue #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option URL: https://github.com/apache/flink/pull/9113#issuecomment-511360277 ## CI report: * b6bb574fbe0e3421adb07aef7ffd1c8068675a74 : PENDING

[jira] [Created] (FLINK-13265) Noisy hive-connector tests

Chesnay Schepler created FLINK-13265: Summary: Noisy hive-connector tests Key: FLINK-13265 URL: https://issues.apache.org/jira/browse/FLINK-13265 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on issue #9115: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

flinkbot commented on issue #9115: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9115#issuecomment-511359943 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot commented on issue #9114: [FLINK-13263] [python] Supports explain DAG plan in flink-python

flinkbot commented on issue #9114: [FLINK-13263] [python] Supports explain DAG plan in flink-python URL: https://github.com/apache/flink/pull/9114#issuecomment-511359581 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] aljoscha opened a new pull request #9115: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

aljoscha opened a new pull request #9115: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9115 ## What is the purpose of the change Before, exceptions that occurred after cancelling a source (as the KafkaConsumer

[jira] [Updated] (FLINK-13263) supports explain DAG plan in flink-python

[ https://issues.apache.org/jira/browse/FLINK-13263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13263: --- Labels: pull-request-available (was: ) > supports explain DAG plan in flink-python >

[GitHub] [flink] kl0u closed pull request #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

kl0u closed pull request #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9090 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] godfreyhe commented on issue #9114: [FLINK-13263] [python] Supports explain DAG plan in flink-python

godfreyhe commented on issue #9114: [FLINK-13263] [python] Supports explain DAG plan in flink-python URL: https://github.com/apache/flink/pull/9114#issuecomment-511359106 cc @dianfu @sunjincheng121 This is an automated

[GitHub] [flink] godfreyhe opened a new pull request #9114: [FLINK-13263] [python] Supports explain DAG plan in flink-python

godfreyhe opened a new pull request #9114: [FLINK-13263] [python] Supports explain DAG plan in flink-python URL: https://github.com/apache/flink/pull/9114 ## What is the purpose of the change *Supports explain DAG plan in flink-python* ## Brief change log

[GitHub] [flink] kl0u commented on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

kl0u commented on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9090#issuecomment-511358940 Merged on master This is an automated message from

[GitHub] [flink] flinkbot commented on issue #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

flinkbot commented on issue #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option URL: https://github.com/apache/flink/pull/9113#issuecomment-511358489 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-13222) Add documentation for AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-13222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13222: --- Labels: pull-request-available (was: ) > Add documentation for

[GitHub] [flink] flinkbot edited a comment on issue #9110: [FLINK-13258] Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator

flinkbot edited a comment on issue #9110: [FLINK-13258] Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator URL: https://github.com/apache/flink/pull/9110#issuecomment-511305693 ## CI report: * 26f95bfde851137cb71fa6060df7587535340afe : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

flinkbot edited a comment on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#issuecomment-511260167 ## CI report: * e290f6b65758fc7d199277e4345a75335de981b2 : FAILURE

[GitHub] [flink] zhuzhurk opened a new pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

zhuzhurk opened a new pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option URL: https://github.com/apache/flink/pull/9113 ## What is the purpose of the change *The PR adds documentation for failover strategy options, including "full" and

[jira] [Comment Edited] (FLINK-13245) Network stack is leaking files

[ https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883829#comment-16883829 ] Chesnay Schepler edited comment on FLINK-13245 at 7/15/19 10:56 AM:

[GitHub] [flink] kl0u commented on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

kl0u commented on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9090#issuecomment-511356439 Sure! I will merge now. This is an automated message

[GitHub] [flink] flinkbot edited a comment on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

flinkbot edited a comment on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#issuecomment-510464651 ## CI report: * b2821a6ae97fd943f3a66b672e85fbd2374126c4 : SUCCESS

[jira] [Updated] (FLINK-13188) Flink runtime MockTtlStateTest failed 94

[ https://issues.apache.org/jira/browse/FLINK-13188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13188: - Issue Type: Bug (was: Test) > Flink runtime MockTtlStateTest failed 94 >

[jira] [Reopened] (FLINK-13188) Flink runtime MockTtlStateTest failed 94

[ https://issues.apache.org/jira/browse/FLINK-13188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-13188: -- > Flink runtime MockTtlStateTest failed 94 > > >

[jira] [Issue Comment Deleted] (FLINK-13245) Network stack is leaking files

[ https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-13245: - Comment: was deleted (was: Thanks for finding this potential issue and the investigation! [~Zentol]

[jira] [Commented] (FLINK-13188) Flink runtime MockTtlStateTest failed 94

[ https://issues.apache.org/jira/browse/FLINK-13188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885080#comment-16885080 ] Yu Li commented on FLINK-13188: --- [~lunge] Mind explain how this is fixed? It seems to me the PR is not

[GitHub] [flink] aljoscha commented on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask

aljoscha commented on issue #9090: [FLINK-13124] Don't forward exceptions when finishing SourceStreamTask URL: https://github.com/apache/flink/pull/9090#issuecomment-511355161 ok, thanks! could you please merge? (just arrived in china  )

[jira] [Comment Edited] (FLINK-13245) Network stack is leaking files

[ https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885076#comment-16885076 ] zhijiang edited comment on FLINK-13245 at 7/15/19 10:46 AM: Thanks for

[jira] [Commented] (FLINK-13245) Network stack is leaking files

[ https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885076#comment-16885076 ] zhijiang commented on FLINK-13245: -- Thanks for finding this potential issue and the investigation!

[GitHub] [flink] flinkbot edited a comment on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

flinkbot edited a comment on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#issuecomment-510464651 ## CI report: * b2821a6ae97fd943f3a66b672e85fbd2374126c4 : SUCCESS

[GitHub] [flink] ben-wangz commented on issue #8717: fix issue https://issues.apache.org/jira/browse/FLINK-12725

ben-wangz commented on issue #8717: fix issue https://issues.apache.org/jira/browse/FLINK-12725 URL: https://github.com/apache/flink/pull/8717#issuecomment-511351314 i cherry-pick this fix to release-1.8.0 and run it with mongo input format (org.mongodb, mongo-hadoop-core, 1.3.0)。 found

[GitHub] [flink] flinkbot edited a comment on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client

flinkbot edited a comment on issue #8756: [FLINK-12406] [Runtime] Report BLOCKING_PERSISTENT result partition meta back to client URL: https://github.com/apache/flink/pull/8756#issuecomment-511260167 ## CI report: * e290f6b65758fc7d199277e4345a75335de981b2 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9111: [FLINK-13259] Fix typo about "access"

flinkbot edited a comment on issue #9111: [FLINK-13259] Fix typo about "access" URL: https://github.com/apache/flink/pull/9111#issuecomment-511309474 ## CI report: * 439d80022ebd673b66b87ddeeb02cd89a35e6083 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/119129778)

[jira] [Commented] (FLINK-13249) Distributed Jepsen test fails with blocked TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885059#comment-16885059 ] Stefan Richter commented on FLINK-13249: [~till.rohrmann] alright, I think then we have a

[jira] [Commented] (FLINK-13249) Distributed Jepsen test fails with blocked TaskExecutor

[ https://issues.apache.org/jira/browse/FLINK-13249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885053#comment-16885053 ] Till Rohrmann commented on FLINK-13249: --- [~gaoyunhaii] explained me the problem and now I finally

<    1   2   3   4   5   6   7   >