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

2016-10-13 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572174#comment-15572174 ] Maximilian Michels commented on FLINK-2821: --- Just to add another option: - Apply the patch that

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

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

[jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

2016-10-13 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572274#comment-15572274 ] Maximilian Michels commented on FLINK-4824: --- I agree that we should differentiate here and print

[jira] [Commented] (FLINK-3037) Make the behavior of the Kafka consumer configurable if the offsets to restore from are not available

2016-10-13 Thread Cody Koeninger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572133#comment-15572133 ] Cody Koeninger commented on FLINK-3037: --- As a user, I want to be able to start low-value,

[jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572151#comment-15572151 ] Greg Hogan commented on FLINK-4824: --- {{WordCount}} should be able to convey to {{ClusterClient}} that

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

2016-10-13 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2386 I had an offline discussion with @aljoscha about this PR, and we decided to remove the `isSink` flag from the `AbstractStreamOperator`. I updated the PR. --- If your project is set up for it,

[jira] [Updated] (FLINK-4825) Implement a RexExecutor that uses Flink's code generation

2016-10-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4825: Description: The added {{ReduceExpressionRule}} leads to inconsistent behavior. Because some parts

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

2016-10-13 Thread Anton Mushin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572115#comment-15572115 ] Anton Mushin commented on FLINK-4604: - Sorry, I will try explain my problem. I have two tests

[GitHub] flink issue #2497: [FLINK-4339][cluster management] Implement Slot Pool core...

2016-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2497 Merged into the `flip-6` feature branch in 48c936eeda7b265f32bbf9f14d15f78eae15c06f --- 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-4339) Implement Slot Pool Core

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

[jira] [Commented] (FLINK-4576) Low Watermark Service in JobManager for Streaming Sources

2016-10-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572142#comment-15572142 ] Aljoscha Krettek commented on FLINK-4576: - Hi, first off, sorry for the late response, I was on

[jira] [Commented] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572160#comment-15572160 ] Greg Hogan commented on FLINK-4823: --- Adding \{code\} before and after this code block will format much

[jira] [Assigned] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-4824: - Assignee: Greg Hogan > CliFrontend shows misleading error message when main() method returns

[GitHub] flink issue #2624: [FLINK-4516] update leadership information in ResourceMan...

2016-10-13 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2624 Merged to `flip-6`. --- 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

[GitHub] flink pull request #2624: [FLINK-4516] update leadership information in Reso...

2016-10-13 Thread mxm
Github user mxm closed the pull request at: https://github.com/apache/flink/pull/2624 --- 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-4516) ResourceManager leadership election

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

[jira] [Resolved] (FLINK-4791) Fix issues caused by expression reduction

2016-10-13 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4791. - Resolution: Fixed Fix Version/s: 1.2.0 Temporarily fixed by disabling the rule in

[jira] [Commented] (FLINK-4516) ResourceManager leadership election

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

[GitHub] flink issue #2588: [FLINK-4735] [cluster management] Migrate some job execut...

2016-10-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2588 Merged to the `flip-6` feature branch in 34fef4752e94b3d0c7afe7a9525799bb651a07b4 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-4735) Migrate some job execution related akka messages to rpc calls

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

[jira] [Commented] (FLINK-4691) Add group-windows for streaming tables

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

[GitHub] flink issue #2562: [FLINK-4691] [table] Add group-windows for streaming tabl...

2016-10-13 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2562 @fhueske I updated the PR. The only thing that is missing now are tests for the `DataStreamAggregate` class. I will add unit tests tomorrow. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-4129) HITSAlgorithm should test for element-wise convergence

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572513#comment-15572513 ] Greg Hogan commented on FLINK-4129: --- [~vkalavri] what do you think we should do with this issue? This is

[jira] [Commented] (FLINK-1472) Web frontend config overview shows wrong value

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572753#comment-15572753 ] Greg Hogan commented on FLINK-1472: --- Building a registry of configuration options will be

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

