[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249213#comment-16249213 ] ASF GitHub Bot commented on FLINK-4228: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3a defau...

2017-11-13 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4939 I think excluding dependencies without declaring them explicitly has the disadvantage that this relies implicitly on another dependency to pull in the right versions. Once this dependency is

[jira] [Comment Edited] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249223#comment-16249223 ] Piotr Nowojski edited comment on FLINK-7845 at 11/13/17 8:15 AM: -

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249256#comment-16249256 ] Flavio Pompermaier commented on FLINK-7845: --- Done.

[jira] [Comment Edited] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249223#comment-16249223 ] Piotr Nowojski edited comment on FLINK-7845 at 11/13/17 8:15 AM: -

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249223#comment-16249223 ] Piotr Nowojski commented on FLINK-7845: --- [~f.pompermaier] could you push a code for {{1.4-SNAPSHOT}}

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249315#comment-16249315 ] ASF GitHub Bot commented on FLINK-7702: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-7475) support update() in ListState

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249311#comment-16249311 ] ASF GitHub Bot commented on FLINK-7475: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #5003: [FLINK-7702] Fix Javadoc build issues

2017-11-13 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5003 @aljoscha I tried to build the docs on my local machine but it still fails with: ``` [ERROR] Error while creating javadoc report: Missing: -- 1)

[jira] [Assigned] (FLINK-8053) Default to asynchronous snapshots for FsStateBackend

2017-11-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-8053: --- Assignee: Aljoscha Krettek > Default to asynchronous snapshots for FsStateBackend >

[jira] [Created] (FLINK-8053) Default to asynchronous snapshots for FsStateBackend

2017-11-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-8053: --- Summary: Default to asynchronous snapshots for FsStateBackend Key: FLINK-8053 URL: https://issues.apache.org/jira/browse/FLINK-8053 Project: Flink

[GitHub] flink issue #4963: [FLINK-7475] [core][DataStream API] support update() in L...

2017-11-13 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4963 @aljoscha IIRC there is no class for `StringAppendTESTOperator ` in the RocksDB Java API. You can only pass a string that is used inside some factory in the native RocksDB code to

[jira] [Closed] (FLINK-8050) RestServer#shutdown() ignores exceptions thrown when shutting down netty.

2017-11-13 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-8050. -- Resolution: Duplicate > RestServer#shutdown() ignores exceptions thrown when shutting down netty. >

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249366#comment-16249366 ] Flavio Pompermaier commented on FLINK-7845: --- Updated scala to 2.11. Maybe it could be a good

[GitHub] flink issue #5004: [FLINK-8040] [tests] Fix test instability in ResourceGuar...

2017-11-13 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5004 👍 ---

[GitHub] flink pull request #4998: [FLINK-7702] Add maven-bundle-plugin to root pom

2017-11-13 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/4998 ---

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249367#comment-16249367 ] Chesnay Schepler commented on FLINK-7845: - To get the IllegalAccessError out of the way,

[jira] [Commented] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249390#comment-16249390 ] ASF GitHub Bot commented on FLINK-8040: --- Github user GJL commented on the issue:

[GitHub] flink pull request #5003: [FLINK-7702] Fix Javadoc build issues

2017-11-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5003 ---

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249435#comment-16249435 ] Piotr Nowojski commented on FLINK-7845: --- [~f.pompermaier] your loop seems to extending the job over

[jira] [Closed] (FLINK-6235) Broken link in documentation

2017-11-13 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-6235. - Resolution: Won't Fix > Broken link in documentation > - > >

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249495#comment-16249495 ] ASF GitHub Bot commented on FLINK-7973: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-7475) support update() in ListState

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249302#comment-16249302 ] ASF GitHub Bot commented on FLINK-7475: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-4809) Operators should tolerate checkpoint failures

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249323#comment-16249323 ] ASF GitHub Bot commented on FLINK-4809: --- Github user StefanRRichter commented on the issue:

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249321#comment-16249321 ] Piotr Nowojski commented on FLINK-7845: --- Thanks, however it doesn't work for me :( When I try to run

[GitHub] flink issue #4883: [FLINK-4809] Operators should tolerate checkpoint failure...

2017-11-13 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4883 @PangZhi No updates, because I was on vacation and we currently give priority to the release 1.4 testing. After that I will finish this, but from the review comments, I would not expect that

[jira] [Updated] (FLINK-8053) Default to asynchronous snapshots for FsStateBackend

2017-11-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-8053: Fix Version/s: 1.4.0 > Default to asynchronous snapshots for FsStateBackend >

[jira] [Commented] (FLINK-7702) Javadocs are not being built

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

[GitHub] flink issue #4998: [FLINK-7702] Add maven-bundle-plugin to root pom

2017-11-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4998 Turns out this doesn't work, we also have to remove the genjavadoc plugin. ---

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249271#comment-16249271 ] ASF GitHub Bot commented on FLINK-7702: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #5003: [FLINK-7702] Fix Javadoc build issues

2017-11-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5003 For me it does work locally but it could be an issue that I have something in my caches that you don't have. Which would be bad because then it wouldn't work on the buildbot either. ---

[GitHub] flink issue #5003: [FLINK-7702] Fix Javadoc build issues

2017-11-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5003 Did you use the branch that has both commits? Not the first PR that doesn't have the `maven-bundle-plugin` fixes? ---

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

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

[GitHub] flink issue #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3a defau...

2017-11-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4939 At the same time, pinning a dependency version can cause problems if a dependency is upgraded and requires another jackson version. There isn't a perfect solution. The current approach works

[jira] [Updated] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

2017-11-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7657: Priority: Blocker (was: Critical) > SQL Timestamps Converted To Wrong Type By Optimizer Causing

[GitHub] flink issue #4961: [FLINK-7973] fix shading and relocating Hadoop for the S3...

2017-11-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4961 This look even better now! Waiting for Travis and then I'll merge. Thanks! 😃 ---

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249324#comment-16249324 ] ASF GitHub Bot commented on FLINK-7702: --- Github user twalthr commented on the issue:

[GitHub] flink issue #5003: [FLINK-7702] Fix Javadoc build issues

2017-11-13 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5003 Wait I might build the wrong branch. Let me check it again. ---

[GitHub] flink issue #5003: [FLINK-7702] Fix Javadoc build issues

2017-11-13 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5003 It worked. +1 for this. ---

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249357#comment-16249357 ] ASF GitHub Bot commented on FLINK-7702: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249377#comment-16249377 ] ASF GitHub Bot commented on FLINK-8040: --- GitHub user StefanRRichter opened a pull request:

[GitHub] flink pull request #5004: [FLINK-8040] [tests] Fix test instability in Resou...

2017-11-13 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/5004 [FLINK-8040] [tests] Fix test instability in ResourceGuardTest This PR only fixes a minor test instability in `ResourceGuardTest` and improves a bit on the comments. You can merge this pull

[jira] [Commented] (FLINK-7702) Javadocs are not being built

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

[GitHub] flink issue #5004: [FLINK-8040] [tests] Fix test instability in ResourceGuar...

2017-11-13 Thread GJL
Github user GJL commented on the issue: https://github.com/apache/flink/pull/5004 👍 ---

[jira] [Commented] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249398#comment-16249398 ] ASF GitHub Bot commented on FLINK-8040: --- Github user GJL commented on the issue:

[jira] [Commented] (FLINK-4575) DataSet aggregate methods should support POJOs

2017-11-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249312#comment-16249312 ] Fabian Hueske commented on FLINK-4575: -- I'm not sure about extending the DataSet API for such special

[jira] [Created] (FLINK-8051) Reactivate Scaladoc aggregation using genjavadoc

2017-11-13 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-8051: --- Summary: Reactivate Scaladoc aggregation using genjavadoc Key: FLINK-8051 URL: https://issues.apache.org/jira/browse/FLINK-8051 Project: Flink Issue

[jira] [Closed] (FLINK-7702) Javadocs are not being built

2017-11-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7702. --- Resolution: Fixed Fixed on release-1.4 in 6aeac3fb77c1053e344d08c0cc68e84a88623a43

[jira] [Created] (FLINK-8052) Bump docs scala version to 2.11

2017-11-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8052: --- Summary: Bump docs scala version to 2.11 Key: FLINK-8052 URL: https://issues.apache.org/jira/browse/FLINK-8052 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249399#comment-16249399 ] Aljoscha Krettek commented on FLINK-7702: - I added a follow-up issue about re-activating

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249275#comment-16249275 ] ASF GitHub Bot commented on FLINK-7702: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request #5003: [FLINK-7702] Fix Javadoc build issues

2017-11-13 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/5003 [FLINK-7702] Fix Javadoc build issues This remove the `genjavadoc` tool which doesn't work with our code base right now and also adds a dependency in the root pom that is needed for building the

[GitHub] flink issue #4963: [FLINK-7475] [core][DataStream API] support update() in L...

2017-11-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4963 I don't know if there's a way of retrieving the class behind the `"stringappendtest"` merge operator. If not, we should just simulate the behaviour of appending with commas in Java code.

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249319#comment-16249319 ] ASF GitHub Bot commented on FLINK-7702: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-7702) Javadocs are not being built

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249320#comment-16249320 ] ASF GitHub Bot commented on FLINK-7702: --- Github user aljoscha commented on the issue:

[jira] [Commented] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

2017-11-13 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249322#comment-16249322 ] Kostas Kloudas commented on FLINK-8046: --- Hi [~jmcejuela]! Thanks a lot for reporting this and

[GitHub] flink issue #4746: [FLINK-7657] [Table] Adding logic to convert RexLiteral t...

2017-11-13 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4746 Thanks for the update @kmurra. I will go over the changes a last time and merge this. ---

[jira] [Commented] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249358#comment-16249358 ] ASF GitHub Bot commented on FLINK-7657: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249385#comment-16249385 ] Piotr Nowojski commented on FLINK-7845: --- After changing it to public {{IllegaltAccessError}} indeed

[jira] [Commented] (FLINK-4575) DataSet aggregate methods should support POJOs

2017-11-13 Thread Gabor Gevay (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249444#comment-16249444 ] Gabor Gevay commented on FLINK-4575: OK, makes sense. Feel free to close this jira, if you think we

[GitHub] flink pull request #5009: [FLINK-8045] Add Internal DATE/TIME/TIMESTAMP as i...

2017-11-13 Thread docete
GitHub user docete opened a pull request: https://github.com/apache/flink/pull/5009 [FLINK-8045] Add Internal DATE/TIME/TIMESTAMP as internal representata... …ion of DATE/TIME/TIMESTAMP *Thank you very much for contributing to Apache Flink - we are happy that you

[jira] [Commented] (FLINK-7873) Introduce CheckpointCacheManager for reading checkpoint data locally when performing failover

2017-11-13 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250747#comment-16250747 ] Sihua Zhou commented on FLINK-7873: --- [~srichter] Thanks for your reply and the introduction of your

[jira] [Commented] (FLINK-8045) Add Internal DATE/TIME/TIMESTAMP as internal representation of DATE/TIME/TIMESTAMP

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250741#comment-16250741 ] ASF GitHub Bot commented on FLINK-8045: --- GitHub user docete opened a pull request:

[GitHub] flink issue #4936: [FLINK-7962] Add built-in support for min/max aggregation...

2017-11-13 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4936 Thanks for the work! The code looks good to me. +1 ---

[jira] [Commented] (FLINK-7962) Add built-in support for min/max aggregation for Timestamp

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250835#comment-16250835 ] ASF GitHub Bot commented on FLINK-7962: --- Github user wuchong commented on the issue:

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

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

[jira] [Updated] (FLINK-8018) RMQ does not support disabling queueDeclare, when the user has no declaration permissions, it cannot connect

2017-11-13 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-8018: -- Fix Version/s: 1.5.0 > RMQ does not support disabling queueDeclare, when the user has no declaration >

[GitHub] flink issue #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3a defau...

2017-11-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4939 So we pin the version, update aws at some point (and forget to check the dependency), and now we got a sleeper failure because there may be a single code-path that fails due to a version mismatch.

[GitHub] flink pull request #5007: [FLINK-7845] Make NettyMessage public

2017-11-13 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5007#discussion_r150755017 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java --- @@ -52,8 +52,10 @@ /** * A simple and

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

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

[jira] [Updated] (FLINK-8054) Deduplicate Time classes

2017-11-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8054: Description: We currently have 2 {{Time}} classes in Flink,

[jira] [Commented] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

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

[GitHub] flink pull request #5004: [FLINK-8040] [tests] Fix test instability in Resou...

2017-11-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5004 ---

[GitHub] flink pull request #4726: [FLINK-7678] [table] Support composite inputs for ...

2017-11-13 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4726#discussion_r150539995 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/CorrelateITCase.scala --- @@ -210,6 +213,31 @@ class

[jira] [Updated] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-7845: -- Attachment: Screen Shot 2017-11-13 at 14.54.38.png > Netty Exception when submitting batch job

[GitHub] flink issue #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3a defau...

2017-11-13 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4939 This is true, however, I think that in case of doubt the more explicit solution should be preferred, because it is more predictable. ---

[GitHub] flink issue #5004: [FLINK-8040] [tests] Fix test instability in ResourceGuar...

2017-11-13 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5004 Thanks @GJL ! Will merge this. ---

[jira] [Commented] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249515#comment-16249515 ] ASF GitHub Bot commented on FLINK-8040: --- Github user StefanRRichter commented on the issue:

[jira] [Closed] (FLINK-8040) Test instability ResourceGuard#testCloseBlockIfAcquired

2017-11-13 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8040. - Resolution: Fixed Merged in ad8ef6d01b. > Test instability

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249545#comment-16249545 ] Flavio Pompermaier commented on FLINK-7845: --- [~pnowojski] now I've pushed a version of the job

[GitHub] flink issue #4989: [Flink 7003] [Table API & SQL] use PEEK_FIELDS_NO_EXPAND ...

2017-11-13 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4989 Maybe we can reduce the number of ITCases in this PR and add tests to `CompositeAccessTest` instead. ---

[jira] [Created] (FLINK-8055) Deduplicate logging messages about QS start

2017-11-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8055: --- Summary: Deduplicate logging messages about QS start Key: FLINK-8055 URL: https://issues.apache.org/jira/browse/FLINK-8055 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8054) Deduplicate Time classes

2017-11-13 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249657#comment-16249657 ] Till Rohrmann commented on FLINK-8054: -- Yes exactly. > Deduplicate Time classes >

[jira] [Created] (FLINK-8057) KvStateRegistry#registerKvState may randomly fail

2017-11-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8057: --- Summary: KvStateRegistry#registerKvState may randomly fail Key: FLINK-8057 URL: https://issues.apache.org/jira/browse/FLINK-8057 Project: Flink Issue

[jira] [Commented] (FLINK-7678) SQL UserDefineTableFunction does not take CompositeType input correctly

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249562#comment-16249562 ] ASF GitHub Bot commented on FLINK-7678: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249564#comment-16249564 ] Piotr Nowojski commented on FLINK-7845: --- Why are you suspecting a memory leak? How is this test

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249653#comment-16249653 ] Flavio Pompermaier commented on FLINK-7845: --- Also looking at the Flink code it seems that only

[jira] [Closed] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Pompermaier closed FLINK-7845. - Resolution: Not A Problem The problem was in the test program > Netty Exception when

[jira] [Updated] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-7845: -- Priority: Blocker (was: Major) Fix Version/s: 1.4.0 > Netty Exception when submitting

[jira] [Reopened] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-7845: --- Assignee: Piotr Nowojski > Netty Exception when submitting batch job repeatedly >

[jira] [Created] (FLINK-8054) Deduplicate Time classes

2017-11-13 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8054: --- Summary: Deduplicate Time classes Key: FLINK-8054 URL: https://issues.apache.org/jira/browse/FLINK-8054 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7678) SQL UserDefineTableFunction does not take CompositeType input correctly

2017-11-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249559#comment-16249559 ] ASF GitHub Bot commented on FLINK-7678: --- Github user twalthr commented on a diff in the pull

[jira] [Commented] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

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

[GitHub] flink pull request #4746: [FLINK-7657] [Table] Adding logic to convert RexLi...

2017-11-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4746 ---

[jira] [Comment Edited] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249627#comment-16249627 ] Piotr Nowojski edited comment on FLINK-7845 at 11/13/17 2:08 PM: -

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249688#comment-16249688 ] Piotr Nowojski commented on FLINK-7845: --- Please do not close this ticket, since {code:java}

[GitHub] flink pull request #5005: Flink 8053 default async

2017-11-13 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/5005 Flink 8053 default async ## What is the purpose of the change This PR changes the default configuration for all heap based state backends to use asynchronous snapshots.

[GitHub] flink issue #5005: Flink 8053 default async

2017-11-13 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5005 CC @aljoscha ---

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249571#comment-16249571 ] Flavio Pompermaier commented on FLINK-7845: --- The job always fails with the same error (Caused

[jira] [Comment Edited] (FLINK-7845) Netty Exception when submitting batch job repeatedly

2017-11-13 Thread Flavio Pompermaier (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249571#comment-16249571 ] Flavio Pompermaier edited comment on FLINK-7845 at 11/13/17 1:53 PM: -

  1   2   >