[jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell

2015-11-23 Thread Nick Dimiduk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022803#comment-15022803 ] Nick Dimiduk commented on FLINK-2522: - Heya folks any progress here? > Integrate Streaming Api into

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022648#comment-15022648 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on a diff in the pull request:

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022649#comment-15022649 ] ASF GitHub Bot commented on FLINK-2111: --- Github user sachingoel0101 commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2015-11-23 Thread mjsax
Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r45640243 --- Diff: flink-runtime-web/web-dashboard/app/partials/jobs/job.jade --- @@ -43,6 +43,10 @@ nav.navbar.navbar-default.navbar-fixed-top.navbar-main(ng-if="job")

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022671#comment-15022671 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2015-11-23 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r45640613 --- Diff: flink-runtime-web/web-dashboard/app/partials/jobs/job.jade --- @@ -43,6 +43,10 @@

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2015-11-23 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r45639014 --- Diff: flink-runtime-web/web-dashboard/app/partials/jobs/job.jade --- @@ -43,6 +43,10 @@

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2015-11-23 Thread mjsax
Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/750#discussion_r45639008 --- Diff: flink-runtime-web/web-dashboard/web/partials/jobs/job.html --- @@ -32,7 +32,7 @@ - {{ job['end-time'] |

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022675#comment-15022675 ] ASF GitHub Bot commented on FLINK-2111: --- Github user sachingoel0101 commented on a diff in the pull

[GitHub] flink pull request: Out-of-core state backend for JDBC databases

2015-11-23 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1305#issuecomment-159048039 If no objections I would like to 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

[GitHub] flink pull request: [FLINK-3000]Adds shutdown hook to clean up lin...

2015-11-23 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1354#issuecomment-159054302 Ping. --- 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

[jira] [Commented] (FLINK-3000) Add ShutdownHook to YARN CLI to prevent lingering sessions

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022924#comment-15022924 ] ASF GitHub Bot commented on FLINK-3000: --- Github user sachingoel0101 commented on the pull request:

[jira] [Resolved] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant

2015-11-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2429. - Resolution: Fixed Assignee: Stephan Ewen Fixed in 68a69c76ae66908658bed17a95dda7b74bc72675

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

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15021887#comment-15021887 ] ASF GitHub Bot commented on FLINK-1994: --- Github user tillrohrmann commented on the pull request:

[GitHub] flink pull request: Flink 1994- Add different gain calculation sch...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1384#issuecomment-158896082 Hi @rawkintrevo, thanks for your contribution. You have some scala style violations in `GradientDescent.scala` line 46 and 168. The lines mustn't be longer

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2015-11-23 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-158912414 Just rebased. Can you please review @StephanEwen @tillrohrmann --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2015-11-23 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-158913013 @sachingoel0101 Is the UI change ok? --- 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

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15021982#comment-15021982 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on the pull request:

[jira] [Commented] (FLINK-2947) Coloured Scala Shell

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022004#comment-15022004 ] ASF GitHub Bot commented on FLINK-2947: --- Github user chiwanpark commented on the pull request:

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022068#comment-15022068 ] ASF GitHub Bot commented on FLINK-2828: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r45600839 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaBatchTranslator.scala --- @@ -118,6 +135,12 @@ class

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022070#comment-15022070 ] ASF GitHub Bot commented on FLINK-2828: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r45600858 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaStreamingTranslator.scala --- @@ -53,6 +55,22 @@ class

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r45600975 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaStreamingTranslator.scala --- @@ -113,8 +131,14 @@ class

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022079#comment-15022079 ] ASF GitHub Bot commented on FLINK-2828: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request:

2015-11-23 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/commit/bf29de981c2bcd5cb5d33c68b158c95c8820f43d#commitcomment-14559720 You can now get the latest nightly binaries here: http://flink.apache.org/contribute-code.html#snapshots-nightly-builds --- If your

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15021981#comment-15021981 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on the pull request:

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r45601100 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/java/table/TableEnvironment.scala --- @@ -45,7 +60,12 @@ class TableEnvironment

[jira] [Commented] (FLINK-2956) Migrate integration tests for Table API

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15021990#comment-15021990 ] ASF GitHub Bot commented on FLINK-2956: --- Github user chiwanpark commented on the pull request:

[GitHub] flink pull request: [FLINK-2956] [tests] Migrate integration tests...

2015-11-23 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1349#issuecomment-158914256 @gallenvara Thanks for update! Looks good to merge for me. If there is no objection until tomorrow, I'll merge this. --- If your project is set up for it, you can

[GitHub] flink pull request: [FLINK-2947] [scala shell] Add color support t...

2015-11-23 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1337#issuecomment-158914974 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r45600786 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaBatchTranslator.scala --- @@ -54,6 +55,22 @@ class

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022073#comment-15022073 ] ASF GitHub Bot commented on FLINK-2828: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022076#comment-15022076 ] ASF GitHub Bot commented on FLINK-2828: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut...

2015-11-23 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/750#issuecomment-158929824 I just investigated the failing test. The test is new and passed up to know. @uce changed `ExecutionGraph.cancel()` recently, allowing to cancel a job when it is in state

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r45601201 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/java/table/TableEnvironment.scala --- @@ -45,7 +60,12 @@ class TableEnvironment

[jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022078#comment-15022078 ] ASF GitHub Bot commented on FLINK-2111: --- Github user mjsax commented on the pull request:

[GitHub] flink pull request: [FLINK-3059] Javadoc fix for DataSet.writeAsTe...

2015-11-23 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1392#discussion_r45580248 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -1343,10 +1343,34 @@ public long count() throws Exception { //

[jira] [Commented] (FLINK-3059) Javadoc fix for DataSet.writeAsText()

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15021746#comment-15021746 ] ASF GitHub Bot commented on FLINK-3059: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-3059) Javadoc fix for DataSet.writeAsText()

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15021742#comment-15021742 ] ASF GitHub Bot commented on FLINK-3059: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3059] Javadoc fix for DataSet.writeAsTe...

2015-11-23 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1392#discussion_r45580214 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -1343,10 +1343,34 @@ public long count() throws Exception { //

[GitHub] flink pull request: [FLINK-3059] Javadoc fix for DataSet.writeAsTe...

2015-11-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1392#issuecomment-158877137 Thanks for improving this. The docs were not obvious, and your change makes it much better. I added two comments, otherwise this looks good to me. --- If

[GitHub] flink pull request: [FLINK-2429] [streaming] Deprecate the "enable...

2015-11-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1382 --- 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] [Commented] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15021794#comment-15021794 ] ASF GitHub Bot commented on FLINK-2429: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant

2015-11-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2429. --- > Remove the "enableCheckpointing()" without interval variant >

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r45602245 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/PredicatePruner.scala --- @@ -0,0 +1,88 @@ +/*

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022097#comment-15022097 ] ASF GitHub Bot commented on FLINK-2828: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r45602446 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/PredicatePushdown.scala --- @@ -0,0 +1,120 @@

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022102#comment-15022102 ] ASF GitHub Bot commented on FLINK-2828: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45604749 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45604736 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45604964 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022121#comment-15022121 ] ASF GitHub Bot commented on FLINK-2017: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

2015-11-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1097 --- 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] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022124#comment-15022124 ] ASF GitHub Bot commented on FLINK-2017: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45605892 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022092#comment-15022092 ] ASF GitHub Bot commented on FLINK-2828: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1237#discussion_r45602715 --- Diff: flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/PredicatePushdown.scala --- @@ -0,0 +1,120 @@

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45604652 --- Diff: flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/classification/HMMSuite.scala --- @@ -0,0 +1,142 @@ +/* --- End diff --

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45604927 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45604868 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-2017] Add predefined required parameter...

2015-11-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1097#issuecomment-158939653 Thank you for addressing the issues so timely. I'll merge the change now, thank you! --- If your project is set up for it, you can reply to this email and

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45605623 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[jira] [Resolved] (FLINK-2017) Add predefined required parameters to ParameterTool

2015-11-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2017. --- Resolution: Fixed Assignee: Martin Liesenberg Fix Version/s: 1.0.0 Resolved

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45605838 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45606011 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45606279 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45606570 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45606691 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45606758 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45606960 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45607019 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45606909 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-3046) Integrate the Either Java type with the TypeExtractor

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022146#comment-15022146 ] ASF GitHub Bot commented on FLINK-3046: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request: [FLINK-3046] Integrate the Either Java type wi...

2015-11-23 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/1393 [FLINK-3046] Integrate the Either Java type with the TypeExtractor This PR implements FLINK-3046. All necessary methods of the TypeExtractor (`getForObject`, `createTypeInfo`, `getForClass` and

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45607309 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45607352 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45607404 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45607673 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/HMM.scala --- @@ -0,0 +1,148 @@ +/* + * Licensed to the

[jira] [Assigned] (FLINK-2996) Add config entry to define BlobServer port

2015-11-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2996: - Assignee: Robert Metzger > Add config entry to define BlobServer port >

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45607939 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/Viterbi.scala --- @@ -0,0 +1,119 @@ +/* + * Licensed to the

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45608006 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/Viterbi.scala --- @@ -0,0 +1,119 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-3060) Add possibility to integrate custom types into the TypeExtractor

2015-11-23 Thread Timo Walther (JIRA)
Timo Walther created FLINK-3060: --- Summary: Add possibility to integrate custom types into the TypeExtractor Key: FLINK-3060 URL: https://issues.apache.org/jira/browse/FLINK-3060 Project: Flink

[GitHub] flink pull request: [FLINK-2861] Fields grouping on split streams ...

2015-11-23 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1387#issuecomment-158952162 That's actually not a stupid question. I did not do it in the first place to avoid "redundant" code (I was not aware that Flink changes names). I just changed it to your

[GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ...

2015-11-23 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1237#issuecomment-158955674 @aljoscha I thought it makes sense to distinguish between `AdaptiveTableSource` and `StaticTableSource`. Calculating the predicates to be pushed down is quite

[jira] [Commented] (FLINK-2861) Fields grouping on split streams fails

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022157#comment-15022157 ] ASF GitHub Bot commented on FLINK-2861: --- Github user mjsax commented on the pull request:

[jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022175#comment-15022175 ] ASF GitHub Bot commented on FLINK-2828: --- Github user twalthr commented on the pull request:

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45610422 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/BaumWelch.scala --- @@ -0,0 +1,346 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

2015-11-23 Thread danielblazevski
Github user danielblazevski commented on a diff in the pull request: https://github.com/apache/flink/pull/1220#discussion_r45692984 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/nn/KNN.scala --- @@ -0,0 +1,321 @@ +/* + * Licensed to the Apache

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

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15023684#comment-15023684 ] ASF GitHub Bot commented on FLINK-1745: --- Github user danielblazevski commented on a diff in the pull

[GitHub] flink pull request: [FLINK-1994] [ml] Add different gain calculati...

2015-11-23 Thread rawkintrevo
GitHub user rawkintrevo opened a pull request: https://github.com/apache/flink/pull/1397 [FLINK-1994] [ml] Add different gain calculation schemes to SGD Continuation of pull request 1384. Fixed long line issue, rebased on top of current master, and changed title per

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

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15023699#comment-15023699 ] ASF GitHub Bot commented on FLINK-1994: --- GitHub user rawkintrevo opened a pull request:

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

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15023696#comment-15023696 ] ASF GitHub Bot commented on FLINK-1994: --- Github user rawkintrevo commented on the pull request:

[GitHub] flink pull request: [FLINK-1994] [ml] Add different gain calculati...

2015-11-23 Thread rawkintrevo
Github user rawkintrevo commented on the pull request: https://github.com/apache/flink/pull/1384#issuecomment-159139713 did what you said ( I think ) and opened a new pull request --- 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: [FLINK-1994] [ml] Add different gain calculati...

2015-11-23 Thread rawkintrevo
Github user rawkintrevo closed the pull request at: https://github.com/apache/flink/pull/1384 --- 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-1994) Add different gain calculation schemes to SGD

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15023697#comment-15023697 ] ASF GitHub Bot commented on FLINK-1994: --- Github user rawkintrevo closed the pull request at:

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

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022334#comment-15022334 ] ASF GitHub Bot commented on FLINK-1745: --- Github user tillrohrmann commented on a diff in the pull

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

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022333#comment-15022333 ] ASF GitHub Bot commented on FLINK-1745: --- Github user tillrohrmann commented on a diff in the pull

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

2015-11-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15022347#comment-15022347 ] ASF GitHub Bot commented on FLINK-1745: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request: [Flink-3007] Implemented a parallel version of...

2015-11-23 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1350#discussion_r45611535 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/BaumWelch.scala --- @@ -0,0 +1,346 @@ +/* + * Licensed to the

  1   2   >