[jira] [Closed] (FLINK-1644) WebClient dies when no ExecutionEnvironment in main method

2016-01-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1644. Resolution: Fixed Fix Version/s: 1.0.0 After a new web client was added to the new web dashbo

[jira] [Commented] (FLINK-1581) Configure DeathWatch parameters properly

2016-01-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092932#comment-15092932 ] Fabian Hueske commented on FLINK-1581: -- [~till.rohrmann], is this issue still valid?

[jira] [Closed] (FLINK-1500) exampleScalaPrograms.EnumTriangleOptITCase does not finish on Travis

2016-01-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1500. Resolution: Invalid I believe we can close this issue since it did not occur since almost a year. Al

[jira] [Commented] (FLINK-1274) Make Flink Streaming's FileSourceFunction type generic

2016-01-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092909#comment-15092909 ] Fabian Hueske commented on FLINK-1274: -- Has this issue been resolved with the reworke

[jira] [Closed] (FLINK-1241) Record processing counter for Dashboard

2016-01-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-1241. Resolution: Duplicate Flink 0.10.0 added a new web dashboard which shows record counts at operator

[jira] [Commented] (FLINK-937) Change the YARN Client to allocate all cluster resources, if no argument given

2016-01-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092848#comment-15092848 ] Fabian Hueske commented on FLINK-937: - [~rmetzger] Is this issue resolved and can this

[jira] [Closed] (FLINK-430) Provide a simple way of parsing text

2016-01-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-430. --- Resolution: Duplicate This issue is subsumed by FLINK-2435. > Provide a simple way of parsing text > -

[jira] [Commented] (FLINK-3192) Add explain support to print ast and sql physical execution plan.

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092823#comment-15092823 ] ASF GitHub Bot commented on FLINK-3192: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-3192] Add explain support to print ast ...

2016-01-11 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1477#issuecomment-170712317 @gallenvara, Then let's keep it like this. Thanks for the update. PR is good to merge --- If your project is set up for it, you can reply to this email and have your re

[jira] [Commented] (FLINK-2551) Fix Several Bugs in Input/Output Formats

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092774#comment-15092774 ] ASF GitHub Bot commented on FLINK-2551: --- GitHub user ndimiduk opened a pull request:

[GitHub] flink pull request: FLINK-2551 Fix Several Bugs in Input/Output Fo...

2016-01-11 Thread ndimiduk
GitHub user ndimiduk opened a pull request: https://github.com/apache/flink/pull/1497 FLINK-2551 Fix Several Bugs in Input/Output Formats This is a patch that fixes the last issue listed on the ticket description, "The Streaming API does not call setInputType if a format implements

[jira] [Commented] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar

2016-01-11 Thread Christophe S (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092748#comment-15092748 ] Christophe S commented on FLINK-3158: - Indeed, I will post it there too. FYI I removed

[jira] [Commented] (FLINK-2716) Checksum method for DataSet and Graph

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092743#comment-15092743 ] ASF GitHub Bot commented on FLINK-2716: --- Github user greghogan commented on the pull

[GitHub] flink pull request: [FLINK-2716] [gelly java scala] New checksum m...

2016-01-11 Thread greghogan
Github user greghogan commented on the pull request: https://github.com/apache/flink/pull/1462#issuecomment-170701135 I'm not seeing a notification email for the second commit I just pushed to my repo. Also, I have attempted to get the Scala API correct but that needs a good review.

[jira] [Commented] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar

2016-01-11 Thread Nick Dimiduk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092736#comment-15092736 ] Nick Dimiduk commented on FLINK-3158: - Sounds like a question for the user list. > Sh

[GitHub] flink pull request: [FLINK-3218] Merging Hadoop configurations ove...

2016-01-11 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/1496 [FLINK-3218] Merging Hadoop configurations overrides user parameters You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink 3218_mer

[jira] [Commented] (FLINK-3218) Merging Hadoop configurations overrides user parameters

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092725#comment-15092725 ] ASF GitHub Bot commented on FLINK-3218: --- GitHub user greghogan opened a pull request

[jira] [Commented] (FLINK-2551) Fix Several Bugs in Input/Output Formats

2016-01-11 Thread Nick Dimiduk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092711#comment-15092711 ] Nick Dimiduk commented on FLINK-2551: - bq. The Streaming API does not call {{setInputT

[jira] [Created] (FLINK-3219) Implement DataSet.count using a single operator

2016-01-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3219: - Summary: Implement DataSet.count using a single operator Key: FLINK-3219 URL: https://issues.apache.org/jira/browse/FLINK-3219 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar

2016-01-11 Thread Christophe S (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092377#comment-15092377 ] Christophe S commented on FLINK-3158: - Do you think it could explain why I can't acces

[jira] [Created] (FLINK-3218) Merging Hadoop configurations overrides user parameters

2016-01-11 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3218: - Summary: Merging Hadoop configurations overrides user parameters Key: FLINK-3218 URL: https://issues.apache.org/jira/browse/FLINK-3218 Project: Flink Issue Type: B

[jira] [Created] (FLINK-3217) Implement NFA for pattern detection

2016-01-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3217: Summary: Implement NFA for pattern detection Key: FLINK-3217 URL: https://issues.apache.org/jira/browse/FLINK-3217 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3216) Define pattern specification

2016-01-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3216: Summary: Define pattern specification Key: FLINK-3216 URL: https://issues.apache.org/jira/browse/FLINK-3216 Project: Flink Issue Type: Sub-task R

[jira] [Created] (FLINK-3215) Add CEP library to Flink

2016-01-11 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3215: Summary: Add CEP library to Flink Key: FLINK-3215 URL: https://issues.apache.org/jira/browse/FLINK-3215 Project: Flink Issue Type: New Feature Re

[jira] [Commented] (FLINK-3212) JobManagerCheckpointRecoveryITCase

2016-01-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092161#comment-15092161 ] Ufuk Celebi commented on FLINK-3212: I've added a retry on failure rule. That should h

[GitHub] flink pull request: [FLINK-3050] [runtime] Add UnrecoverableExcept...

2016-01-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1461 --- 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] [Resolved] (FLINK-3050) Add custom Exception type to suppress job restarts

2016-01-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-3050. Resolution: Implemented Implemented in ebbc85d. > Add custom Exception type to suppress job restart

[jira] [Resolved] (FLINK-2976) Save and load checkpoints manually

2016-01-11 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2976. Resolution: Implemented Implemented in a3c0185..7734885. > Save and load checkpoints manually > ---

[jira] [Commented] (FLINK-3050) Add custom Exception type to suppress job restarts

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

[jira] [Commented] (FLINK-2976) Save and load checkpoints manually

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

[GitHub] flink pull request: [FLINK-2976] Allow to trigger checkpoints manu...

2016-01-11 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1434 --- 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: [FLINK-3140] NULL value data layout in Row Ser...

2016-01-11 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1465#issuecomment-170584470 @fhueske I updated the PR again. I implemented your suggestion of NullAwareComparators wrapping the normal comparators. I also added additional test cases. What do you t

[jira] [Commented] (FLINK-3140) NULL value data layout in Row Serializer/Comparator

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15092067#comment-15092067 ] ASF GitHub Bot commented on FLINK-3140: --- Github user twalthr commented on the pull r

[jira] [Commented] (FLINK-3172) Specify jobmanager port in HA mode

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091940#comment-15091940 ] ASF GitHub Bot commented on FLINK-3172: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-3172] Specify JobManager port in HA mod...

2016-01-11 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1458#issuecomment-170561792 Hmm, to me it is confusing by itself that there are different parameters for ports in HA mode and in standalone mode. Taking a step back, I would expect this

[GitHub] flink pull request: [FLINK-2976] Allow to trigger checkpoints manu...

2016-01-11 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1434#issuecomment-170558665 :+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 a

[jira] [Commented] (FLINK-2976) Save and load checkpoints manually

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091931#comment-15091931 ] ASF GitHub Bot commented on FLINK-2976: --- Github user gyfora commented on the pull re

[jira] [Commented] (FLINK-2976) Save and load checkpoints manually

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091897#comment-15091897 ] ASF GitHub Bot commented on FLINK-2976: --- Github user uce commented on the pull reque

[GitHub] flink pull request: [FLINK-2976] Allow to trigger checkpoints manu...

2016-01-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1434#issuecomment-170550295 I've rebased this. Waiting for Travis and then 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

[jira] [Commented] (FLINK-3109) Join two streams with two different buffer time

2016-01-11 Thread Wang Yangjun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091769#comment-15091769 ] Wang Yangjun commented on FLINK-3109: - During last month, this implementation worked w

[jira] [Commented] (FLINK-3172) Specify jobmanager port in HA mode

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091639#comment-15091639 ] ASF GitHub Bot commented on FLINK-3172: --- Github user uce commented on the pull reque

[GitHub] flink pull request: [FLINK-3172] Specify JobManager port in HA mod...

2016-01-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1458#issuecomment-170477745 All HA configuration is prefixed with `recovery`. If we rename it as you suggest, I would like to move all HA related configuration to `jobmanager.ha`. Any opinions? --- I

[GitHub] flink pull request: [FLINK-2976] Allow to trigger checkpoints manu...

2016-01-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1434#issuecomment-170477891 Thanks Gyula! I will rebase and merge this if there are no objections. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[jira] [Commented] (FLINK-2976) Save and load checkpoints manually

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091640#comment-15091640 ] ASF GitHub Bot commented on FLINK-2976: --- Github user uce commented on the pull reque

[jira] [Commented] (FLINK-3050) Add custom Exception type to suppress job restarts

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091633#comment-15091633 ] ASF GitHub Bot commented on FLINK-3050: --- Github user uce commented on the pull reque

[GitHub] flink pull request: [FLINK-3050] [runtime] Add UnrecoverableExcept...

2016-01-11 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1461#issuecomment-170476156 Any objections against merging 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

[GitHub] flink pull request: [FLINK-3192] Add explain support to print ast ...

2016-01-11 Thread gallenvara
Github user gallenvara commented on the pull request: https://github.com/apache/flink/pull/1477#issuecomment-170467184 @fhueske , i"m favor of showing the whole plan. First, `Table` API converts `DataSet` to a `Table` and provides several operations on the `DataSource`. It's a data-pr

[jira] [Commented] (FLINK-3192) Add explain support to print ast and sql physical execution plan.

2016-01-11 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15091608#comment-15091608 ] ASF GitHub Bot commented on FLINK-3192: --- Github user gallenvara commented on the pul