[jira] [Commented] (FLINK-1434) Web interface cannot be used to run streaming programs

[ https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14287289#comment-14287289 ] Gyula Fora commented on FLINK-1434: --- This issue is also linked with

[jira] [Created] (FLINK-1434) Web interface cannot be used to run streaming programs

Gyula Fora created FLINK-1434: - Summary: Web interface cannot be used to run streaming programs Key: FLINK-1434 URL: https://issues.apache.org/jira/browse/FLINK-1434 Project: Flink Issue Type:

[jira] [Created] (FLINK-1409) Connected datastream functionality broken since the introduction of intermediate results

Gyula Fora created FLINK-1409: - Summary: Connected datastream functionality broken since the introduction of intermediate results Key: FLINK-1409 URL: https://issues.apache.org/jira/browse/FLINK-1409

[jira] [Commented] (FLINK-1409) Connected datastream functionality broken since the introduction of intermediate results

[ https://issues.apache.org/jira/browse/FLINK-1409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14279485#comment-14279485 ] Gyula Fora commented on FLINK-1409: --- To see the problem run either the scala or java

[jira] [Assigned] (FLINK-1409) Connected datastream functionality broken since the introduction of intermediate results

[ https://issues.apache.org/jira/browse/FLINK-1409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-1409: - Assignee: (was: Gyula Fora) Connected datastream functionality broken since the

[jira] [Commented] (FLINK-1409) Connected datastream functionality broken since the introduction of intermediate results

[ https://issues.apache.org/jira/browse/FLINK-1409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14280224#comment-14280224 ] Gyula Fora commented on FLINK-1409: --- Thanks, let me know if I can help in any way.

[jira] [Commented] (FLINK-1381) Only one output splitter supported per operator

[ https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14277061#comment-14277061 ] Gyula Fora commented on FLINK-1381: --- Hey, So the problem is that the splitting is tied

[jira] [Resolved] (FLINK-1566) WindowIntegrationTest fails

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

[jira] [Commented] (FLINK-1566) WindowIntegrationTest fails

[ https://issues.apache.org/jira/browse/FLINK-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14324356#comment-14324356 ] Gyula Fora commented on FLINK-1566: --- it is a concurrency issue while adding to an

[jira] [Updated] (FLINK-1586) Add support for iteration visualization for Streaming programs

[ https://issues.apache.org/jira/browse/FLINK-1586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1586: -- Component/s: Streaming Add support for iteration visualization for Streaming programs

[jira] [Resolved] (FLINK-1451) Enable parallel execution of streaming file sources

[ https://issues.apache.org/jira/browse/FLINK-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1451. --- Resolution: Fixed Assignee: Gyula Fora (was: Márton Balassi)

[jira] [Created] (FLINK-1591) Remove window merge before flatten as an optimization

Gyula Fora created FLINK-1591: - Summary: Remove window merge before flatten as an optimization Key: FLINK-1591 URL: https://issues.apache.org/jira/browse/FLINK-1591 Project: Flink Issue Type:

[jira] [Created] (FLINK-1592) Refactor StreamGraph to store vertex IDs as Integers instead of Strings

Gyula Fora created FLINK-1592: - Summary: Refactor StreamGraph to store vertex IDs as Integers instead of Strings Key: FLINK-1592 URL: https://issues.apache.org/jira/browse/FLINK-1592 Project: Flink

[jira] [Resolved] (FLINK-1434) Web interface cannot be used to run streaming programs

[ https://issues.apache.org/jira/browse/FLINK-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1434. --- Resolution: Fixed Web interface cannot be used to run streaming programs

[jira] [Comment Edited] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294939#comment-14294939 ] Gyula Fora edited comment on FLINK-1450 at 1/28/15 9:47 AM:

[jira] [Closed] (FLINK-1409) Connected datastream functionality broken since the introduction of intermediate results

[ https://issues.apache.org/jira/browse/FLINK-1409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1409. - Resolution: Fixed Connected datastream functionality broken since the introduction of intermediate

[jira] [Created] (FLINK-1450) Add Fold operator to the Streaming api

Gyula Fora created FLINK-1450: - Summary: Add Fold operator to the Streaming api Key: FLINK-1450 URL: https://issues.apache.org/jira/browse/FLINK-1450 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-1449) Extend Streaming guide to include the Scala API

Gyula Fora created FLINK-1449: - Summary: Extend Streaming guide to include the Scala API Key: FLINK-1449 URL: https://issues.apache.org/jira/browse/FLINK-1449 Project: Flink Issue Type: Task

[jira] [Resolved] (FLINK-1380) Update SplitDataStream to extend DataStream

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

[jira] [Assigned] (FLINK-1539) Runtime context not initialized when running streaming PojoExample

[ https://issues.apache.org/jira/browse/FLINK-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-1539: - Assignee: Gyula Fora (was: Márton Balassi) Runtime context not initialized when running

[jira] [Commented] (FLINK-1517) Modify inputiterator for streaming so the channel index of the last record is accessible

[ https://issues.apache.org/jira/browse/FLINK-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316192#comment-14316192 ] Gyula Fora commented on FLINK-1517: ---

[jira] [Commented] (FLINK-1493) Support for streaming jobs preserving global ordering of records

[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316204#comment-14316204 ] Gyula Fora commented on FLINK-1493: --- Hey, I implemented a simple indexed iterator from

[jira] [Commented] (FLINK-1493) Support for streaming jobs preserving global ordering of records

[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14312182#comment-14312182 ] Gyula Fora commented on FLINK-1493: --- Hey, This is actually quite tricky to make it

[jira] [Commented] (FLINK-1176) Add operator for global reduce/aggregations

[ https://issues.apache.org/jira/browse/FLINK-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14320664#comment-14320664 ] Gyula Fora commented on FLINK-1176: --- This feature amongst several others is introduced

[jira] [Commented] (FLINK-1539) Runtime context not initialized when running streaming PojoExample

[ https://issues.apache.org/jira/browse/FLINK-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14320659#comment-14320659 ] Gyula Fora commented on FLINK-1539: --- Fix:

[jira] [Created] (FLINK-1544) Extend streaming aggregation tests to include POJOs

Gyula Fora created FLINK-1544: - Summary: Extend streaming aggregation tests to include POJOs Key: FLINK-1544 URL: https://issues.apache.org/jira/browse/FLINK-1544 Project: Flink Issue Type:

[jira] [Updated] (FLINK-1592) Refactor StreamGraph to store vertex IDs as Integers instead of Strings

[ https://issues.apache.org/jira/browse/FLINK-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1592: -- Labels: starter (was: ) Refactor StreamGraph to store vertex IDs as Integers instead of Strings

[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] [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-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] [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-tabpanelfocusedCommentId=14367368#comment-14367368 ] Gyula Fora commented on FLINK-1503: --- Hey, As you can probably tell from the description

[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-tabpanelfocusedCommentId=14374895#comment-14374895 ] Gyula Fora commented on FLINK-1763: --- I wonder if we should do the same thing with the

[jira] [Resolved] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1450. --- Resolution: Implemented Add Fold operator to the Streaming api

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

Gyula Fora created FLINK-1706: - Summary: Add disk spilling to BarrierBuffer Key: FLINK-1706 URL: https://issues.apache.org/jira/browse/FLINK-1706 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-1619) Add pre-aggregator for time windows

[ https://issues.apache.org/jira/browse/FLINK-1619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1619. --- Resolution: Fixed Fix Version/s: 0.9 Add pre-aggregator for time windows

[jira] [Resolved] (FLINK-1620) Add pre-aggregator for count windows

[ https://issues.apache.org/jira/browse/FLINK-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1620. --- Resolution: Fixed Fix Version/s: 0.9 Add pre-aggregator for count windows

[jira] [Updated] (FLINK-1657) Make count windows local automatically

[ https://issues.apache.org/jira/browse/FLINK-1657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1657: -- Fix Version/s: 0.9 Make count windows local automatically --

[jira] [Resolved] (FLINK-1643) Detect tumbling policies where trigger and eviction match

[ https://issues.apache.org/jira/browse/FLINK-1643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1643. --- Resolution: Fixed Fix Version/s: 0.9 Detect tumbling policies where trigger and eviction

[jira] [Resolved] (FLINK-1657) Make count windows local automatically

[ https://issues.apache.org/jira/browse/FLINK-1657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1657. --- Resolution: Implemented Make count windows local automatically

[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

[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] [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-tabpanelfocusedCommentId=14372024#comment-14372024 ] Gyula Fora edited comment on FLINK-1763 at 3/21/15 11:40 AM: -

[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] [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-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=14371692#comment-14371692 ] Gyula Fora commented on FLINK-1764: --- Ok thats a mistake, but otherwise we need to copy

[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-tabpanelfocusedCommentId=14371664#comment-14371664 ] Gyula Fora commented on FLINK-1764: --- Can you please show an example where it copies

[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

[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-tabpanelfocusedCommentId=14372033#comment-14372033 ] Gyula Fora commented on FLINK-1764: --- I removed the accidental filter double copy in this

[jira] [Closed] (FLINK-1368) Change memory management settings for Streaming programs

[ https://issues.apache.org/jira/browse/FLINK-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1368. - Resolution: Duplicate Replaced by the more general https://issues.apache.org/jira/browse/FLINK-1671

[jira] [Commented] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming

[ https://issues.apache.org/jira/browse/FLINK-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14354817#comment-14354817 ] Gyula Fora commented on FLINK-1617: --- Hello! Thank you for the interest. I suggest you

[jira] [Created] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent

Gyula Fora created FLINK-1658: - Summary: Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent Key: FLINK-1658 URL: https://issues.apache.org/jira/browse/FLINK-1658 Project: Flink

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

Gyula Fora created FLINK-1655: - Summary: Rename StreamInvokable to StreamOperator Key: FLINK-1655 URL: https://issues.apache.org/jira/browse/FLINK-1655 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1657) Make count windows local automatically

Gyula Fora created FLINK-1657: - Summary: Make count windows local automatically Key: FLINK-1657 URL: https://issues.apache.org/jira/browse/FLINK-1657 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming

[ https://issues.apache.org/jira/browse/FLINK-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1617: -- Labels: gsoc2015 java streaming (was: gsoc2015) GSoC project: Query optimisation layer for Flink

[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-tabpanelfocusedCommentId=14385476#comment-14385476 ] Gyula Fora commented on FLINK-1797: --- Jumping window is a sliding window where the slide

[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,

[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

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

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

[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-tabpanelfocusedCommentId=14390474#comment-14390474 ] Gyula Fora commented on FLINK-1239: --- Is there any update on this issue? Should we close

[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:

[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-tabpanelfocusedCommentId=14376069#comment-14376069 ] Gyula Fora commented on FLINK-1772: --- I dont think we should allow chaining of split. It

[jira] [Assigned] (FLINK-1593) Improve exception handling int Streaming runtime

[ https://issues.apache.org/jira/browse/FLINK-1593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-1593: - Assignee: Gyula Fora Improve exception handling int Streaming runtime

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

Gyula Fora created FLINK-1618: - Summary: Add parallel time discretisation for time-window transformations Key: FLINK-1618 URL: https://issues.apache.org/jira/browse/FLINK-1618 Project: Flink

[jira] [Created] (FLINK-1619) Add pre-aggregator for time windows

Gyula Fora created FLINK-1619: - Summary: Add pre-aggregator for time windows Key: FLINK-1619 URL: https://issues.apache.org/jira/browse/FLINK-1619 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1643) Detect tumbling policies where trigger and eviction match

Gyula Fora created FLINK-1643: - Summary: Detect tumbling policies where trigger and eviction match Key: FLINK-1643 URL: https://issues.apache.org/jira/browse/FLINK-1643 Project: Flink Issue

[jira] [Closed] (FLINK-1553) Kafka connectors rework

[ https://issues.apache.org/jira/browse/FLINK-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1553. - Resolution: Fixed Kafka connectors rework --- Key: FLINK-1553

[jira] [Closed] (FLINK-1586) Add support for iteration visualization for Streaming programs

[ https://issues.apache.org/jira/browse/FLINK-1586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1586. - Resolution: Fixed Add support for iteration visualization for Streaming programs

[jira] [Created] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming

Gyula Fora created FLINK-1617: - Summary: GSoC project: Query optimisation layer for Flink Streaming Key: FLINK-1617 URL: https://issues.apache.org/jira/browse/FLINK-1617 Project: Flink Issue

[jira] [Closed] (FLINK-1592) Refactor StreamGraph to store vertex IDs as Integers instead of Strings

[ https://issues.apache.org/jira/browse/FLINK-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1592. - Resolution: Fixed Fix Version/s: 0.9

[jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14336427#comment-14336427 ] Gyula Fora commented on FLINK-1450: --- Hey Amit, Thanks for the interest. Basically there

[jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api

[ https://issues.apache.org/jira/browse/FLINK-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14336431#comment-14336431 ] Gyula Fora commented on FLINK-1450: --- + tests and docs :) Add Fold operator to the

[jira] [Created] (FLINK-1595) Add a complex integration test for Streaming API

Gyula Fora created FLINK-1595: - Summary: Add a complex integration test for Streaming API Key: FLINK-1595 URL: https://issues.apache.org/jira/browse/FLINK-1595 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-1595) Add a complex integration test for Streaming API

[ https://issues.apache.org/jira/browse/FLINK-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1595: -- Labels: Starter (was: ) Add a complex integration test for Streaming API

[jira] [Updated] (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 updated FLINK-1594: -- Description: Trying to window-join a DataStream with itself will result in exceptions. I get the

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

[ https://issues.apache.org/jira/browse/FLINK-1594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14329268#comment-14329268 ] Gyula Fora commented on FLINK-1594: --- We will have to take a look at how self joins are

[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] [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] [Resolved] (FLINK-1381) Only one output splitter supported per operator

[ https://issues.apache.org/jira/browse/FLINK-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1381. --- Resolution: Fixed Only one output splitter supported per operator

[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-tabpanelfocusedCommentId=14375662#comment-14375662 ] Gyula Fora commented on FLINK-1765: --- Stephan's StreamCheckPointingITCase properly tests

[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] [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] [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

[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-tabpanelfocusedCommentId=14376379#comment-14376379 ] Gyula Fora commented on FLINK-1773: --- Thanks, I forgot :) Add interface for grouped

[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-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

[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

[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:

[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

[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] [Commented] (FLINK-1869) Make StreamDiscretizers chainable

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

[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

[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] [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-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] [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

[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

[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-tabpanelfocusedCommentId=14486181#comment-14486181 ] Gyula Fora commented on FLINK-1793: --- I pushed a fix to a bug in the file source

  1   2   3   4   5   6   7   8   9   10   >