[jira] [Commented] (FLINK-7000) Add custom configuration for StreamExecutionEnvironment#createLocalEnvironment

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062342#comment-16062342 ] ASF GitHub Bot commented on FLINK-7000: --- Github user ch33hau commented on the issue:

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062341#comment-16062341 ] ASF GitHub Bot commented on FLINK-5892: --- Github user zentol closed the pull request at:

[GitHub] flink issue #4178: [FLINK-7000] Add custom configuration local environment i...

2017-06-25 Thread ch33hau
Github user ch33hau commented on the issue: https://github.com/apache/flink/pull/4178 Do you mean a new method with `createLocalEnvironment(Int, conf)`? By this way compiler won't complain, just both the value have to be entered. However, I do agree that the way that you

[GitHub] flink issue #4178: [FLINK-7000] Add custom configuration local environment i...

2017-06-25 Thread ch33hau
Github user ch33hau commented on the issue: https://github.com/apache/flink/pull/4178 Hi @zentol , I have updated PR by adding a new method without default values. Thanks =) --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Comment Edited] (FLINK-6958) Async I/O timeout not work

2017-06-25 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062351#comment-16062351 ] Jark Wu edited comment on FLINK-6958 at 6/25/17 3:07 PM: - [~till.rohrmann] I'm

[GitHub] flink pull request #3844: [FLINK-5892] Enable 1.2 keyed state test

2017-06-25 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3844 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink issue #3724: [FLINK-6275] [yarn] Fix unprotected access to resourceMan...

2017-06-25 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/3724 @zentol Sorry. I just forgot. I close it right now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Resolved] (FLINK-6362) Unprotected access to registeredStates in SharedStateRegistry#getReferenceCount

2017-06-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-6362. --- Resolution: Cannot Reproduce > Unprotected access to registeredStates in >

[jira] [Created] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization

2017-06-25 Thread Jark Wu (JIRA)
Jark Wu created FLINK-7001: -- Summary: Improve performance of Sliding Time Window with pane optimization Key: FLINK-7001 URL: https://issues.apache.org/jira/browse/FLINK-7001 Project: Flink Issue

[GitHub] flink issue #3724: [FLINK-6275] [yarn] Fix unprotected access to resourceMan...

2017-06-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3724 @zhangminglei could you close this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[GitHub] flink pull request #3724: [FLINK-6275] [yarn] Fix unprotected access to reso...

2017-06-25 Thread zhangminglei
Github user zhangminglei closed the pull request at: https://github.com/apache/flink/pull/3724 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062347#comment-16062347 ] ASF GitHub Bot commented on FLINK-6275: --- Github user zhangminglei closed the pull request at:

[jira] [Commented] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062346#comment-16062346 ] ASF GitHub Bot commented on FLINK-6275: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #4026: [FLINK-6764] Deduplicate stateless serializers in checkpo...

2017-06-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4026 @tzulitai What's the state of this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062359#comment-16062359 ] ASF GitHub Bot commented on FLINK-6764: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6742) Improve error message when savepoint migration fails due to task removal

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062364#comment-16062364 ] Chesnay Schepler commented on FLINK-6742: - I merged it to 1.3 after your comment, so it was ok ;)

[jira] [Commented] (FLINK-7000) Add custom configuration for StreamExecutionEnvironment#createLocalEnvironment

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062339#comment-16062339 ] ASF GitHub Bot commented on FLINK-7000: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6990) Poor performance with Sliding Time Windows

2017-06-25 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062338#comment-16062338 ] Jark Wu commented on FLINK-6990: [~BriceBingman] [~fhueske] the poor performance of sliding time window is

[GitHub] flink issue #4178: [FLINK-7000] Add custom configuration local environment i...

2017-06-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4178 This method is part of the public API and thus must not be changed. Does the compiler still complain if there is no default value for the configuration? --- If your project is set up for

[jira] [Commented] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062344#comment-16062344 ] ASF GitHub Bot commented on FLINK-6275: --- Github user zentol commented on the issue:

[jira] [Resolved] (FLINK-6433) Unreachable code in SqlToRelConverter#visitCall()

2017-06-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-6433. --- Resolution: Won't Fix > Unreachable code in SqlToRelConverter#visitCall() >

[jira] [Commented] (FLINK-7000) Add custom configuration for StreamExecutionEnvironment#createLocalEnvironment

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062348#comment-16062348 ] ASF GitHub Bot commented on FLINK-7000: --- Github user ch33hau commented on the issue:

[jira] [Commented] (FLINK-6958) Async I/O timeout not work

