[jira] [Commented] (FLINK-14237) No need to rename shipped Flink jar

2019-10-07 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946565#comment-16946565 ] Zili Chen commented on FLINK-14237: --- Hi [~trohrmann], {{flink.jar}} is shipped as fli

[jira] [Commented] (FLINK-14306) flink-python build fails with No module named pkg_resources

2019-10-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946564#comment-16946564 ] Dian Fu commented on FLINK-14306: - Sorry for this problem caused by my commit and also t

[jira] [Commented] (FLINK-14311) Streaming File Sink end-to-end test failed on Travis

2019-10-07 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946556#comment-16946556 ] Yu Li commented on FLINK-14311: --- Another instance: https://api.travis-ci.org/v3/job/594192

[GitHub] [flink] flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper URL: https://github.com/apache/flink/pull/9405#issuecomment-519901201 ## CI report: * c1fedc4de6a92bc2c5f84d0e0c3038f29fd8944f : FAILURE [Build](https://t

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

2019-10-07 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946553#comment-16946553 ] Yu Li edited comment on FLINK-14196 at 10/8/19 6:47 AM: Checked

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

2019-10-07 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946553#comment-16946553 ] Yu Li commented on FLINK-14196: --- Checked several recent cron builds and this NPE issue nev

[GitHub] [flink] flinkbot commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

2019-10-07 Thread GitBox
flinkbot commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-539365871 ## CI report: * 1007e8b66d42b613ceafb86457913381a4e27b0f : UNKNOWN Bot commands The @fli

[GitHub] [flink] flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate …

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate … URL: https://github.com/apache/flink/pull/9355#issuecomment-518089359 ## CI report: * f8f3792f7ce55735f05200c90431b20b99a42d18 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537049332 ## CI report: * abaae048fef753455970fac9d6ab421b660b0536 : UNKNOWN * b96c63552ccd322adae7a41a410615e95b53

[GitHub] [flink] flinkbot edited a comment on issue #9831: [FLINK-14278] Extend DispatcherResourceManagerComponentFactory.create to take ioExecutor

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9831: [FLINK-14278] Extend DispatcherResourceManagerComponentFactory.create to take ioExecutor URL: https://github.com/apache/flink/pull/9831#issuecomment-537027384 ## CI report: * e1d37ab03c1bc62b3d45c45ee11d616ed2c78b0c : SUCCESS [Build](htt

[GitHub] [flink] flinkbot edited a comment on issue #9830: [FLINK-14307] Extract JobGraphWriter from JobGraphStore

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9830: [FLINK-14307] Extract JobGraphWriter from JobGraphStore URL: https://github.com/apache/flink/pull/9830#issuecomment-537017897 ## CI report: * ed86e6d768a1353423d969e6c9dcf5fd967c4f19 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink

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

2019-10-07 Thread GitBox
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 #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo

2019-10-07 Thread GitBox
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

2019-10-07 Thread GitBox
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 #9807: [FLINK-14280] Introduce DispatcherRunner

2019-10-07 Thread GitBox
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

2019-10-07 Thread GitBox
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

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

2019-10-07 Thread GitBox
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

2019-10-07 Thread GitBox
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 #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #9769: [FLINK-14203][ml] add an abstract class for mappers with rich model.

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9769: [FLINK-14203][ml] add an abstract class for mappers with rich model. URL: https://github.com/apache/flink/pull/9769#issuecomment-534932470 ## CI report: * a69f4c99a1a61595c3a75acb56300e190b5adb65 : FAILURE [Build](https://travis-ci.com/f

[GitHub] [flink] flinkbot edited a comment on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper.

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper. URL: https://github.com/apache/flink/pull/9523#issuecomment-524304525 ## CI report: * 31097ad65206951fda5e529b4c6dde0a9f51d1d8 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/bu

[GitHub] [flink] flinkbot commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

2019-10-07 Thread GitBox
flinkbot commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-539356226 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

2019-10-07 Thread GitBox
xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#discussion_r332349068 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/ma

[jira] [Updated] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

2019-10-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14341: --- Labels: pull-request-available (was: ) > Flink-python builds with failure: no such option:

[GitHub] [flink] liupc opened a new pull request #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

2019-10-07 Thread GitBox
liupc opened a new pull request #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851 ## What is the purpose of the change Currently, it reported an error on flink-python module when build flink: ```