2016-10-13 Thread Philipp von dem Bussche (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572639#comment-15572639 ] Philipp von dem Bussche commented on FLINK-2821: [~mxm] thats awesome ! That might work

[jira] [Updated] (FLINK-4117) Wait for CuratorFramework connection to be established

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4117: -- Description: Received the following error when locally running {{mvn verify}}. Searching on the error

[jira] [Commented] (FLINK-720) Forbid catching exceptions only with "e.printStackTrace()" using Checkstyle

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572652#comment-15572652 ] Greg Hogan commented on FLINK-720: -- Are we still looking to add this check? > Forbid catching exceptions

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

2016-10-13 Thread Philipp von dem Bussche (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572723#comment-15572723 ] Philipp von dem Bussche commented on FLINK-2821: [~StephanEwen] yes more than happy to try

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

2016-10-13 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572364#comment-15572364 ] Maximilian Michels commented on FLINK-2821: --- Just out of fun, I actually tried that and got the

[jira] [Updated] (FLINK-4117) Wait for CuratorFramework connection to be established

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4117: -- Description: Received the following error when locally running {{mvn verify}}. Searching on the error

[jira] [Resolved] (FLINK-1936) Normalize keys and default values in ConfigConstants.java

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-1936. --- Resolution: Fixed > Normalize keys and default values in ConfigConstants.java >

[jira] [Resolved] (FLINK-2603) Flink hangs before starting execution

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-2603. --- Resolution: Not A Problem I believe this is due to a configured limit in the size of Akka messages as

[jira] [Resolved] (FLINK-4117) Wait for CuratorFramework connection to be established

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-4117. --- Resolution: Cannot Reproduce > Wait for CuratorFramework connection to be established >

[jira] [Commented] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572633#comment-15572633 ] Greg Hogan commented on FLINK-1890: --- Do we still want this documented or can we close this issue? > Add

[jira] [Resolved] (FLINK-787) Custom termination criterion in delta iteration

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-787. -- Resolution: Duplicate > Custom termination criterion in delta iteration >

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

2016-10-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572671#comment-15572671 ] Stephan Ewen commented on FLINK-2821: - That's pretty amazing. [~philipp.bussche] do you have the time

[jira] [Closed] (FLINK-2222) Memory/CPU graphs in web frontend are not well formatted using Chrome/Safari

2016-10-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-. --- Resolution: Invalid No longer valid as we no longer show graphs in the WebFrontend. >

[jira] [Commented] (FLINK-3302) Save Taskmanager Metrics per Job

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572952#comment-15572952 ] Greg Hogan commented on FLINK-3302: --- I recently closed the aforementioned FLINK-3263 since these

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

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

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

2016-10-13 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2630 [FLINK-4373] [cluster management] Introduce AllocationID, ResourceProfile, and AllocatedSlot These classes are introduced as part of the cluster management rework (FLIP-6) The

[jira] [Commented] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

2016-10-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572810#comment-15572810 ] Fabian Hueske commented on FLINK-1890: -- I'd keep the issue open. I'll add the starter tag to it.

[jira] [Closed] (FLINK-3302) Save Taskmanager Metrics per Job

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3302. - Resolution: Not A Problem > Save Taskmanager Metrics per Job > > >

[jira] [Resolved] (FLINK-2024) Table API mentioned only in Batch in documentation site

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-2024. --- Resolution: Fixed This is fixed in the 1.1 and 1.2-SNAPSHOT documentation currently linked to from

[jira] [Commented] (FLINK-2222) Memory/CPU graphs in web frontend are not well formatted using Chrome/Safari

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572830#comment-15572830 ] Greg Hogan commented on FLINK-: --- Is this fixed since we no longer have memory/CPU graphs? And

[jira] [Commented] (FLINK-3302) Save Taskmanager Metrics per Job

2016-10-13 Thread Pieter Hameete (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573012#comment-15573012 ] Pieter Hameete commented on FLINK-3302: --- Hi Greg, I haven't used Flink for a while but the new

[jira] [Commented] (FLINK-2247) Improve the way memory is reported in the web frontend

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572863#comment-15572863 ] Greg Hogan commented on FLINK-2247: --- It doesn't look like these warnings are present in the new web

[jira] [Closed] (FLINK-2223) Web frontend shows wrong accumulator results for latest job

2016-10-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2223. --- Resolution: Invalid > Web frontend shows wrong accumulator results for latest job >

[jira] [Resolved] (FLINK-4188) Support for outer joins on DataStream

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan resolved FLINK-4188. --- Resolution: Duplicate > Support for outer joins on DataStream > -

[jira] [Commented] (FLINK-2223) Web frontend shows wrong accumulator results for latest job

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572799#comment-15572799 ] Greg Hogan commented on FLINK-2223: --- Is this still an issue? > Web frontend shows wrong accumulator

[jira] [Closed] (FLINK-2247) Improve the way memory is reported in the web frontend

2016-10-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2247. --- Resolution: Invalid We no longer show such warnings in the WebFrontend. We are also showing

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

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

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

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

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

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

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

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

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

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

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

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83288193 --- 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-4771) Compression for AvroOutputFormat

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

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

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2612#discussion_r83290431 --- 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-4370) Offer a default IntelliJ inspection profile with Flink

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15573068#comment-15573068 ] Greg Hogan commented on FLINK-4370: --- [~StephanEwen] have you discovered a third way? Our options so far

[jira] [Updated] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

2016-10-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1890: - Labels: starter (was: ) > Add note to docs that ReadFields annotations are currently not

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

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

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83310338 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83308572 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83310395 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83308865 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[jira] [Created] (FLINK-4826) Add keytab based kerberos support to run Flink in Mesos environment

2016-10-13 Thread Vijay Srinivasaraghavan (JIRA)
Vijay Srinivasaraghavan created FLINK-4826: -- Summary: Add keytab based kerberos support to run Flink in Mesos environment Key: FLINK-4826 URL: https://issues.apache.org/jira/browse/FLINK-4826

[jira] [Updated] (FLINK-4826) Add keytab based kerberos support in Mesos environment

2016-10-13 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan updated FLINK-4826: --- Summary: Add keytab based kerberos support in Mesos environment (was: Add

[jira] [Updated] (FLINK-4826) Add keytab based kerberos support for Mesos environment

2016-10-13 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan updated FLINK-4826: --- Summary: Add keytab based kerberos support for Mesos environment (was: Add

[jira] [Updated] (FLINK-4826) Add keytab based kerberos support to run Flink in Mesos environment

2016-10-13 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan updated FLINK-4826: --- Summary: Add keytab based kerberos support to run Flink in Mesos environment

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319240 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319026 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318311 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

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

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319036 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Closed] (FLINK-4561) replace all the scala version as a `scala.binary.version` property

2016-10-13 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4561. - Resolution: Won't Fix > replace all the scala version as a `scala.binary.version` property >

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318228 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318661 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83310436 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83318300 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83316946 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala --- @@ -224,45 +224,95 @@ class KeyedStream[T,

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83319084 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala --- @@ -362,38 +362,84 @@ class WindowedStream[T,

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy

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

[GitHub] flink pull request #1975: [FLINK-2184] Cannot get last element with maxBy/mi...

2016-10-13 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1975#discussion_r83309671 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala --- @@ -361,38 +361,84 @@ class

[jira] [Commented] (FLINK-3932) Implement State Backend Security

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

[GitHub] flink issue #2589: FLINK-3932 State Backend Security

2016-10-13 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2589 Are we waiting for any additional review? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Comment Edited] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value

2016-10-13 Thread Sajeev Ramakrishnan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15571746#comment-15571746 ] Sajeev Ramakrishnan edited comment on FLINK-4823 at 10/14/16 5:16 AM: --

  1   2   >