[jira] [Commented] (FLINK-10413) requestPartitionState messages overwhelms JM RPC main thread

2018-09-24 Thread tison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626789#comment-16626789 ] tison commented on FLINK-10413: --- This might be a duplicate of FLINK-10319 > requestPartitionState

[jira] [Assigned] (FLINK-10413) requestPartitionState messages overwhelms JM RPC main thread

2018-09-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10413: Assignee: vinoyang > requestPartitionState messages overwhelms JM RPC main thread >

[jira] [Commented] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626767#comment-16626767 ] ASF GitHub Bot commented on FLINK-10412: yanghua opened a new pull request #6755: [FLINK-10412]

[jira] [Updated] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10412: --- Labels: deploy,deployment pull-request-available serialization (was: deploy,deployment

[GitHub] yanghua opened a new pull request #6755: [FLINK-10412] toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread GitBox
yanghua opened a new pull request #6755: [FLINK-10412] toString field in AbstractID should be transient to avoid been serialized URL: https://github.com/apache/flink/pull/6755 ## What is the purpose of the change *This pull request mark toString field in AbstractID as transient to

[jira] [Commented] (FLINK-10319) Too many requestPartitionState would crash JM

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626745#comment-16626745 ] ASF GitHub Bot commented on FLINK-10319: TisonKun removed a comment on issue #6680:

[GitHub] TisonKun removed a comment on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM

2018-09-24 Thread GitBox
TisonKun removed a comment on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM URL: https://github.com/apache/flink/pull/6680#issuecomment-421222747 cc @tillrohrmann @GJL This is an

[jira] [Commented] (FLINK-10319) Too many requestPartitionState would crash JM

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626724#comment-16626724 ] ASF GitHub Bot commented on FLINK-10319: TisonKun removed a comment on issue #6680:

[jira] [Commented] (FLINK-10319) Too many requestPartitionState would crash JM

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626721#comment-16626721 ] ASF GitHub Bot commented on FLINK-10319: TisonKun removed a comment on issue #6680:

[GitHub] TisonKun removed a comment on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM

2018-09-24 Thread GitBox
TisonKun removed a comment on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM URL: https://github.com/apache/flink/pull/6680#issuecomment-422276930 cc @tillrohrmann @GJL @StefanRRichter

[GitHub] TisonKun removed a comment on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM

2018-09-24 Thread GitBox
TisonKun removed a comment on issue #6680: [FLINK-10319] [runtime] Too many requestPartitionState would crash JM URL: https://github.com/apache/flink/pull/6680#issuecomment-421882434 cc @StephanEwen @twalthr This is an

[jira] [Updated] (FLINK-10413) requestPartitionState messages overwhelms JM RPC main thread

2018-09-24 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-10413: Description: We tried to benchmark the job scheduling performance with a 2000x2000 ALL-to-ALL

[jira] [Created] (FLINK-10413) requestPartitionState messages overwhelms JM RPC main thread

2018-09-24 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-10413: --- Summary: requestPartitionState messages overwhelms JM RPC main thread Key: FLINK-10413 URL: https://issues.apache.org/jira/browse/FLINK-10413 Project: Flink Issue

[jira] [Commented] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626712#comment-16626712 ] vinoyang commented on FLINK-10412: -- [~zhuzh] Good catch! Will fix it soon. > toString field in

[jira] [Assigned] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10412: Assignee: vinoyang > toString field in AbstractID should be transient to avoid been serialized >

[jira] [Updated] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-10412: Description: The toString field in AbstractID will be serialized currently, which makes RPC messages

[jira] [Updated] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-10412: Description: The toString field in A > toString field in AbstractID should be transient to avoid been

[jira] [Updated] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-10412: Labels: deploy,deployment serialization (was: ) > toString field in AbstractID should be transient to

[jira] [Updated] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-10412: Component/s: Distributed Coordination > toString field in AbstractID should be transient to avoid been

[jira] [Updated] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-10412: Affects Version/s: 1.7.0 > toString field in AbstractID should be transient to avoid been serialized >

[jira] [Created] (FLINK-10412) toString field in AbstractID should be transient to avoid been serialized

2018-09-24 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-10412: --- Summary: toString field in AbstractID should be transient to avoid been serialized Key: FLINK-10412 URL: https://issues.apache.org/jira/browse/FLINK-10412 Project: Flink

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626693#comment-16626693 ] ASF GitHub Bot commented on FLINK-10134: XuQianJin-Stars edited a comment on issue #6710:

[GitHub] XuQianJin-Stars edited a comment on issue #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-09-24 Thread GitBox
XuQianJin-Stars edited a comment on issue #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#issuecomment-424188954 > I think we need to revisit the way this fix works. At this point, it probably makes sense to close the PR and

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626690#comment-16626690 ] ASF GitHub Bot commented on FLINK-10134: XuQianJin-Stars closed pull request #6710:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626689#comment-16626689 ] ASF GitHub Bot commented on FLINK-10134: XuQianJin-Stars commented on issue #6710: [FLINK-10134]

[GitHub] XuQianJin-Stars commented on issue #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-09-24 Thread GitBox
XuQianJin-Stars commented on issue #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#issuecomment-424188954 > I think we need to revisit the way this fix works. At this point, it probably makes sense to close the PR and go

[GitHub] XuQianJin-Stars closed pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-09-24 Thread GitBox
XuQianJin-Stars closed pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710 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:

[GitHub] yanghua commented on issue #6738: [FLINK-10126] There should be a Scala DataSource

2018-09-24 Thread GitBox
yanghua commented on issue #6738: [FLINK-10126] There should be a Scala DataSource URL: https://github.com/apache/flink/pull/6738#issuecomment-424184780 hi @StephanEwen , Before providing the API directly, I evaluated the implementation of a peer `DataSource` in the flink-scala module.

[jira] [Commented] (FLINK-10126) There should be a Scala DataSource

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626676#comment-16626676 ] ASF GitHub Bot commented on FLINK-10126: yanghua commented on issue #6738: [FLINK-10126] There

[jira] [Commented] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626673#comment-16626673 ] ASF GitHub Bot commented on FLINK-10065: klion26 commented on issue #6498: [FLINK-10065]

[GitHub] klion26 commented on issue #6498: [FLINK-10065] InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-09-24 Thread GitBox
klion26 commented on issue #6498: [FLINK-10065] InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream URL: https://github.com/apache/flink/pull/6498#issuecomment-424183722 @tillrohrmann , @StefanRRichter , @tzulitai thank

[jira] [Commented] (FLINK-10399) Refractor ParameterTool#fromArgs

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626599#comment-16626599 ] ASF GitHub Bot commented on FLINK-10399: TisonKun commented on issue #6737: [FLINK-10399]

[GitHub] TisonKun commented on issue #6737: [FLINK-10399] Refractor ParameterTool#fromArgs

2018-09-24 Thread GitBox
TisonKun commented on issue #6737: [FLINK-10399] Refractor ParameterTool#fromArgs URL: https://github.com/apache/flink/pull/6737#issuecomment-424165441 @StephanEwen Thanks for your review! This is an automated message from

[jira] [Commented] (FLINK-10289) Classify Exceptions to different category for apply different failover strategy

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626469#comment-16626469 ] ASF GitHub Bot commented on FLINK-10289: isunjin commented on issue #6739: [FLINK-10289]

[GitHub] isunjin commented on issue #6739: [FLINK-10289] [JobManager] Classify Exceptions to different category for apply different failover strategy

2018-09-24 Thread GitBox
isunjin commented on issue #6739: [FLINK-10289] [JobManager] Classify Exceptions to different category for apply different failover strategy URL: https://github.com/apache/flink/pull/6739#issuecomment-424127134 > I really like this idea in principle. > > Instead of attaching an enum

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626449#comment-16626449 ] ASF GitHub Bot commented on FLINK-9126: --- bmeriaux commented on a change in pull request #6735:

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

2018-09-24 Thread GitBox
bmeriaux 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_r219984964 ## File path:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626435#comment-16626435 ] ASF GitHub Bot commented on FLINK-9126: --- bmeriaux commented on a change in pull request #6735:

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

2018-09-24 Thread GitBox
bmeriaux 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_r219980389 ## File path:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626308#comment-16626308 ] ASF GitHub Bot commented on FLINK-9126: --- bmeriaux commented on a change in pull request #6735:

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

2018-09-24 Thread GitBox
bmeriaux 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_r219957391 ## File path:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626305#comment-16626305 ] ASF GitHub Bot commented on FLINK-8819: --- GJL commented on a change in pull request #6642:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626303#comment-16626303 ] ASF GitHub Bot commented on FLINK-8819: --- GJL commented on a change in pull request #6642:

[jira] [Commented] (FLINK-10399) Refractor ParameterTool#fromArgs

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626304#comment-16626304 ] ASF GitHub Bot commented on FLINK-10399: StephanEwen commented on issue #6737: [FLINK-10399]

[GitHub] GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages

2018-09-24 Thread GitBox
GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages URL: https://github.com/apache/flink/pull/6642#discussion_r219956271 ## File path: tools/travis_controller.sh ## @@ -0,0 +1,211 @@ +#!/usr/bin/env bash

[GitHub] StephanEwen commented on issue #6737: [FLINK-10399] Refractor ParameterTool#fromArgs

2018-09-24 Thread GitBox
StephanEwen commented on issue #6737: [FLINK-10399] Refractor ParameterTool#fromArgs URL: https://github.com/apache/flink/pull/6737#issuecomment-424092282 **Consensus that the contribution should go into to Flink** - +1 from my side - tests show the behavior is unchanged, so low

[GitHub] GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages

2018-09-24 Thread GitBox
GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages URL: https://github.com/apache/flink/pull/6642#discussion_r219956271 ## File path: tools/travis_controller.sh ## @@ -0,0 +1,211 @@ +#!/usr/bin/env bash

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626299#comment-16626299 ] ASF GitHub Bot commented on FLINK-8819: --- GJL commented on a change in pull request #6642:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626300#comment-16626300 ] ASF GitHub Bot commented on FLINK-8819: --- GJL commented on a change in pull request #6642:

[GitHub] GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages

2018-09-24 Thread GitBox
GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages URL: https://github.com/apache/flink/pull/6642#discussion_r219955579 ## File path: tools/travis_mvn_watchdog.sh ## @@ -160,10 +55,11 @@ esac # -nsu option forbids

[GitHub] GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages

2018-09-24 Thread GitBox
GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages URL: https://github.com/apache/flink/pull/6642#discussion_r219955526 ## File path: tools/travis_controller.sh ## @@ -0,0 +1,211 @@ +#!/usr/bin/env bash

[jira] [Commented] (FLINK-10126) There should be a Scala DataSource

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626292#comment-16626292 ] ASF GitHub Bot commented on FLINK-10126: StephanEwen commented on issue #6738: [FLINK-10126]

[GitHub] StephanEwen commented on issue #6738: [FLINK-10126] There should be a Scala DataSource

2018-09-24 Thread GitBox
StephanEwen commented on issue #6738: [FLINK-10126] There should be a Scala DataSource URL: https://github.com/apache/flink/pull/6738#issuecomment-424090397 This fix seems to be a workaround for the real issue that the Scala API misses a DataSource type. I would suggest to see if that

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626240#comment-16626240 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626239#comment-16626239 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626244#comment-16626244 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626237#comment-16626237 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread GitBox
azagrebin 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_r219941080 ## File path:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626236#comment-16626236 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626241#comment-16626241 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626245#comment-16626245 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626232#comment-16626232 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626234#comment-16626234 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626238#comment-16626238 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626235#comment-16626235 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626233#comment-16626233 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626246#comment-16626246 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626242#comment-16626242 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626243#comment-16626243 ] ASF GitHub Bot commented on FLINK-9126: --- azagrebin commented on a change in pull request #6735:

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

2018-09-24 Thread GitBox
azagrebin 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_r219942450 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219931705 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219930598 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219943693 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219935777 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219943237 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219942318 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219930899 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219934197 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219934055 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219940842 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219929908 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219932299 ## File path:

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

2018-09-24 Thread GitBox
azagrebin 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_r219929097 ## File path:

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

2018-09-24 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626190#comment-16626190 ] Ufuk Celebi commented on FLINK-10292: - I understand that non-determinism may be an issue when

[jira] [Commented] (FLINK-10209) Exclude jdk.tools dependency from hadoop when running with java 9

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626142#comment-16626142 ] ASF GitHub Bot commented on FLINK-10209: StephanEwen commented on issue #6663:

[GitHub] StephanEwen commented on issue #6663: [FLINK-10209][build] Exclude jdk.tools dependency from hadoop

2018-09-24 Thread GitBox
StephanEwen commented on issue #6663: [FLINK-10209][build] Exclude jdk.tools dependency from hadoop URL: https://github.com/apache/flink/pull/6663#issuecomment-424054104 This context may make my line of thinking easier to understand: The hadoop-shaded module is a convenience

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626107#comment-16626107 ] ASF GitHub Bot commented on FLINK-10295: azagrebin commented on issue #6754: [FLINK-10295] Add

[GitHub] azagrebin commented on issue #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

2018-09-24 Thread GitBox
azagrebin commented on issue #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#issuecomment-424045988 cc @zentol This is an

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626106#comment-16626106 ] ASF GitHub Bot commented on FLINK-10295: azagrebin opened a new pull request #6754:

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

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10295: --- Labels: pull-request-available (was: ) > Tokenisation of Program Args resulting in

[GitHub] azagrebin opened a new pull request #6754: [FLINK-10295] Add support of passing jar arguments as list of separate strings in REST API

2018-09-24 Thread GitBox
azagrebin opened a new 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 ## What is the purpose of the change This PR add one more option to specify jar program arguments in

[jira] [Assigned] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

2018-09-24 Thread tison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tison reassigned FLINK-10251: - Assignee: (was: tison) > Handle oversized response messages in AkkaRpcActor >

[jira] [Commented] (FLINK-1960) Add comments and docs for withForwardedFields and related operators

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626069#comment-16626069 ] ASF GitHub Bot commented on FLINK-1960: --- dmpalyvos opened a new pull request #6753: [FLINK-1960]

[jira] [Updated] (FLINK-1960) Add comments and docs for withForwardedFields and related operators

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-1960: -- Labels: documentation pull-request-available starter (was: documentation starter) > Add

[GitHub] dmpalyvos opened a new pull request #6753: [FLINK-1960] [Documentation] Add docs for withForwardedFields and related operators in Scala API

2018-09-24 Thread GitBox
dmpalyvos opened a new pull request #6753: [FLINK-1960] [Documentation] Add docs for withForwardedFields and related operators in Scala API URL: https://github.com/apache/flink/pull/6753 ## What is the purpose of the change The withForwardedFields and related operators have no docs

[jira] [Commented] (FLINK-10396) Remove codebase switch from MiniClusterResource

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626038#comment-16626038 ] ASF GitHub Bot commented on FLINK-10396: zentol commented on a change in pull request #6748:

[GitHub] zentol commented on a change in pull request #6748: [FLINK-10396] Remove CodebaseType

2018-09-24 Thread GitBox
zentol commented on a change in pull request #6748: [FLINK-10396] Remove CodebaseType URL: https://github.com/apache/flink/pull/6748#discussion_r219883500 ## File path: flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITCase.scala ## @@ -322,32

[jira] [Commented] (FLINK-10397) Remove CoreOptions#MODE

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626034#comment-16626034 ] ASF GitHub Bot commented on FLINK-10397: tillrohrmann opened a new pull request #6752:

[jira] [Updated] (FLINK-10397) Remove CoreOptions#MODE

2018-09-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10397: --- Labels: pull-request-available (was: ) > Remove CoreOptions#MODE > ---

[GitHub] tillrohrmann opened a new pull request #6752: [FLINK-10397] Remove CoreOptions#MODE

2018-09-24 Thread GitBox
tillrohrmann opened a new pull request #6752: [FLINK-10397] Remove CoreOptions#MODE URL: https://github.com/apache/flink/pull/6752 ## What is the purpose of the change This PR is based on #6748 and #6751 and is part of the [removal of Flink's legacy

  1   2   3   >