[jira] [Commented] (FLINK-5031) Consecutive DataStream.split() ignored

2016-11-14 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15666015#comment-15666015 ] Renkai Ge commented on FLINK-5031: -- I want to work on this issue > Consecutive DataStrea

[jira] [Assigned] (FLINK-5031) Consecutive DataStream.split() ignored

2016-11-14 Thread Renkai Ge (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renkai Ge reassigned FLINK-5031: Assignee: Renkai Ge > Consecutive DataStream.split() ignored >

[jira] [Commented] (FLINK-4900) Implement Docker image support

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15665739#comment-15665739 ] ASF GitHub Bot commented on FLINK-4900: --- Github user mxm commented on the issue:

[GitHub] flink issue #2703: [FLINK-4900] flink-master: Allow to deploy TM with contai...

2016-11-14 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2703 I'll merge the changes once the comments have been addressed. --- 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-4900) Implement Docker image support

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15665737#comment-15665737 ] ASF GitHub Bot commented on FLINK-4900: --- Github user mxm commented on the issue:

[GitHub] flink issue #2703: [FLINK-4900] flink-master: Allow to deploy TM with contai...

2016-11-14 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2703 It is easier for the review process when you push fixups commits to pull requests. Usually we fixup the commits when merging to master. --- If your project is set up for it, you can reply to this email

[GitHub] flink issue #2740: [FLINK-4964] [ml]

2016-11-14 Thread tfournier314
Github user tfournier314 commented on the issue: https://github.com/apache/flink/pull/2740 @greghogan I've not pushed the code yet because my tests are still incorrect. Indeed the following code: val env = ExecutionEnvironment.getExecutionEnvironment val fitData = env

[jira] [Commented] (FLINK-4964) FlinkML - Add StringIndexer

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15665260#comment-15665260 ] ASF GitHub Bot commented on FLINK-4964: --- Github user tfournier314 commented on the i

[GitHub] flink pull request #2805: Flink 5059

2016-11-14 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2805#discussion_r87900573 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -586,7 +588,18 @@ private boolean performCheckpoi

[jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15665134#comment-15665134 ] ASF GitHub Bot commented on FLINK-3680: --- Github user mushketyk commented on the issu

[GitHub] flink issue #2457: [FLINK-3680][web frontend] Remove "(not set)" text in the...

2016-11-14 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2457 @iampeter @greghogan I've update the PR according to your 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 doe

[jira] [Commented] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent

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

[GitHub] flink issue #2805: Flink 5059

2016-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2805 Please adjust the PR title to the following format: [FLINK-5059] , this allows the mirroring of comments made here to JIRA. --- If your project is set up for it, you can reply to this email and have y

[jira] [Commented] (FLINK-5066) prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only

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

[GitHub] flink pull request #2806: [FLINK-5066] Prevent LocalInputChannel#getNextBuff...

2016-11-14 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/2806 [FLINK-5066] Prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only LocalInputChannel#getNextBuffer de-serialises all incoming events on the

[GitHub] flink pull request #2805: Flink 5059

2016-11-14 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/2805 Flink 5059 Only serialise events once in RecordWriter#broadcastEvent. While adapting this, also clean up some related APIs which is now unused or used similar patterns. You can merge this pu

[jira] [Commented] (FLINK-5067) Make Flink compile with 1.8 Java compiler

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

[GitHub] flink pull request #2804: [FLINK-5067] Make Flink compile with 1.8 Java comp...

2016-11-14 Thread melentye
GitHub user melentye opened a pull request: https://github.com/apache/flink/pull/2804 [FLINK-5067] Make Flink compile with 1.8 Java compiler - New type inference rules changed which overloaded methods are picked. - Renamed java.version property in maven to java.minor.version. Thi

[jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664960#comment-15664960 ] ASF GitHub Bot commented on FLINK-3680: --- Github user iampeter commented on the issue

[GitHub] flink issue #2457: [FLINK-3680][web frontend] Remove "(not set)" text in the...

2016-11-14 Thread iampeter
Github user iampeter commented on the issue: https://github.com/apache/flink/pull/2457 @greghogan right - missed the generated files. @mushketyk I suppose `gulp`ing will help --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[jira] [Created] (FLINK-5067) Make Flink compile with 1.8 Java compiler

2016-11-14 Thread Andrey Melentyev (JIRA)
Andrey Melentyev created FLINK-5067: --- Summary: Make Flink compile with 1.8 Java compiler Key: FLINK-5067 URL: https://issues.apache.org/jira/browse/FLINK-5067 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-4174) Enhance Window Evictor

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664856#comment-15664856 ] ASF GitHub Bot commented on FLINK-4174: --- Github user soniclavier commented on the is

[GitHub] flink issue #2736: [FLINK-4174] Enhance evictor functionality

2016-11-14 Thread soniclavier
Github user soniclavier commented on the issue: https://github.com/apache/flink/pull/2736 @aljoscha made the changes as per your comments, could you please review it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If you

[jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664828#comment-15664828 ] ASF GitHub Bot commented on FLINK-3680: --- Github user greghogan commented on the issu

[GitHub] flink issue #2457: [FLINK-3680][web frontend] Remove "(not set)" text in the...

2016-11-14 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2457 1) `JsonPlanGenerator.java:55` should be reverted to use `NOT_SET`. 2) `index.js` is changing jobServer from the empty string to 'http://localhost:8081/'. 3) `vendor.js` is upgrading the ver

[jira] [Updated] (FLINK-5051) Backwards compatibility for serializers in backend state

2016-11-14 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-5051: -- Description: When a new state is register, e.g. in a keyed backend via `getPartitionedState`, t

[jira] [Updated] (FLINK-5051) Backwards compatibility for serializers in backend state

2016-11-14 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-5051: -- Description: When a new state is register, e.g. in a keyed backend via `getPartitionedState`, t

[jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664767#comment-15664767 ] ASF GitHub Bot commented on FLINK-3680: --- Github user iampeter commented on the issue

[GitHub] flink issue #2457: [FLINK-3680][web frontend] Remove "(not set)" text in the...

2016-11-14 Thread iampeter
Github user iampeter commented on the issue: https://github.com/apache/flink/pull/2457 @mushketyk from my side looks good --- 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

[jira] [Commented] (FLINK-4913) Per-job Yarn clusters: include user jar in system class loader

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664737#comment-15664737 ] ASF GitHub Bot commented on FLINK-4913: --- Github user mxm commented on the issue:

[GitHub] flink issue #2795: Revert "[FLINK-4913][yarn] include user jars in system cl...

2016-11-14 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2795 Thanks for the PR @uce! Could you explain how the user would retrieve the user class loader to load classes during runtime? Is the user class loader exposed to the user? --- If your project is set up f

[jira] [Commented] (FLINK-4964) FlinkML - Add StringIndexer

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664652#comment-15664652 ] ASF GitHub Bot commented on FLINK-4964: --- Github user greghogan commented on a diff i

[jira] [Commented] (FLINK-4964) FlinkML - Add StringIndexer

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664651#comment-15664651 ] ASF GitHub Bot commented on FLINK-4964: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #2740: [FLINK-4964] [ml]

2016-11-14 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2740#discussion_r87860878 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StringIndexer.scala --- @@ -0,0 +1,108 @@ +package org.apache.flink

[GitHub] flink pull request #2740: [FLINK-4964] [ml]

2016-11-14 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2740#discussion_r87863825 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StringIndexer.scala --- @@ -0,0 +1,108 @@ +package org.apache.flink

[jira] [Created] (FLINK-5066) prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only

2016-11-14 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5066: -- Summary: prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only Key: FLINK-5066 URL: https://issues.apache.org/jira/browse/FL

[GitHub] flink pull request #2736: [FLINK-4174] Enhance evictor functionality

2016-11-14 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2736#discussion_r87862442 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/TimestampedValue.java --- @@ -18,28 +18,77 @@ packa

[jira] [Commented] (FLINK-4174) Enhance Window Evictor

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664629#comment-15664629 ] ASF GitHub Bot commented on FLINK-4174: --- Github user aljoscha commented on a diff in

[jira] [Created] (FLINK-5065) Resource leaks in case of lost checkpoint messages

2016-11-14 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5065: Summary: Resource leaks in case of lost checkpoint messages Key: FLINK-5065 URL: https://issues.apache.org/jira/browse/FLINK-5065 Project: Flink Issue Type:

[jira] [Created] (FLINK-5064) Checkpoint messages are not scoped to the leader session ID

2016-11-14 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5064: Summary: Checkpoint messages are not scoped to the leader session ID Key: FLINK-5064 URL: https://issues.apache.org/jira/browse/FLINK-5064 Project: Flink Is

[jira] [Commented] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions

2016-11-14 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664452#comment-15664452 ] Greg Hogan commented on FLINK-5013: --- The parent POM enforces the Maven version but only

[GitHub] flink issue #2800: Update README.md

2016-11-14 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2800 Hi @bitchelov, I don't think we want to advertise the Travis CI status. Builds consistently fail, both due to Flink test instability and issues running on the Travis CI architecture. We test each c

[GitHub] flink issue #2800: Update README.md

2016-11-14 Thread bitchelov
Github user bitchelov commented on the issue: https://github.com/apache/flink/pull/2800 Hi @greghogan ! No, there is no Jira ticket for this PR. It made for convenience and as i said ( to do "README.md" file more informative). --- If your project is set up for it, you can reply to th

[jira] [Commented] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions

2016-11-14 Thread Craig Foster (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664360#comment-15664360 ] Craig Foster commented on FLINK-5013: - I can fix and verify on the EMR side but should

[GitHub] flink issue #2787: [FLINK-5013] [kinesis] Shade AWS dependencies to work wit...

2016-11-14 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2787 I agree that we should try to get this into the RC. +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 do

[jira] [Commented] (FLINK-5013) Flink Kinesis connector doesn't work on old EMR versions

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664349#comment-15664349 ] ASF GitHub Bot commented on FLINK-5013: --- Github user rmetzger commented on the issue

[jira] [Updated] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints

2016-11-14 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5063: - Description: In case that a {{Checkpoint}} is declined or expires, the {{CheckpointCoordinator}}

[jira] [Created] (FLINK-5063) State handles are not properly cleaned up for declined or expired checkpoints

2016-11-14 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5063: Summary: State handles are not properly cleaned up for declined or expired checkpoints Key: FLINK-5063 URL: https://issues.apache.org/jira/browse/FLINK-5063 Project:

[jira] [Assigned] (FLINK-4812) Export currentLowWatermark metric also for sources

2016-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4812: --- Assignee: Chesnay Schepler > Export currentLowWatermark metric also for sources > ---

[jira] [Updated] (FLINK-5062) Ensure that all created threads have a proper name

2016-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5062: Summary: Ensure that all created threads have a proper name (was: Ensure that all create th

[jira] [Created] (FLINK-5062) Ensure that all create threads have a proper name

2016-11-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5062: --- Summary: Ensure that all create threads have a proper name Key: FLINK-5062 URL: https://issues.apache.org/jira/browse/FLINK-5062 Project: Flink Issue T

[GitHub] flink issue #2800: Update README.md

2016-11-14 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2800 Is there a Jira ticket for 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 feature enable

[GitHub] flink pull request #2802: Minor fixes

2016-11-14 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2802#discussion_r87820837 --- Diff: docs/_includes/sidenav.html --- @@ -147,3 +147,4 @@ + --- End diff -- The div is closed on line 85. ---

[jira] [Closed] (FLINK-4527) Drop the "flinkAccumulators" from the Execution

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

[jira] [Commented] (FLINK-4920) Add a Scala Function Gauge

2016-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664157#comment-15664157 ] Chesnay Schepler commented on FLINK-4920: - Currently, in order to create a Gauge t

[jira] [Commented] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664097#comment-15664097 ] ASF GitHub Bot commented on FLINK-5017: --- Github user tzulitai commented on the issue

[GitHub] flink issue #2801: [FLINK-5017] [streaming] Introduce StreamStatus to facili...

2016-11-14 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2801 No problem @aljoscha, 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 an

[jira] [Updated] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

2016-11-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5002: - Assignee: Roman Maier > Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers > --

[GitHub] flink pull request #2803: [FLINK-5061] Remove ContinuousEventTimeTrigger

2016-11-14 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/2803 [FLINK-5061] Remove ContinuousEventTimeTrigger R: @StephanEwen for review You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink remove

[jira] [Commented] (FLINK-5061) Remove ContinuousEventTimeTrigger

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

[jira] [Created] (FLINK-5061) Remove ContinuousEventTimeTrigger

2016-11-14 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5061: --- Summary: Remove ContinuousEventTimeTrigger Key: FLINK-5061 URL: https://issues.apache.org/jira/browse/FLINK-5061 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #2802: Minor fixes

2016-11-14 Thread bitchelov
GitHub user bitchelov opened a pull request: https://github.com/apache/flink/pull/2802 Minor fixes Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the items into acco

[jira] [Commented] (FLINK-4460) Side Outputs in Flink

2016-11-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15664010#comment-15664010 ] Aljoscha Krettek commented on FLINK-4460: - Yup, this was one of the motivations fo

[GitHub] flink issue #2457: [FLINK-3680][web frontend] Remove "(not set)" text in the...

2016-11-14 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2457 Hi @iampeter I've updated the PR according to you suggestion. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project do

[jira] [Commented] (FLINK-3680) Remove or improve (not set) text in the Job Plan UI

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663996#comment-15663996 ] ASF GitHub Bot commented on FLINK-3680: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-4491) Handle index.number_of_shards in the ES connector

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663992#comment-15663992 ] ASF GitHub Bot commented on FLINK-4491: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2790: [FLINK-4491] Handle index.number_of_shards in the ...

2016-11-14 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2790#discussion_r87804804 --- Diff: flink-streaming-connectors/flink-connector-elasticsearch2/src/main/java/org/apache/flink/streaming/connectors/elasticsearch2/helper/ElasticSearchHelper.j

[GitHub] flink pull request #2756: [FLINK-4997] Extending Window Function Metadata

2016-11-14 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2756#discussion_r87801992 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -800,4 +907,39 @@ public StreamExecutionEn

[GitHub] flink pull request #2756: [FLINK-4997] Extending Window Function Metadata

2016-11-14 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2756#discussion_r87802539 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java --- @@ -459,7 +545,28 @@ public WindowedStream(Ke

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663971#comment-15663971 ] ASF GitHub Bot commented on FLINK-4997: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663970#comment-15663970 ] ASF GitHub Bot commented on FLINK-4997: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663953#comment-15663953 ] ASF GitHub Bot commented on FLINK-4883: --- Github user Renkai commented on the issue:

[GitHub] flink issue #2729: [FLINK-4883]Prevent UDFs implementations through Scala si...

2016-11-14 Thread Renkai
Github user Renkai commented on the issue: https://github.com/apache/flink/pull/2729 I'm not very understand why some function need to be cleaned while others are not in the last version of scala API, but I think all of them need to be checked, so I add some checks where has no cleans

[jira] [Resolved] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

2016-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler resolved FLINK-4177. - Resolution: Fixed Possibly resolved in 62523acbe175cf159fe1b4ab6cf5c0412fc4d232. > Cassan

[jira] [Closed] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

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

[jira] [Reopened] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

2016-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-4177: - > CassandraConnectorTest.testCassandraCommitter causing unstable builds >

[GitHub] flink pull request #2484: [FLINK-4177] Harden CassandraConnectorTest

2016-11-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2484 --- 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 enab

[jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

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

[jira] [Assigned] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

2016-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4177: --- Assignee: Chesnay Schepler > CassandraConnectorTest.testCassandraCommitter causing un

[jira] [Commented] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources

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

[GitHub] flink issue #2801: [FLINK-5017] [streaming] Introduce StreamStatus to facili...

2016-11-14 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2801 @tzulitai I won't have much time this week so will review this next week. --- 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 proj

[jira] [Created] (FLINK-5060) only serialise records once in RecordWriter#emit and RecordWriter#broadcastEmit

2016-11-14 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5060: -- Summary: only serialise records once in RecordWriter#emit and RecordWriter#broadcastEmit Key: FLINK-5060 URL: https://issues.apache.org/jira/browse/FLINK-5060 Project: Fl

[jira] [Closed] (FLINK-2839) Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics

2016-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2839. --- Resolution: Invalid Fix Version/s: 1.2.0 The operator-stats module was removed in FLINK

[jira] [Commented] (FLINK-4174) Enhance Window Evictor

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663902#comment-15663902 ] ASF GitHub Bot commented on FLINK-4174: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-4174) Enhance Window Evictor

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663901#comment-15663901 ] ASF GitHub Bot commented on FLINK-4174: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #2736: [FLINK-4174] Enhance evictor functionality

2016-11-14 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2736#discussion_r87798796 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/TimestampedValue.java --- @@ -18,28 +18,77 @@ packa

[GitHub] flink pull request #2736: [FLINK-4174] Enhance evictor functionality

2016-11-14 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2736#discussion_r87798657 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/TimestampedValue.java --- @@ -18,28 +18,77 @@ packa

[jira] [Created] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent

2016-11-14 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5059: -- Summary: only serialise events once in RecordWriter#broadcastEvent Key: FLINK-5059 URL: https://issues.apache.org/jira/browse/FLINK-5059 Project: Flink Issue Typ

[jira] [Commented] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

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

[GitHub] flink issue #2484: [FLINK-4177] Harden CassandraConnectorTest

2016-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2484 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 feat

[jira] [Closed] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

2016-11-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4939. --- Resolution: Fixed Implemented in 381bf5912237420b8e294c1fd38006a85403fd4f > GenericWriteAhead

[GitHub] flink pull request #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the c...

2016-11-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2707 --- 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 enab

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

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

[GitHub] flink pull request #2729: [FLINK-4883]Prevent UDFs implementations through S...

2016-11-14 Thread Renkai
Github user Renkai commented on a diff in the pull request: https://github.com/apache/flink/pull/2729#discussion_r87792198 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/ScalaObjectChecker.java --- @@ -0,0 +1,51 @@ +/* + * Licensed to the Apache Software Found

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663807#comment-15663807 ] ASF GitHub Bot commented on FLINK-4883: --- Github user Renkai commented on a diff in t

[GitHub] flink issue #2707: [FLINK-4939] GenericWriteAheadSink: Decouple the creating...

2016-11-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2707 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 feat

[jira] [Commented] (FLINK-4939) GenericWriteAheadSink: Decouple the creating from the committing subtask for a pending checkpoint

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

[GitHub] flink issue #2467: [FLINK-3719][web frontend] Moving the barrier between gra...

2016-11-14 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2467 Hi @iampeter I've updated the PR according to your 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

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663752#comment-15663752 ] ASF GitHub Bot commented on FLINK-3719: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-5017) Introduce WatermarkStatus stream element to allow for temporarily idle streaming sources

2016-11-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663719#comment-15663719 ] ASF GitHub Bot commented on FLINK-5017: --- Github user tzulitai commented on the issue

  1   2   >