[GitHub] [flink] flinkbot edited a comment on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription

flinkbot edited a comment on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription URL: https://github.com/apache/flink/pull/9821#issuecomment-536618253 ## CI report: * 9ca9df3eaa22965444373a3b6142798ca5559f50 : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

AHeise commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r329898500 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/a

[GitHub] [flink] flinkbot edited a comment on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription

flinkbot edited a comment on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription URL: https://github.com/apache/flink/pull/9821#issuecomment-536618253 ## CI report: * 9ca9df3eaa22965444373a3b6142798ca5559f50 : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese

flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese URL: https://github.com/apache/flink/pull/9815#issuecomment-536343016 ## CI report: * 615acdb2511760c55f8831934f710678a8962acc : FAILURE [Build](https://travis-ci.com/flin

[jira] [Commented] (FLINK-14196) Nightly e2e-sticky-hadoop2.8 fails due to NPE

[ https://issues.apache.org/jira/browse/FLINK-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941548#comment-16941548 ] Till Rohrmann commented on FLINK-14196: --- Why do you think this could not be caused

[jira] [Resolved] (FLINK-14226) Subset of nightly tests fail due to No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-14226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14226. --- Resolution: Duplicate This problem has been fixed as part of FLINK-14178 > Subset of nightl

[jira] [Resolved] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14178. --- Resolution: Fixed Fixed via 81038ff1ec0f809f19677a469447053d489f964c > maven-shade-plugin 3

[GitHub] [flink] tillrohrmann closed pull request #9817: [FLINK-14178] Downgrade maven-shade-plugin to 3.1.0

tillrohrmann closed pull request #9817: [FLINK-14178] Downgrade maven-shade-plugin to 3.1.0 URL: https://github.com/apache/flink/pull/9817 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14178: -- Fix Version/s: (was: 2.0.0) 1.10.0 > maven-shade-plugin 3.2.1 doesn't w

[jira] [Updated] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14178: -- Affects Version/s: (was: 2.0.0) 1.10.0 > maven-shade-plugin 3.2.1 d

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese

flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese URL: https://github.com/apache/flink/pull/9815#issuecomment-536343016 ## CI report: * 615acdb2511760c55f8831934f710678a8962acc : FAILURE [Build](https://travis-ci.com/flin

[GitHub] [flink] Mrart edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

Mrart edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-536870094 @rmetzger Could you help review this PR? Thi

[GitHub] [flink] Mrart commented on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

Mrart commented on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-536870094 @rmetzger Could you help approval this PR? This is

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese

flinkbot edited a comment on issue #9815: [FLINK-14117][docs-zh] Translate changes on index page to Chinese URL: https://github.com/apache/flink/pull/9815#issuecomment-536343016 ## CI report: * 615acdb2511760c55f8831934f710678a8962acc : FAILURE [Build](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration

flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762#issuecomment-534689957 ## CI report: * cefac57542dbd85a6693f6a1b7c8c90d91e85d30 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/128980426)

[GitHub] [flink] walterddr commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

walterddr commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#discussion_r329875995 ## File path: flink-connectors/flink-orc/src/main/java/org

[GitHub] [flink] walterddr commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

walterddr commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#discussion_r329876013 ## File path: flink-formats/flink-parquet/src/main/java/or

[GitHub] [flink] walterddr commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

walterddr commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#discussion_r329876088 ## File path: flink-table/flink-table-planner/src/main/sca

[jira] [Commented] (FLINK-9395) Outer Joins with array types on the outer join input fail

[ https://issues.apache.org/jira/browse/FLINK-9395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941521#comment-16941521 ] Ken Geis commented on FLINK-9395: - Good news. This worked for me using the Blink planner.

[GitHub] [flink] walterddr commented on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

walterddr commented on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#issuecomment-536859787 @KurtYoung sorry for the delay. I just implemented a way to safe check to prevent use

[GitHub] [flink] flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration

flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762#issuecomment-534689957 ## CI report: * cefac57542dbd85a6693f6a1b7c8c90d91e85d30 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/128980426)

[GitHub] [flink] flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration

flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762#issuecomment-534689957 ## CI report: * cefac57542dbd85a6693f6a1b7c8c90d91e85d30 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/128980426)

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] zhengcanbin commented on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

zhengcanbin commented on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-536836014 > One general question from my side: Shall we also allow multiline statements in `sqlQuery()`? In theory we could allo

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] TisonKun commented on a change in pull request #9810: [FLINK-14284] Add shut down future to Dispatcher

