[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API

[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14563759#comment-14563759 ] Márton Balassi commented on FLINK-2103: --- Why is this needed, why wouldn't the user

[jira] [Closed] (FLINK-2046) Quickstarts are missing on the new Website

[ https://issues.apache.org/jira/browse/FLINK-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2046. -- Resolution: Fixed Fixed in e51f2ac. Quickstarts are missing on the new Website

[jira] [Commented] (FLINK-2109) CancelTaskException leads to FAILED task state

[ https://issues.apache.org/jira/browse/FLINK-2109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14563317#comment-14563317 ] ASF GitHub Bot commented on FLINK-2109: --- GitHub user uce opened a pull request:

[GitHub] flink pull request: [FLINK-2109] [runtime] Fix CancelTaskException...

GitHub user uce opened a pull request: https://github.com/apache/flink/pull/745 [FLINK-2109] [runtime] Fix CancelTaskException handling Thanks to @StephanEwen for helping out. I'm waiting to hear back from Travis. You can merge this pull request into a Git repository by running:

[GitHub] flink pull request: [FLINK-1874] [streaming] Connector breakup

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/719#issuecomment-106203949 I added the `parent` suffix to the main pom, because that is how we tend to name modules not containing source code themselves. Then I have realized that the name is

[jira] [Commented] (FLINK-1874) Break up streaming connectors into submodules

[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562403#comment-14562403 ] ASF GitHub Bot commented on FLINK-1874: --- Github user mbalassi commented on the pull

[GitHub] flink pull request: [ml] [WIP] Consolidation of loss function

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/740 [ml] [WIP] Consolidation of loss function This WIP PR shows a prototypical consolidation of the `LossFunction`. Furthermore, it introduces some syntactic sugar to make Scala programming more

[GitHub] flink pull request: [streaming] Source sync

GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/738 [streaming] Source sync This builds on #521 and fixes some issues in it: * The pull request was rebased * fromCollection and generateSequence and the parallel versions have the

[GitHub] flink pull request: [streaming] Source sync

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/738#issuecomment-106224522 Looks good , but we probably should modify (or add) some tests to test the newly added functions because I think none of the new functionality is tested properly. ---

[GitHub] flink pull request: [streaming] Source sync

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/738#issuecomment-106225424 Thanks for the review. The test coverage is the following: * The newly introduced `StreamExecutionEnvionmentTest` is for testing the parallelism issues with

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562512#comment-14562512 ] ASF GitHub Bot commented on FLINK-1319: --- Github user StephanEwen commented on the

[GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/729#issuecomment-106232545 I second Ufuk's comments. Merging it and deactivating it by default. I can see a 0.9.1 or 0.10.0 release coming in very soon afterwards, because we have a big set

[GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo...

Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/729#issuecomment-106236797 +1 for activating hinting locally. I thought logging is the standard way to print, but I can change it to a sysout --- If your project is set up for it, you can

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562532#comment-14562532 ] ASF GitHub Bot commented on FLINK-1319: --- Github user twalthr commented on the pull

[GitHub] flink pull request: [FLINK-2096] Remove implicit conversion from W...

Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/726 --- 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-2096) Remove implicit conversions in Streaming Scala API

[ https://issues.apache.org/jira/browse/FLINK-2096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562539#comment-14562539 ] ASF GitHub Bot commented on FLINK-2096: --- Github user aljoscha closed the pull

[jira] [Commented] (FLINK-2096) Remove implicit conversions in Streaming Scala API

[ https://issues.apache.org/jira/browse/FLINK-2096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562540#comment-14562540 ] ASF GitHub Bot commented on FLINK-2096: --- Github user aljoscha commented on the pull

[jira] [Closed] (FLINK-2096) Remove implicit conversions in Streaming Scala API

[ https://issues.apache.org/jira/browse/FLINK-2096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2096. --- Resolution: Fixed Fix Version/s: 0.9 Fixed in

[GitHub] flink pull request: [FLINK-2096] Remove implicit conversion from W...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/726#issuecomment-106237798 manually merged --- 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

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562547#comment-14562547 ] ASF GitHub Bot commented on FLINK-1319: --- Github user uce commented on the pull

[GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/729#issuecomment-106241536 - I agree with hints going to sysout and activating by default. - For simple functions, most of the transitive allocations will be Flink internal, right? E.g. after

[jira] [Commented] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562448#comment-14562448 ] Márton Balassi commented on FLINK-2088: --- We could do it, but currently streaming

[jira] [Commented] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562459#comment-14562459 ] ASF GitHub Bot commented on FLINK-2088: --- GitHub user mbalassi opened a pull request:

[GitHub] flink pull request: [FLINK-2088] [streaming] [scala] DataStream.na...

GitHub user mbalassi opened a pull request: https://github.com/apache/flink/pull/739 [FLINK-2088] [streaming] [scala] DataStream.name() returns a typed Da… …taStream Just a quickfix. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (FLINK-2103) Expose partitionBy to the user in Stream API

Aljoscha Krettek created FLINK-2103: --- Summary: Expose partitionBy to the user in Stream API Key: FLINK-2103 URL: https://issues.apache.org/jira/browse/FLINK-2103 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562442#comment-14562442 ] Márton Balassi commented on FLINK-2088: --- Thanks for the report, fixing it. change

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562523#comment-14562523 ] ASF GitHub Bot commented on FLINK-1319: --- Github user twalthr commented on the pull

[jira] [Assigned] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2088: - Assignee: Márton Balassi change return type of name function in DataStream scala class

[jira] [Commented] (FLINK-1430) Add test for streaming scala api completeness

[ https://issues.apache.org/jira/browse/FLINK-1430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562464#comment-14562464 ] Márton Balassi commented on FLINK-1430: --- Hey, [~qmlmoon] are you working on this

[GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo...

Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/729#issuecomment-106233384 I disabled the analyzer for all classes starting with org.apache.flink. Because I wanted to reduce the output to the user for build-in UDFs (e.g.

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

[ https://issues.apache.org/jira/browse/FLINK-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562582#comment-14562582 ] Till Rohrmann commented on FLINK-2072: -- Really good idea. I like it a lot :-) This is

[GitHub] flink pull request: [FLINK-1874] [streaming] Connector breakup

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/719#issuecomment-106285952 Okay, I agree with you that we can name the modules the way marton suggested it. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562732#comment-14562732 ] ASF GitHub Bot commented on FLINK-2088: --- GitHub user mbalassi reopened a pull

[jira] [Commented] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562731#comment-14562731 ] ASF GitHub Bot commented on FLINK-2088: --- Github user mbalassi closed the pull

[GitHub] flink pull request: [FLINK-2088] [streaming] [scala] DataStream.na...

GitHub user mbalassi reopened a pull request: https://github.com/apache/flink/pull/739 [FLINK-2088] [streaming] [scala] DataStream.name() returns a typed Da… …taStream Just a quickfix. You can merge this pull request into a Git repository by running: $ git pull

[GitHub] flink pull request: [FLINK-1319][core] Add static code analysis fo...

Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/729#issuecomment-106243626 The `collect()` is a special case, the analyzer does not follow it. But after thinking about it I recognized that I forgot `getRuntimeContext()` I will fix this ;) ---

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562553#comment-14562553 ] ASF GitHub Bot commented on FLINK-1319: --- Github user twalthr commented on the pull

[jira] [Commented] (FLINK-2104) Fallback implicit values for PredictOperation and TransformOperation don't work if Nothing is inferred as the output type

[ https://issues.apache.org/jira/browse/FLINK-2104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562676#comment-14562676 ] ASF GitHub Bot commented on FLINK-2104: --- GitHub user tillrohrmann opened a pull

[GitHub] flink pull request: [FLINK-2088] [streaming] [scala] DataStream.na...

Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/739#issuecomment-106286739 Looks good, let's merge this soon. --- 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-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562727#comment-14562727 ] ASF GitHub Bot commented on FLINK-2088: --- Github user gyfora commented on the pull

[GitHub] flink pull request: [FLINK-2088] [streaming] [scala] DataStream.na...

Github user mbalassi closed the pull request at: https://github.com/apache/flink/pull/739 --- 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-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562597#comment-14562597 ] Aljoscha Krettek commented on FLINK-2098: - I started working on this. I will first

[jira] [Assigned] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2098: --- Assignee: Aljoscha Krettek (was: Stephan Ewen) Checkpoint barrier initiation at

[jira] [Updated] (FLINK-2094) Implement Word2Vec

[ https://issues.apache.org/jira/browse/FLINK-2094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2094: - Assignee: Nikolaas Steenbergen (was: Till Rohrmann) Implement Word2Vec --

[jira] [Updated] (FLINK-2094) Implement Word2Vec

[ https://issues.apache.org/jira/browse/FLINK-2094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2094: - Labels: ML (was: ) Implement Word2Vec -- Key: FLINK-2094

[jira] [Commented] (FLINK-2044) Implementation of Gelly HITS Algorithm

[ https://issues.apache.org/jira/browse/FLINK-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562654#comment-14562654 ] Mohammad Fahim Azizi commented on FLINK-2044: - Hey [~vkalavri], the hits

[jira] [Commented] (FLINK-2061) CSVReader: quotedStringParsing and includeFields yields ParseException

[ https://issues.apache.org/jira/browse/FLINK-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562716#comment-14562716 ] ASF GitHub Bot commented on FLINK-2061: --- Github user fhueske commented on the pull

[GitHub] flink pull request: [FLINK-2061] CSVReader: quotedStringParsing an...

Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/734#issuecomment-106286147 Hi @chiwanpark , thanks for the PR! I'm a bit busy right now but will have a look at the PR soon. Thanks, Fabian --- If your project is set up for it, you can

[jira] [Commented] (FLINK-2047) Rename CoCoA to SVM

[ https://issues.apache.org/jira/browse/FLINK-2047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562580#comment-14562580 ] ASF GitHub Bot commented on FLINK-2047: --- Github user tillrohrmann commented on the

[GitHub] flink pull request: [FLINK-2104] [ml] Fixes problem with type infe...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/741 [FLINK-2104] [ml] Fixes problem with type inference for fallback implicits The solution seems to be to fix the output type to `Any`. This has the consequence that all following operations will

[jira] [Commented] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562728#comment-14562728 ] Fabian Hueske commented on FLINK-687: - [~till.rohrmann] +1 For starting with a

[jira] [Commented] (FLINK-2094) Implement Word2Vec

[ https://issues.apache.org/jira/browse/FLINK-2094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562596#comment-14562596 ] Till Rohrmann commented on FLINK-2094: -- Great pointers [~jkirsch]. We can also use

[jira] [Created] (FLINK-2104) Fallback implicit values for PredictOperation and TransformOperation don't work if Nothing is inferred as the output type

Till Rohrmann created FLINK-2104: Summary: Fallback implicit values for PredictOperation and TransformOperation don't work if Nothing is inferred as the output type Key: FLINK-2104 URL:

[jira] [Created] (FLINK-2106) Add outer joins to API, Optimizer, and Runtime

Fabian Hueske created FLINK-2106: Summary: Add outer joins to API, Optimizer, and Runtime Key: FLINK-2106 URL: https://issues.apache.org/jira/browse/FLINK-2106 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1874) Break up streaming connectors into submodules

[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562838#comment-14562838 ] ASF GitHub Bot commented on FLINK-1874: --- Github user mbalassi commented on the pull

[jira] [Commented] (FLINK-2092) Document (new) behavior of print() and execute()

[ https://issues.apache.org/jira/browse/FLINK-2092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562862#comment-14562862 ] Maximilian Michels commented on FLINK-2092: --- As far as I know, the behavior of

[jira] [Commented] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562879#comment-14562879 ] Ricky Pogalz commented on FLINK-687: Hi, during the project course IMPRO3 at TU-Berlin

[jira] [Created] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

Fabian Hueske created FLINK-2105: Summary: Implement Sort-Merge Outer Join algorithm Key: FLINK-2105 URL: https://issues.apache.org/jira/browse/FLINK-2105 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request: [FLINK-1874] [streaming] Connector breakup

Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/719#issuecomment-106299970 Thanks, merging as soon as travis verifies. --- 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

[jira] [Commented] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562882#comment-14562882 ] Ricky Pogalz commented on FLINK-687: Hi, during the project course IMPRO3 at TU-Berlin

[jira] [Issue Comment Deleted] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ricky Pogalz updated FLINK-687: --- Comment: was deleted (was: Hi, during the project course IMPRO3 at TU-Berlin we planned to work on

[GitHub] flink pull request: [FLINK-2061] CSVReader: quotedStringParsing an...

Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/734#issuecomment-106313923 Okay. :) Because there is Stephen's email address in test code, I modified test code. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request: [FLINK-1874] [streaming] Connector breakup

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/719 --- 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-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562976#comment-14562976 ] Chiwan Park commented on FLINK-687: --- Good. I'll take subtask for a hash-join based outer

[jira] [Commented] (FLINK-2047) Rename CoCoA to SVM

[ https://issues.apache.org/jira/browse/FLINK-2047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562993#comment-14562993 ] ASF GitHub Bot commented on FLINK-2047: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-1874) Break up streaming connectors into submodules

[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562906#comment-14562906 ] ASF GitHub Bot commented on FLINK-1874: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2088] [streaming] [scala] DataStream.na...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/739 --- 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-1907) Scala Interactive Shell

[ https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562921#comment-14562921 ] ASF GitHub Bot commented on FLINK-1907: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-1907] Scala shell

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/672 --- 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] [Issue Comment Deleted] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park updated FLINK-687: -- Comment: was deleted (was: [~r-pogalz] Okay. You can take this issue. :) I don't start work about the

[jira] [Commented] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562963#comment-14562963 ] Fabian Hueske commented on FLINK-687: - How about both of you implement an outer join

[jira] [Commented] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562973#comment-14562973 ] Fabian Hueske commented on FLINK-687: - How about both of you implement an outer join

[jira] [Commented] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562987#comment-14562987 ] Ricky Pogalz commented on FLINK-687: Yeah, I guess this makes sense :) Add support

[GitHub] flink pull request: [FLINK-2047] [ml] Rename CoCoA to SVM

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/733 --- 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-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562907#comment-14562907 ] ASF GitHub Bot commented on FLINK-2088: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562939#comment-14562939 ] Chiwan Park commented on FLINK-687: --- [~r-pogalz] Okay. You can take this issue. :) I

[jira] [Commented] (FLINK-687) Add support for outer-joins

[ https://issues.apache.org/jira/browse/FLINK-687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562937#comment-14562937 ] Chiwan Park commented on FLINK-687: --- [~r-pogalz] Okay. You can take this issue. :) I

[GitHub] flink pull request:

Github user thvasilo commented on the pull request: https://github.com/apache/flink/commit/995f8f9693c4fe2e40efcf6a82c10ccab11c37ba#commitcomment-11408683 In flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/SVM.scala: In

[jira] [Assigned] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

[ https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2105: Assignee: Ricky Pogalz Implement Sort-Merge Outer Join algorithm

[jira] [Commented] (FLINK-2102) Add predict operation for LabeledVector

[ https://issues.apache.org/jira/browse/FLINK-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14563040#comment-14563040 ] Theodore Vasiloudis commented on FLINK-2102: My suggestion for an initial

[jira] [Closed] (FLINK-2091) Lock contention during release of network buffer pools

[ https://issues.apache.org/jira/browse/FLINK-2091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-2091. -- Resolution: Not A Problem The core issue was not lock contention, but having too many tasks run at the

[jira] [Resolved] (FLINK-2047) Rename CoCoA to SVM

[ https://issues.apache.org/jira/browse/FLINK-2047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2047. -- Resolution: Fixed Done with 995f8f9693c4fe2e40efcf6a82c10ccab11c37ba Rename CoCoA to SVM

[jira] [Created] (FLINK-2107) Implement Hash Outer Join algorithm

Fabian Hueske created FLINK-2107: Summary: Implement Hash Outer Join algorithm Key: FLINK-2107 URL: https://issues.apache.org/jira/browse/FLINK-2107 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request: [FLINK-2104] [ml] Fixes problem with type infe...

Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/741#issuecomment-106367425 If there are no more objections, then I would merge it in the next hours. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Assigned] (FLINK-2102) Add predict operation for LabeledVector

[ https://issues.apache.org/jira/browse/FLINK-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Theodore Vasiloudis reassigned FLINK-2102: -- Assignee: Theodore Vasiloudis Add predict operation for LabeledVector

[jira] [Assigned] (FLINK-2107) Implement Hash Outer Join algorithm

[ https://issues.apache.org/jira/browse/FLINK-2107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park reassigned FLINK-2107: -- Assignee: Chiwan Park Implement Hash Outer Join algorithm

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14563209#comment-14563209 ] ASF GitHub Bot commented on FLINK-2098: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/742 [FLINK-2098] Ensure checkpoints and element emission are in order Before, it could happen that a streaming source would keep emitting elements while a checkpoint is being performed. This can

[GitHub] flink pull request: [FLINK-2098] Ensure checkpoints and element em...

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/742#issuecomment-106471093 This also enables the exactly once checkpointing test added earlier by @StephanEwen. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-2098) Checkpoint barrier initiation at source is not aligned with snapshotting

[ https://issues.apache.org/jira/browse/FLINK-2098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14563211#comment-14563211 ] ASF GitHub Bot commented on FLINK-2098: --- Github user aljoscha commented on the pull

[jira] [Created] (FLINK-2109) CancelTaskException leads to FAILED task state

Ufuk Celebi created FLINK-2109: -- Summary: CancelTaskException leads to FAILED task state Key: FLINK-2109 URL: https://issues.apache.org/jira/browse/FLINK-2109 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2110) Early slot release after Execution failure

Ufuk Celebi created FLINK-2110: -- Summary: Early slot release after Execution failure Key: FLINK-2110 URL: https://issues.apache.org/jira/browse/FLINK-2110 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-2104) Fallback implicit values for PredictOperation and TransformOperation don't work if Nothing is inferred as the output type

[ https://issues.apache.org/jira/browse/FLINK-2104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14563086#comment-14563086 ] ASF GitHub Bot commented on FLINK-2104: --- Github user asfgit closed the pull request

[jira] [Created] (FLINK-2108) Add score function for Predictors

Theodore Vasiloudis created FLINK-2108: -- Summary: Add score function for Predictors Key: FLINK-2108 URL: https://issues.apache.org/jira/browse/FLINK-2108 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2102) Add predict operation for LabeledVector

[ https://issues.apache.org/jira/browse/FLINK-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14563067#comment-14563067 ] Till Rohrmann commented on FLINK-2102: -- This should work as a first version. We

[jira] [Resolved] (FLINK-2088) change return type of name function in DataStream scala class

[ https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-2088. --- Resolution: Fixed Fixed via 31efaa1 change return type of name function in DataStream scala

[GitHub] flink pull request: [FLINK-2104] [ml] Fixes problem with type infe...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/741 --- 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] [Closed] (FLINK-2104) Fallback implicit values for PredictOperation and TransformOperation don't work if Nothing is inferred as the output type

[ https://issues.apache.org/jira/browse/FLINK-2104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2104. Resolution: Fixed Fixed via 3e860e7fd5ef9c4aba10f738ce95b12d40654cce Fallback implicit values for

[jira] [Resolved] (FLINK-1874) Break up streaming connectors into submodules

[ https://issues.apache.org/jira/browse/FLINK-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-1874. --- Resolution: Fixed Fix Version/s: 0.9 Fixed via 665bcec and a302817. Break up

[GitHub] flink pull request: [FLINK-2103] Expose partitionBy to user

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/743 [FLINK-2103] Expose partitionBy to user You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink user-partition-by Alternatively you can

  1   2   >