[GitHub] jparkie opened a new pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

2018-10-02 Thread GitBox
jparkie opened a new pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782 ## What is the purpose of the change This pull requests rewrites `CassandraSinkBase` to use a `Phaser` and

[jira] [Updated] (FLINK-9083) Add async backpressure support to Cassandra Connector

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9083: -- Labels: pull-request-available (was: ) > Add async backpressure support to Cassandra Connector

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635087#comment-16635087 ] ASF GitHub Bot commented on FLINK-9083: --- jparkie opened a new pull request #6782: [

[jira] [Assigned] (FLINK-10450) Broken links in the documentation

2018-10-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-10450: Assignee: Chesnay Schepler > Broken links in the documentation >

[jira] [Commented] (FLINK-10474) Don't translate IN to JOIN with VALUES for streaming queries

2018-10-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635096#comment-16635096 ] Fabian Hueske commented on FLINK-10474: --- [~walterddr] Evaluating an IN clause with

[GitHub] aai95 opened a new pull request #6783: [FLINK-10472] [table] Add CBRT math function supported in Table API and SQL

2018-10-02 Thread GitBox
aai95 opened a new pull request #6783: [FLINK-10472] [table] Add CBRT math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6783 ## What is the purpose of the change *This pull request adds `Cbrt` math function supported in Table API and SQL.*

[jira] [Commented] (FLINK-10472) Add CBRT math function supported in Table API and SQL

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635107#comment-16635107 ] ASF GitHub Bot commented on FLINK-10472: aai95 opened a new pull request #6783:

[GitHub] aljoscha commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0

2018-10-02 Thread GitBox
aljoscha commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0 URL: https://github.com/apache/flink/pull/6703#issuecomment-426186194 Excellent! 👌 I'm currently working on adding support for Scala 2.12, and this PR is a prerequisite for that, since it makes it eas

[jira] [Commented] (FLINK-9697) Provide connector for Kafka 2.0.0

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635126#comment-16635126 ] ASF GitHub Bot commented on FLINK-9697: --- aljoscha commented on issue #6703: [FLINK-

[jira] [Created] (FLINK-10477) Add rescale button to web interface

2018-10-02 Thread Sander Ploegsma (JIRA)
Sander Ploegsma created FLINK-10477: --- Summary: Add rescale button to web interface Key: FLINK-10477 URL: https://issues.apache.org/jira/browse/FLINK-10477 Project: Flink Issue Type: Improve

[GitHub] aljoscha opened a new pull request #6784: [FLINK-7811] Add support for Scala 2.12

2018-10-02 Thread GitBox
aljoscha opened a new pull request #6784: [FLINK-7811] Add support for Scala 2.12 URL: https://github.com/apache/flink/pull/6784 This is the first batch of changes on the way to Scala 2.12 support. All these changes are necessary to make the Scala 2.12 compiler happy and I also updated th

[jira] [Updated] (FLINK-7811) Add support for Scala 2.12

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7811: -- Labels: pull-request-available (was: ) > Add support for Scala 2.12 >

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635153#comment-16635153 ] ASF GitHub Bot commented on FLINK-7811: --- aljoscha opened a new pull request #6784:

[jira] [Created] (FLINK-10478) Kafka Producer wrongly formats "%" for transaction ID

2018-10-02 Thread Obi Tetsuya (JIRA)
Obi Tetsuya created FLINK-10478: --- Summary: Kafka Producer wrongly formats "%" for transaction ID Key: FLINK-10478 URL: https://issues.apache.org/jira/browse/FLINK-10478 Project: Flink Issue Typ

[jira] [Closed] (FLINK-1003) Spread out scheduling strategy

2018-10-02 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1003. - Resolution: Won't Fix > Spread out scheduling strategy > -- > >

[jira] [Commented] (FLINK-9635) Local recovery scheduling can cause spread out of tasks

2018-10-02 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635168#comment-16635168 ] Gyula Fora commented on FLINK-9635: --- Should we consider this issue a blocker? I know th

[jira] [Updated] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10469: Priority: Critical (was: Major) > FileChannel may not write the whole buffer in a single call to

[jira] [Commented] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635176#comment-16635176 ] Nico Kruber commented on FLINK-10469: - That's actually a very critical bug you disco

[jira] [Updated] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10469: Fix Version/s: 1.5.5 1.6.2 1.7.0 > FileChannel may not write

[jira] [Updated] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-10469: Component/s: Network > FileChannel may not write the whole buffer in a single call to > FileChann

[GitHub] azagrebin commented on issue #6430: [FLINK-8058][Queryable State]Queryable state should check types

