[jira] [Commented] (FLINK-4108) NPE in Row.productArity

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

[jira] [Assigned] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-10-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-4586: - Assignee: Greg Hogan > NumberSequenceIterator and Accumulator threading issue >

[jira] [Updated] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

2016-10-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4586: -- Fix Version/s: 1.1.4 1.2.0 > NumberSequenceIterator and Accumulator threading issue

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576421#comment-15576421 ] ASF GitHub Bot commented on FLINK-4771: --- Github user qingdao81 commented on the issue:

[GitHub] flink issue #2631: The scala example of SQL on Streaming Tables with wrong v...

2016-10-14 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2631 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[GitHub] flink issue #2477: [FLINK-4506] CsvOutputFormat defaults allowNullValues to ...

2016-10-14 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2477 Thanks for the update @kirill-morozov-epam! Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576438#comment-15576438 ] ASF GitHub Bot commented on FLINK-4771: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-4506) CsvOutputFormat defaults allowNullValues to false, even though doc and declaration says true

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576435#comment-15576435 ] ASF GitHub Bot commented on FLINK-4506: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-4108) NPE in Row.productArity

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15576439#comment-15576439 ] ASF GitHub Bot commented on FLINK-4108: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-4108) NPE in Row.productArity

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

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

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

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

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

[GitHub] flink pull request #2619: [FLINK-4108] [scala] Consider ResultTypeQueryable ...

2016-10-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2619#discussion_r83502181 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala --- @@ -110,7 +110,7 @@ class ExecutionEnvironment(javaEnv:

[jira] [Commented] (FLINK-4586) NumberSequenceIterator and Accumulator threading issue

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

[GitHub] flink pull request #2639: [FLINK-4586] [core] Broken AverageAccumulator

2016-10-14 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2639 [FLINK-4586] [core] Broken AverageAccumulator You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink 4586_broken_averageaccumulator

[GitHub] flink issue #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-14 Thread qingdao81
Github user qingdao81 commented on the issue: https://github.com/apache/flink/pull/2612 Thats good news :-) Thank you! --- 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

[GitHub] flink pull request #2319: [FLINK-4294] [table] Allow access of composite typ...

2016-10-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2319#discussion_r83492573 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/FlinkTypeFactory.scala --- @@ -79,14 +83,27 @@ class

[GitHub] flink pull request #2319: [FLINK-4294] [table] Allow access of composite typ...

2016-10-14 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2319#discussion_r83492774 --- Diff: docs/dev/table_api.md --- @@ -1656,6 +1656,29 @@ temporalOverlaps(TIMEPOINT, TEMPORAL, TIMEPOINT, TEMPORAL) +

[GitHub] flink issue #2631: The scala example of SQL on Streaming Tables with wrong v...

2016-10-14 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2631 Seems like this is the same change as #2632 but on a different version of the master. Closing this PR since #2632 was already merged. --- If your project is set up for it, you can reply to

[jira] [Assigned] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-10-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-2821: - Assignee: Maximilian Michels > Change Akka configuration to allow accessing

[jira] [Commented] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink

2016-10-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574880#comment-15574880 ] Greg Hogan commented on FLINK-4370: --- I thought you had already force-added the file to git, but there is

[jira] [Commented] (FLINK-4828) execute stream job asynchronously

2016-10-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574839#comment-15574839 ] Stephan Ewen commented on FLINK-4828: - I think this is a special case of that issue:

[jira] [Created] (FLINK-4829) Accumulators are not thread safe

2016-10-14 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4829: Summary: Accumulators are not thread safe Key: FLINK-4829 URL: https://issues.apache.org/jira/browse/FLINK-4829 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4829) Accumulators are not thread safe

2016-10-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574886#comment-15574886 ] Maximilian Michels commented on FLINK-4829: --- Actually, they used to be a synchronized map when I

[jira] [Assigned] (FLINK-4829) Accumulators are not thread safe

2016-10-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4829: - Assignee: Maximilian Michels > Accumulators are not thread safe >

