[jira] [Updated] (FLINK-6727) Remove duplicate java8 Join test

2017-05-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6727: Issue Type: Improvement (was: Bug) > Remove duplicate java8 Join test > ---

[jira] [Updated] (FLINK-6727) Remove duplicate java8 Join test

2017-05-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6727: Priority: Minor (was: Major) > Remove duplicate java8 Join test > -

[jira] [Created] (FLINK-6727) Remove duplicate java8 Join test

2017-05-25 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6727: --- Summary: Remove duplicate java8 Join test Key: FLINK-6727 URL: https://issues.apache.org/jira/browse/FLINK-6727 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-6718) Activate strict checkstyle for flink-clients

2017-05-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6718. --- Resolution: Fixed 1.4: c793ea41d88fe84fa97d825728ad95f35e27ef82 > Activate strict checkstyle

[GitHub] flink pull request #3989: [FLINK-6719] Activate strict checkstyle for flink-...

2017-05-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3989 --- 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 enab

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

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

[jira] [Closed] (FLINK-6716) Suppress load errors in checkstyle JavadocMethod

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

[jira] [Commented] (FLINK-6716) Suppress load errors in checkstyle JavadocMethod

2017-05-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025852#comment-16025852 ] Chesnay Schepler commented on FLINK-6716: - OK it now happened for me to. I'm gonna

[jira] [Updated] (FLINK-6726) Allow setting Timers in ProcessWindowFunction

2017-05-25 Thread vishnu viswanath (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vishnu viswanath updated FLINK-6726: Description: Allow registration of timers in ProcessWindowFunction. {code} public abstract

[jira] [Created] (FLINK-6726) Allow setting Timers in ProcessWindowFunction

2017-05-25 Thread vishnu viswanath (JIRA)
vishnu viswanath created FLINK-6726: --- Summary: Allow setting Timers in ProcessWindowFunction Key: FLINK-6726 URL: https://issues.apache.org/jira/browse/FLINK-6726 Project: Flink Issue Type:

[GitHub] flink issue #3979: [FLINK-6704][yarn] Fix user-jars not being possible to ex...

2017-05-25 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3979 LGTM, +1. I'll merge this. --- 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 wish

[jira] [Commented] (FLINK-6704) Cannot disable YARN user jar inclusion

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025759#comment-16025759 ] ASF GitHub Bot commented on FLINK-6704: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-6332) Upgrade Scala version to 2.11.11

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025755#comment-16025755 ] ASF GitHub Bot commented on FLINK-6332: --- Github user tedyu commented on the issue:

[GitHub] flink issue #3957: [FLINK-6332] [build] Upgrade Scala versions

2017-05-25 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/3957 lgtm --- 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] [Comment Edited] (FLINK-6359) Utilize Hierarchical Timing Wheels for performant timer

2017-05-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15991975#comment-15991975 ] Ted Yu edited comment on FLINK-6359 at 5/26/17 3:35 AM: Interestin

[GitHub] flink issue #3987: [FLINK-6714] [runtime] Use user classloader for operator ...

2017-05-25 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3987 Thanks for the review @rmetzger @EronWright. I'll address Eron's comment while merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-6714) Operator state backend should set user classloader as context classloader when snapshotting

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025751#comment-16025751 ] ASF GitHub Bot commented on FLINK-6714: --- Github user tzulitai commented on the issue

[GitHub] flink issue #3981: [FLINK-6646] [yarn] Let YarnJobManager delete Yarn applic...

2017-05-25 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3981 Merging this. My reviews on this change is covered in #3981. @tedyu I'll address your comments while merging, thanks! --- If your project is set up for it, you can reply to this email and have y

[jira] [Commented] (FLINK-6646) YARN session doesn't work with HA

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025750#comment-16025750 ] ASF GitHub Bot commented on FLINK-6646: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-6708) Don't let the FlinkYarnSessionCli fail if it cannot retrieve the ClusterStatus

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025747#comment-16025747 ] ASF GitHub Bot commented on FLINK-6708: --- Github user tzulitai commented on the issue

[GitHub] flink issue #3982: [FLINK-6708] [yarn] Harden FlinkYarnSessionCli to handle ...

2017-05-25 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3982 LGTM! I'll rebase and merge this. --- 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 a

