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

[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-tabpanel&focusedCommentId=14279485#comment-14279485 ] Gyula Fora commented on FLINK-1409: --- To see the problem run either the scala or java Win

[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-tabpanel&focusedCommentId=14280224#comment-14280224 ] Gyula Fora commented on FLINK-1409: --- Thanks, let me know if I can help in any way. > Co

[jira] [Updated] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming

[ https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1421: -- Assignee: Paris Carbone (was: Gyula Fora) > Implement a SAMOA Adapter for Flink Streaming > ---

[jira] [Created] (FLINK-1425) Turn lazy operator execution off for streaming programs

Gyula Fora created FLINK-1425: - Summary: Turn lazy operator execution off for streaming programs Key: FLINK-1425 URL: https://issues.apache.org/jira/browse/FLINK-1425 Project: Flink Issue Type: T

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

[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-tabpanel&focusedCommentId=14287289#comment-14287289 ] Gyula Fora commented on FLINK-1434: --- This issue is also linked with https://issues.apac

[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-tabpanel&focusedCommentId=14287352#comment-14287352 ] Gyula Fora commented on FLINK-1434: --- This actually seems to be a ClassLoader issue, but

[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-tabpanel&focusedCommentId=14287514#comment-14287514 ] Gyula Fora commented on FLINK-1434: --- It seems like I was unaware of the OptimizerPlanEnv

[jira] [Updated] (FLINK-1425) Turn lazy operator execution off for streaming programs

[ https://issues.apache.org/jira/browse/FLINK-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-1425: -- Assignee: Ufuk Celebi > Turn lazy operator execution off for streaming programs > --

[jira] [Updated] (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 updated FLINK-1381: -- Assignee: Mingliang Qi > Only one output splitter supported per operator > -

[jira] [Assigned] (FLINK-1401) Add plan visualiser support for Streaming programs

[ https://issues.apache.org/jira/browse/FLINK-1401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-1401: - Assignee: Gyula Fora > Add plan visualiser support for Streaming programs > -

[jira] [Assigned] (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 reassigned FLINK-1434: - Assignee: Gyula Fora > Web interface cannot be used to run streaming programs > -

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

[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] [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] [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] [Resolved] (FLINK-1081) Add HDFS file-stream source for streaming

[ https://issues.apache.org/jira/browse/FLINK-1081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1081. --- Resolution: Fixed > Add HDFS file-stream source for streaming > --

[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-tabpanel&focusedCommentId=14291852#comment-14291852 ] Gyula Fora commented on FLINK-1450: --- It is actually something quite different. With red

[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] [Resolved] (FLINK-1401) Add plan visualiser support for Streaming programs

[ https://issues.apache.org/jira/browse/FLINK-1401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1401. --- Resolution: Fixed > Add plan visualiser support for Streaming programs > -

[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-tabpanel&focusedCommentId=14294939#comment-14294939 ] Gyula Fora commented on FLINK-1450: --- Yes, more specifically, the first element is the fi

[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-tabpanel&focusedCommentId=14294939#comment-14294939 ] Gyula Fora edited comment on FLINK-1450 at 1/28/15 9:47 AM: Ye

[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-tabpanel&focusedCommentId=14312182#comment-14312182 ] Gyula Fora commented on FLINK-1493: --- Hey, This is actually quite tricky to make it robu

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

Gyula Fora created FLINK-1503: - Summary: GSoC project: Batch and Streaming integration through new operators and unified API Key: FLINK-1503 URL: https://issues.apache.org/jira/browse/FLINK-1503 Project:

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

Gyula Fora created FLINK-1517: - Summary: Modify inputiterator for streaming so the channel index of the last record is accessible Key: FLINK-1517 URL: https://issues.apache.org/jira/browse/FLINK-1517 Proj

[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-tabpanel&focusedCommentId=14316192#comment-14316192 ] Gyula Fora commented on FLINK-1517: --- https://github.com/mbalassi/flink/commit/ee3590ec44

[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-tabpanel&focusedCommentId=14316204#comment-14316204 ] Gyula Fora commented on FLINK-1493: --- Hey, I implemented a simple indexed iterator from w

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

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

[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-tabpanel&focusedCommentId=14320659#comment-14320659 ] Gyula Fora commented on FLINK-1539: --- Fix: https://github.com/mbalassi/flink/commit/592a6

[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-tabpanel&focusedCommentId=14320664#comment-14320664 ] Gyula Fora commented on FLINK-1176: --- This feature amongst several others is introduced h

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

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

[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] [Created] (FLINK-1586) Add support for iteration visualization for Streaming programs

Gyula Fora created FLINK-1586: - Summary: Add support for iteration visualization for Streaming programs Key: FLINK-1586 URL: https://issues.apache.org/jira/browse/FLINK-1586 Project: Flink Issue

[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) https://github.com/apache/flink/co

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

[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] [Created] (FLINK-1593) Improve exception handling int Streaming runtime

Gyula Fora created FLINK-1593: - Summary: Improve exception handling int Streaming runtime Key: FLINK-1593 URL: https://issues.apache.org/jira/browse/FLINK-1593 Project: Flink Issue Type: Improvem

[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-tabpanel&focusedCommentId=14329268#comment-14329268 ] Gyula Fora commented on FLINK-1594: --- We will have to take a look at how self joins are h

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

[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] [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] [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 https://github.com/apache/flink/commit/a911559a1d8d8d160edcdb7

[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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14336431#comment-14336431 ] Gyula Fora commented on FLINK-1450: --- + tests and docs :) > Add Fold operator to the Str

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

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

[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-1620) Add pre-aggregator for count windows

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

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

[ https://issues.apache.org/jira/browse/FLINK-1591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1591. --- Resolution: Fixed > Remove window merge before flatten as an optimization > --

[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-1625) Add cancel method to user defined sources and sinks and call them on task cancellation

Gyula Fora created FLINK-1625: - Summary: Add cancel method to user defined sources and sinks and call them on task cancellation Key: FLINK-1625 URL: https://issues.apache.org/jira/browse/FLINK-1625 Projec

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

Gyula Fora created FLINK-1641: - Summary: Make projection operator chainable Key: FLINK-1641 URL: https://issues.apache.org/jira/browse/FLINK-1641 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 Type:

[jira] [Resolved] (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 resolved FLINK-1593. --- Resolution: Fixed 3abd6c8f4d45b1dc37a8d832a699a4d7fea34332 8436e9ce31b52f1bd8c55b8e8c50cafb57cff84f 08

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

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

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

[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-tabpanel&focusedCommentId=14354817#comment-14354817 ] Gyula Fora commented on FLINK-1617: --- Hello! Thank you for the interest. I suggest you f

[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-tabpanel&focusedCommentId=14356818#comment-14356818 ] Gyula Fora commented on FLINK-1617: --- Hi Gabor, Thanks for the interest, the same info a

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

[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-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-1660) MultiTriggerPolicyTest timeout during test

[ https://issues.apache.org/jira/browse/FLINK-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1660. --- Resolution: Fixed Fix Version/s: 0.9 > MultiTriggerPolicyTest timeout during test > ---

[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] [Assigned] (FLINK-35265) Implement FlinkStateSnapshot custom resource

[ https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-35265: -- Assignee: Mate Czagany > Implement FlinkStateSnapshot custom resource > -

[jira] [Commented] (FLINK-35265) Implement FlinkStateSnapshot custom resource

[ https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872060#comment-17872060 ] Gyula Fora commented on FLINK-35265: merged to main: 0f390144cb8516d31aac61e46b9ce06

[jira] [Updated] (FLINK-35265) Implement FlinkStateSnapshot custom resource

[ https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-35265: --- Fix Version/s: kubernetes-operator-1.10.0 > Implement FlinkStateSnapshot custom resource > -

[jira] [Closed] (FLINK-35265) Implement FlinkStateSnapshot custom resource

[ https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35265. -- Resolution: Fixed > Implement FlinkStateSnapshot custom resource > ---

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872402#comment-17872402 ] Gyula Fora commented on FLINK-36018: Hey Guys, I completely agree with what was said

[jira] [Closed] (FLINK-35267) Documentation and examples for FlinkStateSnapshot CR

[ https://issues.apache.org/jira/browse/FLINK-35267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35267. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: Mate Czagany Resolution: Fixed mer

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872783#comment-17872783 ] Gyula Fora commented on FLINK-36018: Based on your proposals how about simply `job.a

[jira] [Assigned] (FLINK-36031) Migrate kubernetes operator metrics from OKHttp Interceptor API to Fabric8 Interceptor API

[ https://issues.apache.org/jira/browse/FLINK-36031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-36031: -- Assignee: Sam Barker > Migrate kubernetes operator metrics from OKHttp Interceptor API to Fab

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872859#comment-17872859 ] Gyula Fora commented on FLINK-36018: [~mxm] or simply `autoscaler.scale-down.interva

[jira] [Commented] (FLINK-35265) Implement FlinkStateSnapshot custom resource

[ https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873506#comment-17873506 ] Gyula Fora commented on FLINK-35265: d10918c626c19964635a340fd99a627691fedf54 > Imp

[jira] [Closed] (FLINK-36037) Add compability for 1.9 last savepoint info on upgrade/recovery

[ https://issues.apache.org/jira/browse/FLINK-36037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36037. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: Mate Czagany Resolution: Fixed mer

[jira] [Created] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering

Gyula Fora created FLINK-36109: -- Summary: Improve FlinkStateSnapshot resource labels for efficient filtering Key: FLINK-36109 URL: https://issues.apache.org/jira/browse/FLINK-36109 Project: Flink

[jira] [Created] (FLINK-36110) Periodic save points trigger continuously

Gyula Fora created FLINK-36110: -- Summary: Periodic save points trigger continuously Key: FLINK-36110 URL: https://issues.apache.org/jira/browse/FLINK-36110 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering

[ https://issues.apache.org/jira/browse/FLINK-36109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-36109: --- Priority: Critical (was: Major) > Improve FlinkStateSnapshot resource labels for efficient filterin

[jira] [Assigned] (FLINK-36110) Periodic save points trigger continuously

[ https://issues.apache.org/jira/browse/FLINK-36110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-36110: -- Assignee: Mate Czagany > Periodic save points trigger continuously > ---

[jira] [Closed] (FLINK-35493) Make max history age and count configurable for FlinkStateSnapshot resources

[ https://issues.apache.org/jira/browse/FLINK-35493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35493. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: Mate Czagany Resolution: Fixed mer

[jira] [Closed] (FLINK-36031) Migrate kubernetes operator metrics from OKHttp Interceptor API to Fabric8 Interceptor API

[ https://issues.apache.org/jira/browse/FLINK-36031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36031. -- Resolution: Fixed merged to main 39e10d0f0bcec081ca9a91b7c053262f6ce09488 > Migrate kubernetes operat

[jira] [Created] (FLINK-36137) Missing JarURI leads to null pointer in reconciler

Gyula Fora created FLINK-36137: -- Summary: Missing JarURI leads to null pointer in reconciler Key: FLINK-36137 URL: https://issues.apache.org/jira/browse/FLINK-36137 Project: Flink Issue Type: Bu

[jira] [Closed] (FLINK-36110) Periodic save points trigger continuously

[ https://issues.apache.org/jira/browse/FLINK-36110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36110. -- Resolution: Fixed merged to main 0ef627edf001b56aac7d57ea8839546d7ed87681 > Periodic save points trig

[jira] [Commented] (FLINK-33803) Add observedGeneration to Operator's status spec

[ https://issues.apache.org/jira/browse/FLINK-33803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876196#comment-17876196 ] Gyula Fora commented on FLINK-33803: a10fb4501011be4e88fb6164156e3b9e8527950e > Add

[jira] [Commented] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876296#comment-17876296 ] Gyula Fora commented on FLINK-36145: What do you think [~mateczagany] ? > Change Jo

[jira] [Created] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

Gyula Fora created FLINK-36145: -- Summary: Change JobSpec.flinkStateSnapshotReference to snapshotReference Key: FLINK-36145 URL: https://issues.apache.org/jira/browse/FLINK-36145 Project: Flink

[jira] [Commented] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876532#comment-17876532 ] Gyula Fora commented on FLINK-36145: [~mateczagany] let's hold off on this for a lit

[jira] [Commented] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876624#comment-17876624 ] Gyula Fora commented on FLINK-36145: I also like initialStateReference more, we coul

[jira] [Created] (FLINK-36162) Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference

Gyula Fora created FLINK-36162: -- Summary: Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference Key: FLINK-36162 URL: https://issues.apache.org/jira/browse/FLINK-36162 Pro

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