[jira] [Commented] (FLINK-2072) Add a quickstart guide for FlinkML

2015-05-21 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14555474#comment-14555474 ] Chiwan Park commented on FLINK-2072: +1 for this :) > Add a quickstart guide for Flin

[jira] [Updated] (FLINK-2051) Fix disabled test in ComplexIntegrationTest

2015-05-21 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2051: -- Assignee: Péter Szabó > Fix disabled test in ComplexIntegrationTest > --

[jira] [Updated] (FLINK-2051) Fix disabled test in ComplexIntegrationTest

2015-05-21 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2051: -- Assignee: Péter Szabó (was: Márton Balassi) > Fix disabled test in ComplexIntegrationTest > ---

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-05-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14555243#comment-14555243 ] Fabian Hueske commented on FLINK-1848: -- [~Laurent Tardif] I prepared a PR to fix the

[jira] [Created] (FLINK-2077) Rework Path class and add extend support for Windows paths

2015-05-21 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2077: Summary: Rework Path class and add extend support for Windows paths Key: FLINK-2077 URL: https://issues.apache.org/jira/browse/FLINK-2077 Project: Flink Issu

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

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

[GitHub] flink pull request: [FLINK-1848] Fix for file paths with Windows d...

2015-05-21 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/712 [FLINK-1848] Fix for file paths with Windows drive letters Paths with Windows drive letters can be used to specify `FileDataSource` and `FileDataSink` tasks. I verified the fix on a Windows box.

[jira] [Commented] (FLINK-2043) Change the KMeansDataGenerator to allow passing a custom path

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554916#comment-14554916 ] Stephan Ewen commented on FLINK-2043: - Sounds good, welcome to Flink! I added you to

[jira] [Updated] (FLINK-2043) Change the KMeansDataGenerator to allow passing a custom path

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-2043: Assignee: pietro pinoli > Change the KMeansDataGenerator to allow passing a custom path > --

[jira] [Closed] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1985. --- > Streaming does not correctly forward ExecutionConfig to runtime > --

[jira] [Resolved] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1985. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 495a5c3c47af7f09d80b6e534cbfe339f004e26d Th

[jira] [Commented] (FLINK-2043) Change the KMeansDataGenerator to allow passing a custom path

2015-05-21 Thread pietro pinoli (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554898#comment-14554898 ] pietro pinoli commented on FLINK-2043: -- I would like to take care of it, so as to get

[jira] [Resolved] (FLINK-2052) Clear up Serializable warnings in streaming operators

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2052. - Resolution: Fixed Fix Version/s: 0.9 Fixed via 8b904ae21d319c6cd26d160f7c5cc91b5f081577 >

[GitHub] flink pull request: [FLINK-2052] Fix Serialization warnings in Str...

2015-05-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/698 --- 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-1985] Streaming does not correctly forw...

2015-05-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/682 --- 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] [Closed] (FLINK-2052) Clear up Serializable warnings in streaming operators

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2052. --- > Clear up Serializable warnings in streaming operators >

[GitHub] flink pull request: Some fixes for Scala type analysis

2015-05-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/669 --- 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-2052) Clear up Serializable warnings in streaming operators

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

[jira] [Created] (FLINK-2076) Bug in re-openable hash join

2015-05-21 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2076: --- Summary: Bug in re-openable hash join Key: FLINK-2076 URL: https://issues.apache.org/jira/browse/FLINK-2076 Project: Flink Issue Type: Bug Components

[jira] [Commented] (FLINK-2030) Implement an online histogram with Merging and equalization features

2015-05-21 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554720#comment-14554720 ] Sachin Goel commented on FLINK-2030: As of now, I have worked on the implementation gi

[GitHub] flink pull request: Change FlinkMiniCluster#HOSTNAME to FlinkMiniC...

2015-05-21 Thread hsaputra
GitHub user hsaputra opened a pull request: https://github.com/apache/flink/pull/711 Change FlinkMiniCluster#HOSTNAME to FlinkMiniCluster#hostname to match naming convention. The FlinkMiniCluster contain member variable called HOSTNAME which all caps. The naming of al caps usually

[GitHub] flink pull request: Some fixes for Scala type analysis

2015-05-21 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/669#issuecomment-104354647 Thanks :) --- 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

[GitHub] flink pull request: Decision tree [Flink-1727]

2015-05-21 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/710 Decision tree [Flink-1727] This implements a part of the Decision Tree Algorithm. As of now, only continuous valued fields are implemented. Also, Gini index based splitting only. Entropy to b

[GitHub] flink pull request: Decision tree [Flink-1727]

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

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