2017-06-25 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062351#comment-16062351 ] Jark Wu commented on FLINK-6958: [~till.rohrmann] I'm afraid it doesn't work, because the aync io operator

[GitHub] flink pull request #3554: Detached (Remote)StreamEnvironment execution

2017-06-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3554#discussion_r123901226 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java --- @@ -25,229 +25,205 @@ import

[jira] [Commented] (FLINK-7000) Add custom configuration for StreamExecutionEnvironment#createLocalEnvironment

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062263#comment-16062263 ] ASF GitHub Bot commented on FLINK-7000: --- Github user ch33hau commented on the issue:

[GitHub] flink issue #4178: [FLINK-7000] Add custom configuration local environment i...

2017-06-25 Thread ch33hau
Github user ch33hau commented on the issue: https://github.com/apache/flink/pull/4178 Hi @zentol , thanks for taking time for reviewing :) It was my original thought. However turns out due to `Scala` supports `default value` in parameters, in order to achieve same

[jira] [Commented] (FLINK-6999) Print TravisCI CPU, memory, and filesystem info

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062287#comment-16062287 ] ASF GitHub Bot commented on FLINK-6999: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-6999) Print TravisCI CPU, memory, and filesystem info

2017-06-25 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-6999. - Resolution: Implemented master: a13a98f6570fb8648e3780e90407c976178aff7d > Print TravisCI CPU, memory,

[jira] [Updated] (FLINK-6843) ClientConnectionTest fails on travis

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6843: Priority: Blocker (was: Major) > ClientConnectionTest fails on travis >

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062305#comment-16062305 ] Chesnay Schepler commented on FLINK-5892: - The KeyedComplexChainTest was updated to properly use a

[jira] [Closed] (FLINK-6389) Upgrade hbase dependency to 1.3.1

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6389. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 5604930c010b32200facc4c86dfb26c64120349e

[jira] [Closed] (FLINK-6956) Table examples broken

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6956. --- Resolution: Fixed 1.4: 1f6be8372706c1531844857291bc166bf091176b > Table examples broken >

[jira] [Closed] (FLINK-6786) Remove duplicate QueryScopeInfoTest

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6786. --- Resolution: Fixed 1.4: b863b90c80a63e950106b4460bb81f733819dbc2 > Remove duplicate

[jira] [Commented] (FLINK-6742) Improve error message when savepoint migration fails due to task removal

2017-06-25 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062308#comment-16062308 ] Gyula Fora commented on FLINK-6742: --- Ah sorry Chesnay I missed it on the 1.3 branch :/ > Improve error

[jira] [Closed] (FLINK-6967) Fully separate batch and storm examples

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6967. --- Resolution: Fixed 1.4: 9f77073a56cccf06399dae24de1c38dc27dafcb6 > Fully separate batch and

[jira] [Closed] (FLINK-6788) Remove unused GenericFlatTypePostPass/AbstractSchema class

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6788. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: af0ced984ba9f13302f1d4c4d4b064bd580cc29c

[jira] [Closed] (FLINK-6488) Mark deprecated for 'start-local.sh' and 'stop-local' scripts

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6488. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 3557ff8636e899d56ba23534944669aeca2b5df4

[GitHub] flink issue #4177: [FLINK-6999] [build] Print TravisCI CPU, memory, and file...

2017-06-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4177 We can put the plugin into a separate "travis" profile. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-6999) Print TravisCI CPU, memory, and filesystem info

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062254#comment-16062254 ] ASF GitHub Bot commented on FLINK-6999: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6999) Print TravisCI CPU, memory, and filesystem info

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062255#comment-16062255 ] ASF GitHub Bot commented on FLINK-6999: --- Github user zentol commented on the issue:

[GitHub] flink issue #4177: [FLINK-6999] [build] Print TravisCI CPU, memory, and file...

