[jira] [Commented] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming

2015-03-19 Thread Wepngong Ngeh Benaiah (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14370682#comment-14370682 ] Wepngong Ngeh Benaiah commented on FLINK-1617: -- hello Gyula Fora, hello , I h

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14370510#comment-14370510 ] Henry Saputra commented on FLINK-1754: -- Thanks [~fhueske]! > Deadlock in job executi

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14370509#comment-14370509 ] Henry Saputra commented on FLINK-1754: -- Ufff, yeah, like [~rmetzger] have said, looks

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

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

[GitHub] flink pull request: FLINK-1740

2015-03-19 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/501#issuecomment-83774008 @StephanEwen @uce I definitely agree, thanks for the feedback! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] flink pull request: Make Expression API available to Java, Rename ...

2015-03-19 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/503#issuecomment-83760047 We had a discussion on the dev mailing list regarding the name of the API which was leaning a bit towards Table API / DataTable, but I don't think we had a consensus there

[jira] [Commented] (FLINK-1752) Add test to Kafka streaming connector

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

[GitHub] flink pull request: [FLINK-1752] Improvements to Kafka Source/Sink...

2015-03-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/500 --- 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] [Resolved] (FLINK-1752) Add test to Kafka streaming connector

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1752. --- Resolution: Fixed Fix Version/s: 0.9 Fixed in http://git-wip-us.apache.org/repos/asf/fl

[GitHub] flink pull request: Make Expression API available to Java, Rename ...

2015-03-19 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/503 Make Expression API available to Java, Rename it to Table API This also adds tests and more Javadoc documentation for the Table API. You can merge this pull request into a Git repository by running:

[jira] [Resolved] (FLINK-1342) Quickstart's assembly can possibly filter out user's code

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1342. --- Resolution: Fixed Fix Version/s: (was: 0.8.2) > Quickstart's assembly can possibly

[jira] [Commented] (FLINK-1755) NullPointerException in LocalInputChannel.getNextLookAhead()

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369968#comment-14369968 ] Robert Metzger commented on FLINK-1755: --- I restarted the travis job and the issue di

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369956#comment-14369956 ] Fabian Hueske commented on FLINK-1754: -- [~hsaputra] Should be the same as FLINK-1343

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369928#comment-14369928 ] Henry Saputra commented on FLINK-1754: -- [~rmetzger], is there a JIRA filed for the fi

[jira] [Created] (FLINK-1755) NullPointerException in LocalInputChannel.getNextLookAhead()

2015-03-19 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1755: - Summary: NullPointerException in LocalInputChannel.getNextLookAhead() Key: FLINK-1755 URL: https://issues.apache.org/jira/browse/FLINK-1755 Project: Flink

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369833#comment-14369833 ] Robert Metzger commented on FLINK-1754: --- Ah, thank you for updating the JIRA. The i