[jira] [Commented] (FLINK-3722) The divisions in the InMemorySorters' swap/compare methods hurt performance

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574672#comment-15574672 ] ASF GitHub Bot commented on FLINK-3722: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4771) Compression for AvroOutputFormat

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

[GitHub] flink pull request #2612: FLINK-4771: Compression for AvroOutputFormat

2016-10-14 Thread qingdao81
Github user qingdao81 commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83372815 --- Diff: flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/java/io/AvroOutputFormatTest.java --- @@ -0,0 +1,126 @@ +package

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

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

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

2016-10-14 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r83382895 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java --- @@ -0,0 +1,469 @@ +/*

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

2016-10-14 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r83382559 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollector.java --- @@ -0,0 +1,85 @@ +/* + *

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

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

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

2016-10-14 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r83380500 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java --- @@ -0,0 +1,186 @@

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

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

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

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

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

2016-10-14 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r83380141 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java --- @@ -0,0 +1,186 @@

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

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

[GitHub] flink pull request #2629: [FLINK-4391] Provide support for asynchronous oper...

2016-10-14 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2629#discussion_r83380179 --- Diff: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncIOExample.java --- @@ -0,0 +1,186 @@

[jira] [Commented] (FLINK-4373) Introduce SlotID, AllocationID, ResourceProfile

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

[GitHub] flink pull request #2630: [FLINK-4373] [cluster management] Introduce Alloca...

2016-10-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2630 --- 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-2821) Change Akka configuration to allow accessing actors from different URLs

2016-10-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574755#comment-15574755 ] Maximilian Michels commented on FLINK-2821: --- Here you can find the custom release-2.3 branch of

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

2016-10-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4415: Description: Currently, when a {{Trigger}} returns {{PURGE}} (or {{FIRE_AND_PURGE}}) the

[jira] [Closed] (FLINK-4828) execute stream job asynchronously

2016-10-14 Thread David Anderson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson closed FLINK-4828. - Resolution: Duplicate > execute stream job asynchronously > - > >

[jira] [Commented] (FLINK-4717) Naive version of atomic stop signal with savepoint

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

[GitHub] flink pull request #2609: [FLINK-4717] Add CancelJobWithSavepoint

2016-10-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2609 --- 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-4415) Enhance Trigger Interface with onFire()

2016-10-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574827#comment-15574827 ] Aljoscha Krettek commented on FLINK-4415: - [~StephanEwen] do you have any thoughts on this? We had

[jira] [Created] (FLINK-4828) execute stream job asynchronously

2016-10-14 Thread David Anderson (JIRA)
David Anderson created FLINK-4828: - Summary: execute stream job asynchronously Key: FLINK-4828 URL: https://issues.apache.org/jira/browse/FLINK-4828 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-2313) Change Streaming Driver Execution Model

2016-10-14 Thread David Anderson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574877#comment-15574877 ] David Anderson commented on FLINK-2313: --- +1 This would be super helpful when working with streams

[jira] [Commented] (FLINK-4512) Add option for persistent checkpoints

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

[GitHub] flink pull request #2608: [FLINK-4512] [FLIP-10] Add option to persist perio...

2016-10-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2608 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink issue #2628: [FLINK-3722] [runtime] Don't / and % when sorting

2016-10-14 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2628 Thanks for these cool experiments. Looks like a nice improvement. I'll try to dig into your code in the next days... --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574814#comment-15574814 ] ASF GitHub Bot commented on FLINK-2608: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2623: [FLINK-2608] Updated Twitter Chill version.

2016-10-14 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2623 Okay, in detail it seems that compatibility is not maintained for "Unsafe based I/O", but maintained for standard I/O. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-4828) execute stream job asynchronously

2016-10-14 Thread David Anderson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574815#comment-15574815 ] David Anderson commented on FLINK-4828: --- It's not clear to me what this would do to the output from

[jira] [Closed] (FLINK-2265) Tachyon Tests sometimes fail with pre-mature process exists

2016-10-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2265. --- > Tachyon Tests sometimes fail with pre-mature process exists >

[jira] [Resolved] (FLINK-2265) Tachyon Tests sometimes fail with pre-mature process exists

2016-10-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-2265. - Resolution: Invalid These tests are no longer part of the Flink codebase > Tachyon Tests

[jira] [Commented] (FLINK-4370) Offer a default IntelliJ inspection profile with Flink

2016-10-14 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15574851#comment-15574851 ] Stephan Ewen commented on FLINK-4370: - I would like to go with putting the file into {{.idea}}, but

[GitHub] flink pull request #:

2016-10-14 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/commit/6d4dd75859aa5e78a20dc3a9492391f1c7f7ca7a#commitcomment-19438191 In flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java: In

[GitHub] flink pull request #2577: [FLINK-4720] Implement archived version of the Exe...

2016-10-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2577 --- 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-4720) Implement an archived version of the execution graph

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

[jira] [Commented] (FLINK-4492) Cleanup files from canceled snapshots

2016-10-14 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575225#comment-15575225 ] Stefan Richter commented on FLINK-4492: --- I did not add any cleanup on cancel in the changes I did,

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-10-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575226#comment-15575226 ] Maximilian Michels commented on FLINK-2821: --- [~philipp.bussche] Which version of Flink do you

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

2016-10-14 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575320#comment-15575320 ] Timo Walther commented on FLINK-4604: - The problem is that the rule translates not only into {{SUM}}

[jira] [Commented] (FLINK-4829) Accumulators are not thread safe

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

[jira] [Updated] (FLINK-4831) Implement a log4j metric reporter

2016-10-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4831: Summary: Implement a log4j metric reporter (was: IMplement a log4j metric reporter) >

[jira] [Created] (FLINK-4831) IMplement a log4j metric reporter

2016-10-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4831: --- Summary: IMplement a log4j metric reporter Key: FLINK-4831 URL: https://issues.apache.org/jira/browse/FLINK-4831 Project: Flink Issue Type:

[GitHub] flink issue #2633: [FLINK-4497] CassadraSink support for scala tuples/case c...

2016-10-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2633 The important class is `CassandraScalaProductSink` which extracts the fields from the scala classes. Apart from that it behaves exactly like the `CassandraTupleSink`. As a result of that this common

[jira] [Commented] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575145#comment-15575145 ] ASF GitHub Bot commented on FLINK-4497: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-4827) The scala example of SQL on Streaming Tables with wrong variable name in flink document

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

[jira] [Commented] (FLINK-4315) Remove Hadoop Dependency from flink-java

2016-10-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575192#comment-15575192 ] Fabian Hueske commented on FLINK-4315: -- Hi [~kenmy], while discussing to drop Hadoop1 support, the

[jira] [Resolved] (FLINK-2907) Bloom filter for Join

2016-10-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-2907. --- Resolution: Later Closing this issue with current thoughts: - this would only be applicable for batch

[jira] [Updated] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

2016-10-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4315: - Summary: Deprecate Hadoop dependent methods in flink-java (was: Remove Hadoop Dependency from

[GitHub] flink issue #2634: [FLINK-4829] protect user accumulators against concurrent...

2016-10-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2634 I don't think fixes the reported issue. The supplied stacktrace shows that the exception is thrown in a TreeMap, in the AccRegistry we however only deal with HashMaps. The histograms internally have

[jira] [Commented] (FLINK-4829) Accumulators are not thread safe

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575382#comment-15575382 ] ASF GitHub Bot commented on FLINK-4829: --- Github user zentol commented on the issue:

[jira] [Created] (FLINK-4832) Count/Sum 0 elements

2016-10-14 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4832: --- Summary: Count/Sum 0 elements Key: FLINK-4832 URL: https://issues.apache.org/jira/browse/FLINK-4832 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575154#comment-15575154 ] ASF GitHub Bot commented on FLINK-4294: --- Github user twalthr commented on the issue:

[jira] [Commented] (FLINK-3660) Measure latency of elements and expose it through web interface

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575175#comment-15575175 ] ASF GitHub Bot commented on FLINK-3660: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2386: [FLINK-3660] Measure latency and exposes them via a metri...

2016-10-14 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2386 This looks good to merge now! 👍 --- 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

[GitHub] flink pull request #2386: [FLINK-3660] Measure latency and exposes them via ...

2016-10-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2386 --- 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-3660) Measure latency of elements and expose it as a metric

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

[jira] [Resolved] (FLINK-3660) Measure latency of elements and expose it as a metric

2016-10-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3660. --- Resolution: Fixed Fix Version/s: 1.2.0 Resolved in

[jira] [Updated] (FLINK-3660) Measure latency of elements and expose it as a metric

2016-10-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3660: -- Component/s: Metrics > Measure latency of elements and expose it as a metric >

[jira] [Updated] (FLINK-3660) Measure latency of elements and expose it as a metric

2016-10-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3660: -- Summary: Measure latency of elements and expose it as a metric (was: Measure latency of

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-10-14 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575240#comment-15575240 ] Maximilian Michels commented on FLINK-2821: --- Forgot to mention, the build is based on the Hadoop

[jira] [Commented] (FLINK-4315) Deprecate Hadoop dependent methods in flink-java

2016-10-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575288#comment-15575288 ] Fabian Hueske commented on FLINK-4315: -- Thanks, [~kenmy]! I move this method from the FLINK-3975

[jira] [Commented] (FLINK-4652) Don't pass credentials explicitly to AmazonClient - use credentials provider instead

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

[GitHub] flink pull request #2635: [FLINK-4652] [streaming connectors] Automatically ...

2016-10-14 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2635 [FLINK-4652] [streaming connectors] Automatically refresh AWS credentials By using the credentials explicitly we are responsible for checking and refreshing credentials before they expire. If no

[jira] [Resolved] (FLINK-4706) Is there a way to load user classes first?

2016-10-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-4706. --- Resolution: Not A Problem > Is there a way to load user classes first? >

[jira] [Commented] (FLINK-4564) [metrics] Delimiter should be configured per reporter

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

[jira] [Closed] (FLINK-4564) [metrics] Delimiter should be configured per reporter

2016-10-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4564. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented in

[GitHub] flink pull request #2633: [FLINK-4497] CassadraSink support for scala tuples...

2016-10-14 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2633 [FLINK-4497] CassadraSink support for scala tuples/case classes This PR adds support for scala tuples/case classes to the streaming at-least-once-sink. If this pattern works we can extend it to

[jira] [Commented] (FLINK-4497) Add support for Scala tuples and case classes to Cassandra sink

2016-10-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575138#comment-15575138 ] ASF GitHub Bot commented on FLINK-4497: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-4221) Show metrics in WebFrontend

2016-10-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575212#comment-15575212 ] Robert Metzger commented on FLINK-4221: --- I assigned the issue to myself, however, [~Zentol] and

[jira] [Assigned] (FLINK-4221) Show metrics in WebFrontend

2016-10-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4221: - Assignee: Robert Metzger > Show metrics in WebFrontend > --- > >

[GitHub] flink pull request #:

2016-10-14 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/commit/a612b9966f3ee020a5721ac2f039a3633c40146c#commitcomment-19427630 In flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java: In

[jira] [Updated] (FLINK-4315) Remove Hadoop Dependency from flink-java

2016-10-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-4315: - Issue Type: Task (was: Sub-task) Parent: (was: FLINK-3957) > Remove Hadoop

[GitHub] flink pull request #2517: [FLINK-4564] [metrics] Delimiter should be configu...

2016-10-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2517 --- 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 #2613: [FLINK-4774] [metrics] [hotfix] Fix scope concaten...

2016-10-14 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/2613 --- 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-4774) QueryScopeInfo scope concatenation broken

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

[jira] [Closed] (FLINK-4774) QueryScopeInfo scope concatenation broken

2016-10-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4774. --- Resolution: Fixed Fixed in 9948d48443460a881eb79983f586c7bd18201674 > QueryScopeInfo scope

  1   2   >