[jira] [Created] (FLINK-14308) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

2019-10-01 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-14308: - Summary: Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis Key: FLINK-14308 URL:

[jira] [Assigned] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

2019-10-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14224: - Assignee: Alex >

[jira] [Commented] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

2019-10-01 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942512#comment-16942512 ] Till Rohrmann commented on FLINK-14224: --- That would be great [~1u0]. I've assigned you to this

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

2019-10-01 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 #9762: !IGNORE! ZK 3.5.5 shaded migration

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

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

2019-10-01 Thread GitBox
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 #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

2019-10-01 Thread GitBox
flinkbot edited a comment on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774#issuecomment-535311583 ## CI report: * b863a8fcbbf97650009e0947b10f283e6954ace3 : SUCCESS

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

2019-10-01 Thread GitBox
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 #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

2019-10-01 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

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

2019-10-01 Thread GitBox
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 #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

2019-10-01 Thread GitBox
flinkbot edited a comment on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774#issuecomment-535311583 ## CI report: * b863a8fcbbf97650009e0947b10f283e6954ace3 : PENDING

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

2019-10-01 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

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

2019-10-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942428#comment-16942428 ] Xintong Song edited comment on FLINK-14123 at 10/2/19 1:59 AM: ---

[GitHub] [flink] TisonKun commented on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

2019-10-01 Thread GitBox
TisonKun commented on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774#issuecomment-537302703 @flinkbot run travis This is an automated message from the

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

2019-10-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942428#comment-16942428 ] Xintong Song commented on FLINK-14123: -- [~StephanEwen], I'm not sure about this.   Actually,

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

2019-10-01 Thread GitBox
zhengcanbin commented on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-537300882 @flinkbot run travis This is an automated message

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330262955 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330264226 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330264226 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330264226 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330257845 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330260775 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330257639 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330259007 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330256171 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330262955 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330262148 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330257331 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[GitHub] [flink] sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

2019-10-01 Thread GitBox
sjwiesman commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r330260287 ## File path: docs/dev/table/connect.md ## @@ -1075,6

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

