[jira] [Commented] (FLINK-3310) Add back pressure statistics to web frontend

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132123#comment-15132123 ] ASF GitHub Bot commented on FLINK-3310: --- Github user uce commented on the pull request:

[GitHub] flink pull request: [FLINK-3226] Add DataSet scan and conversion t...

2016-02-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1579#issuecomment-179777395 I'll merge this PR to the `tableOnCalcite` branch. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132156#comment-15132156 ] ASF GitHub Bot commented on FLINK-3226: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: Enhance Partitioned State and use it in Window...

2016-02-04 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/1562 --- 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-3201) Enhance Partitioned State Interface with State Types

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132226#comment-15132226 ] ASF GitHub Bot commented on FLINK-3201: --- Github user aljoscha closed the pull request at:

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132235#comment-15132235 ] ASF GitHub Bot commented on FLINK-3234: --- GitHub user chiwanpark opened a pull request:

[GitHub] flink pull request: [FLINK-3234] [dataSet] Add KeySelector support...

2016-02-04 Thread chiwanpark
GitHub user chiwanpark opened a pull request: https://github.com/apache/flink/pull/1585 [FLINK-3234] [dataSet] Add KeySelector support to sortPartition operation. This PR contains following changes: * Add `sortPartition` methods which receive a `KeySelector` instance or a

[jira] [Issue Comment Deleted] (FLINK-3311) Add a connector for streaming data into Cassandra

