[jira] [Created] (FLINK-9360) HA end-to-end nightly test takes more than 15 min in Travis CI

2018-05-14 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9360: -- Summary: HA end-to-end nightly test takes more than 15 min in Travis CI Key: FLINK-9360 URL: https://issues.apache.org/jira/browse/FLINK-9360 Project: Flink

[jira] [Updated] (FLINK-9360) HA end-to-end nightly test takes more than 15 min in Travis CI

2018-05-14 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9360: --- Description: We have not discussed how long the nightly tests should run. Currently overall

[jira] [Assigned] (FLINK-9301) NotSoMiniClusterIterations job fails on travis

2018-05-09 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-9301: -- Assignee: Andrey Zagrebin > NotSoMiniClusterIterations job fails on travis >

[jira] [Resolved] (FLINK-9572) Extend InternalAppendingState with internal stored state access

2018-06-14 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin resolved FLINK-9572. Resolution: Done merged in master, commit 09fbf23f5d > Extend InternalAppendingState with

[jira] [Assigned] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-12 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-9514: -- Assignee: Andrey Zagrebin > Create wrapper with TTL logic for value state >

[jira] [Created] (FLINK-9572) Extend InternalAppendingState with internal stored state access

2018-06-12 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9572: -- Summary: Extend InternalAppendingState with internal stored state access Key: FLINK-9572 URL: https://issues.apache.org/jira/browse/FLINK-9572 Project: Flink

[jira] [Assigned] (FLINK-9515) Create wrapper with TTL logic for list state

2018-06-12 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-9515: -- Assignee: Andrey Zagrebin > Create wrapper with TTL logic for list state >

[jira] [Assigned] (FLINK-9516) Create wrapper with TTL logic for map state

2018-06-12 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-9516: -- Assignee: Andrey Zagrebin > Create wrapper with TTL logic for map state >

[jira] [Assigned] (FLINK-9513) Wrap state binder with TTL logic

2018-06-12 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-9513: -- Assignee: Andrey Zagrebin > Wrap state binder with TTL logic >

[jira] [Created] (FLINK-9571) Switch to internal states in StateBinder

2018-06-12 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9571: -- Summary: Switch to internal states in StateBinder Key: FLINK-9571 URL: https://issues.apache.org/jira/browse/FLINK-9571 Project: Flink Issue Type:

[jira] [Created] (FLINK-9510) State TTL API with cleanup on explicit access

2018-06-04 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9510: -- Summary: State TTL API with cleanup on explicit access Key: FLINK-9510 URL: https://issues.apache.org/jira/browse/FLINK-9510 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9510) State TTL API with cleanup on explicit access

2018-06-04 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16499849#comment-16499849 ] Andrey Zagrebin commented on FLINK-9510: First iteration of state TTL feature > State TTL API

[jira] [Created] (FLINK-9512) StateDescriptor TTL config should be part of versioned meta info snapshot

2018-06-04 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9512: -- Summary: StateDescriptor TTL config should be part of versioned meta info snapshot Key: FLINK-9512 URL: https://issues.apache.org/jira/browse/FLINK-9512 Project:

[jira] [Created] (FLINK-9511) Make StateDescriptor configurable with optional TTL

2018-06-04 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9511: -- Summary: Make StateDescriptor configurable with optional TTL Key: FLINK-9511 URL: https://issues.apache.org/jira/browse/FLINK-9511 Project: Flink Issue

[jira] [Updated] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-04 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9514: --- Description: TTL state decorator uses original state with packed TTL and add TTL logic using

[jira] [Created] (FLINK-9515) Create wrapper with TTL logic for list state

2018-06-04 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9515: -- Summary: Create wrapper with TTL logic for list state Key: FLINK-9515 URL: https://issues.apache.org/jira/browse/FLINK-9515 Project: Flink Issue Type:

[jira] [Updated] (FLINK-9513) Wrap state binder with TTL logic

2018-06-04 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9513: --- Description: The main idea is to wrap user state value with a class holding the value and

[jira] [Updated] (FLINK-9512) StateDescriptor TTL config should be part of versioned meta info snapshot

2018-06-04 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9512: --- Component/s: (was: Java API) > StateDescriptor TTL config should be part of versioned

