[jira] [Created] (FLINK-3961) Possibility to write output to multiple locations based on partitions

2016-05-23 Thread Kirsti Laurila (JIRA)
Kirsti Laurila created FLINK-3961: - Summary: Possibility to write output to multiple locations based on partitions Key: FLINK-3961 URL: https://issues.apache.org/jira/browse/FLINK-3961 Project:

[jira] [Commented] (FLINK-3941) Add support for UNION (with duplicate elimination)

2016-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297679#comment-15297679 ] ASF GitHub Bot commented on FLINK-3941: --- GitHub user yjshen opened a pull request:

[GitHub] flink pull request: [FLINK-3941][TableAPI]Add support for UNION (w...

2016-05-23 Thread yjshen
GitHub user yjshen opened a pull request: https://github.com/apache/flink/pull/2025 [FLINK-3941][TableAPI]Add support for UNION (with duplicate elimination) This PR aims at adding `UNION` support in TableAPI and SQL by: - Extending Table API with a new `union()` method -

[jira] [Updated] (FLINK-3753) KillerWatchDog should not use kill on toKill thread

2016-05-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3753: -- Description: {code} // this is harsh, but this watchdog is a last resort if (toKill.isAlive()) {

[jira] [Commented] (FLINK-3960) EventTimeWindowCheckpointingITCase fails with a segmentation fault

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

[GitHub] flink pull request: [FLINK-3960] ignore EventTimeWindowCheckpointi...

2016-05-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/2022#issuecomment-221046822 +1 to skip the test until the RocksDB config fix is in. Will greatly help other builds... --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-05-23 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296733#comment-15296733 ] ramkrishna.s.vasudevan commented on FLINK-3650: --- [~till.rohrmann] - Any comments on the

[jira] [Commented] (FLINK-3586) Risk of data overflow while use sum/count to calculate AVG value

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

[GitHub] flink pull request: [FLINK-3586] Fix potential overflow of Long AV...

2016-05-23 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/2024 [FLINK-3586] Fix potential overflow of Long AVG aggregation. Fixes a potential overflow of Long `AVG` aggregates in the Table API (intermediate sum is computed using `BigInteger` instead of

[jira] [Commented] (FLINK-3955) Change Table.toSink() to Table.writeToSink()

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

[GitHub] flink pull request: [FLINK-3955] [tableAPI] Rename Table.toSink() ...

2016-05-23 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/2023 [FLINK-3955] [tableAPI] Rename Table.toSink() to Table.writeToSink(). Renames `Table.toSink()` to `Table.writeToSink()`. `Table.toSink()` indicates that the `Table` is converted into a sink

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

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

[GitHub] flink pull request: [FLINK-3923] [connector-kinesis] Unify configu...

2016-05-23 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2016#discussion_r64257599 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@

[jira] [Commented] (FLINK-3960) EventTimeWindowCheckpointingITCase fails with a segmentation fault

2016-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296668#comment-15296668 ] ASF GitHub Bot commented on FLINK-3960: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request: [FLINK-3945] [gelly] Degree annotation for dir...

2016-05-23 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2021 [FLINK-3945] [gelly] Degree annotation for directed graphs You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink

[jira] [Commented] (FLINK-3945) Degree annotation for directed graphs

2016-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296634#comment-15296634 ] ASF GitHub Bot commented on FLINK-3945: --- GitHub user greghogan opened a pull request:

[jira] [Updated] (FLINK-3960) EventTimeWindowCheckpointingITCase fails with a segmentation fault

2016-05-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-3960: -- Summary: EventTimeWindowCheckpointingITCase fails with a segmentation fault (was:

[jira] [Created] (FLINK-3960) EventTimeCheckpointingITCase fails with a segmentation fault

2016-05-23 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3960: - Summary: EventTimeCheckpointingITCase fails with a segmentation fault Key: FLINK-3960 URL: https://issues.apache.org/jira/browse/FLINK-3960 Project: Flink

[jira] [Assigned] (FLINK-3941) Add support for UNION (with duplicate elimination)

2016-05-23 Thread Yijie Shen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yijie Shen reassigned FLINK-3941: - Assignee: Yijie Shen > Add support for UNION (with duplicate elimination) >

[jira] [Commented] (FLINK-3741) Travis Compile Error: MissingRequirementError: object scala.runtime in compiler mirror not found.

2016-05-23 Thread Todd Lisonbee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296549#comment-15296549 ] Todd Lisonbee commented on FLINK-3741: -- This issue has possibly been fixed in the Scala compiler,

[jira] [Commented] (FLINK-3956) Make FileInputFormats independent from Configuration

2016-05-23 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296491#comment-15296491 ] Kostas Kloudas commented on FLINK-3956: --- Thanks [~aljoscha] > Make FileInputFormats independent

[jira] [Commented] (FLINK-3959) Remove implicit sinks

2016-05-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296475#comment-15296475 ] Aljoscha Krettek commented on FLINK-3959: - We should think about this. Most other streaming APIs

[jira] [Updated] (FLINK-3956) Make FileInputFormats independent from Configuration

2016-05-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3956: Summary: Make FileInputFormats independent from Configuration (was: Make FileInputFormats

[jira] [Commented] (FLINK-3956) Make FileInputFormats independent from Configuration

2016-05-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296471#comment-15296471 ] Aljoscha Krettek commented on FLINK-3956: - The title very exactly specified what we want to

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

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

[GitHub] flink pull request: [FLINK-3923] [connector-kinesis] Unify configu...

2016-05-23 Thread aozturk
Github user aozturk commented on a diff in the pull request: https://github.com/apache/flink/pull/2016#discussion_r64235578 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@

[jira] [Commented] (FLINK-3952) Bump Netty to 4.1

2016-05-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296460#comment-15296460 ] Stephan Ewen commented on FLINK-3952: - Good idea in general. Last time we bumped Netty, however, we

[jira] [Created] (FLINK-3959) Remove implicit sinks

2016-05-23 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3959: --- Summary: Remove implicit sinks Key: FLINK-3959 URL: https://issues.apache.org/jira/browse/FLINK-3959 Project: Flink Issue Type: Sub-task Components:

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

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

[GitHub] flink pull request: [FLINK-3953] rename unit-tests execution to de...

2016-05-23 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/2019#issuecomment-220997798 Good fix, thanks! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] flink pull request: [FLINK-3923] [connector-kinesis] Unify configu...

2016-05-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/2016#issuecomment-220997800 The change looks good overall. I think we can soon merge it. Please let me know once you've addressed my comments. --- If your project is set up for it, you

[jira] [Commented] (FLINK-3953) Surefire plugin executes unit tests twice

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

[jira] [Closed] (FLINK-3632) Clean up Table API exceptions

2016-05-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3632. Resolution: Done Done with 9cc629662a34bd9cc6310556a321dd5144a60439 Thanks for the contribution!

[jira] [Closed] (FLINK-3939) Prevent distinct aggregates and grouping sets from being translated

2016-05-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3939. Resolution: Fixed Fixed with 173d24dfdd79c497dc31c6f04dcda47a83ede494 > Prevent distinct

[GitHub] flink pull request: [FLINK-3632][TableAPI]Clean up Table API excep...

2016-05-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2015 --- 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-3632) Clean up Table API exceptions

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

[jira] [Commented] (FLINK-3939) Prevent distinct aggregates and grouping sets from being translated

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

[GitHub] flink pull request: [FLINK-3939] [tableAPI] Prevent translation of...

2016-05-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2014 --- 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-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

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

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

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

[GitHub] flink pull request: [FLINK-3923] [connector-kinesis] Unify configu...

2016-05-23 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2016#discussion_r64231495 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@

[GitHub] flink pull request: [FLINK-3923] [connector-kinesis] Unify configu...

2016-05-23 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2016#discussion_r64230633 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@

[jira] [Created] (FLINK-3958) Access to MetricRegistry doesn't have proper synchronization in some classes

2016-05-23 Thread Ted Yu (JIRA)
Ted Yu created FLINK-3958: - Summary: Access to MetricRegistry doesn't have proper synchronization in some classes Key: FLINK-3958 URL: https://issues.apache.org/jira/browse/FLINK-3958 Project: Flink

[jira] [Created] (FLINK-3957) Breaking API changes for Flink 2.0

2016-05-23 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3957: - Summary: Breaking API changes for Flink 2.0 Key: FLINK-3957 URL: https://issues.apache.org/jira/browse/FLINK-3957 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

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

[GitHub] flink pull request: [FLINK-2314] Make Streaming File Sources Persi...

2016-05-23 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/2020#issuecomment-220988362 Thanks, the changes look good. R: @StephanEwen for taking a look at the API, you would only look at `StreamExecutionEnvironment`, for this. --- If your

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

2016-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296388#comment-15296388 ] ASF GitHub Bot commented on FLINK-3923: --- Github user aozturk commented on the pull request:

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

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

[GitHub] flink pull request: [FLINK-3923] [connector-kinesis] Unify configu...

2016-05-23 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2016#discussion_r64227104 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@

[GitHub] flink pull request: [FLINK-3923] [connector-kinesis] Unify configu...

2016-05-23 Thread aozturk
Github user aozturk commented on the pull request: https://github.com/apache/flink/pull/2016#issuecomment-220988206 Sure. Thanks for the review @rmetzger --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

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

[GitHub] flink pull request: [FLINK-2314] Make Streaming File Sources Persi...

2016-05-23 Thread kl0u
Github user kl0u commented on the pull request: https://github.com/apache/flink/pull/2020#issuecomment-220986678 @aljoscha Thanks a lot for the comments! I integrated them already. --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] flink pull request: [FLINK-3923] [connector-kinesis] Unify configu...

2016-05-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/2016#issuecomment-220986366 I noticed that you didn't update the documentation of the Kinesis Producer. Can you update the page to reflect the changed usage. The file is located here:

[jira] [Commented] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

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

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

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

[GitHub] flink pull request: [FLINK-2314] Make Streaming File Sources Persi...

2016-05-23 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/2020#issuecomment-220981894 All in all, very good work! One thing I'd like to change is the order of parameters in the `readFile` methods. For these telescoping methods is usual to append

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

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

[GitHub] flink pull request: [FLINK-2314] Make Streaming File Sources Persi...

2016-05-23 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2020#discussion_r64221544 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java --- @@ -44,6 +44,11 @@ public

[jira] [Issue Comment Deleted] (FLINK-3955) Change Table.toSink() to Table.writeToSink()

2016-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-3955: --- Comment: was deleted (was: I am not sure if this name solve the issue. What about

[jira] [Created] (FLINK-3956) Make FileInputFormats in Streaming independent from the Configuration object

2016-05-23 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-3956: - Summary: Make FileInputFormats in Streaming independent from the Configuration object Key: FLINK-3956 URL: https://issues.apache.org/jira/browse/FLINK-3956

[jira] [Commented] (FLINK-3955) Change Table.toSink() to Table.writeToSink()

2016-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296356#comment-15296356 ] Matthias J. Sax commented on FLINK-3955: I am not sure if this name solve the issue. What about

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

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

[GitHub] flink pull request: [FLINK-2314] Make Streaming File Sources Persi...

2016-05-23 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2020#discussion_r64220867 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FilePathFilter.java --- @@ -0,0 +1,74 @@ +/* + *

[jira] [Commented] (FLINK-3896) Allow a StreamTask to be Externally Cancelled.

2016-05-23 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296350#comment-15296350 ] Kostas Kloudas commented on FLINK-3896: --- This issue came up while implementing FLINK-2314 and the PR

[jira] [Created] (FLINK-3955) Change Table.toSink() to Table.writeToSink()

2016-05-23 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3955: Summary: Change Table.toSink() to Table.writeToSink() Key: FLINK-3955 URL: https://issues.apache.org/jira/browse/FLINK-3955 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX.

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

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

2016-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296342#comment-15296342 ] ASF GitHub Bot commented on FLINK-3311: --- Github user zentol commented on the pull request:

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

2016-05-23 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1771#issuecomment-220975120 I finally was able to fix the restart issue. there were 2 massive bugs in the CassandraCommitter: - within open() the checkpoint entry was always overridden -

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

2016-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296341#comment-15296341 ] ASF GitHub Bot commented on FLINK-2314: --- GitHub user kl0u opened a pull request:

[GitHub] flink pull request: [FLINK-2314] Make Streaming File Sources Persi...

2016-05-23 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/2020 [FLINK-2314] Make Streaming File Sources Persistent This PR solves FLINK-2314 and combines a number of sub-tasks. In addition, it solves FLINK-3896 which was introduced as part of this task.

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

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

[GitHub] flink pull request: [FLINK-3311/FLINK-3332] Add Cassandra connecto...

2016-05-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/1771#discussion_r64217845 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericAtLeastOnceSink.java --- @@ -0,0 +1,192 @@ +/** + *

[GitHub] flink pull request: [FLINK-1502] [WIP] Basic Metric System

2016-05-23 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/1947 --- 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-3632) Clean up Table API exceptions

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

[GitHub] flink pull request: [FLINK-3632][TableAPI]Clean up Table API excep...

2016-05-23 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/2015#issuecomment-220956222 Will merge 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 not have this

[GitHub] flink pull request: [FLINK-3939] [tableAPI] Prevent translation of...

2016-05-23 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/2014#issuecomment-220956186 Thanks for the review @yjshen! Will address the comment and merge this PR. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-3939) Prevent distinct aggregates and grouping sets from being translated

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

[jira] [Commented] (FLINK-3939) Prevent distinct aggregates and grouping sets from being translated

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

[GitHub] flink pull request: [FLINK-3939] [tableAPI] Prevent translation of...

2016-05-23 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2014#discussion_r64207510 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetAggregateRule.scala --- @@ -33,20 +33,32 @@ class

[jira] [Created] (FLINK-3954) Installing Flink on EMR using EMR bootstrap action

2016-05-23 Thread Akshay Shingote (JIRA)
Akshay Shingote created FLINK-3954: -- Summary: Installing Flink on EMR using EMR bootstrap action Key: FLINK-3954 URL: https://issues.apache.org/jira/browse/FLINK-3954 Project: Flink Issue

[jira] [Closed] (FLINK-3927) TaskManager registration may fail if Yarn versions don't match

2016-05-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3927. - Resolution: Fixed Fixed via 017106e140f3c17ebaaa0507e1dcbbc445c8f0ac > TaskManager

[jira] [Commented] (FLINK-3953) Surefire plugin executes unit tests twice

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

[jira] [Closed] (FLINK-3953) Surefire plugin executes unit tests twice

2016-05-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3953. - Resolution: Fixed Fixed via 5fdf39b1fec032f5816cb188334c129ff9186415 > Surefire plugin

[jira] [Commented] (FLINK-3927) TaskManager registration may fail if Yarn versions don't match

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

[GitHub] flink pull request: [FLINK-3927][yarn] make container id consisten...

2016-05-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2013 --- 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-3953] rename unit-tests execution to de...

2016-05-23 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2019 --- 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-3927) TaskManager registration may fail if Yarn versions don't match

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

[GitHub] flink pull request: [FLINK-3927][yarn] make container id consisten...

2016-05-23 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/2013#issuecomment-220944377 +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

[jira] [Commented] (FLINK-3953) Surefire plugin executes unit tests twice

2016-05-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296191#comment-15296191 ] ASF GitHub Bot commented on FLINK-3953: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request: [FLINK-3953] rename unit-tests execution to de...

2016-05-23 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2019 [FLINK-3953] rename unit-tests execution to default-test After 38698c0b101cbb48f8c10adf4060983ac07e2f4b, there are now two executions defined for the Surefire plugin: unit-tests and

[jira] [Commented] (FLINK-3953) Surefire plugin executes unit tests twice

2016-05-23 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296185#comment-15296185 ] Maximilian Michels commented on FLINK-3953: --- Follow-up of FLINK-3909. > Surefire plugin

[jira] [Created] (FLINK-3953) Surefire plugin executes unit tests twice

2016-05-23 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3953: - Summary: Surefire plugin executes unit tests twice Key: FLINK-3953 URL: https://issues.apache.org/jira/browse/FLINK-3953 Project: Flink Issue