[jira] [Updated] (FLINK-4397) Unstable test SlotCountExceedingParallelismTest.tearDown

[ https://issues.apache.org/jira/browse/FLINK-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4397: -- Assignee: Ufuk Celebi > Unstable test SlotCountExceedingParallelismTest.tearDown > -

[jira] [Created] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery

Kostas Kloudas created FLINK-4398: - Summary: Unstable test KvStateServerHandlerTest.testSimpleQuery Key: FLINK-4398 URL: https://issues.apache.org/jira/browse/FLINK-4398 Project: Flink Issue

[jira] [Updated] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery

[ https://issues.apache.org/jira/browse/FLINK-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4398: -- Labels: test-stability (was: ) > Unstable test KvStateServerHandlerTest.testSimpleQuery > -

[jira] [Updated] (FLINK-4397) Unstable test SlotCountExceedingParallelismTest.tearDown

[ https://issues.apache.org/jira/browse/FLINK-4397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4397: -- Labels: test-stability (was: ) > Unstable test SlotCountExceedingParallelismTest.tearDown > ---

[jira] [Updated] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery

[ https://issues.apache.org/jira/browse/FLINK-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4398: -- Assignee: Ufuk Celebi > Unstable test KvStateServerHandlerTest.testSimpleQuery > ---

[jira] [Created] (FLINK-4397) Unstable test SlotCountExceedingParallelismTest.tearDown

Kostas Kloudas created FLINK-4397: - Summary: Unstable test SlotCountExceedingParallelismTest.tearDown Key: FLINK-4397 URL: https://issues.apache.org/jira/browse/FLINK-4397 Project: Flink Issu

[jira] [Assigned] (FLINK-4407) Implement the trigger DSL

[ https://issues.apache.org/jira/browse/FLINK-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-4407: - Assignee: Kostas Kloudas > Implement the trigger DSL > - > >

[jira] [Created] (FLINK-4407) Implement the trigger DSL

Kostas Kloudas created FLINK-4407: - Summary: Implement the trigger DSL Key: FLINK-4407 URL: https://issues.apache.org/jira/browse/FLINK-4407 Project: Flink Issue Type: Bug Reporte

[jira] [Updated] (FLINK-4407) Implement the trigger DSL

[ https://issues.apache.org/jira/browse/FLINK-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4407: -- Description: This issue refers to the implementation of the trigger DSL. The specification of th

[jira] [Updated] (FLINK-4407) Implement the trigger DSL

[ https://issues.apache.org/jira/browse/FLINK-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4407: -- Description: This issue refers to the implementation of the trigger DSL. The specification of th

[jira] [Created] (FLINK-4433) Refactor the StreamSource.

Kostas Kloudas created FLINK-4433: - Summary: Refactor the StreamSource. Key: FLINK-4433 URL: https://issues.apache.org/jira/browse/FLINK-4433 Project: Flink Issue Type: Bug Report

[jira] [Updated] (FLINK-4433) Refactor the StreamSource.

[ https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4433: -- Description: With the addition of continuous file monitoring, apart from the {{StreamSource}} a

[jira] [Updated] (FLINK-4433) Refactor the StreamSource.

[ https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4433: -- Description: With the addition of continuous file monitoring, apart from the {{StreamSource}} a

[jira] [Created] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator.

Kostas Kloudas created FLINK-4494: - Summary: Expose the TimeServiceProvider from the Task to each Operator. Key: FLINK-4494 URL: https://issues.apache.org/jira/browse/FLINK-4494 Project: Flink

[jira] [Assigned] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator.

[ https://issues.apache.org/jira/browse/FLINK-4494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-4494: - Assignee: Kostas Kloudas > Expose the TimeServiceProvider from the Task to each Operator.

[jira] [Created] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

Kostas Kloudas created FLINK-4496: - Summary: Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable. Key: FLINK-4496 URL: https://issues.apache.org/jira/browse/FLINK-4496 Project:

[jira] [Assigned] (FLINK-4433) Refactor the StreamSource.

[ https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-4433: - Assignee: Kostas Kloudas > Refactor the StreamSource. > -- > >

[jira] [Updated] (FLINK-4415) Enhance Trigger Interface with onFire()

[ https://issues.apache.org/jira/browse/FLINK-4415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4415: -- Summary: Enhance Trigger Interface with onFire() (was: Enhance Trigger Interface with onFire()

[jira] [Updated] (FLINK-4415) Enhance Trigger Interface with onFire()

[ https://issues.apache.org/jira/browse/FLINK-4415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4415: -- Description: Currently, when a {{Trigger}} returns {{PURGE}} (or {{FIRE_AND_PURGE}}) the window

[jira] [Created] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

Kostas Kloudas created FLINK-4651: - Summary: Re-register processing time timers at the WindowOperator upon recovery. Key: FLINK-4651 URL: https://issues.apache.org/jira/browse/FLINK-4651 Project: Flin

[jira] [Updated] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

[ https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4651: -- Description: Currently the {{WindowOperator}} checkpoints the processing time timers, but upon r

[jira] [Updated] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

[ https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-4651: -- Description: Currently the {{WindowOperator}} checkpoints the processing time timers, but upon r

[jira] [Closed] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

[ https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-4496. - Resolution: Fixed > Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable. >

[jira] [Closed] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator.

[ https://issues.apache.org/jira/browse/FLINK-4494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-4494. - Resolution: Fixed > Expose the TimeServiceProvider from the Task to each Operator. > -

[jira] [Comment Edited] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService

[ https://issues.apache.org/jira/browse/FLINK-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903269#comment-15903269 ] Kostas Kloudas edited comment on FLINK-6007 at 3/9/17 4:04 PM: -

[jira] [Commented] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService

[ https://issues.apache.org/jira/browse/FLINK-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15903293#comment-15903293 ] Kostas Kloudas commented on FLINK-6007: --- [~aljoscha] Now that I come to think about

[jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905789#comment-15905789 ] Kostas Kloudas commented on FLINK-5874: --- Merged at f15a7d2d9c9aae72bb3ac3eb2478b3ec4

[jira] [Closed] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing

[ https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5874. - Resolution: Fixed > Reject arrays as keys in DataStream API to avoid inconsistent hashing > --

[jira] [Commented] (FLINK-6024) Need more fine-grained info for "InvalidProgramException: This type (...) cannot be used as key"

[ https://issues.apache.org/jira/browse/FLINK-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907427#comment-15907427 ] Kostas Kloudas commented on FLINK-6024: --- I totally agree that the Error message shou

[jira] [Comment Edited] (FLINK-6024) Need more fine-grained info for "InvalidProgramException: This type (...) cannot be used as key"

[ https://issues.apache.org/jira/browse/FLINK-6024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907427#comment-15907427 ] Kostas Kloudas edited comment on FLINK-6024 at 3/13/17 1:12 PM:

[jira] [Commented] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService

[ https://issues.apache.org/jira/browse/FLINK-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15922763#comment-15922763 ] Kostas Kloudas commented on FLINK-6007: --- Merged at 14c1941d8eaa583eb8f7eeb5478e60585

[jira] [Closed] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService

[ https://issues.apache.org/jira/browse/FLINK-6007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6007. - Resolution: Fixed > ConcurrentModificationException in WatermarkCallbackService >

[jira] [Created] (FLINK-6032) CEP-Clean up the operator state when not needed.

Kostas Kloudas created FLINK-6032: - Summary: CEP-Clean up the operator state when not needed. Key: FLINK-6032 URL: https://issues.apache.org/jira/browse/FLINK-6032 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5969) Add savepoint backwards compatibility tests from 1.2 to 1.3

[ https://issues.apache.org/jira/browse/FLINK-5969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-5969: -- Description: We currently only have tests that test migration from 1.1 to 1.3, because we added

[jira] [Commented] (FLINK-6032) CEP-Clean up the operator state when not needed.

[ https://issues.apache.org/jira/browse/FLINK-6032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15927811#comment-15927811 ] Kostas Kloudas commented on FLINK-6032: --- Merged with e5057b72c0749a75578665c4c86a47b

[jira] [Closed] (FLINK-6032) CEP-Clean up the operator state when not needed.

[ https://issues.apache.org/jira/browse/FLINK-6032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6032. - Resolution: Fixed > CEP-Clean up the operator state when not needed. > ---

[jira] [Closed] (FLINK-5846) CEP: make the operators backwards compatible.

[ https://issues.apache.org/jira/browse/FLINK-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5846. - Resolution: Fixed > CEP: make the operators backwards compatible. > --

[jira] [Commented] (FLINK-5846) CEP: make the operators backwards compatible.

[ https://issues.apache.org/jira/browse/FLINK-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15930147#comment-15930147 ] Kostas Kloudas commented on FLINK-5846: --- Merged with 521a53d9ad68a3f16a32e08843a6fca

[jira] [Commented] (FLINK-5932) Order of legacy vs new state initialization in the AbstractStreamOperator.

[ https://issues.apache.org/jira/browse/FLINK-5932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15930150#comment-15930150 ] Kostas Kloudas commented on FLINK-5932: --- Merged with d998ff9175ec84aa5685fbd6ebe7934

[jira] [Closed] (FLINK-5932) Order of legacy vs new state initialization in the AbstractStreamOperator.

[ https://issues.apache.org/jira/browse/FLINK-5932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5932. - Resolution: Fixed > Order of legacy vs new state initialization in the AbstractStreamOperator. > -

[jira] [Closed] (FLINK-5174) Fix memory leak in the CEP library.

[ https://issues.apache.org/jira/browse/FLINK-5174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5174. - Resolution: Duplicate > Fix memory leak in the CEP library. > ---

[jira] [Created] (FLINK-6123) Add support for the NOT pattern.

Kostas Kloudas created FLINK-6123: - Summary: Add support for the NOT pattern. Key: FLINK-6123 URL: https://issues.apache.org/jira/browse/FLINK-6123 Project: Flink Issue Type: Bug Co

[jira] [Closed] (FLINK-6123) Add support for the NOT pattern.

[ https://issues.apache.org/jira/browse/FLINK-6123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6123. - Resolution: Duplicate > Add support for the NOT pattern. > > >

[jira] [Created] (FLINK-6197) Add support for iterative conditions.

Kostas Kloudas created FLINK-6197: - Summary: Add support for iterative conditions. Key: FLINK-6197 URL: https://issues.apache.org/jira/browse/FLINK-6197 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6198) Update the documentation of the CEP library to include all the new features.

Kostas Kloudas created FLINK-6198: - Summary: Update the documentation of the CEP library to include all the new features. Key: FLINK-6198 URL: https://issues.apache.org/jira/browse/FLINK-6198 Project:

[jira] [Assigned] (FLINK-6069) Add documentation CEP - Watermarks

[ https://issues.apache.org/jira/browse/FLINK-6069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6069: - Assignee: Kostas Kloudas > Add documentation CEP - Watermarks > -

[jira] [Updated] (FLINK-6198) Update the documentation of the CEP library to include all the new features.

[ https://issues.apache.org/jira/browse/FLINK-6198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6198: -- Description: New features to include: * Iterative Functions * Quantifiers * Time handling > Upd

[jira] [Commented] (FLINK-6069) Add documentation CEP - Watermarks

[ https://issues.apache.org/jira/browse/FLINK-6069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944856#comment-15944856 ] Kostas Kloudas commented on FLINK-6069: --- Hi [~patricklx] , Currently the CEP librar

[jira] [Updated] (FLINK-6198) Update the documentation of the CEP library to include all the new features.

[ https://issues.apache.org/jira/browse/FLINK-6198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6198: -- Description: New features to include: * Iterative Functions * Quantifiers * Time handling * Migr

[jira] [Commented] (FLINK-4395) Eager processing of late arrivals in CEP operator

[ https://issues.apache.org/jira/browse/FLINK-4395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944892#comment-15944892 ] Kostas Kloudas commented on FLINK-4395: --- Hi [~ivan.mushketyk]! How are you? I thin

[jira] [Created] (FLINK-6205) Put late elements in side output.

Kostas Kloudas created FLINK-6205: - Summary: Put late elements in side output. Key: FLINK-6205 URL: https://issues.apache.org/jira/browse/FLINK-6205 Project: Flink Issue Type: Bug C

[jira] [Updated] (FLINK-6205) Put late elements in side output.

[ https://issues.apache.org/jira/browse/FLINK-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6205: -- Description: Currently the CEP library had a somehow fuzzy way to handle late events. Essential

[jira] [Commented] (FLINK-6197) Add support for iterative conditions.

[ https://issues.apache.org/jira/browse/FLINK-6197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945452#comment-15945452 ] Kostas Kloudas commented on FLINK-6197: --- Merged with ad21a441434b9ac5886b664871553bf

[jira] [Closed] (FLINK-6197) Add support for iterative conditions.

[ https://issues.apache.org/jira/browse/FLINK-6197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6197. - Resolution: Fixed > Add support for iterative conditions. > -

[jira] [Created] (FLINK-6215) Make the StatefulSequenceSource scalable.

Kostas Kloudas created FLINK-6215: - Summary: Make the StatefulSequenceSource scalable. Key: FLINK-6215 URL: https://issues.apache.org/jira/browse/FLINK-6215 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-6205) Put late elements in side output.

[ https://issues.apache.org/jira/browse/FLINK-6205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6205. - Resolution: Fixed Merged with 48890285d4b1c285bebb971ae0dbfc310c6fcc0e > Put late elements in sid

[jira] [Closed] (FLINK-6069) Add documentation CEP - Watermarks

[ https://issues.apache.org/jira/browse/FLINK-6069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-6069. - Resolution: Fixed Merged with 48890285d4b1c285bebb971ae0dbfc310c6fcc0e > Add documentation CEP -

[jira] [Created] (FLINK-6245) Fix late side output documentation in Window documents.

Kostas Kloudas created FLINK-6245: - Summary: Fix late side output documentation in Window documents. Key: FLINK-6245 URL: https://issues.apache.org/jira/browse/FLINK-6245 Project: Flink Issue

[jira] [Updated] (FLINK-6244) Emit timeouted Patterns as Side Output

[ https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6244: -- Affects Version/s: 1.3.0 > Emit timeouted Patterns as Side Output >

[jira] [Updated] (FLINK-6244) Emit timeouted Patterns as Side Output

[ https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-6244: -- Fix Version/s: 1.3.0 > Emit timeouted Patterns as Side Output >

[jira] [Commented] (FLINK-6244) Emit timeouted Patterns as Side Output

[ https://issues.apache.org/jira/browse/FLINK-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953590#comment-15953590 ] Kostas Kloudas commented on FLINK-6244: --- The only problem I can find, and we have to

[jira] [Created] (FLINK-6248) Make the optional() available to all offered patterns.

Kostas Kloudas created FLINK-6248: - Summary: Make the optional() available to all offered patterns. Key: FLINK-6248 URL: https://issues.apache.org/jira/browse/FLINK-6248 Project: Flink Issue

[jira] [Assigned] (FLINK-6215) Make the StatefulSequenceSource scalable.

[ https://issues.apache.org/jira/browse/FLINK-6215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6215: - Assignee: Kostas Kloudas > Make the StatefulSequenceSource scalable. > --

[jira] [Assigned] (FLINK-6254) Consolidate late data methods on PatternStream and WindowedStream

[ https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-6254: - Assignee: Kostas Kloudas > Consolidate late data methods on PatternStream and WindowedStr

[jira] [Created] (FLINK-6256) Fix documentation of ProcessFunction.

Kostas Kloudas created FLINK-6256: - Summary: Fix documentation of ProcessFunction. Key: FLINK-6256 URL: https://issues.apache.org/jira/browse/FLINK-6256 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-6254) Consolidate late data methods on PatternStream and WindowedStream

[ https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954908#comment-15954908 ] Kostas Kloudas commented on FLINK-6254: --- Merged at 1b6baddca07bfba6093951e82ac9108cf

[jira] [Resolved] (FLINK-6254) Consolidate late data methods on PatternStream and WindowedStream

[ https://issues.apache.org/jira/browse/FLINK-6254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas resolved FLINK-6254. --- Resolution: Fixed > Consolidate late data methods on PatternStream and WindowedStream > --

[jira] [Created] (FLINK-6265) Fix consecutive() for times() pattern.

Kostas Kloudas created FLINK-6265: - Summary: Fix consecutive() for times() pattern. Key: FLINK-6265 URL: https://issues.apache.org/jira/browse/FLINK-6265 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5054) Make the BucketingSink rescalable.

Kostas Kloudas created FLINK-5054: - Summary: Make the BucketingSink rescalable. Key: FLINK-5054 URL: https://issues.apache.org/jira/browse/FLINK-5054 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-5021) Makes the ContinuousFileReaderOperator rescalable.

[ https://issues.apache.org/jira/browse/FLINK-5021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5021. - Resolution: Fixed > Makes the ContinuousFileReaderOperator rescalable. > -

[jira] [Created] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

Kostas Kloudas created FLINK-5056: - Summary: BucketingSink deletes valid data when checkpoint notification is slow. Key: FLINK-5056 URL: https://issues.apache.org/jira/browse/FLINK-5056 Project: Flink

[jira] [Commented] (FLINK-5054) Make the BucketingSink rescalable.

[ https://issues.apache.org/jira/browse/FLINK-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15663309#comment-15663309 ] Kostas Kloudas commented on FLINK-5054: --- This is also included in https://github.com

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15670070#comment-15670070 ] Kostas Kloudas commented on FLINK-2646: --- Big +1 for the feature as well. To revive

[jira] [Commented] (FLINK-5083) Race condition in Rolling/Bucketing Sink pending files cleanup

[ https://issues.apache.org/jira/browse/FLINK-5083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15671880#comment-15671880 ] Kostas Kloudas commented on FLINK-5083: --- Thanks for reporting it! There is a pendin

[jira] [Issue Comment Deleted] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-2646: -- Comment: was deleted (was: Yes, I think we are on the same page. This is what I also meant in my

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15673030#comment-15673030 ] Kostas Kloudas commented on FLINK-2646: --- Yes, I think we are on the same page. This

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15673034#comment-15673034 ] Kostas Kloudas commented on FLINK-2646: --- Yes I agree. This is what I also meant in m

[jira] [Commented] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

[ https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15673721#comment-15673721 ] Kostas Kloudas commented on FLINK-3053: --- another instance: https://api.travis-ci.org

[jira] [Created] (FLINK-5096) Make the RollingSink rescalable.

Kostas Kloudas created FLINK-5096: - Summary: Make the RollingSink rescalable. Key: FLINK-5096 URL: https://issues.apache.org/jira/browse/FLINK-5096 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15679034#comment-15679034 ] Kostas Kloudas commented on FLINK-2646: --- By the way the {{RichFunction}} is annotate

[jira] [Created] (FLINK-5110) Remove the AbstractAlignedProcessingTimeWindowOperator.

Kostas Kloudas created FLINK-5110: - Summary: Remove the AbstractAlignedProcessingTimeWindowOperator. Key: FLINK-5110 URL: https://issues.apache.org/jira/browse/FLINK-5110 Project: Flink Issue

[jira] [Created] (FLINK-5111) Change the assignToKeyGroup() method to not use Object.hashCode()

Kostas Kloudas created FLINK-5111: - Summary: Change the assignToKeyGroup() method to not use Object.hashCode() Key: FLINK-5111 URL: https://issues.apache.org/jira/browse/FLINK-5111 Project: Flink

[jira] [Commented] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist

[ https://issues.apache.org/jira/browse/FLINK-4725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15683703#comment-15683703 ] Kostas Kloudas commented on FLINK-4725: --- I think this issue is resolved already in t

[jira] [Closed] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist

[ https://issues.apache.org/jira/browse/FLINK-4725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-4725. - Resolution: Fixed > BucketingSink throws NPE while restoring state if basePath does not exist > --

[jira] [Closed] (FLINK-5083) Race condition in Rolling/Bucketing Sink pending files cleanup

[ https://issues.apache.org/jira/browse/FLINK-5083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5083. - Resolution: Fixed > Race condition in Rolling/Bucketing Sink pending files cleanup > -

[jira] [Closed] (FLINK-5111) Change the assignToKeyGroup() method to not use Object.hashCode()

[ https://issues.apache.org/jira/browse/FLINK-5111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5111. - Resolution: Invalid > Change the assignToKeyGroup() method to not use Object.hashCode() >

[jira] [Created] (FLINK-5113) Make all the testing Functions implement the CheckpointedFucntion interface.

Kostas Kloudas created FLINK-5113: - Summary: Make all the testing Functions implement the CheckpointedFucntion interface. Key: FLINK-5113 URL: https://issues.apache.org/jira/browse/FLINK-5113 Project:

[jira] [Created] (FLINK-5117) Make the state of the AbstractAlignedProcessingTimeWindowOperator compatible with the WindowOperator.

Kostas Kloudas created FLINK-5117: - Summary: Make the state of the AbstractAlignedProcessingTimeWindowOperator compatible with the WindowOperator. Key: FLINK-5117 URL: https://issues.apache.org/jira/browse/FLINK-5

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15689706#comment-15689706 ] Kostas Kloudas commented on FLINK-2646: --- Can I take the issue? It seems inactive for

[jira] [Created] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks)

Kostas Kloudas created FLINK-5163: - Summary: Make the production functions rescalable (apart from the Rolling/Bucketing Sinks) Key: FLINK-5163 URL: https://issues.apache.org/jira/browse/FLINK-5163 Pro

[jira] [Created] (FLINK-5174) Fix memory leak in the CEP library.

Kostas Kloudas created FLINK-5174: - Summary: Fix memory leak in the CEP library. Key: FLINK-5174 URL: https://issues.apache.org/jira/browse/FLINK-5174 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5264) Improve error message when assigning uid to intermediate operator.

Kostas Kloudas created FLINK-5264: - Summary: Improve error message when assigning uid to intermediate operator. Key: FLINK-5264 URL: https://issues.apache.org/jira/browse/FLINK-5264 Project: Flink

[jira] [Created] (FLINK-5292) Make the remaining operators backwards compatible.

Kostas Kloudas created FLINK-5292: - Summary: Make the remaining operators backwards compatible. Key: FLINK-5292 URL: https://issues.apache.org/jira/browse/FLINK-5292 Project: Flink Issue Type

[jira] [Created] (FLINK-5293) Make the Kafka consumer backwards compatible.

Kostas Kloudas created FLINK-5293: - Summary: Make the Kafka consumer backwards compatible. Key: FLINK-5293 URL: https://issues.apache.org/jira/browse/FLINK-5293 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5294) Make the WindowOperator backwards compatible.

Kostas Kloudas created FLINK-5294: - Summary: Make the WindowOperator backwards compatible. Key: FLINK-5294 URL: https://issues.apache.org/jira/browse/FLINK-5294 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5295) Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible.

Kostas Kloudas created FLINK-5295: - Summary: Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible. Key: FLINK-5295 URL: https://issues.apache.org/jira/browse/FLINK-5295

[jira] [Created] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

Kostas Kloudas created FLINK-5296: - Summary: Expose the old AlignedWindowOperators to the user through explicit commands. Key: FLINK-5296 URL: https://issues.apache.org/jira/browse/FLINK-5296 Project:

[jira] [Created] (FLINK-5316) Make the GenericWriteAheadSink backwards compatible.

Kostas Kloudas created FLINK-5316: - Summary: Make the GenericWriteAheadSink backwards compatible. Key: FLINK-5316 URL: https://issues.apache.org/jira/browse/FLINK-5316 Project: Flink Issue Ty

[jira] [Created] (FLINK-5317) Make the continuous file processing code backwards compatible,

Kostas Kloudas created FLINK-5317: - Summary: Make the continuous file processing code backwards compatible, Key: FLINK-5317 URL: https://issues.apache.org/jira/browse/FLINK-5317 Project: Flink

[jira] [Created] (FLINK-5318) Make the Rolling/Bucketing sink backwards compatible.

Kostas Kloudas created FLINK-5318: - Summary: Make the Rolling/Bucketing sink backwards compatible. Key: FLINK-5318 URL: https://issues.apache.org/jira/browse/FLINK-5318 Project: Flink Issue T

  1   2   3   4   5   6   7   8   9   10   >