[GitHub] [flink] flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract classes for three typical scenarios of (Flat)Mapper URL: https://github.com/apache/flink/pull/9405#issuecomment-519901201 ## CI report: * c1fedc4de6a92bc2c5f84d0e0c3038f29fd8944f : FAILURE [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate …

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate … URL: https://github.com/apache/flink/pull/9355#issuecomment-518089359 ## CI report: * f8f3792f7ce55735f05200c90431b20b99a42d18 : FAILURE [Build](https://travis-ci.com

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

2019-10-07 Thread GitBox
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 #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS [Build](https://travi

[GitHub] [flink] xuyang1706 commented on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate …

2019-10-07 Thread GitBox
xuyang1706 commented on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate … URL: https://github.com/apache/flink/pull/9355#issuecomment-539352393 > Hi @xuyang1706, I read the javadoc again and I think I have some confusion on what you are trying to achieve.

[GitHub] [flink] xuyang1706 commented on a change in pull request #9355: [FLINK-13577][ml] Add an util class to build result row and generate …

2019-10-07 Thread GitBox
xuyang1706 commented on a change in pull request #9355: [FLINK-13577][ml] Add an util class to build result row and generate … URL: https://github.com/apache/flink/pull/9355#discussion_r332347441 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/ut

[GitHub] [flink] flinkbot edited a comment on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper.

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9523: [FLINK-13835][ml] Add class for FeatureHasherMapper. URL: https://github.com/apache/flink/pull/9523#issuecomment-524304525 ## CI report: * 31097ad65206951fda5e529b4c6dde0a9f51d1d8 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/bu

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

2019-10-07 Thread GitBox
hequn8128 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-539351380 @tillrohrmann Thanks a lot for the notice.

[GitHub] [flink] flinkbot edited a comment on issue #9769: [FLINK-14203][ml] add an abstract class for mappers with rich model.

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9769: [FLINK-14203][ml] add an abstract class for mappers with rich model. URL: https://github.com/apache/flink/pull/9769#issuecomment-534932470 ## CI report: * a69f4c99a1a61595c3a75acb56300e190b5adb65 : FAILURE [Build](https://travis-ci.com/f

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

2019-10-07 Thread GitBox
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_r332346972 ## File path: flink-table/flink-table-common/src/main/ja

[jira] [Closed] (FLINK-14280) Introduce DispatcherRunner for better separation of concerns

2019-10-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14280. - Resolution: Done Done via 936a317e7e51b0a03f5f12e3d4c21fedaa6d328e > Introduce DispatcherRunner

[jira] [Closed] (FLINK-14281) Introduce DispatcherRunner#getShutDownFuture

2019-10-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14281. - Resolution: Done Done via 01ad0f6fe23615484e36b4710cd0fdc3a7276bed > Introduce DispatcherRunner

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

2019-10-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14282. - Resolution: Done Done via 870b56418cb795edba9d4e8e282fa91d675efd7a > Simplify DispatcherResourc

[jira] [Closed] (FLINK-14284) Add shut down future to Dispatcher

2019-10-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14284. - Resolution: Done Done via 1c5f7558626bb8c301d564c0cbc15126d6cc1731 > Add shut down future to Di

[jira] [Closed] (FLINK-14285) Simplify Dispatcher factories by removing generics

2019-10-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14285. - Resolution: Done Done via 282dd840fe80bd71830d1c493cdb7e1d0ad5cc6e > Simplify Dispatcher factor

[jira] [Created] (FLINK-14342) Remove method FunctionDefinition#getLanguage

2019-10-07 Thread Dian Fu (Jira)
Dian Fu created FLINK-14342: --- Summary: Remove method FunctionDefinition#getLanguage Key: FLINK-14342 URL: https://issues.apache.org/jira/browse/FLINK-14342 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-14286) Remove Akka specific parsing logic from LeaderConnectionInfo

2019-10-07 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14286. - Resolution: Done Done via 1082c7a470355b938ad0f7de2fa73ca5461c1bc0 > Remove Akka specific parsi

[GitHub] [flink] tillrohrmann closed pull request #9811: [FLINK-14285] Remove generics from Dispatcher factories

2019-10-07 Thread GitBox
tillrohrmann closed pull request #9811: [FLINK-14285] Remove generics from Dispatcher factories URL: https://github.com/apache/flink/pull/9811 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] tillrohrmann closed pull request #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy

2019-10-07 Thread GitBox
tillrohrmann closed pull request #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy URL: https://github.com/apache/flink/pull/9809 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] tillrohrmann closed pull request #9808: [FLINK-14281] Add DispatcherRunner#getShutDownFuture

2019-10-07 Thread GitBox
tillrohrmann closed pull request #9808: [FLINK-14281] Add DispatcherRunner#getShutDownFuture URL: https://github.com/apache/flink/pull/9808 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] tillrohrmann closed pull request #9807: [FLINK-14280] Introduce DispatcherRunner

2019-10-07 Thread GitBox
tillrohrmann closed pull request #9807: [FLINK-14280] Introduce DispatcherRunner URL: https://github.com/apache/flink/pull/9807 This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] tillrohrmann closed pull request #9810: [FLINK-14284] Add shut down future to Dispatcher

2019-10-07 Thread GitBox
tillrohrmann closed pull request #9810: [FLINK-14284] Add shut down future to Dispatcher URL: https://github.com/apache/flink/pull/9810 This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] tillrohrmann closed pull request #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo

2019-10-07 Thread GitBox
tillrohrmann closed pull request #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo URL: https://github.com/apache/flink/pull/9812 This is an automated message from the Apache Git Service. To respond

[jira] [Created] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

2019-10-07 Thread liupengcheng (Jira)
liupengcheng created FLINK-14341: Summary: Flink-python builds with failure: no such option: --prefix Key: FLINK-14341 URL: https://issues.apache.org/jira/browse/FLINK-14341 Project: Flink Is

[GitHub] [flink] flinkbot edited a comment on issue #9824: [FLINK-14302] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9824: [FLINK-14302] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS URL: https://github.com/apache/flink/pull/9824#issuecomment-536928428 ## CI report: * 87ae7

[GitHub] [flink] flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#issuecomment-533554096 ## CI report: * 51167d9aaf8082150738dc5bd8b9e2319dd01570 : SUCCESS [Bu

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

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

2019-10-07 Thread GitBox
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 #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient

2019-10-07 Thread GitBox
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] yanghua commented on a change in pull request #9720: [FLINK-13025] Elasticsearch 7.x support

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

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate …

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate … URL: https://github.com/apache/flink/pull/9355#issuecomment-518089359 ## CI report: * f8f3792f7ce55735f05200c90431b20b99a42d18 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2019-10-07 Thread GitBox
klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r332335659 ## File path: flink-dist/src/main/flink-bin/bin/flink-daemon.sh ## @@ -85

[GitHub] [flink] klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2019-10-07 Thread GitBox
klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r332333021 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -99,6 +99

[GitHub] [flink] klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2019-10-07 Thread GitBox
klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r33284 ## File path: flink-dist/src/main/flink-bin/bin/flink-daemon.sh ## @@ -85

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-535813967 ## CI report: * ed0e04d1cd481b096d68d0c9bf36a997dcca2550 : FAILURE [Build](https://travis-ci.com/flink-

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

2019-10-07 Thread GitBox
HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-539322429 @walterddr Thanks for the comments and suggestions. For the changing of CatalogFunctionImpl constructor, let's wait for @bowenli86 's feedba

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

2019-10-07 Thread GitBox
sunjincheng121 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_r332333999 ## File path: flink-table/flink-table-common/src

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

2019-10-07 Thread GitBox
sunjincheng121 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_r332333999 ## File path: flink-table/flink-table-common/src

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-10-07 Thread GitBox
HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332334043 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-10-07 Thread GitBox
HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332334052 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java

[GitHub] [flink] flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic cron ARM CI job definition

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic cron ARM CI job definition URL: https://github.com/apache/flink/pull/9416#issuecomment-520285701 ## CI report: * dbf749f0d0c3167265287b182dd1ea7b4aed84c1 : FAILURE [Build](https://travis-ci.com/flink

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-10-07 Thread GitBox
HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332333004 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala

[GitHub] [flink] flinkbot edited a comment on issue #9819: [FLINK-14246][runtime] Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9819: [FLINK-14246][runtime] Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG URL: https://github.com/apache/flink/pull/9819#issuecomment-536429067 ## CI report: * 94653a90b144e39f05a3e86de50225a0d538fed0 : SUCCESS [

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS [Build](https://travi

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-10-07 Thread GitBox
HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332331898 ## File path: flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java ###

[jira] [Commented] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

2019-10-07 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946472#comment-16946472 ] Congxian Qiu(klion26) commented on FLINK-14340: --- [~sewen] as you introduce

[jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

2019-10-07 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-14340: -- Description: Currently, when Flink read/write to HDFS, we do not set the DFSCl

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

2019-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946470#comment-16946470 ] Xintong Song commented on FLINK-14123: -- [~liupengcheng], The reason we have smalle

[jira] [Created] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

2019-10-07 Thread Congxian Qiu(klion26) (Jira)
Congxian Qiu(klion26) created FLINK-14340: - Summary: Specify an unique DFSClient name for Hadoop FileSystem Key: FLINK-14340 URL: https://issues.apache.org/jira/browse/FLINK-14340 Project: Flin

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-532638785 ## CI report: * 053ed30d568a00ba42d75d1a9534843c59a068af : SUCCESS [Bu

[GitHub] [flink] flinkbot edited a comment on issue #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario.

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario. URL: https://github.com/apache/flink/pull/9850#issuecomment-539298227 ## CI report: * b344a21f3d6d55e6fca5d9253b0b34ddb2c392e9 : PENDING [Build](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #9829: [FLINK-14184] [core] Add LocalContextListener

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9829: [FLINK-14184] [core] Add LocalContextListener URL: https://github.com/apache/flink/pull/9829#issuecomment-536999846 ## CI report: * 4a2644b80db9de689dd8dfe742010a6c5367ee80 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12

[GitHub] [flink] flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#issuecomment-536416616 ## CI report: * 519051016f02b8257eb1e3d5834f36c315816266 : FAILURE [Build](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116 ## CI report: * cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE [Build]

[GitHub] [flink] wsry commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

2019-10-07 Thread GitBox
wsry commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758#issuecomment-539302270 > What if we didn't share the stats between servers? @zentol From the previous comment and

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS [Build](https://travi

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-10-07 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946458#comment-16946458 ] Congxian Qiu(klion26) commented on FLINK-13808: --- Thanks for the reply [~se

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

2019-10-07 Thread GitBox
zjuwangg commented on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-539299262 > thanks for the contribution @HuangZhenQiu and thanks for the prompt review @bowenli86 . I think overall the approach looks very good to me and I j

[GitHub] [flink] flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#issuecomment-513425405 ## CI report: * bd7ade5e0b57dc8577d7f864afcbbb24c2513e56 : FAILURE [Build](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942 ## CI report: * 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-532638785 ## CI report: * 053ed30d568a00ba42d75d1a9534843c59a068af : SUCCESS [Bu

[GitHub] [flink] flinkbot commented on issue #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario.

2019-10-07 Thread GitBox
flinkbot commented on issue #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario. URL: https://github.com/apache/flink/pull/9850#issuecomment-539298227 ## CI report: * b344a21f3d6d55e6fca5d9253b0b34ddb2c392e9 : UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#issuecomment-536295524 ## CI report: * 9ad039de6bbb953c7e2dd74b3118d80ae552f31e : FAILURE [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

2019-10-07 Thread GitBox
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS [Build](https://travi

[GitHub] [flink] wsry commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

2019-10-07 Thread GitBox
wsry commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-539297211 @pnowojski Thanks for your comments. I have separated the benchmark commit into a new pr htt

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

2019-10-07 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946446#comment-16946446 ] liupengcheng commented on FLINK-14123: -- [~xintongsong] Hi, thanks for your comment

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

2019-10-07 Thread GitBox
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] zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-10-07 Thread GitBox
zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332322097 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java

[GitHub] [flink] zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-10-07 Thread GitBox
zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332322049 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9846: [FLINK-14271][runtime] Remove legacy RestartPipelinedRegionStrategy components

2019-10-07 Thread GitBox
zhuzhurk commented on a change in pull request #9846: [FLINK-14271][runtime] Remove legacy RestartPipelinedRegionStrategy components URL: https://github.com/apache/flink/pull/9846#discussion_r332009233 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongrap

[GitHub] [flink] zhuzhurk commented on a change in pull request #9846: [FLINK-14271][runtime] Remove legacy RestartPipelinedRegionStrategy components

2019-10-07 Thread GitBox
zhuzhurk commented on a change in pull request #9846: [FLINK-14271][runtime] Remove legacy RestartPipelinedRegionStrategy components URL: https://github.com/apache/flink/pull/9846#discussion_r332009233 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongrap

  1   2   3   4   5   6   7   >