[jira] [Commented] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug

[ https://issues.apache.org/jira/browse/FLINK-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15024059#comment-15024059 ] Gyula Fora commented on FLINK-3025: --- I am still getting the same issue after running int

[jira] [Commented] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE

[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15024061#comment-15024061 ] Gyula Fora commented on FLINK-3067: --- I wouldnt say that these two issues are the same. G

[jira] [Commented] (FLINK-3065) Can't cancel failing jobs

[ https://issues.apache.org/jira/browse/FLINK-3065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15024064#comment-15024064 ] Gyula Fora commented on FLINK-3065: --- A failing job that gets stuck (because one of the t

[jira] [Commented] (FLINK-3066) Kafka source fails on leader change

[ https://issues.apache.org/jira/browse/FLINK-3066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15024076#comment-15024076 ] Gyula Fora commented on FLINK-3066: --- I guess this is not critical as long as it doesnt h

[jira] [Resolved] (FLINK-2916) Add more context information for the StateBackend

[ https://issues.apache.org/jira/browse/FLINK-2916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2916. --- Resolution: Fixed https://github.com/gyfora/flink/commit/ad6f826584be7527c58e2126e2828f82afc97875 > A

[jira] [Resolved] (FLINK-2924) Create database state backend

[ https://issues.apache.org/jira/browse/FLINK-2924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2924. --- Resolution: Fixed > Create database state backend > - > >

[jira] [Resolved] (FLINK-2931) Add global recovery timestamp to state restore

[ https://issues.apache.org/jira/browse/FLINK-2931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-2931. --- Resolution: Fixed https://github.com/gyfora/flink/commit/c254bda3e84fcd9303f9a9e2a6f7a175d8e70d1e > A

[jira] [Commented] (FLINK-3065) Can't cancel failing jobs

[ https://issues.apache.org/jira/browse/FLINK-3065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15024184#comment-15024184 ] Gyula Fora commented on FLINK-3065: --- Thanks :) Btw maybe it would be worth to include th

[jira] [Assigned] (FLINK-3072) DbStateBackendTest

[ https://issues.apache.org/jira/browse/FLINK-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-3072: - Assignee: Gyula Fora > DbStateBackendTest > -- > > Key: FLINK-307

[jira] [Commented] (FLINK-3072) DbStateBackendTest

[ https://issues.apache.org/jira/browse/FLINK-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15024743#comment-15024743 ] Gyula Fora commented on FLINK-3072: --- This is weird, I haven't had this on any of my trav

[jira] [Commented] (FLINK-3072) DbStateBackendTest

[ https://issues.apache.org/jira/browse/FLINK-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15024751#comment-15024751 ] Gyula Fora commented on FLINK-3072: --- It seems like the derby server does not start prope

[jira] [Assigned] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods

[ https://issues.apache.org/jira/browse/FLINK-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-3075: - Assignee: Gyula Fora > Rename Either creation methods to avoid name clash with projection methods

[jira] [Updated] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods

[ https://issues.apache.org/jira/browse/FLINK-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-3075: -- Component/s: Java API > Rename Either creation methods to avoid name clash with projection methods > ---

[jira] [Created] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods

Gyula Fora created FLINK-3075: - Summary: Rename Either creation methods to avoid name clash with projection methods Key: FLINK-3075 URL: https://issues.apache.org/jira/browse/FLINK-3075 Project: Flink

[jira] [Resolved] (FLINK-3072) DbStateBackendTest

[ https://issues.apache.org/jira/browse/FLINK-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-3072. --- Resolution: Fixed > DbStateBackendTest > -- > > Key: FLINK-3072 >

[jira] [Commented] (FLINK-3072) DbStateBackendTest

[ https://issues.apache.org/jira/browse/FLINK-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15026700#comment-15026700 ] Gyula Fora commented on FLINK-3072: --- No problem :) > DbStateBackendTest > -

[jira] [Commented] (FLINK-3079) Add utility for measuring the raw read throughput from a Kafka topic

[ https://issues.apache.org/jira/browse/FLINK-3079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15026921#comment-15026921 ] Gyula Fora commented on FLINK-3079: --- Have you checked this project? https://github.com/

[jira] [Resolved] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods

[ https://issues.apache.org/jira/browse/FLINK-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-3075. --- Resolution: Fixed > Rename Either creation methods to avoid name clash with projection methods > -

[jira] [Created] (FLINK-3840) RocksDB local parent dir is polluted with empty folders with random names

Gyula Fora created FLINK-3840: - Summary: RocksDB local parent dir is polluted with empty folders with random names Key: FLINK-3840 URL: https://issues.apache.org/jira/browse/FLINK-3840 Project: Flink

[jira] [Created] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators

Gyula Fora created FLINK-3841: - Summary: RocksDB statebackend creates empty dbs for stateless operators Key: FLINK-3841 URL: https://issues.apache.org/jira/browse/FLINK-3841 Project: Flink Issue

[jira] [Commented] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators

[ https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262030#comment-15262030 ] Gyula Fora commented on FLINK-3841: --- I won't really have time to work on this until the

[jira] [Updated] (FLINK-3844) Checkpoint failures should not always lead to job failures

[ https://issues.apache.org/jira/browse/FLINK-3844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-3844: -- Description: Currently when a checkpoint fails the job crashes immediately. This is not the desired beha

[jira] [Created] (FLINK-3844) Checkpoint failures should not always lead to job failures

Gyula Fora created FLINK-3844: - Summary: Checkpoint failures should not always lead to job failures Key: FLINK-3844 URL: https://issues.apache.org/jira/browse/FLINK-3844 Project: Flink Issue Type

[jira] [Commented] (FLINK-3790) Rolling File sink does not pick up hadoop configuration

[ https://issues.apache.org/jira/browse/FLINK-3790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15263095#comment-15263095 ] Gyula Fora commented on FLINK-3790: --- Ah sorry, will try to fix it tomorrow if nobody did

[jira] [Created] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

Gyula Fora created FLINK-4038: - Summary: Impossible to set more than 1 JVM argument in env.java.opts Key: FLINK-4038 URL: https://issues.apache.org/jira/browse/FLINK-4038 Project: Flink Issue Ty

[jira] [Created] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments

Gyula Fora created FLINK-4039: - Summary: G1 garbage collector only set if no custom jvm arguments Key: FLINK-4039 URL: https://issues.apache.org/jira/browse/FLINK-4039 Project: Flink Issue Type:

[jira] [Created] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK

Gyula Fora created FLINK-4040: - Summary: Same env.java.opts is applied for TM , JM and ZK Key: FLINK-4040 URL: https://issues.apache.org/jira/browse/FLINK-4040 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK

[ https://issues.apache.org/jira/browse/FLINK-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-4040: -- Component/s: Start-Stop Scripts > Same env.java.opts is applied for TM , JM and ZK > ---

[jira] [Updated] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK

[ https://issues.apache.org/jira/browse/FLINK-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-4040: -- Fix Version/s: 1.1.0 > Same env.java.opts is applied for TM , JM and ZK > --

[jira] [Updated] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

[ https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-4038: -- Fix Version/s: 1.1.0 > Impossible to set more than 1 JVM argument in env.java.opts > ---

[jira] [Updated] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments

[ https://issues.apache.org/jira/browse/FLINK-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-4039: -- Fix Version/s: 1.1.0 > G1 garbage collector only set if no custom jvm arguments > --

[jira] [Commented] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

[ https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333822#comment-15333822 ] Gyula Fora commented on FLINK-4038: --- I feel that these issues are rather easy to solve o

[jira] [Commented] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

[ https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15333824#comment-15333824 ] Gyula Fora commented on FLINK-4038: --- Should I open a discussion thread on the mailing li

[jira] [Assigned] (FLINK-1003) Spread out scheduling strategy

[ https://issues.apache.org/jira/browse/FLINK-1003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-1003: - Assignee: Gyula Fora > Spread out scheduling strategy > -- > >

[jira] [Commented] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments

[ https://issues.apache.org/jira/browse/FLINK-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15342033#comment-15342033 ] Gyula Fora commented on FLINK-4039: --- I think the only reasonable solution I see would be

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

[ https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15342845#comment-15342845 ] Gyula Fora commented on FLINK-2313: --- Btw, do you have any thoughts on how should this be

[jira] [Closed] (FLINK-1196) Interfaces wrapping the persistence layer for source fault tolerance

[ https://issues.apache.org/jira/browse/FLINK-1196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1196. - Resolution: Invalid > Interfaces wrapping the persistence layer for source fault tolerance > -

[jira] [Resolved] (FLINK-1184) Streaming stateful computation support

[ https://issues.apache.org/jira/browse/FLINK-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1184. --- Resolution: Implemented > Streaming stateful computation support > ---

[jira] [Resolved] (FLINK-1641) Make projection operator chainable

[ https://issues.apache.org/jira/browse/FLINK-1641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1641. --- Resolution: Implemented > Make projection operator chainable > -- > >

[jira] [Closed] (FLINK-1192) Streaming source fault tolerance

[ https://issues.apache.org/jira/browse/FLINK-1192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1192. - Resolution: Invalid > Streaming source fault tolerance > > >

[jira] [Commented] (FLINK-1503) GSoC project: Batch and Streaming integration through new operators and unified API

[ https://issues.apache.org/jira/browse/FLINK-1503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14367368#comment-14367368 ] Gyula Fora commented on FLINK-1503: --- Hey, As you can probably tell from the description

[jira] [Resolved] (FLINK-1706) Add disk spilling to BarrierBuffer

[ https://issues.apache.org/jira/browse/FLINK-1706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1706. --- Resolution: Implemented > Add disk spilling to BarrierBuffer > -- > >

[jira] [Resolved] (FLINK-1618) Add parallel time discretisation for time-window transformations

[ https://issues.apache.org/jira/browse/FLINK-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1618. --- Resolution: Implemented > Add parallel time discretisation for time-window transformations >

[jira] [Resolved] (FLINK-1594) DataStreams don't support self-join

[ https://issues.apache.org/jira/browse/FLINK-1594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1594. --- Resolution: Fixed > DataStreams don't support self-join > --- > >

[jira] [Resolved] (FLINK-1715) Remove print statements in MultiEvictionPolicy and GroupedDataStream

[ https://issues.apache.org/jira/browse/FLINK-1715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1715. --- Resolution: Fixed https://github.com/apache/flink/commit/ac888b239936d146b1109eca8b9a193458cdaf9f > R

[jira] [Resolved] (FLINK-1757) java.lang.ClassCastException is thrown while summing Short values on window

[ https://issues.apache.org/jira/browse/FLINK-1757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1757. --- Resolution: Fixed https://github.com/apache/flink/commit/22e00655fa70a4986b87b1cde6f998b2baaf0507 > j

[jira] [Resolved] (FLINK-1740) StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries()

[ https://issues.apache.org/jira/browse/FLINK-1740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1740. --- Resolution: Fixed > StreamExecutionEnvironment is not respecting the setNumberOfExecutionRetries() > -

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371664#comment-14371664 ] Gyula Fora commented on FLINK-1764: --- Can you please show an example where it copies mult

[jira] [Comment Edited] (FLINK-1764) Rework record copying logic in streaming API

[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371692#comment-14371692 ] Gyula Fora edited comment on FLINK-1764 at 3/20/15 5:31 PM: Ok

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371692#comment-14371692 ] Gyula Fora commented on FLINK-1764: --- Ok thats a mistake, but otherwise we need to copy g

[jira] [Commented] (FLINK-1765) Reducer grouping is skippted when parallelism is one

[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371725#comment-14371725 ] Gyula Fora commented on FLINK-1765: --- This error was introduced today as I enabled chaini

[jira] [Assigned] (FLINK-1765) Reducer grouping is skippted when parallelism is one

[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-1765: - Assignee: Gyula Fora > Reducer grouping is skippted when parallelism is one > ---

[jira] [Commented] (FLINK-1763) Remove "cancel" from streaming SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14372024#comment-14372024 ] Gyula Fora commented on FLINK-1763: --- I still think that it makes sense to have a cancel

[jira] [Resolved] (FLINK-1765) Reducer grouping is skippted when parallelism is one

[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1765. --- Resolution: Fixed It was an error in the GroupedDataStream implementation that never appeared without

[jira] [Commented] (FLINK-1764) Rework record copying logic in streaming API

[ https://issues.apache.org/jira/browse/FLINK-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14372033#comment-14372033 ] Gyula Fora commented on FLINK-1764: --- I removed the accidental filter double copy in this

[jira] [Comment Edited] (FLINK-1763) Remove "cancel" from streaming SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14372024#comment-14372024 ] Gyula Fora edited comment on FLINK-1763 at 3/21/15 11:40 AM: -

[jira] [Commented] (FLINK-1763) Remove "cancel" from streaming SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14374895#comment-14374895 ] Gyula Fora commented on FLINK-1763: --- I wonder if we should do the same thing with the So

[jira] [Commented] (FLINK-1765) Reducer grouping is skippted when parallelism is one

[ https://issues.apache.org/jira/browse/FLINK-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375662#comment-14375662 ] Gyula Fora commented on FLINK-1765: --- Stephan's StreamCheckPointingITCase properly tests

[jira] [Commented] (FLINK-1772) Chain of split/select does not work

[ https://issues.apache.org/jira/browse/FLINK-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376069#comment-14376069 ] Gyula Fora commented on FLINK-1772: --- I dont think we should allow chaining of split. It

[jira] [Created] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups

Gyula Fora created FLINK-1773: - Summary: Add interface for grouped policies to broadcast information to other groups Key: FLINK-1773 URL: https://issues.apache.org/jira/browse/FLINK-1773 Project: Flink

[jira] [Created] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

Gyula Fora created FLINK-1775: - Summary: BarrierBuffers don't correctly handle end of stream events Key: FLINK-1775 URL: https://issues.apache.org/jira/browse/FLINK-1775 Project: Flink Issue Type

[jira] [Assigned] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

[ https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-1775: - Assignee: Gyula Fora > BarrierBuffers don't correctly handle end of stream events > -

[jira] [Commented] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups

[ https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14376379#comment-14376379 ] Gyula Fora commented on FLINK-1773: --- Thanks, I forgot :) > Add interface for grouped po

[jira] [Updated] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

[ https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1775: -- Component/s: Streaming > BarrierBuffers don't correctly handle end of stream events > --

[jira] [Resolved] (FLINK-1773) Add interface for grouped policies to broadcast information to other groups

[ https://issues.apache.org/jira/browse/FLINK-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1773. --- Resolution: Implemented https://github.com/apache/flink/pull/523 > Add interface for grouped policies

[jira] [Closed] (FLINK-1772) Chain of split/select does not work

[ https://issues.apache.org/jira/browse/FLINK-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1772. - Resolution: Not a Problem > Chain of split/select does not work > --- > >

[jira] [Closed] (FLINK-1775) BarrierBuffers don't correctly handle end of stream events

[ https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1775. - Resolution: Fixed > BarrierBuffers don't correctly handle end of stream events > -

[jira] [Created] (FLINK-1797) Add jumping pre-reducer for Count and Time windows

Gyula Fora created FLINK-1797: - Summary: Add jumping pre-reducer for Count and Time windows Key: FLINK-1797 URL: https://issues.apache.org/jira/browse/FLINK-1797 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-1797) Add jumping pre-reducer for Count and Time windows

[ https://issues.apache.org/jira/browse/FLINK-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14385476#comment-14385476 ] Gyula Fora commented on FLINK-1797: --- Jumping window is a sliding window where the slide

[jira] [Commented] (FLINK-1798) Bug in IterateExample while running with parallelism > 1: broker slot is already occupied

[ https://issues.apache.org/jira/browse/FLINK-1798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14386428#comment-14386428 ] Gyula Fora commented on FLINK-1798: --- Hey [~senorcarbone] ! Is this issue related to what

[jira] [Closed] (FLINK-1699) Co-task sometimes returns null

[ https://issues.apache.org/jira/browse/FLINK-1699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1699. - Resolution: Fixed > Co-task sometimes returns null > -- > > Ke

[jira] [Updated] (FLINK-1662) NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy

[ https://issues.apache.org/jira/browse/FLINK-1662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1662: -- Assignee: Péter Szabó > NullFieldException is thrown when testing IterativeDataStream with tuples, > wi

[jira] [Created] (FLINK-1803) Add type hints to the streaming api

Gyula Fora created FLINK-1803: - Summary: Add type hints to the streaming api Key: FLINK-1803 URL: https://issues.apache.org/jira/browse/FLINK-1803 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-1797) Add jumping pre-reducer for Count and Time windows

[ https://issues.apache.org/jira/browse/FLINK-1797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1797. --- Resolution: Implemented > Add jumping pre-reducer for Count and Time windows > ---

[jira] [Resolved] (FLINK-1662) NullFieldException is thrown when testing IterativeDataStream with tuples, windowing and maxBy

[ https://issues.apache.org/jira/browse/FLINK-1662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1662. --- Resolution: Fixed 1a3ae03baff7cc3a406e2e63e7d57b3f7c71ea26 > NullFieldException is thrown when testin

[jira] [Commented] (FLINK-1239) Fix iteration example getting stuck with large input

[ https://issues.apache.org/jira/browse/FLINK-1239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14390474#comment-14390474 ] Gyula Fora commented on FLINK-1239: --- Is there any update on this issue? Should we close

[jira] [Commented] (FLINK-1670) Collect method for streaming

[ https://issues.apache.org/jira/browse/FLINK-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14390485#comment-14390485 ] Gyula Fora commented on FLINK-1670: --- I would probably implement this as a combination of

[jira] [Created] (FLINK-1813) Barrier broadcast sometimes causes illegal state exception in source RecordWriter

Gyula Fora created FLINK-1813: - Summary: Barrier broadcast sometimes causes illegal state exception in source RecordWriter Key: FLINK-1813 URL: https://issues.apache.org/jira/browse/FLINK-1813 Project: Fl

[jira] [Created] (FLINK-1824) Allow missing types for DataStreams

Gyula Fora created FLINK-1824: - Summary: Allow missing types for DataStreams Key: FLINK-1824 URL: https://issues.apache.org/jira/browse/FLINK-1824 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-1803) Add type hints to the streaming api

[ https://issues.apache.org/jira/browse/FLINK-1803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1803. --- Resolution: Fixed > Add type hints to the streaming api > --- > >

[jira] [Created] (FLINK-1838) Update streaming programming guide

Gyula Fora created FLINK-1838: - Summary: Update streaming programming guide Key: FLINK-1838 URL: https://issues.apache.org/jira/browse/FLINK-1838 Project: Flink Issue Type: Task Compone

[jira] [Created] (FLINK-1853) TopSpeedWindowing example cannot be run from the ComandLine or Webclient

Gyula Fora created FLINK-1853: - Summary: TopSpeedWindowing example cannot be run from the ComandLine or Webclient Key: FLINK-1853 URL: https://issues.apache.org/jira/browse/FLINK-1853 Project: Flink

[jira] [Created] (FLINK-1854) Planvisualizer cannot visualize the streaming iteration example

Gyula Fora created FLINK-1854: - Summary: Planvisualizer cannot visualize the streaming iteration example Key: FLINK-1854 URL: https://issues.apache.org/jira/browse/FLINK-1854 Project: Flink Issu

[jira] [Created] (FLINK-1855) SocketTextStreamWordCount example cannot be run from the webclient

Gyula Fora created FLINK-1855: - Summary: SocketTextStreamWordCount example cannot be run from the webclient Key: FLINK-1855 URL: https://issues.apache.org/jira/browse/FLINK-1855 Project: Flink I

[jira] [Resolved] (FLINK-1813) Barrier broadcast sometimes causes illegal state exception in source RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-1813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1813. --- Resolution: Fixed > Barrier broadcast sometimes causes illegal state exception in source > RecordWrit

[jira] [Commented] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14486181#comment-14486181 ] Gyula Fora commented on FLINK-1793: --- I pushed a fix to a bug in the file source cancelli

[jira] [Created] (FLINK-1876) Refactor StreamGraph to be node centric

Gyula Fora created FLINK-1876: - Summary: Refactor StreamGraph to be node centric Key: FLINK-1876 URL: https://issues.apache.org/jira/browse/FLINK-1876 Project: Flink Issue Type: Bug Com

[jira] [Resolved] (FLINK-1793) Streaming File Source cannot be canceled

[ https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1793. --- Resolution: Fixed > Streaming File Source cannot be canceled > ---

[jira] [Commented] (FLINK-1655) Rename StreamInvokable to StreamOperator

[ https://issues.apache.org/jira/browse/FLINK-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14495001#comment-14495001 ] Gyula Fora commented on FLINK-1655: --- https://github.com/apache/flink/pull/594 > Rename

[jira] [Commented] (FLINK-1876) Refactor StreamGraph to be node centric

[ https://issues.apache.org/jira/browse/FLINK-1876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14495000#comment-14495000 ] Gyula Fora commented on FLINK-1876: --- https://github.com/apache/flink/pull/594 > Refacto

[jira] [Resolved] (FLINK-1876) Refactor StreamGraph to be node centric

[ https://issues.apache.org/jira/browse/FLINK-1876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1876. --- Resolution: Done > Refactor StreamGraph to be node centric > --- >

[jira] [Resolved] (FLINK-1655) Rename StreamInvokable to StreamOperator

[ https://issues.apache.org/jira/browse/FLINK-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1655. --- Resolution: Done > Rename StreamInvokable to StreamOperator >

[jira] [Commented] (FLINK-1869) Make StreamDiscretizers chainable

[ https://issues.apache.org/jira/browse/FLINK-1869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14501320#comment-14501320 ] Gyula Fora commented on FLINK-1869: --- Hey, The purpose of operator chaining is to make i

[jira] [Created] (FLINK-1909) Refactor streaming scala api to use returns for adding typeinfo

Gyula Fora created FLINK-1909: - Summary: Refactor streaming scala api to use returns for adding typeinfo Key: FLINK-1909 URL: https://issues.apache.org/jira/browse/FLINK-1909 Project: Flink Issu

[jira] [Updated] (FLINK-1909) Refactor streaming scala api to use returns for adding typeinfo

[ https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1909: -- Issue Type: Improvement (was: Bug) > Refactor streaming scala api to use returns for adding typeinfo >

[jira] [Updated] (FLINK-1909) Refactor streaming scala api to use returns for adding typeinfo

[ https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1909: -- Priority: Major (was: Minor) > Refactor streaming scala api to use returns for adding typeinfo > --

[jira] [Created] (FLINK-1911) DataStream and DataSet projection is out of sync

Gyula Fora created FLINK-1911: - Summary: DataStream and DataSet projection is out of sync Key: FLINK-1911 URL: https://issues.apache.org/jira/browse/FLINK-1911 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-1909) Refactor streaming scala api to use returns for adding typeinfo

[ https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1909. --- Resolution: Fixed https://github.com/apache/flink/commit/6df1dd2cc848d0a691a98309a3bb760f9a998673 > R

[jira] [Created] (FLINK-1940) StockPrice example cannot be visualized

Gyula Fora created FLINK-1940: - Summary: StockPrice example cannot be visualized Key: FLINK-1940 URL: https://issues.apache.org/jira/browse/FLINK-1940 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-1948) Add manual task slot handling for streaming jobs

Gyula Fora created FLINK-1948: - Summary: Add manual task slot handling for streaming jobs Key: FLINK-1948 URL: https://issues.apache.org/jira/browse/FLINK-1948 Project: Flink Issue Type: Improvem

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