TisonKun commented on a change in pull request #9810: [FLINK-14284] Add shut down future to Dispatcher URL: https://github.com/apache/flink/pull/9810#discussion_r329858169 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@

[GitHub] [flink] TisonKun commented on a change in pull request #9810: [FLINK-14284] Add shut down future to Dispatcher

TisonKun commented on a change in pull request #9810: [FLINK-14284] Add shut down future to Dispatcher URL: https://github.com/apache/flink/pull/9810#discussion_r329857622 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@

[GitHub] [flink] TisonKun commented on a change in pull request #9810: [FLINK-14284] Add shut down future to Dispatcher

TisonKun commented on a change in pull request #9810: [FLINK-14284] Add shut down future to Dispatcher URL: https://github.com/apache/flink/pull/9810#discussion_r329857622 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@

[GitHub] [flink] TisonKun commented on a change in pull request #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy

TisonKun commented on a change in pull request #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy URL: https://github.com/apache/flink/pull/9809#discussion_r329855229 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/Def

[GitHub] [flink] TisonKun commented on a change in pull request #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy

TisonKun commented on a change in pull request #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy URL: https://github.com/apache/flink/pull/9809#discussion_r329855229 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/Def

[jira] [Commented] (FLINK-14282) Simplify DispatcherResourceManagerComponent

