[GitHub] [flink] flinkbot edited a comment on issue #9122: [FLINK-13269] [table] copy RelDecorrelator & FlinkFilterJoinRule to flink planner to fix CALCITE-3169 & CALCITE-3170

flinkbot edited a comment on issue #9122: [FLINK-13269] [table] copy RelDecorrelator & FlinkFilterJoinRule to flink planner to fix CALCITE-3169 & CALCITE-3170 URL: https://github.com/apache/flink/pull/9122#issuecomment-511645215 ## CI report: *

[jira] [Commented] (FLINK-13251) Add bandwidth throttling for checkpoint uploading/downloading

[ https://issues.apache.org/jira/browse/FLINK-13251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885861#comment-16885861 ] Yu Li commented on FLINK-13251: --- Thanks for the reference [~sjwiesman], but these two things are kind of

[GitHub] [flink] flinkbot edited a comment on issue #9122: [FLINK-13269] [table] copy RelDecorrelator & FlinkFilterJoinRule to flink planner to fix CALCITE-3169 & CALCITE-3170

flinkbot edited a comment on issue #9122: [FLINK-13269] [table] copy RelDecorrelator & FlinkFilterJoinRule to flink planner to fix CALCITE-3169 & CALCITE-3170 URL: https://github.com/apache/flink/pull/9122#issuecomment-511645215 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9053: [FLINK-13182][Table SQL / Client] Fix Spelling mistake in flink-table

flinkbot edited a comment on issue #9053: [FLINK-13182][Table SQL / Client] Fix Spelling mistake in flink-table URL: https://github.com/apache/flink/pull/9053#issuecomment-511282008 ## CI report: * 3d8aa4ead36ebc700ba46936fe009a512b0e69ba : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9053: [FLINK-13182][Table SQL / Client] Fix Spelling mistake in flink-table

flinkbot edited a comment on issue #9053: [FLINK-13182][Table SQL / Client] Fix Spelling mistake in flink-table URL: https://github.com/apache/flink/pull/9053#issuecomment-511282008 ## CI report: * 3d8aa4ead36ebc700ba46936fe009a512b0e69ba : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9070: [FLINK-13193][tests] Enable custom flink cluster config per test

flinkbot edited a comment on issue #9070: [FLINK-13193][tests] Enable custom flink cluster config per test URL: https://github.com/apache/flink/pull/9070#issuecomment-511639502 ## CI report: * 8e7598bcc34fdc48284d5f5d74a73e5cf427 : SUCCESS

[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] 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] 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 : SUCCESS

[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] [Commented] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