[jira] [Comment Edited] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369833#comment-14369833 ] Robert Metzger edited comment on FLINK-1754 at 3/19/15 6:09 PM:

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Sebastian Kruse (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369819#comment-14369819 ] Sebastian Kruse commented on FLINK-1754: It is the 0.8.1 version. I also just want

[jira] [Updated] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Sebastian Kruse (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebastian Kruse updated FLINK-1754: --- Affects Version/s: 0.8.1 > Deadlock in job execution > - > >

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369818#comment-14369818 ] Robert Metzger commented on FLINK-1754: --- Thank you for reporting the issue. Which v

[jira] [Commented] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Sebastian Kruse (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369815#comment-14369815 ] Sebastian Kruse commented on FLINK-1754: Here is a thread dump. If you need any fu

[jira] [Created] (FLINK-1754) Deadlock in job execution

2015-03-19 Thread Sebastian Kruse (JIRA)
Sebastian Kruse created FLINK-1754: -- Summary: Deadlock in job execution Key: FLINK-1754 URL: https://issues.apache.org/jira/browse/FLINK-1754 Project: Flink Issue Type: Bug Repor

[jira] [Commented] (FLINK-1752) Add test to Kafka streaming connector

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

[GitHub] flink pull request: [FLINK-1752] Improvements to Kafka Source/Sink...

2015-03-19 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/500#issuecomment-83692070 We're addressed all comments on the pull request. I'm currently running some tests: https://travis-ci.org/rmetzger/flink/builds/55061414. I'll merge the chang

[jira] [Closed] (FLINK-1708) KafkaSink not working from Usercode classloader

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1708. - Resolution: Invalid I was working on a broken pull request --> closed as invalid. > KafkaSink not

[jira] [Updated] (FLINK-1753) Add more tests for Kafka Connectors

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1753: -- Description: The current {{KafkaITCase}} is only doing a single test. We need to refactor that

[jira] [Commented] (FLINK-1752) Add test to Kafka streaming connector

2015-03-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369773#comment-14369773 ] ASF GitHub Bot commented on FLINK-1752: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1752] Improvements to Kafka Source/Sink...

2015-03-19 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/500#discussion_r26778761 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/pom.xml --- @@ -46,9 +53,13 @@ under the License.

[jira] [Commented] (FLINK-441) Renaming in pact-compiler

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

[jira] [Commented] (FLINK-441) Renaming in pact-compiler

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

[GitHub] flink pull request: [FLINK-441] Rename Pact* and Nephele* classes ...

2015-03-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/492#issuecomment-83669510 After correcting the commit message ;-) --- 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

[GitHub] flink pull request: [FLINK-441] Rename Pact* and Nephele* classes ...

2015-03-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/492#issuecomment-83669339 Good, then I'll try and merge this today... --- 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

[GitHub] flink pull request: Fix issue where Windows paths were not recogni...

2015-03-19 Thread balidani
Github user balidani commented on the pull request: https://github.com/apache/flink/pull/491#issuecomment-83666214 I doubt that paths like `/C:/...` are valid on Windows. I guess Path should be changed then? How can we tell whether a path comes from Windows or not? The Travis

[jira] [Resolved] (FLINK-1709) Add support for programs with slot count exceeding parallelism

2015-03-19 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1709. Resolution: Fixed Fixed in 5c6603e. > Add support for programs with slot count exceeding parallelis

[jira] [Commented] (FLINK-1724) TestingCluster uses local communication with multiple task managers

2015-03-19 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369699#comment-14369699 ] Ufuk Celebi commented on FLINK-1724: I'll leave the issue open, but the fix has been i

[jira] [Commented] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check.

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

[GitHub] flink pull request: [FLINK-1739]Fix the bug of JobManager and Task...

2015-03-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/499#issuecomment-83660699 Merged. Thank you for the patch! --- 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] [Resolved] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check.

2015-03-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1739. - Resolution: Fixed Fixed via 0a3ef15bd584ae3706f1f1bbf3ae52530d34e92d Thank you for the patch! >

[jira] [Commented] (FLINK-1709) Add support for programs with slot count exceeding parallelism

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

[jira] [Resolved] (FLINK-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc

2015-03-19 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1720. - Resolution: Fixed Fixed via ce39c190a2befa837fd03436a8420d40edf8d713 > Integrate ScalaDoc in Scal

[GitHub] flink pull request: [FLINK-1709] [wip] Add SlotCountExceedingParal...

2015-03-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/498 --- 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-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc

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

[jira] [Commented] (FLINK-1739) Fix the bug of JobManager and TaskManager Port Check.

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

[GitHub] flink pull request: Add final modifier to PollingThread#lock objec...

2015-03-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/494 --- 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

[GitHub] flink pull request: [FLINK-1720] Integrate ScalaDoc into JavaDoc

2015-03-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/497 --- 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

[GitHub] flink pull request: [FLINK-1739]Fix the bug of JobManager and Task...

2015-03-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/499 --- 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-1709) Add support for programs with slot count exceeding parallelism

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

[GitHub] flink pull request: [FLINK-1709] [wip] Add SlotCountExceedingParal...

2015-03-19 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/498#issuecomment-83657553 Will squash and 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 fe

[jira] [Commented] (FLINK-441) Renaming in pact-compiler

2015-03-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14369664#comment-14369664 ] ASF GitHub Bot commented on FLINK-441: -- Github user hsaputra commented on the pull req

[GitHub] flink pull request: [FLINK-441] Rename Pact* and Nephele* classes ...

2015-03-19 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/492#issuecomment-83655940 +1 SHIP 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 feature enab

[jira] [Commented] (FLINK-441) Renaming in pact-compiler

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

[GitHub] flink pull request: [FLINK-441] Rename Pact* and Nephele* classes ...

2015-03-19 Thread matadorhong
Github user matadorhong commented on the pull request: https://github.com/apache/flink/pull/492#issuecomment-83649446 As in your comment in this PR, I think you make a small spelling mistake "Renames the package org.apache.flink.compiler to org.apache.fink.optimizer", which should be

[GitHub] flink pull request: Remove redundant codes which never been execut...

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

[jira] [Resolved] (FLINK-1751) Update CLI documentation page

2015-03-19 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-1751. --- Resolution: Fixed Updated in the master documentation with 6e38eb84102e421a4b27eacfa0

[jira] [Updated] (FLINK-1753) Add more tests for Kafka Connectors

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1753: -- Description: The current {{KafkaITCase}} is only doing a single test. We need to refactor that

[jira] [Created] (FLINK-1753) Add more tests for Kafka Connectors

2015-03-19 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1753: - Summary: Add more tests for Kafka Connectors Key: FLINK-1753 URL: https://issues.apache.org/jira/browse/FLINK-1753 Project: Flink Issue Type: Improvement

[GitHub] flink pull request: Improvements to Kafka Source/Sink & some bugfi...

2015-03-19 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/500#discussion_r26762000 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/pom.xml --- @@ -46,9 +53,13 @@ under the License.

[jira] [Created] (FLINK-1752) Add test to Kafka streaming connector

2015-03-19 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-1752: - Summary: Add test to Kafka streaming connector Key: FLINK-1752 URL: https://issues.apache.org/jira/browse/FLINK-1752 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-1751) Update CLI documentation page

2015-03-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1751: -- Priority: Major (was: Trivial) > Update CLI documentation page > -

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-19 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-83614068 > If I understand correctly, this does not affect the default mode of building against Scala 2.10 Correct. It just adds a profile that (optionally) builds with

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-19 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-83613932 > Can we "retrofit" some of the other builds to use Scala 2.11 ? I guess @rmetzger should answer this. --- If your project is set up for it, you can reply to this

[GitHub] flink pull request: Improvements to Kafka Source/Sink & some bugfi...

2015-03-19 Thread gaborhermann
Github user gaborhermann commented on a diff in the pull request: https://github.com/apache/flink/pull/500#discussion_r26760037 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java --- @@ -0,0

[jira] [Created] (FLINK-1751) Update CLI documentation page

2015-03-19 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-1751: - Summary: Update CLI documentation page Key: FLINK-1751 URL: https://issues.apache.org/jira/browse/FLINK-1751 Project: Flink Issue Type: Bug

[GitHub] flink pull request: Improvements to Kafka Source/Sink & some bugfi...

2015-03-19 Thread gaborhermann
Github user gaborhermann commented on a diff in the pull request: https://github.com/apache/flink/pull/500#discussion_r26758570 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/simple/SimpleKafkaSource.java

[GitHub] flink pull request: Improvements to Kafka Source/Sink & some bugfi...

2015-03-19 Thread gaborhermann
Github user gaborhermann commented on a diff in the pull request: https://github.com/apache/flink/pull/500#discussion_r26758463 --- Diff: flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/simple/iterator/KafkaOneParti

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-83603852 One thing, though: The travis build matrix contains now 7 entries. We decided to keep it at 5 entries, because that is how many build travis does concurrently.

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-83601122 If I understand correctly, this does not affect the default mode of building against Scala 2.10 In that case I see no reason not to merge this... --- If your

[jira] [Created] (FLINK-1750) Add canonical correlation analysis (CCA) to machine learning library

2015-03-19 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1750: Summary: Add canonical correlation analysis (CCA) to machine learning library Key: FLINK-1750 URL: https://issues.apache.org/jira/browse/FLINK-1750 Project: Flink

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-19 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-83521096 Rebased against the current master (798e59523f0599096a214c24045a8f011b53ddbc). Can we please proceed with merging? The POMs are changing on a daily basis, an

[jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets

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

[GitHub] flink pull request: [FLINK-1615] [java api] SimpleTweetInputFormat

2015-03-19 Thread Elbehery
Github user Elbehery commented on the pull request: https://github.com/apache/flink/pull/442#issuecomment-83519001 @StephanEwen, I have removed the license from the resource file, excluded it from RAT, and added the license file. Also I did rebase against upstream/master, before commi

[jira] [Created] (FLINK-1749) Add Boosting algorithm for ensemble learning to machine learning library

2015-03-19 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1749: Summary: Add Boosting algorithm for ensemble learning to machine learning library Key: FLINK-1749 URL: https://issues.apache.org/jira/browse/FLINK-1749 Project: Flink

[jira] [Updated] (FLINK-1723) Add cross validation for parameter selection and validation

2015-03-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1723: - Description: Cross validation [1] is a standard tool to select proper parameters for you model an

[jira] [Updated] (FLINK-1728) Add random forest ensemble method to machine learning library

2015-03-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1728: - Description: Random forests [2,3] are a well-established mean to mitigate the decision trees' wea

[jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets

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

[GitHub] flink pull request: [FLINK-1615] [java api] SimpleTweetInputFormat

2015-03-19 Thread Elbehery
Github user Elbehery commented on the pull request: https://github.com/apache/flink/pull/442#issuecomment-83499608 @StephanEwen I have checked and I found that the RAT plugin is included in parent pom.xml file. Shall I exclude the resources folder in flink-contribute, or add the plug

[jira] [Created] (FLINK-1748) Integrate PageRank implementation into machine learning library

2015-03-19 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1748: Summary: Integrate PageRank implementation into machine learning library Key: FLINK-1748 URL: https://issues.apache.org/jira/browse/FLINK-1748 Project: Flink

[jira] [Resolved] (FLINK-1332) Possible deadlock with two broadcast sets

2015-03-19 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1332. Resolution: Fixed Fix Version/s: 0.9 Fixed in 9d7acf3, 9c77f07. > Possible deadlock with two

[jira] [Resolved] (FLINK-1359) Make IntermediateResultPartitionManager aware of consumed partitions

2015-03-19 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1359. Resolution: Fixed Fix Version/s: 0.9 Fixed in 9d7acf3, 9c77f07. > Make IntermediateResultPar

[jira] [Resolved] (FLINK-1141) Selfjoin fails after DataSet exceeds certain size

2015-03-19 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1141. Resolution: Fixed Fix Version/s: 0.9 Fixed in 9d7acf3, 9c77f07. Added a test case based on y

[jira] [Resolved] (FLINK-1343) Branching Join Program Deadlocks

2015-03-19 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1343. Resolution: Fixed Fix Version/s: 0.9 Fixed in 9d7acf3, 9c77f07. > Branching Join Program Dea

[jira] [Created] (FLINK-1747) Remove deadlock detection and pipeline breaker placement in optimizer

2015-03-19 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1747: -- Summary: Remove deadlock detection and pipeline breaker placement in optimizer Key: FLINK-1747 URL: https://issues.apache.org/jira/browse/FLINK-1747 Project: Flink

[jira] [Created] (FLINK-1746) Add linear discriminant analysis to machine learning library

2015-03-19 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1746: Summary: Add linear discriminant analysis to machine learning library Key: FLINK-1746 URL: https://issues.apache.org/jira/browse/FLINK-1746 Project: Flink I

[jira] [Updated] (FLINK-1746) Add linear discriminant analysis to machine learning library

2015-03-19 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1746: - Labels: ML (was: ) > Add linear discriminant analysis to machine learning library > -

[GitHub] flink pull request: Improvements to Kafka Source/Sink & some bugfi...

2015-03-19 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/500#discussion_r26742487 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -182,7 +182,6 @@ protected void fillInType(TypeInformation typeInfo) {

[jira] [Resolved] (FLINK-1350) Add blocking intermediate result partitions

2015-03-19 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1350. Resolution: Implemented Fix Version/s: 0.9 Implemented in 9d7acf3. > Add blocking intermedia

[GitHub] flink pull request: [FLINK-1709] [wip] Add SlotCountExceedingParal...

2015-03-19 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/498#issuecomment-83493468 Changed the test accordingly and rebased. Can we 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

[jira] [Commented] (FLINK-1709) Add support for programs with slot count exceeding parallelism

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

[jira] [Commented] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

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

[GitHub] flink pull request: Add support for building Flink with Scala 2.11

2015-03-19 Thread aalexandrov
Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/477#issuecomment-83491250 One more thing. If we agree to add suffixes and ship multi-build artifacts, and we are going to restructure the maven projects anyway, why not add suffixes to both set

[GitHub] flink pull request: FLINK-1740

2015-03-19 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/501#issuecomment-83491306 Just a minor thing: I vote that PR titles should include some text about what the PR is about, for example like the first commit msg. That way it is easier to figure out what

[jira] [Created] (FLINK-1745) Add k-nearest-neighbours algorithm to machine learning library

2015-03-19 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1745: Summary: Add k-nearest-neighbours algorithm to machine learning library Key: FLINK-1745 URL: https://issues.apache.org/jira/browse/FLINK-1745 Project: Flink

[jira] [Commented] (FLINK-441) Renaming in pact-compiler

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

[GitHub] flink pull request: [FLINK-441] Rename Pact* and Nephele* classes ...

2015-03-19 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/492#issuecomment-83469816 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 an

[jira] [Commented] (FLINK-441) Renaming in pact-compiler

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

[GitHub] flink pull request: [FLINK-441] Rename Pact* and Nephele* classes ...

2015-03-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/492#issuecomment-83463402 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 do

[GitHub] flink pull request: [FLINK-1720] Integrate ScalaDoc into JavaDoc

2015-03-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/497#issuecomment-83456516 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-1720) Integrate ScalaDoc in Scala sources into overall JavaDoc

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

[jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets

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

[GitHub] flink pull request: [FLINK-1615] [java api] SimpleTweetInputFormat

2015-03-19 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/442#issuecomment-83455819 Your own tests fail for this code. Probably because they get thrown off by the comment in the sample JSON file. A way to make this work is to exclude this file

  1   2   >