[jira] [Created] (FLINK-2153) Exclude dependency on hbase annotations module

Márton Balassi created FLINK-2153: - Summary: Exclude dependency on hbase annotations module Key: FLINK-2153 URL: https://issues.apache.org/jira/browse/FLINK-2153 Project: Flink Issue Type

[jira] [Assigned] (FLINK-2139) Test Streaming Outputformats

[ https://issues.apache.org/jira/browse/FLINK-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2139: - Assignee: Márton Balassi > Test Streaming Outputform

[jira] [Assigned] (FLINK-2153) Exclude dependency on hbase annotations module

[ https://issues.apache.org/jira/browse/FLINK-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2153: - Assignee: Márton Balassi > Exclude dependency on hbase annotations mod

[jira] [Updated] (FLINK-2153) Exclude dependency on hbase annotations module

[ https://issues.apache.org/jira/browse/FLINK-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2153: -- Assignee: Lokesh Rajaram (was: Márton Balassi) > Exclude dependency on hbase annotati

[jira] [Created] (FLINK-2154) ActiveTriggerPolicy collects elements to a closed buffer after job finishes

Márton Balassi created FLINK-2154: - Summary: ActiveTriggerPolicy collects elements to a closed buffer after job finishes Key: FLINK-2154 URL: https://issues.apache.org/jira/browse/FLINK-2154 Project

[jira] [Assigned] (FLINK-2002) Iterative test fails when ran with other tests in the same environment

[ https://issues.apache.org/jira/browse/FLINK-2002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2002: - Assignee: Márton Balassi > Iterative test fails when ran with other tests in the s

[jira] [Commented] (FLINK-2002) Iterative test fails when ran with other tests in the same environment

[ https://issues.apache.org/jira/browse/FLINK-2002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14574199#comment-14574199 ] Márton Balassi commented on FLINK-2002: --- [~gyfora] has already fixed this,

[jira] [Commented] (FLINK-2153) Exclude dependency on hbase annotations module

[ https://issues.apache.org/jira/browse/FLINK-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14574688#comment-14574688 ] Márton Balassi commented on FLINK-2153: --- I would like to ask you to try do i

[jira] [Assigned] (FLINK-2153) Exclude dependency on hbase annotations module

[ https://issues.apache.org/jira/browse/FLINK-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2153: - Assignee: Márton Balassi (was: Lokesh Rajaram) > Exclude dependency on hb

[jira] [Commented] (FLINK-2153) Exclude dependency on hbase annotations module

[ https://issues.apache.org/jira/browse/FLINK-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14574736#comment-14574736 ] Márton Balassi commented on FLINK-2153: --- Thanks for the quick feedback. >

[jira] [Created] (FLINK-2172) Stabilize SocketOutputFormatTest

Márton Balassi created FLINK-2172: - Summary: Stabilize SocketOutputFormatTest Key: FLINK-2172 URL: https://issues.apache.org/jira/browse/FLINK-2172 Project: Flink Issue Type: Test

[jira] [Closed] (FLINK-2139) Test Streaming Outputformats

[ https://issues.apache.org/jira/browse/FLINK-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2139. - Resolution: Implemented Implemented via f72e5c8 > Test Streaming Outputform

[jira] [Commented] (FLINK-2136) Test the streaming scala API

[ https://issues.apache.org/jira/browse/FLINK-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14575795#comment-14575795 ] Márton Balassi commented on FLINK-2136: --- Merged the first PR, please add

[jira] [Closed] (FLINK-2069) writeAsCSV function in DataStream Scala API creates no file

[ https://issues.apache.org/jira/browse/FLINK-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2069. - Resolution: Fixed Assignee: Márton Balassi This is already fixed and tested on master

[jira] [Created] (FLINK-2180) Streaming iterate test fails spuriously

Márton Balassi created FLINK-2180: - Summary: Streaming iterate test fails spuriously Key: FLINK-2180 URL: https://issues.apache.org/jira/browse/FLINK-2180 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-2180) Streaming iterate test fails spuriously

[ https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-2180: Assignee: Gábor Hermann > Streaming iterate test fails spuriou

[jira] [Closed] (FLINK-2080) Execute Flink with sbt

[ https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2080. - Resolution: Fixed Fix Version/s: 0.9 Implemented via 3e9af82. > Execute Flink with

[jira] [Closed] (FLINK-2153) Exclude dependency on hbase annotations module

[ https://issues.apache.org/jira/browse/FLINK-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2153. - Resolution: Fixed Implemented via 1484e00 > Exclude dependency on hbase annotations mod

[jira] [Commented] (FLINK-2180) Streaming iterate test fails spuriously

[ https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14576968#comment-14576968 ] Gábor Hermann commented on FLINK-2180: -- I could only reproduce this with sleepin

[jira] [Commented] (FLINK-2180) Streaming iterate test fails spuriously

[ https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14577109#comment-14577109 ] Márton Balassi commented on FLINK-2180: --- Usually in similar situations si

[jira] [Commented] (FLINK-2180) Streaming iterate test fails spuriously

[ https://issues.apache.org/jira/browse/FLINK-2180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14577169#comment-14577169 ] Gábor Hermann commented on FLINK-2180: -- Okay, thank you. I will try and imple

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

Gábor Hermann created FLINK-2184: Summary: Cannot get last element with maxBy/minBy Key: FLINK-2184 URL: https://issues.apache.org/jira/browse/FLINK-2184 Project: Flink Issue Type

[jira] [Assigned] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

[ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2191: - Assignee: Márton Balassi > Inconsistent use of Closure Cleaner in Streaming

[jira] [Closed] (FLINK-2182) Add stateful Streaming Sequence Source

[ https://issues.apache.org/jira/browse/FLINK-2182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2182. - Resolution: Fixed Fix Version/s: 0.10 Implemented via 31d3eaa > Add stateful Stream

[jira] [Closed] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails

[ https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2192. - Resolution: Duplicate This is a duplicate of FLINK-2180

[jira] [Commented] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails

[ https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14580293#comment-14580293 ] Márton Balassi commented on FLINK-2192: --- It is a duplicate, because the fai

[jira] [Created] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

Philipp Götze created FLINK-2200: Summary: Flink API with Scala 2.11 - Maven Repository Key: FLINK-2200 URL: https://issues.apache.org/jira/browse/FLINK-2200 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-2201) Inconsistent use of ClosureCleaner in streaming window helpers

Márton Balassi created FLINK-2201: - Summary: Inconsistent use of ClosureCleaner in streaming window helpers Key: FLINK-2201 URL: https://issues.apache.org/jira/browse/FLINK-2201 Project: Flink

[jira] [Closed] (FLINK-2191) Inconsistent use of Closure Cleaner in Streaming API

[ https://issues.apache.org/jira/browse/FLINK-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2191. - Resolution: Fixed Fix Version/s: 0.9 Implemented via e2304c4. Minor issue remains, tracked

[jira] [Commented] (FLINK-1877) Stalled Flink on Tez build

[ https://issues.apache.org/jira/browse/FLINK-1877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14582454#comment-14582454 ] André Kelpe commented on FLINK-1877: It might be https://issues.apache.org/

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14583126#comment-14583126 ] Márton Balassi commented on FLINK-2209: --- I suggest including the first three in

[jira] [Assigned] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2209: - Assignee: Márton Balassi > Document how to use TableAPI, Gelly and Flin

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14583323#comment-14583323 ] Márton Balassi commented on FLINK-2209: --- Ok, agreed at least for now. Adding

[jira] [Commented] (FLINK-2208) Build error for Java IBM

[ https://issues.apache.org/jira/browse/FLINK-2208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14584610#comment-14584610 ] Johannes Günther commented on FLINK-2208: - My first guess is that the IBM JD

[jira] [Created] (FLINK-2211) Generalize ALS API

Ronny Bräunlich created FLINK-2211: -- Summary: Generalize ALS API Key: FLINK-2211 URL: https://issues.apache.org/jira/browse/FLINK-2211 Project: Flink Issue Type: Bug Components

[jira] [Closed] (FLINK-2002) Iterative test fails when ran with other tests in the same environment

[ https://issues.apache.org/jira/browse/FLINK-2002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2002. - Resolution: Fixed Fix Version/s: 0.9 > Iterative test fails when ran with other tests

[jira] [Commented] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14585246#comment-14585246 ] Márton Balassi commented on FLINK-2209: --- I think this is more cluster execu

[jira] [Commented] (FLINK-2221) Checkpoints to "file://" are not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586078#comment-14586078 ] Márton Balassi commented on FLINK-2221: --- So the current architecture has

[jira] [Commented] (FLINK-2221) Checkpoints to "file://" are not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586134#comment-14586134 ] Márton Balassi commented on FLINK-2221: --- We can go down the check and retry r

[jira] [Commented] (FLINK-2221) Checkpoints to "file://" are not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586135#comment-14586135 ] Márton Balassi commented on FLINK-2221: --- We can go down the check and retry r

[jira] [Issue Comment Deleted] (FLINK-2221) Checkpoints to "file://" are not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2221: -- Comment: was deleted (was: We can go down the check and retry route, but as it is distributed

[jira] [Commented] (FLINK-2221) Checkpoints to "file://" are not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586149#comment-14586149 ] Márton Balassi commented on FLINK-2221: --- After a bit more careful consideration

[jira] [Commented] (FLINK-2221) Checkpoints to "file://" are not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586148#comment-14586148 ] Márton Balassi commented on FLINK-2221: --- After a bit more careful consideration

[jira] [Issue Comment Deleted] (FLINK-2221) Checkpoints to "file://" are not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2221: -- Comment: was deleted (was: After a bit more careful consideration and checking other parts of

[jira] [Commented] (FLINK-2221) Checkpoints to "file://" are not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586154#comment-14586154 ] Márton Balassi commented on FLINK-2221: --- Ok, so for the release I am adding

[jira] [Commented] (FLINK-2211) Generalize ALS API

[ https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14586536#comment-14586536 ] Ronny Bräunlich commented on FLINK-2211: Sure, why not ;) > Generalize

[jira] [Commented] (FLINK-2232) StormWordCountLocalITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587677#comment-14587677 ] Márton Balassi commented on FLINK-2232: --- The root cause seems to be a connec

[jira] [Closed] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2209. - Resolution: Implemented Implemented via be50795. > Document how to use TableAPI, Gelly

[jira] [Commented] (FLINK-2221) Checkpoints to "file://" are not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14587883#comment-14587883 ] Márton Balassi commented on FLINK-2221: --- A documentation for 0.9 has been pu

[jira] [Commented] (FLINK-2211) Generalize ALS API

[ https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14588562#comment-14588562 ] Ronny Bräunlich commented on FLINK-2211: Hey people, I have a small (big, m

[jira] [Commented] (FLINK-2211) Generalize ALS API

[ https://issues.apache.org/jira/browse/FLINK-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14589562#comment-14589562 ] Ronny Bräunlich commented on FLINK-2211: I guess then we can close this issu

[jira] [Commented] (FLINK-2232) StormWordCountLocalITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14591586#comment-14591586 ] Márton Balassi commented on FLINK-2232: --- Merged a commit from [~mjsax] increa

[jira] [Created] (FLINK-2243) Add finite spout functionality to Storm compatibility layer

Péter Szabó created FLINK-2243: -- Summary: Add finite spout functionality to Storm compatibility layer Key: FLINK-2243 URL: https://issues.apache.org/jira/browse/FLINK-2243 Project: Flink Issue

[jira] [Created] (FLINK-2256) Handling Broker failures on the KafkaSink side

Márton Balassi created FLINK-2256: - Summary: Handling Broker failures on the KafkaSink side Key: FLINK-2256 URL: https://issues.apache.org/jira/browse/FLINK-2256 Project: Flink Issue Type

[jira] [Created] (FLINK-2257) Open and close of RichWindowFunctions is not called

Márton Balassi created FLINK-2257: - Summary: Open and close of RichWindowFunctions is not called Key: FLINK-2257 URL: https://issues.apache.org/jira/browse/FLINK-2257 Project: Flink Issue

[jira] [Created] (FLINK-2263) ExecutionGraph uses Thread.sleep to delay execution retries

Márton Balassi created FLINK-2263: - Summary: ExecutionGraph uses Thread.sleep to delay execution retries Key: FLINK-2263 URL: https://issues.apache.org/jira/browse/FLINK-2263 Project: Flink

[jira] [Assigned] (FLINK-2209) Document how to use TableAPI, Gelly and FlinkML, StreamingConnectors on a cluster

[ https://issues.apache.org/jira/browse/FLINK-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2209: - Assignee: Márton Balassi > Document how to use TableAPI, Gelly and Flin

[jira] [Closed] (FLINK-2255) In the TopSpeedWindowing examples, every window contains only 1 element, because event time is in millisec, but eviction is in sec

[ https://issues.apache.org/jira/browse/FLINK-2255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2255. - Resolution: Fixed Fix Version/s: 0.10 Fixed via af05b94d0d > In the TopSpeedWindow

[jira] [Assigned] (FLINK-2138) PartitionCustom for streaming

[ https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-2138: Assignee: Gábor Hermann > PartitionCustom for stream

[jira] [Assigned] (FLINK-2285) Active policy emits elements of the last window twice

[ https://issues.apache.org/jira/browse/FLINK-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2285: - Assignee: Márton Balassi > Active policy emits elements of the last window tw

[jira] [Created] (FLINK-2285) Active policy emits elements of the last window twice

Márton Balassi created FLINK-2285: - Summary: Active policy emits elements of the last window twice Key: FLINK-2285 URL: https://issues.apache.org/jira/browse/FLINK-2285 Project: Flink Issue

[jira] [Created] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window

Márton Balassi created FLINK-2286: - Summary: Window ParallelMerge sometimes swallows elements of the last window Key: FLINK-2286 URL: https://issues.apache.org/jira/browse/FLINK-2286 Project: Flink

[jira] [Created] (FLINK-2303) Add count method to GroupedDataStream

Gábor Hermann created FLINK-2303: Summary: Add count method to GroupedDataStream Key: FLINK-2303 URL: https://issues.apache.org/jira/browse/FLINK-2303 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-2303) Add count method to GroupedDataStream

[ https://issues.apache.org/jira/browse/FLINK-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-2303: Assignee: Gábor Hermann > Add count method to GroupedDataStr

[jira] [Commented] (FLINK-2303) Add count method to GroupedDataStream

[ https://issues.apache.org/jira/browse/FLINK-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14610412#comment-14610412 ] Gábor Hermann commented on FLINK-2303: -- Okay, I will mark it as not an issue. &

[jira] [Resolved] (FLINK-2303) Add count method to GroupedDataStream

[ https://issues.apache.org/jira/browse/FLINK-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann resolved FLINK-2303. -- Resolution: Not A Problem > Add count method to GroupedDataStr

[jira] [Assigned] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window

[ https://issues.apache.org/jira/browse/FLINK-2286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gábor Hermann reassigned FLINK-2286: Assignee: Gábor Hermann (was: Márton Balassi) > Window ParallelMerge sometimes swall

[jira] [Resolved] (FLINK-2285) Active policy emits elements of the last window twice

[ https://issues.apache.org/jira/browse/FLINK-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi resolved FLINK-2285. --- Resolution: Fixed Fixed via 6c21862. > Active policy emits elements of the last window tw

[jira] [Reopened] (FLINK-2152) Provide zipWithIndex utility in flink-contrib

[ https://issues.apache.org/jira/browse/FLINK-2152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Günther reopened FLINK-2152: - When Using zip with index in a longer running job the following error occurs

[jira] [Updated] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

[ https://issues.apache.org/jira/browse/FLINK-2446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2446: -- Affects Version/s: (was: 0.8.1) 0.10 > SocketTextStreamFunction

[jira] [Assigned] (FLINK-2423) Properly test checkpoint notifications

[ https://issues.apache.org/jira/browse/FLINK-2423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2423: - Assignee: Márton Balassi > Properly test checkpoint notificati

[jira] [Closed] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server

[ https://issues.apache.org/jira/browse/FLINK-2446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2446. - Resolution: Fixed Fix Version/s: 0.10 Fixed via b0f2379. > SocketTextStreamFunction

[jira] [Updated] (FLINK-2468) StreamCheckpointingITCase failure

[ https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2468: -- Component/s: Tests Streaming > StreamCheckpointingITCase fail

[jira] [Commented] (FLINK-2468) StreamCheckpointingITCase failure

[ https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653269#comment-14653269 ] Márton Balassi commented on FLINK-2468: --- These tests share the basic setup and

[jira] [Assigned] (FLINK-2468) StreamCheckpointingITCase failure

[ https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2468: - Assignee: Márton Balassi > StreamCheckpointingITCase fail

[jira] [Commented] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653271#comment-14653271 ] Márton Balassi commented on FLINK-2474: --- These tests share the basic setup and

[jira] [Assigned] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2474: - Assignee: Márton Balassi > Occasional failures in PartitionedStateCheckpointingITC

[jira] [Commented] (FLINK-2468) StreamCheckpointingITCase failure

[ https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653398#comment-14653398 ] Márton Balassi commented on FLINK-2468: --- [~StephanEwen] Sure, I am touching

[jira] [Commented] (FLINK-2468) StreamCheckpointingITCase failure

[ https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653479#comment-14653479 ] Márton Balassi commented on FLINK-2468: --- Fixed the oversight in [1], the ques

[jira] [Created] (FLINK-2481) Test at least once processing guarantee for streaming

Márton Balassi created FLINK-2481: - Summary: Test at least once processing guarantee for streaming Key: FLINK-2481 URL: https://issues.apache.org/jira/browse/FLINK-2481 Project: Flink Issue

[jira] [Updated] (FLINK-2481) Test at least once processing guarantee for streaming

[ https://issues.apache.org/jira/browse/FLINK-2481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2481: -- Issue Type: Test (was: Bug) > Test at least once processing guarantee for stream

[jira] [Created] (FLINK-2482) Document sreaming processing guarantees

Márton Balassi created FLINK-2482: - Summary: Document sreaming processing guarantees Key: FLINK-2482 URL: https://issues.apache.org/jira/browse/FLINK-2482 Project: Flink Issue Type: Bug

[jira] [Reopened] (FLINK-2464) BufferSpillerTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reopened FLINK-2464: --- Thanks for the fix, [~StephanEwen]. Unfortunately I still see tests of the `flink-streaming-core

[jira] [Closed] (FLINK-2243) Add finite spout functionality to Storm compatibility layer

[ https://issues.apache.org/jira/browse/FLINK-2243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2243. - Resolution: Implemented Via dba2946 & 6d9eeb5. > Add finite spout functionality t

[jira] [Commented] (FLINK-2493) Simplify names of example program JARs

[ https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14662462#comment-14662462 ] Márton Balassi commented on FLINK-2493: --- +1 It can be done by replacing

[jira] [Assigned] (FLINK-2491) Operators are not participating in state checkpointing in some cases

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2491: - Assignee: Márton Balassi > Operators are not participating in state checkpointing

[jira] [Updated] (FLINK-2491) Operators are not participating in state checkpointing in some cases

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2491: -- Fix Version/s: 0.10 > Operators are not participating in state checkpointing in some ca

[jira] [Closed] (FLINK-2423) Properly test checkpoint notifications

[ https://issues.apache.org/jira/browse/FLINK-2423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2423. - Resolution: Implemented Fix Version/s: 0.10 Via 10ce2e2. > Properly test checkpo

[jira] [Closed] (FLINK-2507) Rename the function tansformAndEmit in org.apache.flink.stormcompatibility.wrappers.AbstractStormCollector

[ https://issues.apache.org/jira/browse/FLINK-2507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-2507. - Resolution: Fixed Fix Version/s: 0.10 Via 54311aa. > Rename the function tansformAndE

[jira] [Commented] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14693282#comment-14693282 ] Márton Balassi commented on FLINK-2508: --- Thanks for spotting this, I think

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14693304#comment-14693304 ] Márton Balassi commented on FLINK-2491: --- This is troublesome, when setting

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14693387#comment-14693387 ] Márton Balassi commented on FLINK-2491: --- Here is the root cause. [1] [1] h

[jira] [Commented] (FLINK-2493) Simplify names of example program JARs

[ https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14694842#comment-14694842 ] Márton Balassi commented on FLINK-2493: --- Hey [~chenliang], please do not com

[jira] [Commented] (FLINK-2493) Simplify names of example program JARs

[ https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14694852#comment-14694852 ] Márton Balassi commented on FLINK-2493: --- Ok, fair enough then. > Simplify n

[jira] [Updated] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution.

[ https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2514: -- Fix Version/s: 0.10 > Local and Remote environment behave differently when re-trigger

[jira] [Assigned] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution.

[ https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2514: - Assignee: Márton Balassi > Local and Remote environment behave differently when

[jira] [Assigned] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-2508: - Assignee: Márton Balassi > Confusing sharing of StreamExecutionEnvironm

[jira] [Issue Comment Deleted] (FLINK-2491) Operators are not participating in state checkpointing in some cases

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2491: -- Comment: was deleted (was: Here is the root cause. [1] [1] https://github.com/apache/flink

[jira] [Updated] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution.

[ https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-2514: -- Assignee: Aljoscha Krettek (was: Márton Balassi) > Local and Remote environment beh

[jira] [Commented] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution.

[ https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14699252#comment-14699252 ] Márton Balassi commented on FLINK-2514: --- Cool, thanks. > Local and

<    2   3   4   5   6   7   8   9   10   11   >