[jira] [Created] (FLINK-9516) Create wrapper with TTL logic for map state

2018-06-04 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9516: -- Summary: Create wrapper with TTL logic for map state Key: FLINK-9516 URL: https://issues.apache.org/jira/browse/FLINK-9516 Project: Flink Issue Type:

[jira] [Created] (FLINK-9513) Wrap state binder with TTL logic

2018-06-04 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9513: -- Summary: Wrap state binder with TTL logic Key: FLINK-9513 URL: https://issues.apache.org/jira/browse/FLINK-9513 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-04 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9514: -- Summary: Create wrapper with TTL logic for value state Key: FLINK-9514 URL: https://issues.apache.org/jira/browse/FLINK-9514 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-05-28 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492760#comment-16492760 ] Andrey Zagrebin commented on FLINK-9231: [~yuzhih...@gmail.com] just wondering could you please

[jira] [Updated] (FLINK-9511) Make StateDescriptor configurable with optional TTL

2018-07-02 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9511: --- Description: TTL can be enabled and configured in the constructor of abstract

[jira] [Commented] (FLINK-9511) Make StateDescriptor configurable with optional TTL

2018-07-02 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16529598#comment-16529598 ] Andrey Zagrebin commented on FLINK-9511: Hi [~yanghua], `TtlConfig` has to be moved to

[jira] [Updated] (FLINK-9511) Implement TTL config

2018-07-02 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9511: --- Description: `TtlConfig` has to be in flink core module. Another option is to consider

[jira] [Updated] (FLINK-9511) Implement TTL config

2018-07-02 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9511: --- Summary: Implement TTL config (was: Make StateDescriptor configurable with optional TTL) >

[jira] [Assigned] (FLINK-9512) StateDescriptor TTL config should be part of versioned meta info snapshot

2018-07-02 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-9512: -- Assignee: Andrey Zagrebin > StateDescriptor TTL config should be part of versioned

[jira] [Assigned] (FLINK-9637) Add public user documentation for TTL feature

2018-07-02 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-9637: -- Assignee: Andrey Zagrebin > Add public user documentation for TTL feature >

[jira] [Created] (FLINK-9701) Activate TTL in state descriptors

2018-07-02 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9701: -- Summary: Activate TTL in state descriptors Key: FLINK-9701 URL: https://issues.apache.org/jira/browse/FLINK-9701 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-9510) State TTL API with cleanup on explicit access

2018-06-21 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-9510: -- Assignee: Andrey Zagrebin > State TTL API with cleanup on explicit access >

[jira] [Updated] (FLINK-9511) Make StateDescriptor configurable with optional TTL

2018-06-21 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9511: --- Description: TTL can be enabled and configured in the constructor of abstract

[jira] [Created] (FLINK-9637) Add public user documentation for TTL feature

2018-06-21 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9637: -- Summary: Add public user documentation for TTL feature Key: FLINK-9637 URL: https://issues.apache.org/jira/browse/FLINK-9637 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool

2018-06-22 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520206#comment-16520206 ] Andrey Zagrebin edited comment on FLINK-9493 at 6/22/18 10:14 AM: --

[jira] [Assigned] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool

2018-06-22 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-9493: -- Assignee: Andrey Zagrebin (was: vinoyang) > Forward exception when releasing a

[jira] [Commented] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool

2018-06-22 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520206#comment-16520206 ] Andrey Zagrebin commented on FLINK-9493: [~yanghua], sorry, I thought there was no started

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

2018-08-01 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565583#comment-16565583 ] Andrey Zagrebin commented on FLINK-10011: - This problem might be related to the recently fixed

[jira] [Closed] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-08-09 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9231. -- Resolution: Unresolved Release Note: I am closing the issue because of inactivity, it

