[jira] [Commented] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14876916#comment-14876916 ] ASF GitHub Bot commented on FLINK-2622: --- Github user chiwanpark commented on the pul

[GitHub] flink pull request: [FLINK-2622][streaming]add WriteMode for write...

2015-09-18 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1098#issuecomment-141629844 There is a checkstyle error: ``` [INFO] There is 1 error reported by Checkstyle 6.2 with /tools/maven/checkstyle.xml ruleset. [ERROR] src/main/java/o

[jira] [Commented] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14876915#comment-14876915 ] ASF GitHub Bot commented on FLINK-2622: --- Github user HuangWHWHW commented on the pul

[GitHub] flink pull request: [FLINK-2622][streaming]add WriteMode for write...

2015-09-18 Thread HuangWHWHW
Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/1098#issuecomment-141629775 Hi, could anyone tell me why the last CI failed? Thanks:) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub a

[jira] [Commented] (FLINK-2576) Add outer joins to API and Optimizer

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14876425#comment-14876425 ] ASF GitHub Bot commented on FLINK-2576: --- Github user jkovacs commented on the pull r

[GitHub] flink pull request: [FLINK-2576] Add Outer Join operator to Optimi...

2015-09-18 Thread jkovacs
Github user jkovacs commented on the pull request: https://github.com/apache/flink/pull/1138#issuecomment-141569673 To partly answer my own question: One big drawback of downgrading the tuple field types to `GenericTypeInfo` is that for (de)serialization and comparison the generic Kry

[jira] [Created] (FLINK-2709) line editing in scala shell

2015-09-18 Thread Matthew Farrellee (JIRA)
Matthew Farrellee created FLINK-2709: Summary: line editing in scala shell Key: FLINK-2709 URL: https://issues.apache.org/jira/browse/FLINK-2709 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-2525) Add configuration support in Storm-compatibility

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

[GitHub] flink pull request: [FLINK-2525]Add configuration support in Storm...

2015-09-18 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1046#issuecomment-141550369 Hi @ffbin, not sure if you followed the discussion on the mailing list, but we discussed to use the ExecutionConfig instead of the JobConfig. The reason is that Exec

[jira] [Closed] (FLINK-2708) Potential null pointer dereference in JoinWithSolutionSetFirstDriver#run()

2015-09-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2708. Resolution: Not A Problem Thanks for opening this issue. However, null values are actually fine in t

[jira] [Created] (FLINK-2708) Potential null pointer dereference in JoinWithSolutionSetFirstDriver#run()

2015-09-18 Thread Ted Yu (JIRA)
Ted Yu created FLINK-2708: - Summary: Potential null pointer dereference in JoinWithSolutionSetFirstDriver#run() Key: FLINK-2708 URL: https://issues.apache.org/jira/browse/FLINK-2708 Project: Flink I

[GitHub] flink pull request: Windows

2015-09-18 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1147 Windows Adds new dedicated implementations for grouped windows on aligned processing time (tumbling and sliding time windows). A lot of code is written to be easily adaptable to event-time impl

[jira] [Resolved] (FLINK-2707) Set state checkpointer before default state for PartitionedStreamOperatorState

2015-09-18 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2707. --- Resolution: Fixed Fixed + added a test case https://github.com/apache/flink/commit/3e233a3894a2701cc1

[jira] [Assigned] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems

2015-09-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2706: --- Assignee: Aljoscha Krettek > Add support for streaming RollingFileSink to truncate /

[jira] [Commented] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems

2015-09-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875948#comment-14875948 ] Aljoscha Krettek commented on FLINK-2706: - This should not be too hard. The Java F

[jira] [Commented] (FLINK-2576) Add outer joins to API and Optimizer

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875879#comment-14875879 ] ASF GitHub Bot commented on FLINK-2576: --- Github user jkovacs commented on the pull r

[GitHub] flink pull request: [FLINK-2576] Add Outer Join operator to Optimi...