[ https://issues.apache.org/jira/browse/FLINK-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885834#comment-16885834 ] Zhenqiu Huang commented on FLINK-13132: --- [~till.rohrmann] Would you please take a look the

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

[ https://issues.apache.org/jira/browse/FLINK-13273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885833#comment-16885833 ] Aljoscha Krettek commented on FLINK-13273: -- Added 1.9.0 tag until we resolve whether it will go

[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=16885832#comment-16885832 ] zhijiang edited comment on FLINK-13245 at 7/16/19 4:16 AM: --- We have some

[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=16885832#comment-16885832 ] zhijiang commented on FLINK-13245: -- We have some previous assumptions that ResultSubpartitionView could

[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: [~azagrebin] I have not seen your latest comments before submitting above.

[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 ] Aljoscha Krettek updated FLINK-13273: - Fix Version/s: 1.9.0 > Allow switching planners in SQL Client >

[GitHub] [flink] godfreyhe commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

godfreyhe commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#issuecomment-511656010 @wuchong thanks for the update, LGTM. @flinkbot approve all

[GitHub] [flink] wuchong commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

wuchong commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#issuecomment-511655250 @godfreyhe , updated.

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

flinkbot edited a comment 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] [Resolved] (FLINK-13268) Revert SqlSplittableAggFunction to support making 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 resolved FLINK-13268. - Resolution: Fixed Fixed in 1.10.0: a7bdbb9aff734fc586e74c95984c7f956dbf576c Fixed in 1.9.0:

[GitHub] [flink] asfgit closed pull request #9119: [FLINK-13268] [table-planner-blink] Revert SqlSplittableAggFunction to support making two planners available in one jar

asfgit closed pull request #9119: [FLINK-13268] [table-planner-blink] Revert SqlSplittableAggFunction to support making two planners available in one jar URL: https://github.com/apache/flink/pull/9119 This is an automated

[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] wuchong commented on issue #9119: [FLINK-13268] [table-planner-blink] Revert SqlSplittableAggFunction to support making two planners available in one jar

wuchong commented on issue #9119: [FLINK-13268] [table-planner-blink] Revert SqlSplittableAggFunction to support making two planners available in one jar URL: https://github.com/apache/flink/pull/9119#issuecomment-511652205 Travis is passed.

[GitHub] [flink] flinkbot edited a comment on issue #9119: [FLINK-13268] [table-planner-blink] Revert SqlSplittableAggFunction to support making two planners available in one jar

flinkbot edited a comment on issue #9119: [FLINK-13268] [table-planner-blink] Revert SqlSplittableAggFunction to support making two planners available in one jar URL: https://github.com/apache/flink/pull/9119#issuecomment-511404379 ## CI report: *

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

flinkbot edited a comment 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 : FAILURE

[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] 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 #9119: [FLINK-13268] [table-planner-blink] Revert SqlSplittableAggFunction to support making two planners available in one jar

flinkbot edited a comment on issue #9119: [FLINK-13268] [table-planner-blink] Revert SqlSplittableAggFunction to support making two planners available in one jar URL: https://github.com/apache/flink/pull/9119#issuecomment-511404379 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

flinkbot edited a comment on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#issuecomment-511424128 ## CI report: * e907364a720f6c6086c903e75079fca0fc2ab4ac :

[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] 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: *

[GitHub] [flink] wuchong commented on a change in pull request #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

wuchong commented on a change in pull request #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#discussion_r303715525 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

wuchong commented on a change in pull request #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#discussion_r303715390 ## File path:

[GitHub] [flink] wuchong commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

wuchong commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#issuecomment-511649681 Hi @JingsongLi , the single parallelism is not deterministic too with a

[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] 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] 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/119247129)

[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] walterddr commented on a change in pull request #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner

walterddr commented on a change in pull request #9056: [FLINK-13185] [sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser & flink planner URL: https://github.com/apache/flink/pull/9056#discussion_r303711467 ## File path:

[GitHub] [flink] flinkbot commented on issue #9122: [FLINK-13269] [table] copy RelDecorrelator & FlinkFilterJoinRule to flink planner to fix CALCITE-3169 & CALCITE-3170

flinkbot commented on issue #9122: [FLINK-13269] [table] copy RelDecorrelator & FlinkFilterJoinRule to flink planner to fix CALCITE-3169 & CALCITE-3170 URL: https://github.com/apache/flink/pull/9122#issuecomment-511645215 ## CI report: * 2f968ce7ffc295992471254265a1feef450a63f3 :

[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 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/119236394)

[GitHub] [flink] flinkbot commented on issue #9122: [FLINK-13269] [table] copy RelDecorrelator & FlinkFilterJoinRule to flink planner to fix CALCITE-3169 & CALCITE-3170

flinkbot commented on issue #9122: [FLINK-13269] [table] copy RelDecorrelator & FlinkFilterJoinRule to flink planner to fix CALCITE-3169 & CALCITE-3170 URL: https://github.com/apache/flink/pull/9122#issuecomment-511643189 Thanks a lot for your contribution to the Apache Flink project. I'm

[jira] [Updated] (FLINK-13269) copy RelDecorrelator & FlinkFilterJoinRule 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: --- Description: [CALCITE-3169|https://issues.apache.org/jira/browse/CALCITE-3169] &

[GitHub] [flink] JingsongLi commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

JingsongLi commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#issuecomment-511642613 > Hi @godfreyhe , the failure happens in a very extreme situation which

[GitHub] [flink] flinkbot edited a comment on issue #9053: [FLINK-13182][Table SQL / Client] Fix Spelling mistake in flink-table

flinkbot edited a comment on issue #9053: [FLINK-13182][Table SQL / Client] Fix Spelling mistake in flink-table URL: https://github.com/apache/flink/pull/9053#issuecomment-511282008 ## CI report: * 3d8aa4ead36ebc700ba46936fe009a512b0e69ba : PENDING

[jira] [Updated] (FLINK-13269) copy RelDecorrelator & FlinkFilterJoinRule 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: --- Description: [CALCITE-3169|https://issues.apache.org/jira/browse/CALCITE-3169] &

[jira] [Commented] (FLINK-13250) Blink Planner should assign concrete resources to all nodes

[ https://issues.apache.org/jira/browse/FLINK-13250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885788#comment-16885788 ] Till Rohrmann commented on FLINK-13250: --- Are you actively working on this [~StephanEwen]? > Blink

[GitHub] [flink] JingsongLi commented on a change in pull request #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

JingsongLi commented on a change in pull request #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#discussion_r303708438 ## File path:

[jira] [Updated] (FLINK-13269) copy RelDecorrelator & FlinkFilterJoinRule 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 & FlinkFilterJoinRule to flink planner to fix CALCITE-3169 &

[jira] [Commented] (FLINK-13257) blink runner should avoid stream operator implementing BoundedOneInput

[ https://issues.apache.org/jira/browse/FLINK-13257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885787#comment-16885787 ] Till Rohrmann commented on FLINK-13257: --- Is this strictly needed for 1.9.0 [~lzljs3620320]

[jira] [Updated] (FLINK-13258) Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator

[ https://issues.apache.org/jira/browse/FLINK-13258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13258: -- Component/s: Table SQL / Planner > Add tests for LongHashPartition, StringCallGen and

[GitHub] [flink] flinkbot edited a comment on issue #9053: [FLINK-13182][Table SQL / Client] Fix Spelling mistake in flink-table

flinkbot edited a comment on issue #9053: [FLINK-13182][Table SQL / Client] Fix Spelling mistake in flink-table URL: https://github.com/apache/flink/pull/9053#issuecomment-511282008 ## CI report: * 3d8aa4ead36ebc700ba46936fe009a512b0e69ba : FAILURE

[GitHub] [flink] flinkbot commented on issue #9070: [FLINK-13193][tests] Enable custom flink cluster config per test

flinkbot commented on issue #9070: [FLINK-13193][tests] Enable custom flink cluster config per test URL: https://github.com/apache/flink/pull/9070#issuecomment-511639502 ## CI report: * 8e7598bcc34fdc48284d5f5d74a73e5cf427 : PENDING

[jira] [Commented] (FLINK-11843) Dispatcher fails to recover jobs if leader change happens during JobManagerRunner termination

[ https://issues.apache.org/jira/browse/FLINK-11843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885782#comment-16885782 ] Till Rohrmann commented on FLINK-11843: --- Made this a critial issue for 1.9.0 [~tzulitai],

[jira] [Updated] (FLINK-11843) Dispatcher fails to recover jobs if leader change happens during JobManagerRunner termination

[ https://issues.apache.org/jira/browse/FLINK-11843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11843: -- Affects Version/s: 1.9.0 > Dispatcher fails to recover jobs if leader change happens during

[jira] [Updated] (FLINK-11843) Dispatcher fails to recover jobs if leader change happens during JobManagerRunner termination

[ https://issues.apache.org/jira/browse/FLINK-11843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11843: -- Fix Version/s: 1.10.0 1.9.0 > Dispatcher fails to recover jobs if leader

[GitHub] [flink] wuchong commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

wuchong commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#issuecomment-511637850 Hi @godfreyhe , the failure happens in a very extreme situation which can't

[GitHub] [flink] flinkbot edited a comment on issue #8990: [FLINK-13104][metrics] Updated request callback to log warning on failure

flinkbot edited a comment on issue #8990: [FLINK-13104][metrics] Updated request callback to log warning on failure URL: https://github.com/apache/flink/pull/8990#issuecomment-510684087 ## CI report: * f29b2ae71ed7d7dcd823399dc3427f76534b38d1 : FAILURE

[jira] [Commented] (FLINK-13169) IT test for fine-grained recovery (task executor failures)

[ https://issues.apache.org/jira/browse/FLINK-13169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885778#comment-16885778 ] Till Rohrmann commented on FLINK-13169: --- Made this a critical issue for 1.9.0. I would like to get

[jira] [Updated] (FLINK-13169) IT test for fine-grained recovery (task executor failures)

[ https://issues.apache.org/jira/browse/FLINK-13169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13169: -- Priority: Critical (was: Major) > IT test for fine-grained recovery (task executor failures)

[jira] [Commented] (FLINK-13145) Run HA dataset E2E test with new RestartPipelinedRegionStrategy

[ https://issues.apache.org/jira/browse/FLINK-13145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885777#comment-16885777 ] Till Rohrmann commented on FLINK-13145: --- Made this a blocker since we should have an end to end

[jira] [Commented] (FLINK-13176) remember current catalog and database in SQL CLI SessionContext

[ https://issues.apache.org/jira/browse/FLINK-13176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885774#comment-16885774 ] Bowen Li commented on FLINK-13176: -- [~ykt836] sorry I just saw your comment. I wouldn't call them

[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-13145) Run HA dataset E2E test with new RestartPipelinedRegionStrategy

[ https://issues.apache.org/jira/browse/FLINK-13145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13145: -- Priority: Blocker (was: Critical) > Run HA dataset E2E test with new

[GitHub] [flink] tillrohrmann commented on a change in pull request #9117: [FLINK-13223][dist] Enable fine-grained recovery by default in distribution

tillrohrmann commented on a change in pull request #9117: [FLINK-13223][dist] Enable fine-grained recovery by default in distribution URL: https://github.com/apache/flink/pull/9117#discussion_r303702233 ## File path:

[jira] [Updated] (FLINK-13176) remember current catalog and database in SQL CLI SessionContext

[ https://issues.apache.org/jira/browse/FLINK-13176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13176: - Fix Version/s: 1.10.0 > remember current catalog and database in SQL CLI SessionContext >

[jira] [Closed] (FLINK-13176) remember current catalog and database in SQL CLI SessionContext

[ https://issues.apache.org/jira/browse/FLINK-13176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13176. Resolution: Fixed merged in 1.10.0: a740f0c2799ba48e19acb185c1138115fd63aa65 1.9.0:

[GitHub] [flink] asfgit closed pull request #9049: [FLINK-13176][SQL CLI] remember current catalog and database in SQL CLI SessionContext

asfgit closed pull request #9049: [FLINK-13176][SQL CLI] remember current catalog and database in SQL CLI SessionContext URL: https://github.com/apache/flink/pull/9049 This is an automated message from the Apache Git

[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] [Commented] (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:comment-tabpanel=16885768#comment-16885768 ] Till Rohrmann commented on FLINK-13269: --- cc [~tzulitai], [~ykt836] > copy RelDecorrelator to

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

[ https://issues.apache.org/jira/browse/FLINK-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13272: -- Labels: test-stability (was: ) > Local recovery and sticky scheduling end-to-end test fails

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

[ https://issues.apache.org/jira/browse/FLINK-13273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885766#comment-16885766 ] Till Rohrmann commented on FLINK-13273: --- Does this mean that this needs to go into the

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

[ https://issues.apache.org/jira/browse/FLINK-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13272: -- Priority: Critical (was: Major) > Local recovery and sticky scheduling end-to-end test fails

[GitHub] [flink] godfreyhe commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result

godfreyhe commented on issue #9120: [FLINK-13216][FLINK-13153][table-planner-blink] Fix Max_Retract and Min_Retract may produce incorrect result URL: https://github.com/apache/flink/pull/9120#issuecomment-511632376 thanks for this pr @wuchong , could your add some tests to recur the

[jira] [Commented] (FLINK-13275) Race condition in SourceStreamTaskTest.finishingIgnoresExceptions()

[ https://issues.apache.org/jira/browse/FLINK-13275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885765#comment-16885765 ] Till Rohrmann commented on FLINK-13275: --- Does this only affects the current master and not the

[jira] [Updated] (FLINK-13275) Race condition in SourceStreamTaskTest.finishingIgnoresExceptions()

[ https://issues.apache.org/jira/browse/FLINK-13275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13275: -- Labels: test-stability (was: ) > Race condition in

[jira] [Updated] (FLINK-13280) Revert blink changes in DateTimeUtils, and keep it same as flink version.

[ https://issues.apache.org/jira/browse/FLINK-13280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-13280: - Priority: Critical (was: Major) > Revert blink changes in DateTimeUtils, and keep it same as

[jira] [Updated] (FLINK-13275) Race condition in SourceStreamTaskTest.finishingIgnoresExceptions()

[ https://issues.apache.org/jira/browse/FLINK-13275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13275: -- Fix Version/s: 1.10.0 > Race condition in SourceStreamTaskTest.finishingIgnoresExceptions() >

[jira] [Assigned] (FLINK-13280) Revert blink changes in DateTimeUtils, and keep it same as flink version.

[ https://issues.apache.org/jira/browse/FLINK-13280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao reassigned FLINK-13280: Assignee: Zhenghua Gao > Revert blink changes in DateTimeUtils, and keep it same as

[jira] [Updated] (FLINK-13276) write a quickstart documentation for Hive integration

[ https://issues.apache.org/jira/browse/FLINK-13276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13276: -- Priority: Blocker (was: Major) > write a quickstart documentation for Hive integration >

[jira] [Commented] (FLINK-13276) write a quickstart documentation for Hive integration

[ https://issues.apache.org/jira/browse/FLINK-13276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885764#comment-16885764 ] Till Rohrmann commented on FLINK-13276: --- Same reasoning as with FLINK-13277. cc [~tzulitai]

[jira] [Created] (FLINK-13280) Revert blink changes in DateTimeUtils, and keep it same as flink version.

Zhenghua Gao created FLINK-13280: Summary: Revert blink changes in DateTimeUtils, and keep it same as flink version. Key: FLINK-13280 URL: https://issues.apache.org/jira/browse/FLINK-13280 Project:

[jira] [Comment Edited] (FLINK-13277) add documentation of Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885763#comment-16885763 ] Till Rohrmann edited comment on FLINK-13277 at 7/16/19 1:45 AM: I would

[jira] [Commented] (FLINK-13277) add documentation of Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885763#comment-16885763 ] Till Rohrmann commented on FLINK-13277: --- I would make this a blocker for the moment because a

[jira] [Updated] (FLINK-13277) add documentation of Hive source/sink

[ https://issues.apache.org/jira/browse/FLINK-13277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13277: -- Priority: Blocker (was: Major) > add documentation of Hive source/sink >

[jira] [Commented] (FLINK-13086) add Chinese documentation for catalogs

[ https://issues.apache.org/jira/browse/FLINK-13086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885759#comment-16885759 ] Shengnan YU commented on FLINK-13086: - yes I'm glad to do that if having chance > add Chinese

[GitHub] [flink] flinkbot edited a comment on issue #9119: [FLINK-13268] [table-planner-blink] Revert SqlSplittableAggFunction to support making two planners available in one jar

flinkbot edited a comment on issue #9119: [FLINK-13268] [table-planner-blink] Revert SqlSplittableAggFunction to support making two planners available in one jar URL: https://github.com/apache/flink/pull/9119#issuecomment-511404379 ## CI report: *

[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

[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=16885754#comment-16885754 ] Jark Wu commented on FLINK-13266: - Hi [~twalthr], I think it's a good idea. However, the

[GitHub] [flink] TsReaper commented on issue #9111: [FLINK-13259] Fix typo about "access"

TsReaper commented on issue #9111: [FLINK-13259] Fix typo about "access" URL: https://github.com/apache/flink/pull/9111#issuecomment-511628994 Travis: https://travis-ci.com/TsReaper/flink/builds/119121901 This is an automated

[GitHub] [flink] TsReaper commented on issue #9110: [FLINK-13258] Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator

TsReaper commented on issue #9110: [FLINK-13258] Add tests for LongHashPartition, StringCallGen and EqualiserCodeGenerator URL: https://github.com/apache/flink/pull/9110#issuecomment-511629083 Travis: https://travis-ci.com/TsReaper/flink/builds/119120737

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

[GitHub] [flink] xintongsong commented on issue #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance.

xintongsong commented on issue #9105: [FLINK-13241][Yarn/Mesos] Fix Yarn/MesosResourceManager setting managed memory size into wrong configuration instance. URL: https://github.com/apache/flink/pull/9105#issuecomment-511626675 Thanks for the comment, @azagrebin. However, I'm not sure

[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 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 : 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] flinkbot edited a comment on issue #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

flinkbot edited a comment 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

  1   2   3   4   5   6   7   >