[jira] [Created] (FLINK-10151) [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

2018-08-15 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10151: --- Summary: [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource Key: FLINK-10151 URL:

[jira] [Updated] (FLINK-10151) [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

2018-08-15 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10151: Description: *TransformingStateTableKeyGroupPartitioner* currently calls *tryAddToSource* 

[jira] [Updated] (FLINK-10151) [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

2018-08-15 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10151: Component/s: State Backends, Checkpointing > [State TTL] Fix false recursion call in >

[jira] [Updated] (FLINK-10151) [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

2018-08-15 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10151: Fix Version/s: 1.7.0 > [State TTL] Fix false recursion call in >

[jira] [Updated] (FLINK-10151) [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

2018-08-15 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10151: Fix Version/s: 1.6.1 > [State TTL] Fix false recursion call in >

[jira] [Updated] (FLINK-10151) [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

2018-08-15 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10151: Affects Version/s: 1.6.0 > [State TTL] Fix false recursion call in >

[jira] [Commented] (FLINK-10157) The TTL state not allow `null` state value

2018-08-16 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582175#comment-16582175 ] Andrey Zagrebin commented on FLINK-10157: - Thanks for reporting this issue [~wucj]! I will have

[jira] [Assigned] (FLINK-10157) The TTL state not allow `null` state value

2018-08-16 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-10157: --- Assignee: Andrey Zagrebin > The TTL state not allow `null` state value >

[jira] [Created] (FLINK-10095) Change the serialisation order in TTL value wrapper

2018-08-07 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10095: --- Summary: Change the serialisation order in TTL value wrapper Key: FLINK-10095 URL: https://issues.apache.org/jira/browse/FLINK-10095 Project: Flink

[jira] [Assigned] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo

2018-08-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-9126: -- Assignee: Andrey Zagrebin (was: Jeffrey Carter) > Creation of the

[jira] [Closed] (FLINK-9510) State TTL API with cleanup on explicit access

2018-08-13 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9510. -- Resolution: Implemented Fix Version/s: (was: 1.6.1) 1.6.0 >

[jira] [Commented] (FLINK-10125) Unclosed ByteArrayDataOutputView in RocksDBMapState

2018-08-13 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16578008#comment-16578008 ] Andrey Zagrebin commented on FLINK-10125: - The *ByteArrayDataOutputView* is recently introduced

[jira] [Updated] (FLINK-9938) State TTL cleanup of full state snapshot upon checkpointing

2018-08-13 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9938: --- Summary: State TTL cleanup of full state snapshot upon checkpointing (was: State TTL

[jira] [Updated] (FLINK-9938) State TTL cleanup of full state snapshot upon checkpointing

2018-08-13 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-9938: --- Description: We can try to piggyback full state scan during certain checkpoint processes in

[jira] [Created] (FLINK-10132) Incremental cleanup of local expired state with TTL discovered in full snapshot

2018-08-13 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10132: --- Summary: Incremental cleanup of local expired state with TTL discovered in full snapshot Key: FLINK-10132 URL: https://issues.apache.org/jira/browse/FLINK-10132

[jira] [Assigned] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-8290: -- Assignee: Andrey Zagrebin (was: xymaqingxiang) > Modify clientId to groupId in

[jira] [Assigned] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-8290: -- Assignee: xymaqingxiang (was: Andrey Zagrebin) > Modify clientId to groupId in

[jira] [Assigned] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-8290: -- Assignee: Andrey Zagrebin (was: xymaqingxiang) > Modify clientId to groupId in

[jira] [Assigned] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-8290: -- Assignee: xymaqingxiang (was: Andrey Zagrebin) > Modify clientId to groupId in

[jira] [Created] (FLINK-10249) Document hadoop/presto s3 file system configuration forwarding

2018-08-29 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10249: --- Summary: Document hadoop/presto s3 file system configuration forwarding Key: FLINK-10249 URL: https://issues.apache.org/jira/browse/FLINK-10249 Project: Flink

[jira] [Closed] (FLINK-9701) Activate TTL in state descriptors

2018-07-20 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9701. -- Followup changes are merged in Master: 

[jira] [Created] (FLINK-9858) State TTL End-to-End Test

2018-07-16 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9858: -- Summary: State TTL End-to-End Test Key: FLINK-9858 URL: https://issues.apache.org/jira/browse/FLINK-9858 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-9938) State TTL cleanup during full state scan upon checkpointing

2018-07-25 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16555336#comment-16555336 ] Andrey Zagrebin commented on FLINK-9938: I think it could be also possible, though would need

[jira] [Commented] (FLINK-9098) ClassLoaderITCase unstable

2018-07-24 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554473#comment-16554473 ] Andrey Zagrebin commented on FLINK-9098: I also looped it 668 iterations, no error:

[jira] [Created] (FLINK-9938) State TTL cleanup during full state scan upon checkpointing

2018-07-24 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9938: -- Summary: State TTL cleanup during full state scan upon checkpointing Key: FLINK-9938 URL: https://issues.apache.org/jira/browse/FLINK-9938 Project: Flink

[jira] [Assigned] (FLINK-8439) Document using a custom AWS Credentials Provider with flink-3s-fs-hadoop

2018-07-24 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-8439: -- Assignee: Andrey Zagrebin > Document using a custom AWS Credentials Provider with

[jira] [Commented] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files

2018-07-13 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16542830#comment-16542830 ] Andrey Zagrebin commented on FLINK-9587: Hi [~shumanski] *ContinuousFileMonitoringFunction* is

[jira] [Resolved] (FLINK-9512) StateDescriptor TTL config should be part of versioned meta info snapshot

2018-07-12 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin resolved FLINK-9512. Resolution: Won't Do Release Note: Conclusion so far is that TTL config is just a way

[jira] [Closed] (FLINK-9572) Extend InternalAppendingState with internal stored state access

2018-07-12 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9572. -- > Extend InternalAppendingState with internal stored state access >

[jira] [Closed] (FLINK-9512) StateDescriptor TTL config should be part of versioned meta info snapshot

2018-07-12 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9512. -- > StateDescriptor TTL config should be part of versioned meta info snapshot >

[jira] [Created] (FLINK-9254) Move NotSoMiniClusterIterations to be an end-to-end test

2018-04-25 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-9254: -- Summary: Move NotSoMiniClusterIterations to be an end-to-end test Key: FLINK-9254 URL: https://issues.apache.org/jira/browse/FLINK-9254 Project: Flink

[jira] [Assigned] (FLINK-8978) End-to-end test: Job upgrade

2018-04-26 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-8978: -- Assignee: Andrey Zagrebin > End-to-end test: Job upgrade >

[jira] [Closed] (FLINK-9515) Create wrapper with TTL logic for list state

2018-06-29 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9515. -- Resolution: Implemented Merged in: master: 2c13e00c1c > Create wrapper with TTL logic for

[jira] [Closed] (FLINK-9514) Create wrapper with TTL logic for value state

2018-06-29 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9514. -- Resolution: Fixed Merged in: master: 2c13e00c1c > Create wrapper with TTL logic for value

[jira] [Closed] (FLINK-9516) Create wrapper with TTL logic for map state

2018-06-29 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-9516. -- Resolution: Fixed Merged in: master: 2c13e00c1c > Create wrapper with TTL logic for map state

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-06-29 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527575#comment-16527575 ] Andrey Zagrebin commented on FLINK-9231: Is there still an interest in working on this problem?

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-06-29 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527672#comment-16527672 ] Andrey Zagrebin commented on FLINK-9231: [~triones], [~yuzhih...@gmail.com] I would suggest to

[jira] [Comment Edited] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

2018-06-29 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16527672#comment-16527672 ] Andrey Zagrebin edited comment on FLINK-9231 at 6/29/18 2:16 PM: -

[jira] [Commented] (FLINK-10471) State TTL cleanup using RocksDb compaction filter

2018-10-05 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639954#comment-16639954 ] Andrey Zagrebin commented on FLINK-10471: - [RocksDB PR for Flink compaction

[jira] [Created] (FLINK-10515) Improve tokenisation of program args passed as string

2018-10-08 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10515: --- Summary: Improve tokenisation of program args passed as string Key: FLINK-10515 URL: https://issues.apache.org/jira/browse/FLINK-10515 Project: Flink

[jira] [Commented] (FLINK-10095) Change the serialisation order in TTL value wrapper

2018-10-23 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16660258#comment-16660258 ] Andrey Zagrebin commented on FLINK-10095: - Hi [~aitozi], the options for timestamp positioning

[jira] [Assigned] (FLINK-10627) Extend test_streaming_file_sink to test S3 writer

2018-10-23 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-10627: --- Assignee: Andrey Zagrebin > Extend test_streaming_file_sink to test S3 writer >

[jira] [Assigned] (FLINK-10628) Add end-to-end test for REST communication encryption

2018-10-30 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-10628: --- Assignee: Andrey Zagrebin > Add end-to-end test for REST communication encryption

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-10-30 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668520#comment-16668520 ] Andrey Zagrebin commented on FLINK-10074: - I created an issue FLINK-10074 to revisit failure

[jira] [Created] (FLINK-10724) Refactor failure handling in check point coordinator

2018-10-30 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10724: --- Summary: Refactor failure handling in check point coordinator Key: FLINK-10724 URL: https://issues.apache.org/jira/browse/FLINK-10724 Project: Flink

[jira] [Updated] (FLINK-10724) Refactor failure handling in check point coordinator

2018-10-30 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10724: Description: At the moment failure handling of asynchronously triggered checkpoint in 

[jira] [Updated] (FLINK-10724) Refactor failure handling in check point coordinator

2018-10-30 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10724: Description: At the moment failure handling of asynchronously triggered checkpoint in 

[jira] [Assigned] (FLINK-10455) Potential Kafka producer leak in case of failures

2018-10-31 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-10455: --- Assignee: Andrey Zagrebin > Potential Kafka producer leak in case of failures >

[jira] [Commented] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

2018-11-02 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672800#comment-16672800 ] Andrey Zagrebin commented on FLINK-10473: - Hi, I have added > State TTL incremental cleanup

[jira] [Updated] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

2018-11-02 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10473: Description: This feature enables lazy background cleanup of state with time-to-live in

[jira] [Created] (FLINK-10830) Consider making processing time provider pluggable

2018-11-08 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10830: --- Summary: Consider making processing time provider pluggable Key: FLINK-10830 URL: https://issues.apache.org/jira/browse/FLINK-10830 Project: Flink

[jira] [Created] (FLINK-10833) FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify failed on Travis

2018-11-08 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10833: --- Summary: FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify failed on Travis Key: FLINK-10833 URL:

[jira] [Created] (FLINK-10831) Consider making processing time monotonically increasing by default

2018-11-08 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10831: --- Summary: Consider making processing time monotonically increasing by default Key: FLINK-10831 URL: https://issues.apache.org/jira/browse/FLINK-10831 Project:

[jira] [Commented] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis

2018-11-12 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683457#comment-16683457 ] Andrey Zagrebin commented on FLINK-10736: - I uploaded the words file as public s3 object in

[jira] [Resolved] (FLINK-10738) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed on Travis

2018-11-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin resolved FLINK-10738. - Resolution: Cannot Reproduce Release Note: tried it 5x20 times locally and on

[jira] [Resolved] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

2018-11-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin resolved FLINK-10737. - Resolution: Cannot Reproduce Release Note: tried it 5x20 times locally and on

[jira] [Assigned] (FLINK-10738) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed on Travis

2018-11-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-10738: --- Assignee: Andrey Zagrebin > FlinkKafkaProducerITCase.testScaleUpAfterScalingDown

[jira] [Commented] (FLINK-10738) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed on Travis

2018-11-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676386#comment-16676386 ] Andrey Zagrebin commented on FLINK-10738: - tried it 5x20 times locally and on travis:

[jira] [Commented] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

2018-11-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16676385#comment-16676385 ] Andrey Zagrebin commented on FLINK-10737: - tried it 5x20 times locally and on travis:

[jira] [Assigned] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

2018-11-06 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-10737: --- Assignee: Andrey Zagrebin >

[jira] [Created] (FLINK-10876) Deadlock if closing firstly pending transactions in FlinkKafkaProducer(011).close()

2018-11-14 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10876: --- Summary: Deadlock if closing firstly pending transactions in FlinkKafkaProducer(011).close() Key: FLINK-10876 URL: https://issues.apache.org/jira/browse/FLINK-10876

[jira] [Created] (FLINK-10842) Waiting loops are broken in e2e/common.sh

2018-11-09 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10842: --- Summary: Waiting loops are broken in e2e/common.sh Key: FLINK-10842 URL: https://issues.apache.org/jira/browse/FLINK-10842 Project: Flink Issue Type:

[jira] [Updated] (FLINK-10842) Waiting loops are broken in e2e/common.sh

2018-11-09 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10842: Affects Version/s: 1.7.0 > Waiting loops are broken in e2e/common.sh >

  1   2   3   4   5   >