2018-10-02 Thread GitBox
azagrebin commented on issue #6430: [FLINK-8058][Queryable State]Queryable state should check types URL: https://github.com/apache/flink/pull/6430#issuecomment-426203590 hi @klion26, do I understand correctly that the idea now is that the state descriptor is serialised and sent for every r

[jira] [Commented] (FLINK-8058) Queryable state should check types

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635178#comment-16635178 ] ASF GitHub Bot commented on FLINK-8058: --- azagrebin commented on issue #6430: [FLINK

[jira] [Updated] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-10469: --- Priority: Blocker (was: Critical) > FileChannel may not write the whole buffer in a single

[jira] [Commented] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-02 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635180#comment-16635180 ] Piotr Nowojski commented on FLINK-10469: Good find [~gaoyunhaii]. Can you fix it

[jira] [Closed] (FLINK-10450) Broken links in the documentation

2018-10-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10450. Resolution: Fixed master: 168a6a1fd25cf25c7bef5d1c60cef24bfb867cb5 > Broken links in the

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221880693 ## File path: flink-connectors/flink-connector-cassandra/src/test/j

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635192#comment-16635192 ] ASF GitHub Bot commented on FLINK-9126: --- zentol commented on a change in pull reque

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221881385 ## File path: flink-connectors/flink-connector-cassandra/src/test/j

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221882439 ## File path: flink-connectors/flink-connector-cassandra/src/main/j

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221881036 ## File path: flink-connectors/flink-connector-cassandra/src/test/j

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221883320 ## File path: flink-connectors/flink-connector-cassandra/src/test/j

[GitHub] zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6735: [FLINK-9126] New CassandraPojoInputFormat to output data as a custom annotated Cassandra Pojo URL: https://github.com/apache/flink/pull/6735#discussion_r221882020 ## File path: flink-connectors/flink-connector-cassandra/src/test/j

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635202#comment-16635202 ] ASF GitHub Bot commented on FLINK-9126: --- zentol commented on a change in pull reque

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635200#comment-16635200 ] ASF GitHub Bot commented on FLINK-9126: --- zentol commented on a change in pull reque

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635201#comment-16635201 ] ASF GitHub Bot commented on FLINK-9126: --- zentol commented on a change in pull reque

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635203#comment-16635203 ] ASF GitHub Bot commented on FLINK-9126: --- zentol commented on a change in pull reque

[jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635199#comment-16635199 ] ASF GitHub Bot commented on FLINK-9126: --- zentol commented on a change in pull reque

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221887770 ## File path: flink-runtime-web/src/test/java/org/apache/flink/runtime

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221888363 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221888435 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r221888186 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime

[GitHub] zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API URL: https://github.com/apache/flink/pull/6754#discussion_r22197 ## File path: flink-runtime-web/src/main/java/org/apache/flink/runtime

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635234#comment-16635234 ] ASF GitHub Bot commented on FLINK-10295: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635233#comment-16635233 ] ASF GitHub Bot commented on FLINK-10295: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635232#comment-16635232 ] ASF GitHub Bot commented on FLINK-10295: zentol commented on a change in pull re

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221889992 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java #

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635231#comment-16635231 ] ASF GitHub Bot commented on FLINK-10295: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10295) Tokenisation of Program Args resulting in unexpected results

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635230#comment-16635230 ] ASF GitHub Bot commented on FLINK-10295: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635235#comment-16635235 ] ASF GitHub Bot commented on FLINK-10134: fhueske commented on a change in pull r

[GitHub] zentol commented on a change in pull request #6761: [FLINK-10279] [documentation] Make jython limitations more obvious in documentation.

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6761: [FLINK-10279] [documentation] Make jython limitations more obvious in documentation. URL: https://github.com/apache/flink/pull/6761#discussion_r221894735 ## File path: docs/dev/stream/python.md ## @@ -50,7 +53,12 @@ exist

[GitHub] zentol commented on a change in pull request #6761: [FLINK-10279] [documentation] Make jython limitations more obvious in documentation.

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6761: [FLINK-10279] [documentation] Make jython limitations more obvious in documentation. URL: https://github.com/apache/flink/pull/6761#discussion_r221894414 ## File path: docs/dev/stream/python.md ## @@ -24,6 +24,9 @@ specif

[jira] [Commented] (FLINK-10279) Make jython limitations more obvious in documentation

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635245#comment-16635245 ] ASF GitHub Bot commented on FLINK-10279: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10279) Make jython limitations more obvious in documentation

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635246#comment-16635246 ] ASF GitHub Bot commented on FLINK-10279: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10451) TableFunctionCollector should handle the life cycle of ScalarFunction

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635248#comment-16635248 ] ASF GitHub Bot commented on FLINK-10451: asfgit closed pull request #6771: [FLIN

[GitHub] asfgit closed pull request #6771: [FLINK-10451] [table] TableFunctionCollector should handle the life cycle of ScalarFunction

2018-10-02 Thread GitBox
asfgit closed pull request #6771: [FLINK-10451] [table] TableFunctionCollector should handle the life cycle of ScalarFunction URL: https://github.com/apache/flink/pull/6771 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Resolved] (FLINK-10451) TableFunctionCollector should handle the life cycle of ScalarFunction

2018-10-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-10451. -- Resolution: Fixed Fix Version/s: 1.5.5 1.6.2 1.7.0

[GitHub] GJL opened a new pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
GJL opened a new pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785 ## What is the purpose of the change *Wait for the result of asynchronous operations to be served before shutting do

[jira] [Updated] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10309: --- Labels: pull-request-available (was: ) > Cancel flink job occurs java.net.ConnectException

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635282#comment-16635282 ] ASF GitHub Bot commented on FLINK-10309: GJL opened a new pull request #6785: [F

[jira] [Created] (FLINK-10479) Add Firebase Firestore Connector

2018-10-02 Thread JIRA
Niklas Gögge created FLINK-10479: Summary: Add Firebase Firestore Connector Key: FLINK-10479 URL: https://issues.apache.org/jira/browse/FLINK-10479 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-10480) Add Firebase Firestore Connector

2018-10-02 Thread JIRA
Niklas Gögge created FLINK-10480: Summary: Add Firebase Firestore Connector Key: FLINK-10480 URL: https://issues.apache.org/jira/browse/FLINK-10480 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-10480) Add Firebase Firestore Connector

2018-10-02 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Niklas Gögge closed FLINK-10480. Resolution: Duplicate > Add Firebase Firestore Connector > > >

[GitHub] zentol commented on issue #6784: [FLINK-7811] Add support for Scala 2.12

2018-10-02 Thread GitBox
zentol commented on issue #6784: [FLINK-7811] Add support for Scala 2.12 URL: https://github.com/apache/flink/pull/6784#issuecomment-426240532 I'm currently preparing an asm6 version for `flink-shaded` since we also need it for java 9 compatibility.

[GitHub] zentol commented on issue #6784: [FLINK-7811] Add support for Scala 2.12

2018-10-02 Thread GitBox
zentol commented on issue #6784: [FLINK-7811] Add support for Scala 2.12 URL: https://github.com/apache/flink/pull/6784#issuecomment-426240677 Note that the GitHub link for the version you're using results in a 404. This is an

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635328#comment-16635328 ] ASF GitHub Bot commented on FLINK-7811: --- zentol commented on issue #6784: [FLINK-78

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635329#comment-16635329 ] ASF GitHub Bot commented on FLINK-7811: --- zentol commented on issue #6784: [FLINK-78

[GitHub] zentol commented on issue #6784: [FLINK-7811] Add support for Scala 2.12

2018-10-02 Thread GitBox
zentol commented on issue #6784: [FLINK-7811] Add support for Scala 2.12 URL: https://github.com/apache/flink/pull/6784#issuecomment-426241033 For `flink-shaded-asm` it would be useful to know which components of asm are actually required. --

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635331#comment-16635331 ] ASF GitHub Bot commented on FLINK-7811: --- zentol commented on issue #6784: [FLINK-78

[GitHub] zentol opened a new pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools

2018-10-02 Thread GitBox
zentol opened a new pull request #6786: [FLINK-10292][rest] Separate REST and Dispatcher RPC thread pools URL: https://github.com/apache/flink/pull/6786 ## What is the purpose of the change This PR separates the REST and DispatcherRPC thread pools. Basically the `WebMonitorE

[jira] [Updated] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10292: --- Labels: pull-request-available (was: ) > Generate JobGraph in StandaloneJobClusterEntrypoin

[jira] [Commented] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635339#comment-16635339 ] ASF GitHub Bot commented on FLINK-10292: zentol opened a new pull request #6786:

[jira] [Commented] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635360#comment-16635360 ] Till Rohrmann commented on FLINK-10475: --- Hi [~Jamalarm], this sounds as if ZooKeep

[jira] [Comment Edited] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635360#comment-16635360 ] Till Rohrmann edited comment on FLINK-10475 at 10/2/18 12:11 PM: -

[GitHub] twalthr commented on a change in pull request #6455: [FLINK-9997] [table] Improve Expression Reduce

2018-10-02 Thread GitBox
twalthr commented on a change in pull request #6455: [FLINK-9997] [table] Improve Expression Reduce URL: https://github.com/apache/flink/pull/6455#discussion_r221923802 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala

[GitHub] twalthr commented on a change in pull request #6455: [FLINK-9997] [table] Improve Expression Reduce

2018-10-02 Thread GitBox
twalthr commented on a change in pull request #6455: [FLINK-9997] [table] Improve Expression Reduce URL: https://github.com/apache/flink/pull/6455#discussion_r221917365 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/ExpressionReductionRulesTest

[GitHub] twalthr commented on a change in pull request #6455: [FLINK-9997] [table] Improve Expression Reduce

2018-10-02 Thread GitBox
twalthr commented on a change in pull request #6455: [FLINK-9997] [table] Improve Expression Reduce URL: https://github.com/apache/flink/pull/6455#discussion_r221924196 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/FlinkRuleSets.scala #

[jira] [Commented] (FLINK-9997) Improve Expression Reduce

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635369#comment-16635369 ] ASF GitHub Bot commented on FLINK-9997: --- twalthr commented on a change in pull requ

[GitHub] twalthr commented on a change in pull request #6455: [FLINK-9997] [table] Improve Expression Reduce

2018-10-02 Thread GitBox
twalthr commented on a change in pull request #6455: [FLINK-9997] [table] Improve Expression Reduce URL: https://github.com/apache/flink/pull/6455#discussion_r221917625 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/ExpressionReductionRulesTest

[jira] [Commented] (FLINK-9997) Improve Expression Reduce

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635370#comment-16635370 ] ASF GitHub Bot commented on FLINK-9997: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-9997) Improve Expression Reduce

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635368#comment-16635368 ] ASF GitHub Bot commented on FLINK-9997: --- twalthr commented on a change in pull requ

[jira] [Commented] (FLINK-9997) Improve Expression Reduce

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635367#comment-16635367 ] ASF GitHub Bot commented on FLINK-9997: --- twalthr commented on a change in pull requ

[GitHub] zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221919990 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handle

[GitHub] zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221926520 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handle

[GitHub] zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221919360 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handle

[GitHub] zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221920986 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handle

[GitHub] zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221921902 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handle

[GitHub] zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations

2018-10-02 Thread GitBox
zentol commented on a change in pull request #6785: [FLINK-10309][rest] Before shutting down cluster, wait for asynchronous operations URL: https://github.com/apache/flink/pull/6785#discussion_r221923131 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handle

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635378#comment-16635378 ] ASF GitHub Bot commented on FLINK-10309: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635380#comment-16635380 ] ASF GitHub Bot commented on FLINK-10309: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635379#comment-16635379 ] ASF GitHub Bot commented on FLINK-10309: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635382#comment-16635382 ] ASF GitHub Bot commented on FLINK-10309: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635381#comment-16635381 ] ASF GitHub Bot commented on FLINK-10309: zentol commented on a change in pull re

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635383#comment-16635383 ] ASF GitHub Bot commented on FLINK-10309: zentol commented on a change in pull re

[jira] [Commented] (FLINK-8819) Rework travis script to use build stages

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635388#comment-16635388 ] ASF GitHub Bot commented on FLINK-8819: --- zentol closed pull request #6642: [FLINK-8

[GitHub] zentol closed pull request #6642: [FLINK-8819][travis] Rework travis script to use stages

2018-10-02 Thread GitBox
zentol closed pull request #6642: [FLINK-8819][travis] Rework travis script to use stages URL: https://github.com/apache/flink/pull/6642 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is

[jira] [Closed] (FLINK-8819) Rework travis script to use build stages

2018-10-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8819. --- Resolution: Fixed Fix Version/s: 1.7.0 master: c9fe541ebe13f19cc2d2db9b5fa7fdcf6bd584e

[jira] [Commented] (FLINK-10208) Bump mockito to 2.0+

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635397#comment-16635397 ] ASF GitHub Bot commented on FLINK-10208: tillrohrmann commented on a change in p

[GitHub] tillrohrmann commented on a change in pull request #6634: [FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5

2018-10-02 Thread GitBox
tillrohrmann commented on a change in pull request #6634: [FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5 URL: https://github.com/apache/flink/pull/6634#discussion_r221892988 ## File path: pom.xml ## @@ -123,8 +123,8 @@ under the License.

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221932785 ## File path: flink-java/src/main/java/org/apache/flink/api/java/io/TextInputFormat.java ##

[GitHub] fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-02 Thread GitBox
fhueske commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r221933563 ## File path: flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java ###

  1   2   3   >