2015-05-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554643#comment-14554643 ] ASF GitHub Bot commented on FLINK-1954: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-21 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/705#discussion_r30821561 --- Diff: flink-tests/src/test/java/org/apache/flink/test/exampleJavaPrograms/WordCountITCase.java --- @@ -27,7 +27,6 @@ protected String textPath;

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-21 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/705#discussion_r30821430 --- Diff: flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java --- @@ -30,20 +30,20 @@ import org.junit.Test; publi

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

2015-05-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554639#comment-14554639 ] ASF GitHub Bot commented on FLINK-1954: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-21 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/705#discussion_r30821256 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -148,6 +148,16 @@ public static final String TASK_MANAGER_NET

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

2015-05-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554636#comment-14554636 ] ASF GitHub Bot commented on FLINK-1954: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-2052] Fix Serialization warnings in Str...

2015-05-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/698#issuecomment-104346370 +1, will merge this BTW: It is always a good idea to make fields final that are constant. Gets you additional compiler checks and (in some corner cases better

[jira] [Commented] (FLINK-2052) Clear up Serializable warnings in streaming operators

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

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/682#issuecomment-104344423 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 have this

[GitHub] flink pull request: Some fixes for Scala type analysis

2015-05-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/669#issuecomment-104342103 Looks reasonable. Will merge this with the next batch... --- If your project is set up for it, you can reply to this email and have your reply appear on GitH

[GitHub] flink pull request: [YARN] Cut off 25% of the heap as a safety mar...

2015-05-21 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/709 [YARN] Cut off 25% of the heap as a safety margin Users were reporting issues with Flink on YARN because the NodeManager was killing containers due to resource overuse. When a user requests

[jira] [Commented] (FLINK-2037) Unable to start Python API using ./bin/pyflink*.sh

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

[GitHub] flink pull request: [FLINK-2037] Provide flink-python.jar in lib/

2015-05-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/691#issuecomment-104338801 Okay, python should definitely work in the release, so let's go for the short term fix first. --- If your project is set up for it, you can reply to this email and h

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

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

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/705#issuecomment-104335429 I think this looks good. +1 to get it in fast and give it a bit of exposure before the release. --- If your project is set up for it, you can reply to this e

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

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

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-21 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/705#discussion_r30817964 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -148,6 +148,16 @@ public static final String TASK_MAN

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

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

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-21 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/705#discussion_r30817054 --- Diff: flink-tests/src/test/java/org/apache/flink/test/exampleJavaPrograms/WordCountITCase.java --- @@ -27,7 +27,6 @@ protected String textPath

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

2015-05-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554572#comment-14554572 ] ASF GitHub Bot commented on FLINK-1954: --- Github user uce commented on a diff in the

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-21 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/705#discussion_r30817476 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -148,6 +148,16 @@ public static final String TASK_MANAGER_NET

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

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

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-21 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/705#discussion_r30817061 --- Diff: flink-tests/src/test/java/org/apache/flink/test/classloading/ClassLoaderITCase.java --- @@ -30,20 +30,20 @@ import org.junit.Test;

[jira] [Commented] (FLINK-1954) Task Failures and Error Handling

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

[GitHub] flink pull request: [FLINK-1954] [FLINK-1636] [runtime] Improve pa...

2015-05-21 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/705#discussion_r30816631 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -148,6 +148,16 @@ public static final String TASK_MAN

[jira] [Created] (FLINK-2075) Shade akka and protobuf dependencies away

2015-05-21 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-2075: Summary: Shade akka and protobuf dependencies away Key: FLINK-2075 URL: https://issues.apache.org/jira/browse/FLINK-2075 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file

2015-05-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2069: Priority: Blocker (was: Major) > writeAsCSV function in DataStream Scala API creates no fil

[jira] [Updated] (FLINK-2073) Add contribution guide for FlinkML

2015-05-21 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-2073: --- Description: We need a guide for contributions to FlinkML in order to encourage the e

[GitHub] flink pull request: Decision tree [Flink-1727]

2015-05-21 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/708 Decision tree [Flink-1727] This implements a part of the Decision Tree Algorithm. As of now, only continuous valued fields are implemented. Also, Gini index based splitting only. Entropy to b

[jira] [Updated] (FLINK-1994) Add different gain calculation schemes to SGD

2015-05-21 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-1994: --- Labels: ML Starter (was: ML) > Add different gain calculation schemes to SGD > --

[jira] [Updated] (FLINK-1844) Add Normaliser to ML library

2015-05-21 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-1844: --- Labels: ML Starter (was: ML) > Add Normaliser to ML library > ---