2015-09-18 Thread jkovacs
Github user jkovacs commented on the pull request: https://github.com/apache/flink/pull/1138#issuecomment-141497981 Thanks @fhueske, that's a good point I haven't considered. Another idea that occurred to me was to convert the result tuple types to `GenericTypeInfo` (instead

[jira] [Assigned] (FLINK-2697) Deadlock in StreamDiscretizer

2015-09-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2697: --- Assignee: Aljoscha Krettek > Deadlock in StreamDiscretizer >

[jira] [Commented] (FLINK-2697) Deadlock in StreamDiscretizer

2015-09-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875857#comment-14875857 ] Aljoscha Krettek commented on FLINK-2697: - I've seen this before as well. But this

[jira] [Commented] (FLINK-2697) Deadlock in StreamDiscretizer

2015-09-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875858#comment-14875858 ] Aljoscha Krettek commented on FLINK-2697: - Should we keep the issue around until t

[jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case

2015-09-18 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875850#comment-14875850 ] Aljoscha Krettek commented on FLINK-2600: - But that's differente, isn't it? The ot

[jira] [Created] (FLINK-2707) Set state checkpointer before default state for PartitionedStreamOperatorState

2015-09-18 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-2707: - Summary: Set state checkpointer before default state for PartitionedStreamOperatorState Key: FLINK-2707 URL: https://issues.apache.org/jira/browse/FLINK-2707 Project: Flink

[jira] [Created] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems

2015-09-18 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2706: --- Summary: Add support for streaming RollingFileSink to truncate / append on UNIX file systems Key: FLINK-2706 URL: https://issues.apache.org/jira/browse/FLINK-2706 Proje

[jira] [Closed] (FLINK-2583) Add Stream Sink For Rolling HDFS Files

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2583. --- > Add Stream Sink For Rolling HDFS Files > -- > > Key:

[jira] [Commented] (FLINK-2643) Change Travis Build Profile to Exclude Hadoop 2.0.0-alpha, Include 2.7.0

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875753#comment-14875753 ] Stephan Ewen commented on FLINK-2643: - First version by [~aljoscha] merged in b234b0b1

[jira] [Resolved] (FLINK-2583) Add Stream Sink For Rolling HDFS Files

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2583. - Resolution: Fixed Done in 35dcceb9ebc3a8a47b8b8aeb2c4e1e2d453767f4 > Add Stream Sink For Rolling

[jira] [Commented] (FLINK-2685) TaskManager deadlock on NetworkBufferPool

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875748#comment-14875748 ] Stephan Ewen commented on FLINK-2685: - Thanks for posing this, Greg! We'll have a loo

[jira] [Commented] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

2015-09-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875740#comment-14875740 ] Till Rohrmann commented on FLINK-2671: -- The maven log does not really help to find ou

[jira] [Commented] (FLINK-2652) Failing PartitionRequestClientFactoryTest

2015-09-18 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875729#comment-14875729 ] Ufuk Celebi commented on FLINK-2652: Will look into it next week. But I didn't change

[jira] [Commented] (FLINK-2030) Implement discrete and continuous histograms

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875702#comment-14875702 ] ASF GitHub Bot commented on FLINK-2030: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2030][FLINK-2274][core][utils]Histogram...

2015-09-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/861#issuecomment-141471679 Rebased to reflect the changes in the scala utility functions. Travis failure on an unrelated error. Reported at jira id 2700. This has already undergon

[jira] [Commented] (FLINK-2643) Change Travis Build Profile to Exclude Hadoop 2.0.0-alpha, Include 2.7.0

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875696#comment-14875696 ] ASF GitHub Bot commented on FLINK-2643: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-2643] [build] Update Travis build matri...

2015-09-18 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1146#issuecomment-141470722 +1 to merge --- 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 e

[jira] [Commented] (FLINK-2652) Failing PartitionRequestClientFactoryTest

2015-09-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875691#comment-14875691 ] Till Rohrmann commented on FLINK-2652: -- I couldn't reproduce the problem locally. [~u

[jira] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875680#comment-14875680 ] ASF GitHub Bot commented on FLINK-2616: --- Github user tillrohrmann commented on the p

[jira] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875681#comment-14875681 ] ASF GitHub Bot commented on FLINK-2616: --- Github user tillrohrmann closed the pull re

[GitHub] flink pull request: [FLINK-2616] [test-stability] Hardens ZooKeepe...

2015-09-18 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/1143 --- 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 i

[GitHub] flink pull request: [FLINK-2616] [test-stability] Hardens ZooKeepe...

2015-09-18 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1143#issuecomment-141465883 Hmm, it does not seem to solve the problem. I will further investigate the problem and reopen a PR which will hopefully fix it. --- If your project is set up for i

[jira] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

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

[GitHub] flink pull request: [FLINK-2616] [test-stability] Hardens ZooKeepe...

2015-09-18 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1143#issuecomment-141462318 Changes look good. Good debug messages as well :) --- 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 pro

[jira] [Commented] (FLINK-2643) Change Travis Build Profile to Exclude Hadoop 2.0.0-alpha, Include 2.7.0

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875669#comment-14875669 ] ASF GitHub Bot commented on FLINK-2643: --- GitHub user StephanEwen opened a pull reque

[GitHub] flink pull request: [FLINK-2643] [build] Update Travis build matri...

2015-09-18 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1146 [FLINK-2643] [build] Update Travis build matrix and change snapshot deploy profiles Changes Travis build profiles to test the following Hadoop versions: - 1.0 - 2.3 - 2.4

[jira] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

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

[GitHub] flink pull request: [FLINK-2616] [test-stability] Hardens ZooKeepe...

2015-09-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1143#issuecomment-141461360 Let's merge this and see if it fixes the problem... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875663#comment-14875663 ] ASF GitHub Bot commented on FLINK-2488: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c...

2015-09-18 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1026#issuecomment-141461094 Is it possible to get this in soon? I need access to the task manager configuration for something I'm working on. @StephanEwen --- If your project is set up for

[jira] [Commented] (FLINK-2696) ZookeeperOffsetHandlerTest.runOffsetManipulationinZooKeeperTest failed on Travis

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

[GitHub] flink pull request: [FLINK-2696] [test-stability] Hardens Zookeepe...

2015-09-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1144#issuecomment-141460904 +1 to merge --- 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 featur

[jira] [Commented] (FLINK-2583) Add Stream Sink For Rolling HDFS Files

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

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875654#comment-14875654 ] ASF GitHub Bot commented on FLINK-1789: --- Github user aalexandrov commented on the pu

[GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow...

2015-09-18 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/593#issuecomment-141459804 @rmetzger the final 10.0, this and the Scala 2.11 compatibility are the two pending issues that make the current Emma master incompatible with vanilla Flink. --- If

[GitHub] flink pull request: [FLINK-2583] Add Stream Sink For Rolling HDFS ...

2015-09-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1084 --- 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-2694) JobManagerProcessReapingTest.testReapProcessOnFailure failed on Travis

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875644#comment-14875644 ] ASF GitHub Bot commented on FLINK-2694: --- GitHub user tillrohrmann opened a pull requ

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875643#comment-14875643 ] ASF GitHub Bot commented on FLINK-1789: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-2694] [test-stability] Hardens the JobM...

2015-09-18 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1145 [FLINK-2694] [test-stability] Hardens the JobManagerProcessReapingTest.testReapProcessOnFailure test case The `JobManagerProcessReapingTest.testReapProcessOnFailure` predetermines the port for

[GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow...

2015-09-18 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/593#issuecomment-141457169 Do you mean the 0.10-milestone-1 release? or the final 0.10 release? Fabian is managing the 0.10-milestone-1 release, as far as I know he has not started with th

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14875637#comment-14875637 ] ASF GitHub Bot commented on FLINK-1789: --- Github user aalexandrov commented on the pu

[GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow...

2015-09-18 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/593#issuecomment-141455406 @twalthr @rmetzger is there a chance to include this PR in the 10.0 release? --- If your project is set up for it, you can reply to this email and have your reply app

[jira] [Created] (FLINK-2705) Yarn fails with NoSuchMethodError when log level is set to DEBUG

2015-09-18 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2705: Summary: Yarn fails with NoSuchMethodError when log level is set to DEBUG Key: FLINK-2705 URL: https://issues.apache.org/jira/browse/FLINK-2705 Project: Flink

[GitHub] flink pull request: [FLINK-2696] [test-stability] Hardens Zookeepe...

2015-09-18 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1144#issuecomment-141443252 +1 to merge --- 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 e

[jira] [Commented] (FLINK-2696) ZookeeperOffsetHandlerTest.runOffsetManipulationinZooKeeperTest failed on Travis

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14852725#comment-14852725 ] ASF GitHub Bot commented on FLINK-2696: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-2696) ZookeeperOffsetHandlerTest.runOffsetManipulationinZooKeeperTest failed on Travis

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14848542#comment-14848542 ] ASF GitHub Bot commented on FLINK-2696: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request: [FLINK-2696] [test-stability] Hardens Zookeepe...

2015-09-18 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1144 [FLINK-2696] [test-stability] Hardens ZookeeperOffsetHandlerTest.runOffsetManipulationinZooKeeperTest The test case `ZookeeperOffsetHandlerTest.runOffsetManipulationinZooKeeperTest` failed, b

[jira] [Resolved] (FLINK-2701) Getter for wrapped Java StreamExecutionEnvironment in the Scala Api

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2701. - Resolution: Fixed Fixed in 6dcc38d532e68a08b0ba04d0d58f652e4140a68c Thank you for the contributio

[jira] [Commented] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously

2015-09-18 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14847317#comment-14847317 ] Till Rohrmann commented on FLINK-1831: -- The posted log is not really helpful in track

[jira] [Resolved] (FLINK-2627) Make Scala Data Set utils easier to access

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2627. - Resolution: Fixed Fix Version/s: 0.10 Fixed in 0c5ebc8b9361e48c32425f1235a86e5e1bf34976 Th

[jira] [Closed] (FLINK-2702) Add an implementation of distributed copying utility using Flink

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2702. --- > Add an implementation of distributed copying utility using Flink > -

[jira] [Closed] (FLINK-2627) Make Scala Data Set utils easier to access

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2627. --- > Make Scala Data Set utils easier to access > -- > >

[jira] [Resolved] (FLINK-2698) Add trailing newline to flink-conf.yaml

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2698. - Resolution: Fixed Fix Version/s: 0.10 Fixed via db49a3f097e1c1b9f87f5ec0dfba23d9a5faab1a T

[jira] [Resolved] (FLINK-2702) Add an implementation of distributed copying utility using Flink

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2702. - Resolution: Fixed Added in b9148b667d24d4d30a0fd877848c1178e4be647a > Add an implementation of di

[jira] [Resolved] (FLINK-2557) Manual type information via "returns" fails in DataSet API

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2557. - Resolution: Fixed Fix Version/s: 0.10 Fixed in 3fe9145df37fd353229d1de297cc134f3a553c07 Th

[jira] [Resolved] (FLINK-2704) Clean up naming of State/Checkpoint Interfaces

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2704. - Resolution: Fixed Merged in 0571094885da2766dfb52a6fb38020cab7602114 > Clean up naming of State/C

[jira] [Closed] (FLINK-2704) Clean up naming of State/Checkpoint Interfaces

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2704. --- > Clean up naming of State/Checkpoint Interfaces > -- > >

[GitHub] flink pull request: Clean up naming of State/Checkpoint Interfaces

2015-09-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/671 --- 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 enabl

[jira] [Commented] (FLINK-2698) Add trailing newline to flink-conf.yaml

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

[GitHub] flink pull request: Getter for wrapped StreamExecutionEnvironment ...

2015-09-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1120 --- 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] [Closed] (FLINK-2557) Manual type information via "returns" fails in DataSet API

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2557. --- > Manual type information via "returns" fails in DataSet API > ---

[jira] [Closed] (FLINK-2698) Add trailing newline to flink-conf.yaml

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2698. --- > Add trailing newline to flink-conf.yaml > --- > > Ke

[jira] [Closed] (FLINK-2701) Getter for wrapped Java StreamExecutionEnvironment in the Scala Api

2015-09-18 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2701. --- > Getter for wrapped Java StreamExecutionEnvironment in the Scala Api > --

[GitHub] flink pull request: [FLINK-2698] Add trailing newline to flink-con...

2015-09-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1142 --- 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-2627) Make Scala Data Set utils easier to access

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

[GitHub] flink pull request: [FLINK-2627][utils]Make Scala Data Set utils e...

2015-09-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1099 --- 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-2557) Manual type information via "returns" fails in DataSet API

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