[ https://issues.apache.org/jira/browse/FLINK-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941460#comment-16941460 ] Zili Chen commented on FLINK-14282: --- Well I misunderstand so we still have multiple {{

[jira] [Commented] (FLINK-14282) Simplify DispatcherResourceManagerComponent

[ https://issues.apache.org/jira/browse/FLINK-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941459#comment-16941459 ] Zili Chen commented on FLINK-14282: --- Nice to have! The difference between {{JobCluster

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#issuecomment-524372146 ## CI report: * baae1632aabac35e6e08b402065857c4d67491f2 : FAILURE [

[GitHub] [flink] flinkbot edited a comment on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog

flinkbot edited a comment on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog URL: https://github.com/apache/flink/pull/9822#issuecomment-536774896 ## CI report: * 611ecdea461d9c202e0fd3ad0b33f24e8a4db061 : CANCELED [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#issuecomment-524372146 ## CI report: * baae1632aabac35e6e08b402065857c4d67491f2 : FAILURE [

[GitHub] [flink] dianfu commented on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

dianfu commented on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-536794706 @tillrohrmann Very appreciated for your sugge

[GitHub] [flink] dianfu commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

dianfu commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r329827390 ## File path: flink-table/flink-table-common/src/main/ja

[GitHub] [flink] bowenli86 commented on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog

bowenli86 commented on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog URL: https://github.com/apache/flink/pull/9822#issuecomment-536792601 @xuefuz @lirui-apache @zjuwangg This is an aut

[GitHub] [flink] bowenli86 commented on issue #9689: [FLINK-7151] add a basic function ddl

bowenli86 commented on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-536792400 Tests are failing. Can you first them first? This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog

flinkbot edited a comment on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog URL: https://github.com/apache/flink/pull/9822#issuecomment-536774896 ## CI report: * 611ecdea461d9c202e0fd3ad0b33f24e8a4db061 : CANCELED [Build](https://travis-ci.c

[GitHub] [flink] flinkbot commented on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot commented on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog

flinkbot edited a comment on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog URL: https://github.com/apache/flink/pull/9822#issuecomment-536774896 ## CI report: * 611ecdea461d9c202e0fd3ad0b33f24e8a4db061 : PENDING [Build](https://travis-ci.co

[jira] [Commented] (FLINK-14273) when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing

[ https://issues.apache.org/jira/browse/FLINK-14273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941378#comment-16941378 ] hailong wang commented on FLINK-14273: -- Thank you. Jark Wu, I had submit a PR, I ap

[GitHub] [flink] flinkbot commented on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot commented on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536777025 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-14273) when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing

[ https://issues.apache.org/jira/browse/FLINK-14273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14273: --- Labels: pull-request-available (was: ) > when User-Defined Aggregate Functions(UDAF) parame

[GitHub] [flink] wangxlong opened a new pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

wangxlong opened a new pull request #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823 ## What is the purpose of the change Add accumulator type to actual type list in AggSqlFunction according to issue

[GitHub] [flink] flinkbot commented on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog

flinkbot commented on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog URL: https://github.com/apache/flink/pull/9822#issuecomment-536774896 ## CI report: * 611ecdea461d9c202e0fd3ad0b33f24e8a4db061 : UNKNOWN ---

[jira] [Commented] (FLINK-11632) Make TaskManager automatic bind address picking more explicit (by default) and more configurable

[ https://issues.apache.org/jira/browse/FLINK-11632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941373#comment-16941373 ] Tim commented on FLINK-11632: - Which version of Flink is this fix available in?  Thanks; >

[GitHub] [flink] dianfu commented on issue #9817: [FLINK-14178] Downgrade maven-shade-plugin to 3.1.0

dianfu commented on issue #9817: [FLINK-14178] Downgrade maven-shade-plugin to 3.1.0 URL: https://github.com/apache/flink/pull/9817#issuecomment-536772915 @tillrohrmann Thanks a lot for sharing the link. The end-to-end tests have passed from the link you shared and so downgrade to 3.1.

[GitHub] [flink] dianfu edited a comment on issue #9817: [FLINK-14178] Downgrade maven-shade-plugin to 3.1.0

dianfu edited a comment on issue #9817: [FLINK-14178] Downgrade maven-shade-plugin to 3.1.0 URL: https://github.com/apache/flink/pull/9817#issuecomment-536772915 @tillrohrmann Thanks a lot for sharing the link. The end-to-end tests have passed from the link you shared and so downgra

[GitHub] [flink] flinkbot commented on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog

flinkbot commented on issue #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog URL: https://github.com/apache/flink/pull/9822#issuecomment-536770082 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to rev

[jira] [Created] (FLINK-14301) add documentation for temp and temp system functions and new function resolution order

Bowen Li created FLINK-14301: Summary: add documentation for temp and temp system functions and new function resolution order Key: FLINK-14301 URL: https://issues.apache.org/jira/browse/FLINK-14301 Projec

[jira] [Updated] (FLINK-14216) introduce temp system functions to FunctionCatalog

[ https://issues.apache.org/jira/browse/FLINK-14216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14216: --- Labels: pull-request-available (was: ) > introduce temp system functions to FunctionCatalog

[GitHub] [flink] bowenli86 opened a new pull request #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog

bowenli86 opened a new pull request #9822: [FLINK-14216][table] introduce temp system functions to FunctionCatalog URL: https://github.com/apache/flink/pull/9822 ## What is the purpose of the change adapt existing APIs to the introduction of temporary system functions according to F

[jira] [Comment Edited] (FLINK-14201) SQL supports redis sink connector

[ https://issues.apache.org/jira/browse/FLINK-14201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941331#comment-16941331 ] Xiaochuan Yu edited comment on FLINK-14201 at 9/30/19 9:36 PM: ---

[jira] [Commented] (FLINK-14201) SQL supports redis sink connector

[ https://issues.apache.org/jira/browse/FLINK-14201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941331#comment-16941331 ] Xiaochuan Yu commented on FLINK-14201: -- {quote}We can support the TableSink and Tab

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941325#comment-16941325 ] Stephan Ewen commented on FLINK-14123: -- [~xintongsong][~azagrebin] Given that in th

[GitHub] [flink] flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient

flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient URL: https://github.com/apache/flink/pull/9820#issuecomment-536452582 ## CI report: * ff3ef7ae21616fb0295e3bdc53fa349c8f136a4b : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout

flinkbot edited a comment on issue #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout URL: https://github.com/apache/flink/pull/9794#issuecomment-536174033 ## CI report: * f9fbec1b59a8519c83bfb3dff4f6f1d9a785350b : F

[GitHub] [flink] flinkbot edited a comment on issue #9787: [FLINK-14252][coordination] Encapsulate Dispatcher services in DispatcherServices

flinkbot edited a comment on issue #9787: [FLINK-14252][coordination] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787#issuecomment-535981579 ## CI report: * 872b66ca40938834c13f34d32b3d340064c1bf95 : SUCCESS [Build](https://tr

[jira] [Updated] (FLINK-14300) StreamTask#invoke leaks threads if OperatorChain fails to be constructed

[ https://issues.apache.org/jira/browse/FLINK-14300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marcos Klein updated FLINK-14300: - Summary: StreamTask#invoke leaks threads if OperatorChain fails to be constructed (was: org.apa

[jira] [Created] (FLINK-14300) org.apache.flink.streaming.runtime.tasks.StreamTask#invoke leaks threads if org.apache.flink.streaming.runtime.tasks.OperatorChain fails to be constructed

Marcos Klein created FLINK-14300: Summary: org.apache.flink.streaming.runtime.tasks.StreamTask#invoke leaks threads if org.apache.flink.streaming.runtime.tasks.OperatorChain fails to be constructed Key: FLINK-14300

[GitHub] [flink] flinkbot edited a comment on issue #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo

flinkbot edited a comment on issue #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo URL: https://github.com/apache/flink/pull/9812#issuecomment-536322371 ## CI report: * c1ca1131b02a2c555cd8386fd07aa1cfccbab161 : FAILURE [Build](https://travis-ci.com/f

[GitHub] [flink] flinkbot edited a comment on issue #9811: [FLINK-14285] Remove generics from Dispatcher factories

flinkbot edited a comment on issue #9811: [FLINK-14285] Remove generics from Dispatcher factories URL: https://github.com/apache/flink/pull/9811#issuecomment-536320588 ## CI report: * 658cddd4424505c1a904a926ad6e626abbd85cd7 : FAILURE [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription

flinkbot edited a comment on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription URL: https://github.com/apache/flink/pull/9821#issuecomment-536618253 ## CI report: * 9ca9df3eaa22965444373a3b6142798ca5559f50 : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9810: [FLINK-14284] Add shut down future to Dispatcher

flinkbot edited a comment on issue #9810: [FLINK-14284] Add shut down future to Dispatcher URL: https://github.com/apache/flink/pull/9810#issuecomment-536320582 ## CI report: * 3ea0f47e7dd76ec115db4ef583b416685107604b : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds

[GitHub] [flink] flinkbot edited a comment on issue #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy

flinkbot edited a comment on issue #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy URL: https://github.com/apache/flink/pull/9809#issuecomment-536318695 ## CI report: * 531cd688ceb25b544833025d9b556a0d686b29c4 : FAILURE [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9807: [FLINK-14280] Introduce DispatcherRunner

flinkbot edited a comment on issue #9807: [FLINK-14280] Introduce DispatcherRunner URL: https://github.com/apache/flink/pull/9807#issuecomment-536314902 ## CI report: * 9ef8fe986e4b06d6ae8512e5051933458363511c : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/129597

[GitHub] [flink] flinkbot edited a comment on issue #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint

flinkbot edited a comment on issue #9790: [FLINK-14261] Add PermanentlyFencedRpcEndpoint URL: https://github.com/apache/flink/pull/9790#issuecomment-535998099 ## CI report: * f1bcc25d3af40fc482018fb8459bd8b942b15f68 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/1

[GitHub] [flink] flinkbot edited a comment on issue #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout

flinkbot edited a comment on issue #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout URL: https://github.com/apache/flink/pull/9794#issuecomment-536174033 ## CI report: * f9fbec1b59a8519c83bfb3dff4f6f1d9a785350b : F

[GitHub] [flink] flinkbot edited a comment on issue #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory

flinkbot edited a comment on issue #9789: [FLINK-14260] Remove Mockito usage from TestingJobManagerRunnerFactory URL: https://github.com/apache/flink/pull/9789#issuecomment-535998019 ## CI report: * 8e00c88ee19da724ffd4dcf0a6bfea732141d2e9 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] yanghua commented on a change in pull request #9720: [FLINK-13025] Elasticsearch 7.x support

yanghua commented on a change in pull request #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#discussion_r329662780 ## File path: flink-connectors/flink-sql-connector-elasticsearch7/src/main/resources/META-INF/NOTICE ## @@ -0,

[jira] [Created] (FLINK-14299) Factor status and system metrics out of JobManagerMetricGroup

Till Rohrmann created FLINK-14299: - Summary: Factor status and system metrics out of JobManagerMetricGroup Key: FLINK-14299 URL: https://issues.apache.org/jira/browse/FLINK-14299 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient

flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient URL: https://github.com/apache/flink/pull/9820#issuecomment-536452582 ## CI report: * ff3ef7ae21616fb0295e3bdc53fa349c8f136a4b : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription

flinkbot edited a comment on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription URL: https://github.com/apache/flink/pull/9821#issuecomment-536618253 ## CI report: * 9ca9df3eaa22965444373a3b6142798ca5559f50 : PENDING [Build](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout

flinkbot edited a comment on issue #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout URL: https://github.com/apache/flink/pull/9794#issuecomment-536174033 ## CI report: * f9fbec1b59a8519c83bfb3dff4f6f1d9a785350b : F

[GitHub] [flink] flinkbot edited a comment on issue #9786: [FLINK-14251] Add FutureUtils#forward utility

flinkbot edited a comment on issue #9786: [FLINK-14251] Add FutureUtils#forward utility URL: https://github.com/apache/flink/pull/9786#issuecomment-535968595 ## CI report: * 426cd9dc6c60f5582848fa52f2fa5f76182c8125 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12

[GitHub] [flink] flinkbot edited a comment on issue #9787: [FLINK-14252][coordination] Encapsulate Dispatcher services in DispatcherServices

flinkbot edited a comment on issue #9787: [FLINK-14252][coordination] Encapsulate Dispatcher services in DispatcherServices URL: https://github.com/apache/flink/pull/9787#issuecomment-535981579 ## CI report: * 872b66ca40938834c13f34d32b3d340064c1bf95 : SUCCESS [Build](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration

flinkbot edited a comment on issue #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762#issuecomment-534689957 ## CI report: * cefac57542dbd85a6693f6a1b7c8c90d91e85d30 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/128980426)

[GitHub] [flink] aljoscha commented on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient

aljoscha commented on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient URL: https://github.com/apache/flink/pull/9820#issuecomment-536623553 @flinkbot run travis This is an automated messa

[GitHub] [flink] flinkbot commented on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription

flinkbot commented on issue #9821: [FLINK-14298] Replace LeaderContender#getAddress with #getDescription URL: https://github.com/apache/flink/pull/9821#issuecomment-536618253 ## CI report: * 9ca9df3eaa22965444373a3b6142798ca5559f50 : UNKNOWN -

[GitHub] [flink] flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient

flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient URL: https://github.com/apache/flink/pull/9820#issuecomment-536452582 ## CI report: * ff3ef7ae21616fb0295e3bdc53fa349c8f136a4b : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] zhuzhurk commented on a change in pull request #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout

zhuzhurk commented on a change in pull request #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout URL: https://github.com/apache/flink/pull/9794#discussion_r329645418 ## File path: flink-runtime/src/main/java/org/apac

[GitHub] [flink] flinkbot edited a comment on issue #9813: [FLINK-14287] Decouple leader address from LeaderContender

flinkbot edited a comment on issue #9813: [FLINK-14287] Decouple leader address from LeaderContender URL: https://github.com/apache/flink/pull/9813#issuecomment-536324105 ## CI report: * b7a7e7b6dc8a16d23097911aa98852e2cf4d9c00 : FAILURE [Build](https://travis-ci.com/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #9811: [FLINK-14285] Remove generics from Dispatcher factories

flinkbot edited a comment on issue #9811: [FLINK-14285] Remove generics from Dispatcher factories URL: https://github.com/apache/flink/pull/9811#issuecomment-536320588 ## CI report: * 658cddd4424505c1a904a926ad6e626abbd85cd7 : FAILURE [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo

flinkbot edited a comment on issue #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo URL: https://github.com/apache/flink/pull/9812#issuecomment-536322371 ## CI report: * c1ca1131b02a2c555cd8386fd07aa1cfccbab161 : FAILURE [Build](https://travis-ci.com/f

[GitHub] [flink] zhuzhurk commented on a change in pull request #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout

zhuzhurk commented on a change in pull request #9794: [FLINK-14247][runtime] Use NoResourceAvailableException to wrap TimeoutException on slot allocation timeout URL: https://github.com/apache/flink/pull/9794#discussion_r329645078 ## File path: flink-runtime/src/test/java/org/apac

[GitHub] [flink] flinkbot edited a comment on issue #9810: [FLINK-14284] Add shut down future to Dispatcher

flinkbot edited a comment on issue #9810: [FLINK-14284] Add shut down future to Dispatcher URL: https://github.com/apache/flink/pull/9810#issuecomment-536320582 ## CI report: * 3ea0f47e7dd76ec115db4ef583b416685107604b : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds

[GitHub] [flink] flinkbot edited a comment on issue #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy

flinkbot edited a comment on issue #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy URL: https://github.com/apache/flink/pull/9809#issuecomment-536318695 ## CI report: * 531cd688ceb25b544833025d9b556a0d686b29c4 : FAILURE [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9807: [FLINK-14280] Introduce DispatcherRunner

flinkbot edited a comment on issue #9807: [FLINK-14280] Introduce DispatcherRunner URL: https://github.com/apache/flink/pull/9807#issuecomment-536314902 ## CI report: * 9ef8fe986e4b06d6ae8512e5051933458363511c : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/129597

[GitHub] [flink] flinkbot edited a comment on issue #9808: [FLINK-14281] Add DispatcherRunner#getShutDownFuture

flinkbot edited a comment on issue #9808: [FLINK-14281] Add DispatcherRunner#getShutDownFuture URL: https://github.com/apache/flink/pull/9808#issuecomment-536316924 ## CI report: * 02c93d5d7d69324c33461040fec5c4014eb2b8d6 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/bu

  1   2   3   4   >