[jira] (FLINK-5633) ClassCastException: X cannot be cast to X when re-submitting a job.

2017-01-30 Thread Giuliano Caliari (JIRA)
Title: Message Title Giuliano Caliari closed an issue as Workaround

[jira] (FLINK-5633) ClassCastException: X cannot be cast to X when re-submitting a job.

2017-01-30 Thread Giuliano Caliari (JIRA)
Title: Message Title Giuliano Caliari commented on FLINK-5633

[jira] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

2017-01-30 Thread sunjincheng (JIRA)
Title: Message Title sunjincheng assigned an issue to sunjincheng

[jira] (FLINK-5678) User-defined TableFunctions do not support all types of parameters

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5678

[GitHub] flink pull request #3232: [FLINK-5183] [py] Support mulitple jobs per plan f...

2017-01-30 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3232#discussion_r98445731 --- Diff: flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/Environment.py --- @@ -27,17 +27,24 @@ import sys

[jira] (FLINK-5183) [py] Support multiple jobs per Python plan file

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5183

[GitHub] flink pull request #3232: [FLINK-5183] [py] Support mulitple jobs per plan f...

2017-01-30 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3232#discussion_r98443058 --- Diff: flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/PythonOperationInfo.java --- @@ -92,6 +96,11 @@ public

[GitHub] flink pull request #3232: [FLINK-5183] [py] Support mulitple jobs per plan f...

2017-01-30 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3232#discussion_r98443208 --- Diff: flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/functions/PythonMapPartition.java --- @@ -32,7 +32,7 @@ private

[jira] (FLINK-5183) [py] Support multiple jobs per Python plan file

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5183

[jira] (FLINK-5183) [py] Support multiple jobs per Python plan file

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5183

[GitHub] flink pull request #3192: [FLINK-1731][ml] Add KMeans clustering(Lloyd's alg...

2017-01-30 Thread skonto
Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/3192#discussion_r98453679 --- Diff: flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/clustering/ClusteringData.scala --- @@ -0,0 +1,277 @@ +/* + * Licensed to the

[jira] (FLINK-1456) Projection to fieldnames, keyselectors

2017-01-30 Thread Fabian Hueske (JIRA)
Title: Message Title Fabian Hueske closed an issue as Won't Fix

[jira] (FLINK-1098) flatArray() operator that converts arrays to elements

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek commented on FLINK-1098

[jira] (FLINK-1098) flatArray() operator that converts arrays to elements

2017-01-30 Thread Timo Walther (JIRA)
Title: Message Title Timo Walther commented on FLINK-1098

[jira] (FLINK-5612) GlobPathFilter not-serializable exception

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5612

[GitHub] flink issue #3215: [FLINK-5628] [webfrontend] Fix serialization of stats tra...

2017-01-30 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3215 @uce +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 enabled and wishes so, or

[jira] (FLINK-4604) Add support for standard deviation/variance

2017-01-30 Thread Timo Walther (JIRA)
Title: Message Title Timo Walther commented on FLINK-4604

[GitHub] flink issue #3184: [5456] [docs] state intro and new interfaces

2017-01-30 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3184 @alpinegizmo Could you please check out these changes: https://github.com/aljoscha/flink/tree/pr-3184-state-documentation? I took your PR, reshuffled the sections (keyed state is now mentioned

[GitHub] flink pull request #3192: [FLINK-1731][ml] Add KMeans clustering(Lloyd's alg...

2017-01-30 Thread skonto
Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/3192#discussion_r98456054 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala --- @@ -0,0 +1,263 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