[jira] [Updated] (FLINK-1736) Add CountVectorizer to machine learning library

2015-05-21 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-1736: --- Labels: ML Starter (was: ML) > Add CountVectorizer to machine learning library >

[jira] [Updated] (FLINK-1737) Add statistical whitening transformation to machine learning library

2015-05-21 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-1737: --- Labels: ML Starter (was: ML) > Add statistical whitening transformation to machine le

[jira] [Updated] (FLINK-1738) Add mean centering transformation to machine learning library

2015-05-21 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis updated FLINK-1738: --- Labels: ML Starter (was: ML) > Add mean centering transformation to machine learning

[jira] [Commented] (FLINK-2034) Add vision and roadmap for ML library to docs

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

[GitHub] flink pull request: [FLINK-2034] [docs] Add vision and roadmap for...

2015-05-21 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/688#issuecomment-104282245 Added all the changes we discussed, this should be good to merge now. --- If your project is set up for it, you can reply to this email and have your reply appear on Git

[jira] [Commented] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

2015-05-21 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554281#comment-14554281 ] Aljoscha Krettek commented on FLINK-2074: - You can try it with this modified examp

[jira] [Closed] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1418. --- > Make 'print()' output on the client command line, rather than on the task > manager sysout > --

[jira] [Resolved] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1418. - Resolution: Incomplete Fix Version/s: 0.9 Implemented in 6220f34b626e9ed92b190042e0d69020e1

[jira] [Closed] (FLINK-2071) Projection function can fail non serializable

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2071. --- > Projection function can fail non serializable > - > >

[jira] [Resolved] (FLINK-2071) Projection function can fail non serializable

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2071. - Resolution: Fixed Fixed in ad1d9362c88343972b19fdcce0b041d8380805a9 > Projection function can fai

[GitHub] flink pull request: Eager print

2015-05-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/699 --- 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] [Created] (FLINK-2074) Sliding Window Keeps Emitting Elements After Source Stops Producing

2015-05-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2074: --- Summary: Sliding Window Keeps Emitting Elements After Source Stops Producing Key: FLINK-2074 URL: https://issues.apache.org/jira/browse/FLINK-2074 Project: Flin