[GitHub] flink pull request: Implementation of distributed copying utility ...

2015-09-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1090 --- 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-2557] TypeExtractor properly returns Mi...

2015-09-18 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1045 --- 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-2200) Flink API with Scala 2.11 - Maven Repository

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14847296#comment-14847296 ] ASF GitHub Bot commented on FLINK-2200: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

2015-09-18 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/885#issuecomment-141425832 Sure, I don't have time over the weekend to work on this anyways ;) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave...

2015-09-18 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/885#issuecomment-141416793 I hope to create a shell script and make setting for deploying `_2.11_ artifact. Could you wait a while to update this? Maybe I can update this PR until this weekend.

[jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14824511#comment-14824511 ] ASF GitHub Bot commented on FLINK-2200: --- Github user chiwanpark commented on the pul

[jira] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14818819#comment-14818819 ] ASF GitHub Bot commented on FLINK-2616: --- Github user tillrohrmann commented on the p

[GitHub] flink pull request: [FLINK-2616] [test-stability] Hardens ZooKeepe...

2015-09-18 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1143#issuecomment-141416101 I really tried hard to reproduce the failing test case `ZooKeeperLeaderElectionTest.testMultipleLeaders` but it was really hard. I think the test case fails because

[jira] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14810734#comment-14810734 ] ASF GitHub Bot commented on FLINK-2616: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request: [FLINK-2616] [test-stability] Hardens ZooKeepe...

2015-09-18 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1143 [FLINK-2616] [test-stability] Hardens ZooKeeperLeaderElectionTest Replaces Curator's TestingCluster with TestingServer in ZooKeeperElection/RetrievalTests. This should be more lightweight. Incr

[GitHub] flink pull request: Clean up naming of State/Checkpoint Interfaces

2015-09-18 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/671#issuecomment-141413305 ok, I'm merging it --- 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 fea

[GitHub] flink pull request: [FLINK-2583] Add Stream Sink For Rolling HDFS ...

2015-09-18 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1084#issuecomment-141411612 Looks good, will 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

[jira] [Commented] (FLINK-2583) Add Stream Sink For Rolling HDFS Files

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

[jira] [Created] (FLINK-2704) Clean up naming of State/Checkpoint Interfaces

2015-09-18 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2704: --- Summary: Clean up naming of State/Checkpoint Interfaces Key: FLINK-2704 URL: https://issues.apache.org/jira/browse/FLINK-2704 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback

2015-09-18 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2703: - Summary: Remove log4j classes from fat jar / document how to use Flink with logback Key: FLINK-2703 URL: https://issues.apache.org/jira/browse/FLINK-2703 Project: F

[jira] [Created] (FLINK-2702) Add an implementation of distributed copying utility using Flink

2015-09-18 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2702: --- Summary: Add an implementation of distributed copying utility using Flink Key: FLINK-2702 URL: https://issues.apache.org/jira/browse/FLINK-2702 Project: Flink

[jira] [Commented] (FLINK-2312) Random Splits

2015-09-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14805323#comment-14805323 ] ASF GitHub Bot commented on FLINK-2312: --- Github user sachingoel0101 closed the pull

  1   2   >