2017-01-30 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r98455947 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java --- @@ -0,0 +1,140 @@ +/* + * Licensed to

[jira] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-1731

[jira] (FLINK-2168) Add HBaseTableSource

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-2168

[jira] (FLINK-5044) Converting operator and function state from Flink 1.1 for all changed operators in 1.2

2017-01-30 Thread Stefan Richter (JIRA)
Title: Message Title Stefan Richter commented on FLINK-5044

[jira] (FLINK-1146) Add a way to provide types for generic type variables

2017-01-30 Thread Timo Walther (JIRA)
Title: Message Title Timo Walther closed an issue as Won't Fix

[jira] (FLINK-1146) Add a way to provide types for generic type variables

2017-01-30 Thread Timo Walther (JIRA)
Title: Message Title Timo Walther commented on FLINK-1146

[jira] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek commented on FLINK-4275

[jira] (FLINK-5612) GlobPathFilter not-serializable exception

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5612

[GitHub] flink pull request #:

2017-01-30 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/commit/3400a87dce9940ac8da95c89ff9791ca6a687776#commitcomment-20662491 In flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: In

[jira] (FLINK-5645) IOMetrics transfer through ExecGraph does not work for failed jobs

2017-01-30 Thread Chesnay Schepler (JIRA)
Title: Message Title Chesnay Schepler assigned an issue to Chesnay Schepler

[jira] (FLINK-2923) Make it possible to mix-and-match StateBackends with KvState implementations

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek closed an issue as Not A Problem

[jira] (FLINK-4407) Add DSL for specifying Window Triggers

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek updated an issue

[jira] (FLINK-2284) Confusing/inconsistent PartitioningStrategy

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek commented on FLINK-2284

[GitHub] flink issue #3206: [FLINK-5612] Fix GlobPathFilter not-serializable exceptio...

2017-01-30 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3206 @mushketyk The changes have been merged, could you close this PR? --- 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] (FLINK-5612) GlobPathFilter not-serializable exception

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5612

[GitHub] flink pull request #3206: [FLINK-5612] Fix GlobPathFilter not-serializable e...

2017-01-30 Thread mushketyk
Github user mushketyk closed the pull request at: https://github.com/apache/flink/pull/3206 --- 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

[GitHub] flink issue #3206: [FLINK-5612] Fix GlobPathFilter not-serializable exceptio...

2017-01-30 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/3206 @zentol Sure. Thank you for merging this! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] (FLINK-5628) CheckpointStatsTracker implements Serializable but isn't

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5628

[GitHub] flink pull request #3192: [FLINK-1731][ml] Add KMeans clustering(Lloyd's alg...

2017-01-30 Thread skonto
Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/3192#discussion_r98454397 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/package.scala --- @@ -18,13 +18,16 @@ package org.apache.flink +

[jira] (FLINK-5044) Converting operator and function state from Flink 1.1 for all changed operators in 1.2

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek commented on FLINK-5044

[jira] (FLINK-1526) Add Minimum Spanning Tree library method and example

2017-01-30 Thread Xingcan Cui (JIRA)
Title: Message Title Xingcan Cui commented on FLINK-1526

[jira] (FLINK-5678) User-defined TableFunctions do not support all types of parameters

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5678

[jira] (FLINK-3849) Add FilterableTableSource interface and translation rule

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-3849

[jira] (FLINK-5441) Directly allow SQL queries on a Table

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5441

[jira] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-1731

[jira] (FLINK-3039) Trigger KeyValueState cannot be Scala Int

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek closed an issue as Won't Fix

[jira] (FLINK-2983) Add StateLoader as an alternative to default KvState

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek closed an issue as Won't Fix

[jira] (FLINK-3237) Create AsynchronousKvStateSnapshot similar to AsynchronousStateHandle

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek closed an issue as Won't Fix

[GitHub] flink pull request #3233: [FLINK-5678] [table] Fix User-defined Functions do...

2017-01-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3233 --- 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] (FLINK-5678) User-defined TableFunctions do not support all types of parameters

2017-01-30 Thread Timo Walther (JIRA)
Title: Message Title Timo Walther resolved as Fixed

[GitHub] flink pull request #3192: [FLINK-1731][ml] Add KMeans clustering(Lloyd's alg...

2017-01-30 Thread skonto
Github user skonto commented on a diff in the pull request: https://github.com/apache/flink/pull/3192#discussion_r98454850 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala --- @@ -0,0 +1,263 @@ +/* + * Licensed to the Apache

[jira] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-1731

[jira] (FLINK-5456) Add docs about new state and checkpointing interfaces

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek assigned an issue to David Anderson

[GitHub] flink issue #3233: [FLINK-5678] [table] Fix User-defined Functions do not su...

2017-01-30 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3233 Thanks for fixing this issue @wuchong! The general fix looks good. I just added the case that boxed types of temporal types can also represent null values. I will merge this... --- If your project

[jira] (FLINK-5183) [py] Support multiple jobs per Python plan file

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5183

[GitHub] flink pull request #3232: [FLINK-5183] [py] Support mulitple jobs per plan f...

2017-01-30 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3232#discussion_r98441018 --- Diff: flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/PythonPlanBinder.java --- @@ -139,15 +139,28 @@ private void

[GitHub] flink issue #3166: [FLINK-3849] Add FilterableTableSource interface and Rule...

2017-01-30 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3166 @fhueske the problem is that we have currently no tool that converts RexNodes back to expressions. If we want to support all types of expressions, we need to implement a conversion method for all

[jira] (FLINK-5481) Cannot create Collection of Row

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5481

[GitHub] flink issue #3127: [FLINK-5481] Add type extraction from collection

2017-01-30 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3127 In the Table API we implemented `org.apache.flink.table.api.Types` to improve the user experience. We could also think about moving this to core. I would be helpful to have a class that enumerates

[GitHub] flink issue #3107: [FLINK-5441] [table] Directly allow SQL queries on a Tabl...

2017-01-30 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3107 @KurtYoung I agree that this syntax can be misused like `table.sql("SELECT * FROM otherTable")`. But right now it is very inconvenient to always register a table first, especially if you want to

[jira] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-1731

[jira] (FLINK-1456) Projection to fieldnames, keyselectors

2017-01-30 Thread Fabian Hueske (JIRA)
Title: Message Title Fabian Hueske commented on FLINK-1456

[jira] (FLINK-1456) Projection to fieldnames, keyselectors

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek commented on FLINK-1456

[jira] (FLINK-3606) Expose Configuration from RichFunctions

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek commented on FLINK-3606

[jira] (FLINK-4407) Add DSL for specifying Window Triggers

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek updated an issue

[jira] (FLINK-4679) Add TumbleRow row-windows to Table API

2017-01-30 Thread Fabian Hueske (JIRA)
Title: Message Title Fabian Hueske commented on FLINK-4679

[jira] (FLINK-5659) FileBaseUtils#deleteFileOrDirectory not thread-safe on Windows

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5659

[GitHub] flink issue #3219: [FLINK-5659] Harden FileBaseUtils#deleteFileOrDirectory o...

2017-01-30 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3219 @StephanEwen I've update the PR. The `deleteDirectory()` method now has separate paths for windows and unix. --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink issue #3149: FLINK-2168 Add HBaseTableSource

2017-01-30 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/3149 @ramkrish86 sorry for confusing, don't pay attention to new generating maps. I think `PushProjectIntoBatchTableSourceScanRule` is not good enough for nested data types. but we can project at

[jira] (FLINK-4604) Add support for standard deviation/variance

2017-01-30 Thread Anton Mushin (JIRA)
Title: Message Title Anton Mushin commented on FLINK-4604

[jira] (FLINK-3918) Not configuring any time characteristic leads to a ClassCastException

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek closed an issue as Fixed

[jira] (FLINK-2168) Add HBaseTableSource

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-2168

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

2017-01-30 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r98434792 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java --- @@ -0,0 +1,140 @@ +/* + * Licensed to

[GitHub] flink pull request #3149: FLINK-2168 Add HBaseTableSource

2017-01-30 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/3149#discussion_r98435113 --- Diff: flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java --- @@ -0,0 +1,140 @@ +/* + * Licensed to

[jira] (FLINK-2168) Add HBaseTableSource

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-2168

[jira] (FLINK-1526) Add Minimum Spanning Tree library method and example

2017-01-30 Thread Xingcan Cui (JIRA)
Title: Message Title Xingcan Cui commented on FLINK-1526

[jira] (FLINK-1526) Add Minimum Spanning Tree library method and example

2017-01-30 Thread Vasia Kalavri (JIRA)
Title: Message Title Vasia Kalavri commented on FLINK-1526

[jira] (FLINK-4604) Add support for standard deviation/variance

2017-01-30 Thread Anton Mushin (JIRA)
Title: Message Title Anton Mushin updated an issue

[jira] (FLINK-5685) Connection leak in Taskmanager

2017-01-30 Thread Andrey (JIRA)
Title: Message Title Andrey created an issue

[jira] (FLINK-2168) Add HBaseTableSource

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-2168

[jira] (FLINK-1526) Add Minimum Spanning Tree library method and example

2017-01-30 Thread Xingcan Cui (JIRA)
Title: Message Title Xingcan Cui edited a comment on FLINK-1526

[jira] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

2017-01-30 Thread ramkrishna.s.vasudevan (JIRA)
Title: Message Title ramkrishna.s.vasudevan commented on FLINK-4810

[GitHub] flink issue #3127: [FLINK-5481] Add type extraction from collection

2017-01-30 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/3127 I suggest add a little bit more sugar ```java TypeInformation infoNew = RowTypeInfo.from( new String[]{"1c", "2c"}, RowTypeInfo.from( new String[]{"1.1", "1.2c"},

[jira] (FLINK-5481) Cannot create Collection of Row

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-5481

[jira] (FLINK-3177) Add Stream Operator that Discards Late Elements

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek closed an issue as Not A Problem

[jira] (FLINK-4415) Enhance Trigger Interface with onFire()

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek closed an issue as Won't Fix

[jira] (FLINK-5415) ContinuousFileProcessingTest failed on travis

2017-01-30 Thread Ufuk Celebi (JIRA)
Title: Message Title Ufuk Celebi updated an issue

[GitHub] flink issue #3192: [FLINK-1731][ml] Add KMeans clustering(Lloyd's algorithm)

2017-01-30 Thread skonto
Github user skonto commented on the issue: https://github.com/apache/flink/pull/3192 @sachingoel0101 I am having a look. --- 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

[jira] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-1731

[jira] (FLINK-1407) Enable log output (error level) for test cases

2017-01-30 Thread Till Rohrmann (JIRA)
Title: Message Title Till Rohrmann closed an issue as Fixed

[jira] (FLINK-5044) Converting operator and function state from Flink 1.1 for all changed operators in 1.2

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek closed an issue as Fixed

[jira] (FLINK-5480) User-provided hashes for operators

2017-01-30 Thread Stefan Richter (JIRA)
Title: Message Title Stefan Richter commented on FLINK-5480

[GitHub] flink issue #3219: [FLINK-5659] Harden FileBaseUtils#deleteFileOrDirectory o...

2017-01-30 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3219 I added a few more thoughts on how we could improve the behavior of the function. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] (FLINK-5681) Make ReaperThread for SafetyNetCloseableRegistry a singleton

2017-01-30 Thread Stephan Ewen (JIRA)
Title: Message Title Stephan Ewen closed an issue as Fixed

[GitHub] flink issue #3192: [FLINK-1731][ml] Add KMeans clustering(Lloyd's algorithm)

2017-01-30 Thread skonto
Github user skonto commented on the issue: https://github.com/apache/flink/pull/3192 @sachingoel0101 please add an example at least under flink examples. Is the code documentation enough? @thvasilo ? --- If your project is set up for it, you can reply to this email and have your

[jira] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2017-01-30 Thread ASF GitHub Bot (JIRA)
Title: Message Title ASF GitHub Bot commented on FLINK-1731

[jira] (FLINK-1541) GSoC project: Distributed profiling

2017-01-30 Thread Till Rohrmann (JIRA)
Title: Message Title Till Rohrmann closed an issue as Won't Fix

[GitHub] flink pull request #3192: [FLINK-1731][ml] Add KMeans clustering(Lloyd's alg...

2017-01-30 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/3192#discussion_r98471870 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/clustering/KMeans.scala --- @@ -0,0 +1,263 @@ +/* + * Licensed to the

[jira] (FLINK-1583) TaskManager reregistration in case of a restart

2017-01-30 Thread Till Rohrmann (JIRA)
Title: Message Title Till Rohrmann closed an issue as Fixed

[GitHub] flink issue #3192: [FLINK-1731][ml] Add KMeans clustering(Lloyd's algorithm)

2017-01-30 Thread sachingoel0101
Github user sachingoel0101 commented on the issue: https://github.com/apache/flink/pull/3192 I'm not sure about adding examples under flink-examples project. None of the other ml algorithms are there either. Also, requires adding flink-ml as a dependency in the pom. I can however add

[jira] (FLINK-5456) Add docs about new state and checkpointing interfaces

2017-01-30 Thread Aljoscha Krettek (JIRA)
Title: Message Title Aljoscha Krettek closed an issue as Fixed

  1   2   >