[jira] [Comment Edited] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-05-21 Thread Laurent Tardif (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554265#comment-14554265 ] Laurent Tardif edited comment on FLINK-1848 at 5/21/15 1:21 PM:

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-05-21 Thread Laurent Tardif (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554265#comment-14554265 ] Laurent Tardif commented on FLINK-1848: --- Hi [~fhueske]] , I'm agree to add the "\\

[jira] [Created] (FLINK-2073) Add contribution guide for FlinkML

2015-05-21 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2073: -- Summary: Add contribution guide for FlinkML Key: FLINK-2073 URL: https://issues.apache.org/jira/browse/FLINK-2073 Project: Flink Issue Type: New

[jira] [Created] (FLINK-2072) Add a quickstart guide for FlinkML

2015-05-21 Thread Theodore Vasiloudis (JIRA)
Theodore Vasiloudis created FLINK-2072: -- Summary: Add a quickstart guide for FlinkML Key: FLINK-2072 URL: https://issues.apache.org/jira/browse/FLINK-2072 Project: Flink Issue Type: New

[jira] [Created] (FLINK-2071) Projection function can fail non serializable

2015-05-21 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2071: --- Summary: Projection function can fail non serializable Key: FLINK-2071 URL: https://issues.apache.org/jira/browse/FLINK-2071 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2050) Add pipelining mechanism for chainable transformers and estimators

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

[GitHub] flink pull request: [FLINK-2050] Introduces new pipelining mechani...

2015-05-21 Thread thvasilo
Github user thvasilo commented on the pull request: https://github.com/apache/flink/pull/704#issuecomment-104248691 LGTM 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 project does not have this feature

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-21 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/682#issuecomment-104245060 +1, can you do it @rmetzger ? --- 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 ha

[jira] [Created] (FLINK-2070) Confusing methods print() that print on client vs on TaskManager

2015-05-21 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2070: --- Summary: Confusing methods print() that print on client vs on TaskManager Key: FLINK-2070 URL: https://issues.apache.org/jira/browse/FLINK-2070 Project: Flink

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-21 Thread HilmiYildirim
Github user HilmiYildirim commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-104243817 The problem was that the TwitterSource.next method was not implemented properly. There were also dead code. I fixed it and now it is working. --- If your project

[jira] [Closed] (FLINK-2063) Streaming checkpoints consider only input and output vertices

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2063. --- > Streaming checkpoints consider only input and output vertices >

[jira] [Resolved] (FLINK-2063) Streaming checkpoints consider only input and output vertices

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2063. - Resolution: Fixed Fixed via 7bd7b056a2947440ad5acab6dbd45915c356f145 > Streaming checkpoints cons

[jira] [Resolved] (FLINK-2062) Fix names of memory segment config parameter

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2062. - Resolution: Fixed Fixed via 939e3fc40fbdb05f2a564c241eb2c791e869f2d3 > Fix names of memory segmen

[jira] [Closed] (FLINK-2062) Fix names of memory segment config parameter

2015-05-21 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2062. --- > Fix names of memory segment config parameter > > >

[jira] [Created] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file

2015-05-21 Thread Faye Beligianni (JIRA)
Faye Beligianni created FLINK-2069: -- Summary: writeAsCSV function in DataStream Scala API creates no file Key: FLINK-2069 URL: https://issues.apache.org/jira/browse/FLINK-2069 Project: Flink

[GitHub] flink pull request: [FLINK-1992] [ml] Add convergence criterion to...

2015-05-21 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/692#discussion_r30794495 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -76,86 +77,163 @@ class GradientDescent(runPara

[jira] [Commented] (FLINK-1992) Add convergence criterion to SGD optimizer

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

[GitHub] flink pull request: [FLINK-2062] [core] Fix names of memory size c...

2015-05-21 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/703 --- 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-2062) Fix names of memory segment config parameter

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

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-21 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/682#issuecomment-104241003 +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 en

[GitHub] flink pull request: Eager print

2015-05-21 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/699#issuecomment-104240529 Looks good now. Will merge this. Thank you for the contribution! --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-1992) Add convergence criterion to SGD optimizer

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

[GitHub] flink pull request: [FLINK-1992] [ml] Add convergence criterion to...

2015-05-21 Thread thvasilo
Github user thvasilo commented on a diff in the pull request: https://github.com/apache/flink/pull/692#discussion_r30794038 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -76,86 +77,163 @@ class GradientDescent(runPara

[jira] [Commented] (FLINK-1992) Add convergence criterion to SGD optimizer

2015-05-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14554162#comment-14554162 ] ASF GitHub Bot commented on FLINK-1992: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request: [FLINK-1992] [ml] Add convergence criterion to...

2015-05-21 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/692#discussion_r30793945 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala --- @@ -76,86 +77,163 @@ class GradientDescent(run

[GitHub] flink pull request: [Flink-1985] Streaming does not correctly forw...

2015-05-21 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/682#issuecomment-104231736 Done. --- 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

[GitHub] flink pull request:

2015-05-21 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/commit/35d7b5be823e3c4578b8d51f8d03f53018fb1066#commitcomment-11303380 In flink-clients/src/main/java/org/apache/flink/client/web/JobsServlet.java: In flink-clients/src/main/java/org/apache/flink/clien

[GitHub] flink pull request: [FLINK-2068] WebUI support multiple jobs per j...

2015-05-21 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/707 [FLINK-2068] WebUI support multiple jobs per jar file - program-class can contain multiple comma seperated entry classes - WebClient shows checkbox for each entry class and can display plan for it

[GitHub] flink pull request: Implemented TwitterSourceFilter and adapted Tw...

2015-05-21 Thread HilmiYildirim
Github user HilmiYildirim commented on the pull request: https://github.com/apache/flink/pull/695#issuecomment-104230142 TwitterSource does not work after the last update. Now, it sends null messages. I try to fix it. --- If your project is set up for it, you can reply to this email

[jira] [Commented] (FLINK-2068) WebUI support multiple jobs per jar file

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

[jira] [Created] (FLINK-2068) WebUI support multiple jobs per jar file

2015-05-21 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2068: -- Summary: WebUI support multiple jobs per jar file Key: FLINK-2068 URL: https://issues.apache.org/jira/browse/FLINK-2068 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-2067) Chained streaming operators should not throw chained exceptions

2015-05-21 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-2067: --- Summary: Chained streaming operators should not throw chained exceptions Key: FLINK-2067 URL: https://issues.apache.org/jira/browse/FLINK-2067 Project: Flink

[GitHub] flink pull request: From stream to h base

2015-05-21 Thread HilmiYildirim
Github user HilmiYildirim commented on the pull request: https://github.com/apache/flink/pull/702#issuecomment-104220763 I had some merging conflicts. Therefore, I did a new Pull Request https://github.com/apache/flink/pull/706 --- If your project is set up for it, you can reply to t

  1   2   3   >