2016-02-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3311: -- Comment: was deleted (was: Hi Andrea, your code looks quite nice. I also like your approach of

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

2016-02-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132061#comment-15132061 ] Robert Metzger commented on FLINK-3311: --- Hi Andrea, your code looks quite nice. I also like your

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

2016-02-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132064#comment-15132064 ] Chesnay Schepler commented on FLINK-3311: - Sounds good to me. > Add a connector for streaming

[jira] [Assigned] (FLINK-3329) Unclosed BackupEngine in AbstractRocksDBState#snapshot()

2016-02-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-3329: --- Assignee: Aljoscha Krettek > Unclosed BackupEngine in

[jira] [Commented] (FLINK-3329) Unclosed BackupEngine in AbstractRocksDBState#snapshot()

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132242#comment-15132242 ] ASF GitHub Bot commented on FLINK-3329: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request: [FLINK-3329] Auto-Close BackupEngine in Abstra...

2016-02-04 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1586 [FLINK-3329] Auto-Close BackupEngine in AbstractRocksDBState You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink rocksdb-auto-close

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

2016-02-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132090#comment-15132090 ] Robert Metzger commented on FLINK-3311: --- Great. [~alkagin], I gave you "Contributor" permissions

[jira] [Updated] (FLINK-3311) Add a connector for streaming data into Cassandra

2016-02-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3311: -- Assignee: Andrea Sella > Add a connector for streaming data into Cassandra >

[jira] [Commented] (FLINK-3310) Add back pressure statistics to web frontend

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132103#comment-15132103 ] ASF GitHub Bot commented on FLINK-3310: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-3310] [runtime, runtime-web] Add back p...

2016-02-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1578#issuecomment-179758751 Is it actually a bad thing that this is available for batch jobs? Batch jobs have multiple pipelined tasks as well, and this would figure out where in the pipeline

[jira] [Created] (FLINK-3333) Documentation about object reuse should be improved

2016-02-04 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-: -- Summary: Documentation about object reuse should be improved Key: FLINK- URL: https://issues.apache.org/jira/browse/FLINK- Project: Flink Issue Type:

[GitHub] flink pull request: [FLINK-3226] Add DataSet scan and conversion t...

2016-02-04 Thread fhueske
Github user fhueske closed the pull request at: https://github.com/apache/flink/pull/1579 --- 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] [Created] (FLINK-3332) Provide an exactly-once Cassandra connector

2016-02-04 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3332: - Summary: Provide an exactly-once Cassandra connector Key: FLINK-3332 URL: https://issues.apache.org/jira/browse/FLINK-3332 Project: Flink Issue Type:

[GitHub] flink pull request: [FLINK-3328] Incorrectly shaded dependencies i...

2016-02-04 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/1584 [FLINK-3328] Incorrectly shaded dependencies in flink-runtime You can merge this pull request into a Git repository by running: $ git pull https://github.com/rmetzger/flink flink3328

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

2016-02-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132062#comment-15132062 ] Robert Metzger commented on FLINK-3311: --- Hi Andrea, your code looks quite nice. I also like your

[jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra

2016-02-04 Thread Andrea Sella (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132074#comment-15132074 ] Andrea Sella commented on FLINK-3311: - Sound good to me, too. > Add a connector for streaming data

[jira] [Assigned] (FLINK-2213) Configure number of vcores

2016-02-04 Thread Kostas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas reassigned FLINK-2213: - Assignee: Kostas > Configure number of vcores > -- > > Key:

[jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector

2016-02-04 Thread Andrea Sella (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132110#comment-15132110 ] Andrea Sella commented on FLINK-3332: - Hi guys, Do you have something about "exactly once"

[jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132120#comment-15132120 ] ASF GitHub Bot commented on FLINK-2523: --- Github user kl0u closed the pull request at:

[jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector

2016-02-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132119#comment-15132119 ] Robert Metzger commented on FLINK-3332: --- Hi, I think there is some documentation on our

[jira] [Commented] (FLINK-3221) Move Table API on top of Apache Calcite

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132121#comment-15132121 ] ASF GitHub Bot commented on FLINK-3221: --- Github user fhueske commented on the pull request:

[jira] [Assigned] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

2016-02-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3328: - Assignee: Robert Metzger > Incorrectly shaded dependencies in flink-runtime >

[GitHub] flink pull request: FLINK-2523: making the task cancellation inter...

2016-02-04 Thread kl0u
Github user kl0u closed the pull request at: https://github.com/apache/flink/pull/1546 --- 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-3328) Incorrectly shaded dependencies in flink-runtime

2016-02-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132134#comment-15132134 ] Robert Metzger commented on FLINK-3328: --- I had an offline chat with Stephan. The file is only 7.6

[jira] [Created] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp

2016-02-04 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-3334: - Summary: Change default log4j.properties Conversion pattern to include year-month-day in the timestamp Key: FLINK-3334 URL: https://issues.apache.org/jira/browse/FLINK-3334

[jira] [Created] (FLINK-3340) Fix object juggling in reduce drivers

2016-02-04 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3340: - Summary: Fix object juggling in reduce drivers Key: FLINK-3340 URL: https://issues.apache.org/jira/browse/FLINK-3340 Project: Flink Issue Type: Bug

[GitHub] flink pull request: [FLINK-2721] [Storm Compatibility] Add Tuple m...

2016-02-04 Thread mjsax
GitHub user mjsax opened a pull request: https://github.com/apache/flink/pull/1591 [FLINK-2721] [Storm Compatibility] Add Tuple meta information You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/flink

[jira] [Commented] (FLINK-2721) Add Tuple meta information

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133293#comment-15133293 ] ASF GitHub Bot commented on FLINK-2721: --- GitHub user mjsax opened a pull request:

[jira] [Commented] (FLINK-2721) Add Tuple meta information

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133300#comment-15133300 ] ASF GitHub Bot commented on FLINK-2721: --- Github user mjsax commented on the pull request:

[GitHub] flink pull request: [FLINK-2721] [Storm Compatibility] Add Tuple m...

2016-02-04 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/1591#issuecomment-180098460 @mxm I would like to get this into 1.0 release. Would be great if you could review it. --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request: [FLINK-2678]DataSet API does not support multi...

2016-02-04 Thread sbcd90
Github user sbcd90 commented on the pull request: https://github.com/apache/flink/pull/1566#issuecomment-180152337 Hello @tillrohrmann please review the commit as the work to be done is nearly complete I believe. Please comment. --- If your project is set up for it, you can reply to

[jira] [Comment Edited] (FLINK-1733) Add PCA to machine learning library

2016-02-04 Thread Thang Nguyen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133521#comment-15133521 ] Thang Nguyen edited comment on FLINK-1733 at 2/5/16 2:14 AM: - {quote} I'm not

[GitHub] flink pull request: [FLINK-3234] [dataSet] Add KeySelector support...

2016-02-04 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1585#issuecomment-180224231 @fhueske I addressed your comments. To reduce modifying original code, I added some variables for key selector only. But this make the source code quite

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133753#comment-15133753 ] ASF GitHub Bot commented on FLINK-3234: --- Github user chiwanpark commented on the pull request:

[jira] [Commented] (FLINK-1733) Add PCA to machine learning library

2016-02-04 Thread Thang Nguyen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133521#comment-15133521 ] Thang Nguyen commented on FLINK-1733: - | I'm not sure that {{DenseMatrix}} fits for sPCA What if the

[jira] [Commented] (FLINK-1733) Add PCA to machine learning library

2016-02-04 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133568#comment-15133568 ] Chiwan Park commented on FLINK-1733: Oh, you can continue work for it, [~thang]. Sorry for confusing.

[jira] [Commented] (FLINK-1733) Add PCA to machine learning library

2016-02-04 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133465#comment-15133465 ] Chiwan Park commented on FLINK-1733: Hi [~thang], You can use {{breeze.linalg.DenseMatrix}}. But you

[jira] [Commented] (FLINK-1733) Add PCA to machine learning library

2016-02-04 Thread Thang Nguyen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133447#comment-15133447 ] Thang Nguyen commented on FLINK-1733: - Thanks [~till.rohrmann], I've been flipping through the Odersky

[jira] [Updated] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML

2016-02-04 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park updated FLINK-3330: --- Assignee: Till Rohrmann (was: Chiwan Park) > Add SparseVector support to BLAS library in FlinkML >

[jira] [Updated] (FLINK-3330) Add SparseVector support to GradientDescent in FlinkML

2016-02-04 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chiwan Park updated FLINK-3330: --- Summary: Add SparseVector support to GradientDescent in FlinkML (was: Add SparseVector support to

[jira] [Comment Edited] (FLINK-3330) Add SparseVector support to GradientDescent in FlinkML

2016-02-04 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133436#comment-15133436 ] Chiwan Park edited comment on FLINK-3330 at 2/5/16 12:54 AM: - [~till.rohrmann]

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133490#comment-15133490 ] ASF GitHub Bot commented on FLINK-2678: --- Github user sbcd90 commented on the pull request:

[jira] [Commented] (FLINK-3330) Add SparseVector support to GradientDescent in FlinkML

2016-02-04 Thread Chiwan Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15133436#comment-15133436 ] Chiwan Park commented on FLINK-3330: [~till.rohrmann] Thanks! I assigned this issue to you and rename

[jira] [Commented] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML

2016-02-04 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132270#comment-15132270 ] Theodore Vasiloudis commented on FLINK-3330: [~chiwanpark] I'm not familiar with this, why

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132295#comment-15132295 ] ASF GitHub Bot commented on FLINK-3234: --- Github user fhueske commented on a diff in the pull

[jira] [Created] (FLINK-3335) DataSourceTask object reuse when disabled

2016-02-04 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3335: - Summary: DataSourceTask object reuse when disabled Key: FLINK-3335 URL: https://issues.apache.org/jira/browse/FLINK-3335 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3310) Add back pressure statistics to web frontend

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132374#comment-15132374 ] ASF GitHub Bot commented on FLINK-3310: --- Github user StephanEwen commented on the pull request:

[jira] [Closed] (FLINK-3268) Unstable test JobManagerSubmittedJobGraphsRecoveryITCase

2016-02-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3268. --- > Unstable test JobManagerSubmittedJobGraphsRecoveryITCase >

[jira] [Commented] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML

2016-02-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132412#comment-15132412 ] Till Rohrmann commented on FLINK-3330: -- I just tried this as a fix and it seems to solve the problem.

[jira] [Commented] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132430#comment-15132430 ] ASF GitHub Bot commented on FLINK-3330: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request: Scala DataStream accessors fix

2016-02-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1574#issuecomment-179895516 Thanks, 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

[jira] [Commented] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML

2016-02-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132411#comment-15132411 ] Till Rohrmann commented on FLINK-3330: -- Hi [~chiwanpark], yes the problem is that the

[GitHub] flink pull request: [FLINK-3234] [dataSet] Add KeySelector support...

2016-02-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1585#discussion_r51869883 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -1377,6 +1377,20 @@ public long count() throws Exception {

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132281#comment-15132281 ] ASF GitHub Bot commented on FLINK-3234: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3234] [dataSet] Add KeySelector support...

2016-02-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1585#discussion_r51870870 --- Diff: flink-java/src/test/java/org/apache/flink/api/java/operator/SortPartitionTest.java --- @@ -169,6 +169,38 @@ public void

[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

2016-02-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1581#issuecomment-179859441 I just checked out your pull request locally and looked through it. I think the following things need to be fixed before we can merge it: - Squash the 60+

[GitHub] flink pull request:

2016-02-04 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/commit/f8f747f2290ad623bd8a4f0d8ff4708fada6792a#commitcomment-15888699 Thanks for looking into it. `ZKPaths.deleteChildren` actually looks like it already handles this. The

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132284#comment-15132284 ] ASF GitHub Bot commented on FLINK-3234: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132309#comment-15132309 ] ASF GitHub Bot commented on FLINK-3234: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132308#comment-15132308 ] ASF GitHub Bot commented on FLINK-3234: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132369#comment-15132369 ] ASF GitHub Bot commented on FLINK-2021: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3328] Incorrectly shaded dependencies i...

2016-02-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1584#issuecomment-179866261 It works with CDH 5.4.2, which uses Hadoop 2.6.0. I'll merge it. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132335#comment-15132335 ] ASF GitHub Bot commented on FLINK-3234: --- Github user chiwanpark commented on the pull request:

[GitHub] flink pull request: [FLINK-3234] [dataSet] Add KeySelector support...

2016-02-04 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1585#issuecomment-179843708 Thanks for review @fhueske! I'll address your comments. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132378#comment-15132378 ] ASF GitHub Bot commented on FLINK-3328: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3330] [ml] Fix SparseVector support in ...

2016-02-04 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1587 [FLINK-3330] [ml] Fix SparseVector support in GradientDescent The GradientDescent implementation did not work with sparse input data because it requires the gradient to be dense. This patch

[GitHub] flink pull request: [FLINK-3234] [dataSet] Add KeySelector support...

2016-02-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1585#discussion_r51870368 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/SortPartitionOperator.java --- @@ -59,6 +62,14 @@ public

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132289#comment-15132289 ] ASF GitHub Bot commented on FLINK-3234: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

2016-02-04 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/1581#discussion_r51874764 --- Diff: flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/distcp/DistCp.java --- @@ -62,18 +63,32 @@ public static

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132358#comment-15132358 ] ASF GitHub Bot commented on FLINK-2021: --- Github user stefanobaghino commented on a diff in the pull

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132379#comment-15132379 ] ASF GitHub Bot commented on FLINK-2021: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

2016-02-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1581#issuecomment-179867266 OK, let's do it. +1 for @rmetzger's suggestion. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

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

[jira] [Resolved] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

2016-02-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3328. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/7378f014 >

[jira] [Resolved] (FLINK-3268) Unstable test JobManagerSubmittedJobGraphsRecoveryITCase

2016-02-04 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3268. - Resolution: Fixed Assignee: Stephan Ewen (was: Ufuk Celebi) Fixed via

[GitHub] flink pull request: [FLINK-3234] [dataSet] Add KeySelector support...

2016-02-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1585#issuecomment-179835764 Hi @chiwanpark, thanks for picking up this issue and filling this gap in the DataSet API. Would be nice, if it could make it into the 1.0 release, IMO. However,

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132348#comment-15132348 ] ASF GitHub Bot commented on FLINK-2021: --- Github user rmetzger commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT...

2016-02-04 Thread stefanobaghino
Github user stefanobaghino commented on a diff in the pull request: https://github.com/apache/flink/pull/1581#discussion_r51875652 --- Diff: flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/distcp/DistCp.java --- @@ -62,18 +63,32 @@ public

[jira] [Created] (FLINK-3341) Kafka connector's 'auto.offset.reset' inconsistent with Kafka

2016-02-04 Thread Shikhar Bhushan (JIRA)
Shikhar Bhushan created FLINK-3341: -- Summary: Kafka connector's 'auto.offset.reset' inconsistent with Kafka Key: FLINK-3341 URL: https://issues.apache.org/jira/browse/FLINK-3341 Project: Flink

[GitHub] flink pull request: [FLINK-3336] Add Semi-Rebalance Data Shipping ...

2016-02-04 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/1589 [FLINK-3336] Add Semi-Rebalance Data Shipping for DataStream The name of this is still up for discussion but I'm opening this so that people can look at the implementation and especially, the unit

[jira] [Commented] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132830#comment-15132830 ] ASF GitHub Bot commented on FLINK-3336: --- GitHub user aljoscha opened a pull request:

[jira] [Commented] (FLINK-3339) Checkpointing NPE when using filterWithState

2016-02-04 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132853#comment-15132853 ] Aljoscha Krettek commented on FLINK-3339: - The problem is that the recent change to the state

[GitHub] flink pull request: Scala DataStream accessors fix

2016-02-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1574 --- 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 pull request: [FLINK-2021] Rework examples to use ParameterT...

2016-02-04 Thread stefanobaghino
Github user stefanobaghino commented on the pull request: https://github.com/apache/flink/pull/1581#issuecomment-179949096 Following your suggestions, thanks. * squash: should I squash the commits coming from the review as well? * tests: I thought it was about some Travis

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132602#comment-15132602 ] ASF GitHub Bot commented on FLINK-2021: --- Github user stefanobaghino commented on the pull request:

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132298#comment-15132298 ] ASF GitHub Bot commented on FLINK-3234: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3328] Incorrectly shaded dependencies i...

2016-02-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1584#issuecomment-179861292 Cool, thanks for fixing this. Changes look good to me! --- 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-3328] Incorrectly shaded dependencies i...

2016-02-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1584 --- 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-3328) Incorrectly shaded dependencies in flink-runtime

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132372#comment-15132372 ] ASF GitHub Bot commented on FLINK-3328: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132269#comment-15132269 ] ASF GitHub Bot commented on FLINK-3328: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3234] [dataSet] Add KeySelector support...

2016-02-04 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1585#discussion_r51870056 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/DataSet.java --- @@ -1377,6 +1377,20 @@ public long count() throws Exception {

[jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions

2016-02-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132306#comment-15132306 ] ASF GitHub Bot commented on FLINK-3234: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request: [FLINK-3310] [runtime, runtime-web] Add back p...

2016-02-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1578#issuecomment-179863296 We can still move the tab in the UI later. I don't think there is a thing like "breaking changes" in the UI ;-) --- If your project is set up for it, you can

  1   2   >