2019-10-01 Thread Ankur Goenka (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942291#comment-16942291 ] Ankur Goenka commented on FLINK-10672: -- I don't have the original graph as the code has changed.

[GitHub] [flink] YuvalItzchakov commented on issue #9780: [FLINK-14042] [flink-table-planner] Fix TemporalTable row schema always inferred as nullable

2019-10-01 Thread GitBox
YuvalItzchakov commented on issue #9780: [FLINK-14042] [flink-table-planner] Fix TemporalTable row schema always inferred as nullable URL: https://github.com/apache/flink/pull/9780#issuecomment-537200121 Anyone? This is an

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

2019-10-01 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 *

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

2019-10-01 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

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

2019-10-01 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

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

2019-10-01 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

[jira] [Commented] (FLINK-12675) Event time synchronization in Kafka consumer

2019-10-01 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942196#comment-16942196 ] Thomas Weise commented on FLINK-12675: -- [~gerardg] yes it is still the plan to implement source

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

2019-10-01 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 *

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

2019-10-01 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

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

2019-10-01 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

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

2019-10-01 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

[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-01 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

[GitHub] [flink] tillrohrmann commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-01 Thread GitBox
tillrohrmann commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537131326 @flinkbot run travis This is an automated message from

[GitHub] [flink] tillrohrmann commented on issue #9813: [FLINK-14287] Decouple leader address from LeaderContender

2019-10-01 Thread GitBox
tillrohrmann commented on issue #9813: [FLINK-14287] Decouple leader address from LeaderContender URL: https://github.com/apache/flink/pull/9813#issuecomment-537131144 @flinkbot run travis This is an automated message from

[GitHub] [flink] tillrohrmann commented on issue #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo

2019-10-01 Thread GitBox
tillrohrmann commented on issue #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo URL: https://github.com/apache/flink/pull/9812#issuecomment-537130961 @flinkbot run travis This is an automated

[GitHub] [flink] tillrohrmann commented on issue #9807: [FLINK-14280] Introduce DispatcherRunner

2019-10-01 Thread GitBox
tillrohrmann commented on issue #9807: [FLINK-14280] Introduce DispatcherRunner URL: https://github.com/apache/flink/pull/9807#issuecomment-537130667 @flinkbot run travis This is an automated message from the Apache Git

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

2019-10-01 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

[jira] [Updated] (FLINK-10995) Copy intermediate serialization results only once for broadcast mode

2019-10-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-10995: --- Fix Version/s: 1.10.0 Affects Version/s: 1.9.0 > Copy intermediate serialization

[jira] [Closed] (FLINK-10995) Copy intermediate serialization results only once for broadcast mode

2019-10-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10995. -- > Copy intermediate serialization results only once for broadcast mode >

[jira] [Commented] (FLINK-10995) Copy intermediate serialization results only once for broadcast mode

2019-10-01 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942129#comment-16942129 ] Piotr Nowojski commented on FLINK-10995: After modifying the benchmarks to actually use this

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

2019-10-01 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

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

2019-10-01 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

[GitHub] [flink] TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-01 Thread GitBox
TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537111552 Thanks for opening this pull request. The description and commit history looks good. Will check out the branch and do

[GitHub] [flink] TisonKun commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-01 Thread GitBox
TisonKun commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#discussion_r330140600 ## File path:

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

2019-10-01 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

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

2019-10-01 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

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

2019-10-01 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

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

2019-10-01 Thread GitBox
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_r330125371 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@

[jira] [Updated] (FLINK-14184) Provide a stage listener API to be invoked per task manager

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14184: --- Component/s: Runtime / Coordination > Provide a stage listener API to be invoked per task

[jira] [Updated] (FLINK-14254) Introduce BatchFileSystemSink

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14254: --- Component/s: Table SQL / Planner > Introduce BatchFileSystemSink >

[jira] [Updated] (FLINK-13984) Separate on-heap and off-heap managed memory pools

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13984: --- Component/s: Runtime / Coordination > Separate on-heap and off-heap managed memory pools >

[jira] [Updated] (FLINK-13925) ClassLoader in BlobLibraryCacheManager is not using context class loader

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13925: --- Component/s: Runtime / Coordination > ClassLoader in BlobLibraryCacheManager is not using

[jira] [Updated] (FLINK-14060) Set slot sharing groups according to pipelined regions

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14060: --- Component/s: Runtime / Coordination > Set slot sharing groups according to pipelined

[jira] [Updated] (FLINK-14156) Execute/run processing timer triggers taking into account operator level mailbox loops

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14156: --- Component/s: Runtime / Task > Execute/run processing timer triggers taking into account

[jira] [Updated] (FLINK-14239) Emitting the max watermark in StreamSource#run may cause it to arrive the downstream early

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14239: --- Component/s: API / DataStream > Emitting the max watermark in StreamSource#run may cause it

[jira] [Updated] (FLINK-13982) Implement memory calculation logics

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13982: --- Component/s: (was: Runtime / Task) Runtime / Coordination > Implement

[jira] [Updated] (FLINK-13982) Implement memory calculation logics

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13982: --- Component/s: Runtime / Task > Implement memory calculation logics >

[jira] [Updated] (FLINK-13803) Introduce SpillableHeapKeyedStateBackend and all necessities

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13803: --- Component/s: Runtime / State Backends > Introduce SpillableHeapKeyedStateBackend and all

[jira] [Updated] (FLINK-13983) Launch task executor with new memory calculation logics

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13983: --- Component/s: Runtime / Task > Launch task executor with new memory calculation logics >

[jira] [Updated] (FLINK-13813) metrics is different between overview ui and metric response

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13813: --- Component/s: Runtime / Web Frontend > metrics is different between overview ui and metric

[jira] [Updated] (FLINK-13846) Implement benchmark case on MapState#isEmpty

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13846: --- Component/s: Benchmarks > Implement benchmark case on MapState#isEmpty >

[jira] [Updated] (FLINK-13860) Flink Apache Kudu Connector

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13860: --- Component/s: Connectors / Common > Flink Apache Kudu Connector >

[jira] [Updated] (FLINK-14099) SQL supports timestamp in Long

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14099: --- Component/s: Table SQL / Planner > SQL supports timestamp in Long >

[jira] [Updated] (FLINK-14057) Add Remove Other Timers to TimerService

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14057: --- Component/s: API / DataStream > Add Remove Other Timers to TimerService >

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

2019-10-01 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

[jira] [Updated] (FLINK-14172) Implement KubeClient with official Java client library for kubernetes

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14172: --- Component/s: Deployment / Kubernetes > Implement KubeClient with official Java client

[jira] [Updated] (FLINK-14063) Operators use fractions to decide how many managed memory to allocate

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14063: --- Component/s: Runtime / Task > Operators use fractions to decide how many managed memory to

[jira] [Updated] (FLINK-14191) Extend SlotManager to support dynamic slot allocation on pending task executors

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14191: --- Component/s: Runtime / Coordination > Extend SlotManager to support dynamic slot allocation

[jira] [Updated] (FLINK-14134) Introduce LimitableTableSource to optimize limit

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14134: --- Component/s: Connectors / Hive > Introduce LimitableTableSource to optimize limit >

[jira] [Updated] (FLINK-14062) Set managed memory fractions according to slot sharing groups

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14062: --- Component/s: Runtime / Task > Set managed memory fractions according to slot sharing groups

[jira] [Updated] (FLINK-14192) Enable the dynamic slot allocation feature.

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14192: --- Component/s: Runtime / Coordination > Enable the dynamic slot allocation feature. >

[jira] [Updated] (FLINK-14061) Introduce managed memory fractions to StreamConfig

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14061: --- Component/s: Runtime / Task > Introduce managed memory fractions to StreamConfig >

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

2019-10-01 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 *

[jira] [Updated] (FLINK-14190) Extend SlotManager to support dynamic slot allocation on registered TaskExecutors.

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14190: --- Component/s: Runtime / Coordination > Extend SlotManager to support dynamic slot allocation

[jira] [Updated] (FLINK-14194) Clean-up of legacy mode.

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14194: --- Component/s: Runtime / Coordination > Clean-up of legacy mode. > >

[jira] [Updated] (FLINK-14199) Only use dedicated/named classes for mailbox letters.

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14199: --- Component/s: Runtime / Task > Only use dedicated/named classes for mailbox letters. >

[jira] [Updated] (FLINK-14193) Update RestAPI / Web UI

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14193: --- Component/s: Runtime / Web Frontend Runtime / Coordination > Update

[jira] [Updated] (FLINK-14189) Extend TaskExecutor to support dynamic slot allocation

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14189: --- Component/s: Runtime / Coordination > Extend TaskExecutor to support dynamic slot

[jira] [Updated] (FLINK-14188) TaskExecutor derive and register with default slot resource profile

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14188: --- Component/s: Runtime / Coordination > TaskExecutor derive and register with default slot

[jira] [Updated] (FLINK-13854) Support Aggregating in Join and CoGroup

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13854: --- Component/s: API / DataStream > Support Aggregating in Join and CoGroup >

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

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

[jira] [Updated] (FLINK-13986) Clean-up of legacy mode

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13986: --- Component/s: Runtime / Task > Clean-up of legacy mode > --- > >

[jira] [Updated] (FLINK-14146) Introduce Pulsar connector

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14146: --- Component/s: Connectors / Common > Introduce Pulsar connector > --

[jira] [Updated] (FLINK-13985) Use unsafe memory for managed memory.

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13985: --- Component/s: Runtime / Task > Use unsafe memory for managed memory. >

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

2019-10-01 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

[jira] [Updated] (FLINK-14100) Introduce OracleDialect

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14100: --- Component/s: Connectors / JDBC > Introduce OracleDialect > --- > >

[jira] [Updated] (FLINK-14102) Introduce DB2Dialect

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14102: --- Component/s: (was: Table SQL / Planner) Connectors / JDBC > Introduce

[jira] [Updated] (FLINK-14101) Introduce SqlServerDialect

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14101: --- Component/s: Connectors / JDBC > Introduce SqlServerDialect > -- >

[jira] [Updated] (FLINK-14102) Introduce DB2Dialect

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-14102: --- Component/s: Table SQL / Planner > Introduce DB2Dialect > > >

[jira] [Updated] (FLINK-13878) Flink CLI fails (TimeoutException) for unknown reason

2019-10-01 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13878: --- Component/s: Command Line Client > Flink CLI fails (TimeoutException) for unknown reason >

  1   2   3   4   >