2017-06-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4177 As for printing it for each module, this should be easy if we move the code into a separate script and use the ´exec-maven-plugin` or smth. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-5595) Add links to sub-sections in the left-hand navigation bar

2017-06-25 Thread Mike Winters (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062270#comment-16062270 ] Mike Winters commented on FLINK-5595: - Yes, please do! Thanks [~nssalian] > Add links to sub-sections

[jira] [Closed] (FLINK-6774) build-helper-maven-plugin version not set

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6774. --- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 1.3:

[jira] [Commented] (FLINK-6997) SavepointITCase fails in master branch sometimes

2017-06-25 Thread Shashank Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062257#comment-16062257 ] Shashank Agarwal commented on FLINK-6997: - I have tried savepoint on release-1.3 getting same

[GitHub] flink pull request #4177: [FLINK-6999] [build] Print TravisCI CPU, memory, a...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4177 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Updated] (FLINK-6965) Avro is missing snappy dependency

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6965: Priority: Blocker (was: Major) > Avro is missing snappy dependency >

[GitHub] flink pull request #4180: Merge PR for 1.3

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4180 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6774) build-helper-maven-plugin version not set

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062242#comment-16062242 ] ASF GitHub Bot commented on FLINK-6774: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6488) Mark deprecated for 'start-local.sh' and 'stop-local' scripts

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062239#comment-16062239 ] ASF GitHub Bot commented on FLINK-6488: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4159: [FLINK-6967] Remove batch-examples dependency from...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4159 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6682) Improve error message in case parallelism exceeds maxParallelism

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062235#comment-16062235 ] ASF GitHub Bot commented on FLINK-6682: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4074: [FLINK-6488] [scripts] Mark deprecated 'start-loca...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4074 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6769) Replace usage of deprecated FileSystem#create(Path, boolean)

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062227#comment-16062227 ] ASF GitHub Bot commented on FLINK-6769: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6782) Update savepoint documentation

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062231#comment-16062231 ] ASF GitHub Bot commented on FLINK-6782: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6742) Improve error message when savepoint migration fails due to task removal

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062229#comment-16062229 ] ASF GitHub Bot commented on FLINK-6742: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6956) Table examples broken

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062241#comment-16062241 ] ASF GitHub Bot commented on FLINK-6956: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3894: [FLINK-6541] Improve tmp dir setup in TM/WebMonito...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3894 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6863) Fully separate streaming examples

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062228#comment-16062228 ] ASF GitHub Bot commented on FLINK-6863: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4116: [FLINK-6769] Replace usage of deprecated FileSyste...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4116 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #4140: [FLINK-6943] Improve exceptions within TypeExtract...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4140 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6788) Remove unused GenericFlatTypePostPass/AbstractSchema class

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062232#comment-16062232 ] ASF GitHub Bot commented on FLINK-6788: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6868) Using `scala.binary.version` for `flink-streaming-scala` in `Cassandra Connector`

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062236#comment-16062236 ] ASF GitHub Bot commented on FLINK-6868: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4151: [FLINK-6389] [connector] Upgrade hbase dependency ...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4151 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #4125: [FLINK-6682] [checkpoints] Improve error message i...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4125 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6786) Remove duplicate QueryScopeInfoTest

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062237#comment-16062237 ] ASF GitHub Bot commented on FLINK-6786: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6541) Jar upload directory not created

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062233#comment-16062233 ] ASF GitHub Bot commented on FLINK-6541: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4034: [FLINK-6786] [metrics] Deduplicate QueryScopeIntoT...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4034 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #4083: [FLINK-6742] Improve savepoint migration failure e...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4083 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #4024: [FLINK-6782][docs] update snapshot documentation t...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4024 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #4017: [FLINK-6774][build] set missing build-helper-maven...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4017 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6920) Remove minor guava usages in several modules

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062225#comment-16062225 ] ASF GitHub Bot commented on FLINK-6920: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4115: [FLINK-6863] Remove batchdependency from streaming...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4115 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #4148: [FLINK-6956] Make table example POJO classes publi...

2017-06-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4148 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Closed] (FLINK-6682) Improve error message in case parallelism exceeds maxParallelism

2017-06-25 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang closed FLINK-6682. --- Resolution: Fixed > Improve error message in case parallelism exceeds maxParallelism >

[jira] [Closed] (FLINK-6784) Add some notes about externalized checkpoints and the difference to savepoints

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6784. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3: c815ada2b68fd0692b1ccd77c4bcff2a3e9175ea

[jira] [Closed] (FLINK-6798) Remove/update documentation about network buffer tuning

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6798. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3: 31fd58258b1346f3c9adcf397ffdec316333a4bd

[jira] [Commented] (FLINK-6742) Improve error message when savepoint migration fails due to task removal

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062297#comment-16062297 ] Chesnay Schepler commented on FLINK-6742: - 1.3: 2bbfe0292c13d875b531a6c168ea78bfc7f21f0b 1.4:

[jira] [Closed] (FLINK-6782) Update savepoint documentation

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6782. --- Resolution: Fixed Fix Version/s: 1.4.0 1.3: bfba2b1d453266f28523c47682d3cfe5ae67ce74

[GitHub] flink pull request #4180: Merge PR for 1.3

2017-06-25 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4180 Merge PR for 1.3 Please ignore. You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink m3 Alternatively you can review and apply these

[jira] [Closed] (FLINK-6943) Improve exceptions within TypeExtractionUtils#getSingleAbstractMethod

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6943. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 2274bf74f0ac84fdcf6a6109426ada3c61b4454e

[GitHub] flink issue #4178: [FLINK-7000] Add custom configuration local environment i...

2017-06-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4178 you're modifying an existing method, didn't you mean to _add_ a new one? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[GitHub] flink issue #4177: [FLINK-6999] [build] Print TravisCI CPU, memory, and file...

2017-06-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4177 cool stuff, +1. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-7000) Add custom configuration for StreamExecutionEnvironment#createLocalEnvironment

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062253#comment-16062253 ] ASF GitHub Bot commented on FLINK-7000: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6999) Print TravisCI CPU, memory, and filesystem info

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062252#comment-16062252 ] ASF GitHub Bot commented on FLINK-6999: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6994) Wrong base url in master docs

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062286#comment-16062286 ] ASF GitHub Bot commented on FLINK-6994: --- Github user greghogan commented on the issue:

[GitHub] flink issue #4175: [FLINK-6994] [docs] Wrong base url in master docs

2017-06-25 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/4175 Why do we have both `flink-docs-master` and `flink-docs-release-1.4`? The main page only links to 1.3 and 1.4 but the flink-docs-master documentation links to 1.3, 1.2, 1.1, and 1.0. But each of

[jira] [Closed] (FLINK-6682) Improve error message in case parallelism exceeds maxParallelism

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6682. --- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 1.3:

[jira] [Closed] (FLINK-6541) Jar upload directory not created

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6541. --- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 1.3:

[jira] [Reopened] (FLINK-6682) Improve error message in case parallelism exceeds maxParallelism

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-6682: - > Improve error message in case parallelism exceeds maxParallelism >

[jira] [Closed] (FLINK-6769) Replace usage of deprecated FileSystem#create(Path, boolean)

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6769. --- Resolution: Fixed 1.4: d7bf7eebed29f35c797bd3e21bafd0eb071f9f34 > Replace usage of

[jira] [Closed] (FLINK-6863) Fully separate streaming examples

2017-06-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6863. --- Resolution: Fixed 1.4: 387dc4b992fc0ea3b728ee343c3a052bc746e3a3 > Fully separate streaming

[jira] [Commented] (FLINK-6742) Improve error message when savepoint migration fails due to task removal

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062282#comment-16062282 ] ASF GitHub Bot commented on FLINK-6742: --- Github user gyfora commented on a diff in the pull request:

[GitHub] flink pull request #4083: [FLINK-6742] Improve savepoint migration failure e...

2017-06-25 Thread gyfora
Github user gyfora commented on a diff in the pull request: https://github.com/apache/flink/pull/4083#discussion_r123895607 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointV2.java --- @@ -168,10 +168,27 @@ public static Savepoint

[GitHub] flink pull request #4160: {FLINK-6965] Include snappy-java in flink-dist

2017-06-25 Thread packet23
Github user packet23 commented on a diff in the pull request: https://github.com/apache/flink/pull/4160#discussion_r123909436 --- Diff: tools/travis_mvn_watchdog.sh --- @@ -182,6 +182,13 @@ check_shaded_artifacts() { exit 1 fi + SNAPPY=`cat