[jira] [Commented] (FLINK-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token.

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025736#comment-16025736 ] ASF GitHub Bot commented on FLINK-6376: --- Github user Rucongzhang commented on the is

[GitHub] flink issue #3776: [FLINK-6376]when deploy flink cluster on the yarn, it is ...

2017-05-25 Thread Rucongzhang
Github user Rucongzhang commented on the issue: https://github.com/apache/flink/pull/3776 @tzulitai , you are right. There are two problems in yarn cluster mode: 1、when we use the keytab,we do not set the HDFS delegation token to yarn container context, but yarn need. 2

[jira] [Commented] (FLINK-6725) make requiresOver as a contracted method in udagg

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025732#comment-16025732 ] ASF GitHub Bot commented on FLINK-6725: --- GitHub user shaoxuan-wang opened a pull req

[GitHub] flink pull request #3993: [FLINK-6725][table] make requiresOver as a contrac...

2017-05-25 Thread shaoxuan-wang
GitHub user shaoxuan-wang opened a pull request: https://github.com/apache/flink/pull/3993 [FLINK-6725][table] make requiresOver as a contracted method in udagg Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into cons

[jira] [Created] (FLINK-6725) make requiresOver as a contracted method in udagg

2017-05-25 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6725: Summary: make requiresOver as a contracted method in udagg Key: FLINK-6725 URL: https://issues.apache.org/jira/browse/FLINK-6725 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-6722) Activate strict checkstyle for flink-table

2017-05-25 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025524#comment-16025524 ] Greg Hogan commented on FLINK-6722: --- [~fhueske] [~Zentol] the only modifications to Scal

[jira] [Commented] (FLINK-6701) Activate strict checkstyle for flink-yarn

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025476#comment-16025476 ] ASF GitHub Bot commented on FLINK-6701: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3992: [FLINK-6711] Activate strict checkstyle for flink-...

2017-05-25 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3992 [FLINK-6711] Activate strict checkstyle for flink-connectors You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 6711_cs_con Alternativ

[jira] [Commented] (FLINK-6711) Activate strict checkstyle for flink-connectors

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025479#comment-16025479 ] ASF GitHub Bot commented on FLINK-6711: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-6721) Activate strict checkstyle for flink-fs-tests

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025477#comment-16025477 ] ASF GitHub Bot commented on FLINK-6721: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3991: [FLINK-6721] Activate strict checkstyle for flink-...

2017-05-25 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3991 [FLINK-6721] Activate strict checkstyle for flink-fs-tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 6721_cs_fst Alternativel

[GitHub] flink pull request #3990: [FLINK-6701] Activate strict checkstyle for flink-...

2017-05-25 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3990 [FLINK-6701] Activate strict checkstyle for flink-yarn You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 6701_checkstyle_yarn Alterna

[jira] [Commented] (FLINK-6722) Activate strict checkstyle for flink-table

2017-05-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025464#comment-16025464 ] Chesnay Schepler commented on FLINK-6722: - yes, scala code is unaffected. > Activ

[jira] [Commented] (FLINK-6722) Activate strict checkstyle for flink-table

2017-05-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025454#comment-16025454 ] Fabian Hueske commented on FLINK-6722: -- The checkstyle to add only affects Java code,

[jira] [Created] (FLINK-6724) Include function class name in UserDefinedFunctionUtils exceptions

2017-05-25 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6724: --- Summary: Include function class name in UserDefinedFunctionUtils exceptions Key: FLINK-6724 URL: https://issues.apache.org/jira/browse/FLINK-6724 Project: Flink

[jira] [Assigned] (FLINK-6722) Activate strict checkstyle for flink-table

2017-05-25 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-6722: - Assignee: Greg Hogan > Activate strict checkstyle for flink-table > -

[jira] [Created] (FLINK-6723) Activate strict checkstyle for flink-libraries

2017-05-25 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6723: --- Summary: Activate strict checkstyle for flink-libraries Key: FLINK-6723 URL: https://issues.apache.org/jira/browse/FLINK-6723 Project: Flink Issue Type

[jira] [Created] (FLINK-6722) Activate strict checkstyle for flink-table

2017-05-25 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6722: --- Summary: Activate strict checkstyle for flink-table Key: FLINK-6722 URL: https://issues.apache.org/jira/browse/FLINK-6722 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-6721) Activate strict checkstyle for flink-fs-tests

2017-05-25 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6721: --- Summary: Activate strict checkstyle for flink-fs-tests Key: FLINK-6721 URL: https://issues.apache.org/jira/browse/FLINK-6721 Project: Flink Issue Type:

[jira] [Created] (FLINK-6720) Activate strict checkstyle for flink-java8

2017-05-25 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6720: --- Summary: Activate strict checkstyle for flink-java8 Key: FLINK-6720 URL: https://issues.apache.org/jira/browse/FLINK-6720 Project: Flink Issue Type: Su

[jira] [Commented] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025221#comment-16025221 ] ASF GitHub Bot commented on FLINK-6719: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #3989: [FLINK-6719] Activate strict checkstyle for flink-...

2017-05-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3989#discussion_r118558312 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -369,68 +372,87 @@ public static void main(String[] args) throws

[jira] [Commented] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink

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

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

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

[jira] [Commented] (FLINK-6642) EnvInformation#getOpenFileHandlesLimit should return -1 for Windows

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

[jira] [Closed] (FLINK-6715) Activate strict checkstyle in for flink-mesos

2017-05-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6715. --- Resolution: Fixed 1.4: 0bca76ede8b7447014a7d7ed17633d77ecfafe18 > Activate strict checkstyle

[jira] [Closed] (FLINK-6642) EnvInformation#getOpenFileHandlesLimit should return -1 for Windows

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

[jira] [Commented] (FLINK-6715) Activate strict checkstyle in for flink-mesos

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

[jira] [Closed] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink

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

[GitHub] flink pull request #3956: [FLINK-6642] Return -1 in EnvInfo#getOpenFileHandl...

2017-05-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3956 --- 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 enab

[GitHub] flink pull request #2633: [FLINK-4497] CassadraSink support for scala tuples...

2017-05-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2633 --- 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 enab

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

2017-05-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3842 --- 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 enab

[GitHub] flink pull request #3988: [FLINK-6715] Activate strict checkstyle for flink-...

2017-05-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3988 --- 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 enab

[jira] [Commented] (FLINK-6692) The flink-dist jar contains unshaded netty jar

2017-05-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025107#comment-16025107 ] Robert Metzger commented on FLINK-6692: --- Okay "good", so its not a regression due to

[jira] [Commented] (FLINK-6704) Cannot disable YARN user jar inclusion

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025096#comment-16025096 ] ASF GitHub Bot commented on FLINK-6704: --- Github user rmetzger commented on the issue

[GitHub] flink issue #3979: [FLINK-6704][yarn] Fix user-jars not being possible to ex...

2017-05-25 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3979 +1 to merge (assuming this change has been tested on a cluster) --- 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 n

[jira] [Created] (FLINK-6719) Add details about fault-tolerance of timers to ProcessFunction docs

2017-05-25 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6719: -- Summary: Add details about fault-tolerance of timers to ProcessFunction docs Key: FLINK-6719 URL: https://issues.apache.org/jira/browse/FLINK-6719 Project

[jira] [Commented] (FLINK-6714) Operator state backend should set user classloader as context classloader when snapshotting

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024995#comment-16024995 ] ASF GitHub Bot commented on FLINK-6714: --- Github user EronWright commented on a diff

[GitHub] flink pull request #3987: [FLINK-6714] [runtime] Use user classloader for op...

2017-05-25 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/3987#discussion_r118530090 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java --- @@ -185,13 +185,18 @@ public void dispose() {

[jira] [Commented] (FLINK-6708) Don't let the FlinkYarnSessionCli fail if it cannot retrieve the ClusterStatus

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024949#comment-16024949 ] ASF GitHub Bot commented on FLINK-6708: --- Github user tzulitai commented on the issue

[GitHub] flink issue #3982: [FLINK-6708] [yarn] Harden FlinkYarnSessionCli to handle ...

2017-05-25 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3982 Verified that Flink YARN sessions + HA works nicely now. 1. Started non-detached YARN session 2. Submit job 3. Kill JobManager 4. YARN session correctly messages disassociation wi

[jira] [Assigned] (FLINK-6712) Bump Kafka010 version to 0.10.2.0

2017-05-25 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-6712: -- Assignee: Tzu-Li (Gordon) Tai > Bump Kafka010 version to 0.10.2.0 > ---

[jira] [Commented] (FLINK-6708) Don't let the FlinkYarnSessionCli fail if it cannot retrieve the ClusterStatus

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024797#comment-16024797 ] ASF GitHub Bot commented on FLINK-6708: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3982: [FLINK-6708] [yarn] Harden FlinkYarnSessionCli to ...

2017-05-25 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3982#discussion_r118499283 --- Diff: flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala --- @@ -89,5 +92,37 @@ class YarnJobManager( flinkConfiguration.g

[jira] [Commented] (FLINK-6708) Don't let the FlinkYarnSessionCli fail if it cannot retrieve the ClusterStatus

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024790#comment-16024790 ] ASF GitHub Bot commented on FLINK-6708: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3982: [FLINK-6708] [yarn] Harden FlinkYarnSessionCli to ...

2017-05-25 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3982#discussion_r118497398 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -413,14 +413,18 @@ public static void runInteractiveCli(YarnCl

[GitHub] flink pull request #3989: [FLINK-6719] Activate strict checkstyle for flink-...

2017-05-25 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3989#discussion_r118492307 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java --- @@ -369,68 +372,87 @@ public static void main(String[] args) thro

[GitHub] flink issue #3989: [FLINK-6719] Activate strict checkstyle for flink-clients

2017-05-25 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3989 +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 the featur

[jira] [Commented] (FLINK-6715) Activate strict checkstyle in for flink-mesos

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024757#comment-16024757 ] ASF GitHub Bot commented on FLINK-6715: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6642) EnvInformation#getOpenFileHandlesLimit should return -1 for Windows

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

[GitHub] flink issue #3956: [FLINK-6642] Return -1 in EnvInfo#getOpenFileHandlesLimit...

2017-05-25 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3956 merging. --- 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 fea

[GitHub] flink pull request #3988: [FLINK-6715] Activate strict checkstyle for flink-...

2017-05-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3988#discussion_r118490372 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java --- @@ -284,8 +286,8 @@ public String toString

[jira] [Commented] (FLINK-6715) Activate strict checkstyle in for flink-mesos

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024708#comment-16024708 ] ASF GitHub Bot commented on FLINK-6715: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #3988: [FLINK-6715] Activate strict checkstyle for flink-...

2017-05-25 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3988#discussion_r118480485 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java --- @@ -284,8 +286,8 @@ public String toString

[jira] [Commented] (FLINK-6715) Activate strict checkstyle in for flink-mesos

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024696#comment-16024696 ] ASF GitHub Bot commented on FLINK-6715: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #3988: [FLINK-6715] Activate strict checkstyle for flink-...

2017-05-25 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3988#discussion_r118477940 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java --- @@ -284,8 +286,8 @@ public String toStr

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024677#comment-16024677 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on the issue

[GitHub] flink issue #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream SQL

2017-05-25 Thread rtudoran
Github user rtudoran commented on the issue: https://github.com/apache/flink/pull/3889 @fhueske @stefanobortoli @shijinkui @hongyuhong I have updated the PR. In principle all remarks were addressed. This should be ready to merge (i hope) --- If your project is set up for it, you

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-05-25 Thread rtudoran
Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r118475890 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SortTest.scala --- @@ -0,0 +1,89 @@ +/* + * Licens

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024668#comment-16024668 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in

[jira] [Commented] (FLINK-6712) Bump Kafka010 version to 0.10.2.0

2017-05-25 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024662#comment-16024662 ] Greg Hogan commented on FLINK-6712: --- +1 and also a version bump is required to build for

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024597#comment-16024597 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-05-25 Thread rtudoran
Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r118468562 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SortITCase.scala --- @@ -0,0 +1,133 @@ +/* + * Lic

[GitHub] flink pull request #3989: [FLINK-6719] Activate strict checkstyle for flink-...

2017-05-25 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3989 [FLINK-6719] Activate strict checkstyle for flink-clients You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 6718_cs_cl Alternatively

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024575#comment-16024575 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-05-25 Thread rtudoran
Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r118466310 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SortITCase.scala --- @@ -0,0 +1,133 @@ +/* + * Lic

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-05-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024565#comment-16024565 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-05-25 Thread rtudoran
Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r118465274 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/aggregate/ProcTimeSortProcessFunctionTest.scala --- @@ -0,0 +1,165 @@

[jira] [Closed] (FLINK-6669) [Build] Scala style check errror on Windows

2017-05-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6669. --- Resolution: Fixed Fix Version/s: 1.3.1 1.3: 401e997593631399e4311511f942692a0187e4bb M

[jira] [Closed] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase

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

[jira] [Closed] (FLINK-6659) RocksDBMergeIteratorTest, SavepointITCase leave temporary directories behind

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

[jira] [Commented] (FLINK-6706) remove ChaosMonkeyITCase

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

[jira] [Commented] (FLINK-6699) Activate strict-checkstyle in flink-yarn-tests

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

[jira] [Commented] (FLINK-6707) Activate strict checkstyle for flink-examples

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

[jira] [Closed] (FLINK-6707) Activate strict checkstyle for flink-examples

2017-05-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6707. --- Resolution: Fixed 1.4: 789ed8a8246d140e1621a5860645a747132d6618 > Activate strict checkstyle

[GitHub] flink pull request #3986: [FLINK-6707] [examples] Activate strict checkstyle...

2017-05-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3986 --- 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 enab

[GitHub] flink pull request #3980: [FLINK-6706] remove outdated/unused ChaosMonkeyITC...

2017-05-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3980 --- 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 enab

[GitHub] flink pull request #3985: [FLINK-6699] Activate strict checkstyle for flink-...

2017-05-25 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3985 --- 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 enab

[jira] [Assigned] (FLINK-6706) remove ChaosMonkeyITCase

2017-05-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6706: --- Assignee: Nico Kruber > remove ChaosMonkeyITCase > > >

  1   2   >