[jira] [Updated] (FLINK-7002) Partitioning broken if enum is used in compound key specified using field expression

2017-06-25 Thread Sebastian Klemke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Klemke updated FLINK-7002: Attachment: TestJob.java WorkingTestJob.java testdata.avro

[GitHub] flink issue #4145: [FLINK-6938][FLINK-6939] [cep] Not store IterativeConditi...

2017-06-25 Thread kl0u
Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4145 Hi @wuchong ! Nice work! I have some changes to propose in the code itself, but before moving on with this, I have some questions about the need of the change. For the second, I have

[jira] [Commented] (FLINK-6938) IterativeCondition should support RichFunction interface

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062403#comment-16062403 ] ASF GitHub Bot commented on FLINK-6938: --- Github user kl0u commented on the issue:

[GitHub] flink pull request #4178: [FLINK-7000] Add custom configuration local enviro...

2017-06-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4178#discussion_r123906377 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala --- @@ -768,6 +768,18 @@ object

[jira] [Commented] (FLINK-6939) Not store IterativeCondition with NFA state

2017-06-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062398#comment-16062398 ] Kostas Kloudas commented on FLINK-6939: --- Hi [~jark], I reviewed your PR and have some comments on

[jira] [Commented] (FLINK-7000) Add custom configuration for StreamExecutionEnvironment#createLocalEnvironment

2017-06-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16062406#comment-16062406 ] ASF GitHub Bot commented on FLINK-7000: --- Github user zentol commented on a diff in the pull request:

  1   2   >