[jira] [Closed] (FLINK-5751) 404 in documentation

[ https://issues.apache.org/jira/browse/FLINK-5751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5751. -- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 67e3d9d (release-1.2), 67e3d9d

[jira] [Closed] (FLINK-5807) improved wording for doc home page

[ https://issues.apache.org/jira/browse/FLINK-5807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5807. -- Resolution: Fixed Fixed in d1b415b (release-1.2), 5ae9195 (master). > improved wording for doc home

[jira] [Closed] (FLINK-5806) TaskExecutionState toString format have wrong key

[ https://issues.apache.org/jira/browse/FLINK-5806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5806. -- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in b065226 (master),

[jira] [Closed] (FLINK-5796) broken links in the docs

[ https://issues.apache.org/jira/browse/FLINK-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5796. -- Resolution: Fixed Fix Version/s: 1.2.0 1.3.0 Fixed 8368681 (release-1.2),

[jira] [Closed] (FLINK-5745) Set uncaught exception handler for Netty threads

[ https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5745. -- Resolution: Fixed Fix Version/s: 1.3.0 Fixed in 9b4cd34 (release-1.2). > Set uncaught exception

[jira] [Assigned] (FLINK-5801) Queryable State from Scala job/client fails with key of type Long

[ https://issues.apache.org/jira/browse/FLINK-5801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5801: -- Assignee: Ufuk Celebi > Queryable State from Scala job/client fails with key of type Long >

[jira] [Commented] (FLINK-5801) Queryable State from Scala job/client fails with key of type Long

[ https://issues.apache.org/jira/browse/FLINK-5801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867418#comment-15867418 ] Ufuk Celebi commented on FLINK-5801: Thanks for reporting this. I will look into this later today. >

[jira] [Commented] (FLINK-5796) broken links in the docs

[ https://issues.apache.org/jira/browse/FLINK-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865881#comment-15865881 ] Ufuk Celebi commented on FLINK-5796: [~rmetzger] Can we integrate this check with the build bot? >

[jira] [Created] (FLINK-5781) Generation HTML from ConfigOption

Ufuk Celebi created FLINK-5781: -- Summary: Generation HTML from ConfigOption Key: FLINK-5781 URL: https://issues.apache.org/jira/browse/FLINK-5781 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5780) Extend ConfigOption with descriptions

Ufuk Celebi created FLINK-5780: -- Summary: Extend ConfigOption with descriptions Key: FLINK-5780 URL: https://issues.apache.org/jira/browse/FLINK-5780 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5779) Auto generate configuration docs

Ufuk Celebi created FLINK-5779: -- Summary: Auto generate configuration docs Key: FLINK-5779 URL: https://issues.apache.org/jira/browse/FLINK-5779 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5778) Split FileStateHandle into fileName and basePath

Ufuk Celebi created FLINK-5778: -- Summary: Split FileStateHandle into fileName and basePath Key: FLINK-5778 URL: https://issues.apache.org/jira/browse/FLINK-5778 Project: Flink Issue Type:

[jira] [Created] (FLINK-5777) Pass savepoint information to CheckpointingOperation

Ufuk Celebi created FLINK-5777: -- Summary: Pass savepoint information to CheckpointingOperation Key: FLINK-5777 URL: https://issues.apache.org/jira/browse/FLINK-5777 Project: Flink Issue Type:

[jira] [Created] (FLINK-5765) Add noindex meta tag for older docs

Ufuk Celebi created FLINK-5765: -- Summary: Add noindex meta tag for older docs Key: FLINK-5765 URL: https://issues.apache.org/jira/browse/FLINK-5765 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5764) Don't serve ancient docs

[ https://issues.apache.org/jira/browse/FLINK-5764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859817#comment-15859817 ] Ufuk Celebi commented on FLINK-5764: Furthermore, we should look into explicitly removing the old docs

[jira] [Created] (FLINK-5764) Don't serve ancient docs

Ufuk Celebi created FLINK-5764: -- Summary: Don't serve ancient docs Key: FLINK-5764 URL: https://issues.apache.org/jira/browse/FLINK-5764 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5763) Make savepoints self-contained and relocatable

Ufuk Celebi created FLINK-5763: -- Summary: Make savepoints self-contained and relocatable Key: FLINK-5763 URL: https://issues.apache.org/jira/browse/FLINK-5763 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5742) Breakpoints on documentation website

[ https://issues.apache.org/jira/browse/FLINK-5742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859307#comment-15859307 ] Ufuk Celebi commented on FLINK-5742: Thanks for reporting this [~colinbreame]. I fully agree. Do you

[jira] [Created] (FLINK-5745) Set uncaught exception handler for Netty threads

Ufuk Celebi created FLINK-5745: -- Summary: Set uncaught exception handler for Netty threads Key: FLINK-5745 URL: https://issues.apache.org/jira/browse/FLINK-5745 Project: Flink Issue Type:

[jira] [Closed] (FLINK-5732) Java quick start mvn command line is incorrect

[ https://issues.apache.org/jira/browse/FLINK-5732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5732. -- Resolution: Fixed Assignee: Ufuk Celebi Fix Version/s: 1.2.1 Thanks for spotting this.

[jira] [Closed] (FLINK-5699) Cancel with savepoint fails with a NPE if savepoint target directory not set

[ https://issues.apache.org/jira/browse/FLINK-5699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5699. -- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Fixed in b452c8b (master),

[jira] [Created] (FLINK-5731) Split up CI builds

Ufuk Celebi created FLINK-5731: -- Summary: Split up CI builds Key: FLINK-5731 URL: https://issues.apache.org/jira/browse/FLINK-5731 Project: Flink Issue Type: Improvement Components:

[jira] [Closed] (FLINK-5575) in old releases, warn users and guide them to the latest stable docs

[ https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5575. -- Resolution: Fixed Fix Version/s: 1.2.0 1.1.5 1.3.0

[jira] [Closed] (FLINK-5618) Add queryable state documentation

[ https://issues.apache.org/jira/browse/FLINK-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5618. -- Resolution: Fixed Fix Version/s: 1.2.0 1.3.0 e09c4c5 (master), a9a5004

[jira] [Assigned] (FLINK-5699) Cancel with savepoint fails with a NPE if savepoint target directory not set

[ https://issues.apache.org/jira/browse/FLINK-5699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5699: -- Assignee: Ufuk Celebi > Cancel with savepoint fails with a NPE if savepoint target directory

[jira] (FLINK-5672) Job fails with java.lang.IllegalArgumentException: port out of range:-1

Title: Message Title Ufuk Celebi commented on FLINK-5672

[jira] (FLINK-5673) NullPointerException in RemoteInputChannel.requestSubpartition

Title: Message Title Ufuk Celebi updated an issue

[jira] (FLINK-5673) NullPointerException in RemoteInputChannel.requestSubpartition

Title: Message Title Ufuk Celebi commented on FLINK-5673

[jira] (FLINK-5608) Cancel button not always visible

Title: Message Title Ufuk Celebi closed an issue as Fixed

[jira] (FLINK-5480) User-provided hashes for operators

Title: Message Title Ufuk Celebi closed an issue as Fixed

[jira] (FLINK-5686) Print meaningful message when JM is lost

Title: Message Title Ufuk Celebi created an issue

[jira] (FLINK-5628) CheckpointStatsTracker implements Serializable but isn't

Title: Message Title Ufuk Celebi closed an issue as Fixed

[jira] (FLINK-5415) ContinuousFileProcessingTest failed on travis

Title: Message Title Ufuk Celebi commented on FLINK-5415

[jira] (FLINK-5415) ContinuousFileProcessingTest failed on travis

Title: Message Title Ufuk Celebi updated an issue

[jira] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

Title: Message Title Ufuk Celebi assigned an issue to Ufuk Celebi

[jira] [Updated] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5509: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-5675 > Replace QueryableStateClient

[jira] [Updated] (FLINK-5603) Use Flink's futures in QueryableStateClient

[ https://issues.apache.org/jira/browse/FLINK-5603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5603: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-5675 > Use Flink's futures in

[jira] [Updated] (FLINK-5604) Replace QueryableStateClient constructor

[ https://issues.apache.org/jira/browse/FLINK-5604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5604: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-5675 > Replace QueryableStateClient

[jira] [Updated] (FLINK-5605) Make KvStateRequestSerializer package private

[ https://issues.apache.org/jira/browse/FLINK-5605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5605: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-5675 > Make KvStateRequestSerializer

[jira] [Updated] (FLINK-5607) Move location lookup retry out of KvStateLocationLookupService

[ https://issues.apache.org/jira/browse/FLINK-5607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5607: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-5675 > Move location lookup retry out

[jira] [Updated] (FLINK-5606) Remove magic number in key and namespace serialization

[ https://issues.apache.org/jira/browse/FLINK-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5606: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-5675 > Remove magic number in key and

[jira] [Updated] (FLINK-5604) Replace QueryableStateClient constructor

[ https://issues.apache.org/jira/browse/FLINK-5604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5604: --- Assignee: (was: Ufuk Celebi) > Replace QueryableStateClient constructor >

[jira] [Updated] (FLINK-5605) Make KvStateRequestSerializer package private

[ https://issues.apache.org/jira/browse/FLINK-5605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5605: --- Assignee: (was: Ufuk Celebi) > Make KvStateRequestSerializer package private >

[jira] [Updated] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5509: --- Assignee: (was: Ufuk Celebi) > Replace QueryableStateClient keyHashCode argument >

[jira] [Updated] (FLINK-5603) Use Flink's futures in QueryableStateClient

[ https://issues.apache.org/jira/browse/FLINK-5603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5603: --- Assignee: (was: Ufuk Celebi) > Use Flink's futures in QueryableStateClient >

[jira] [Updated] (FLINK-5606) Remove magic number in key and namespace serialization

[ https://issues.apache.org/jira/browse/FLINK-5606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5606: --- Assignee: (was: Ufuk Celebi) > Remove magic number in key and namespace serialization >

[jira] [Updated] (FLINK-5611) Add QueryableStateException type

[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5611: --- Assignee: (was: Ufuk Celebi) > Add QueryableStateException type >

[jira] [Updated] (FLINK-5607) Move location lookup retry out of KvStateLocationLookupService

[ https://issues.apache.org/jira/browse/FLINK-5607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5607: --- Assignee: (was: Ufuk Celebi) > Move location lookup retry out of KvStateLocationLookupService >

[jira] [Updated] (FLINK-5611) Add QueryableStateException type

[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5611: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-5675 > Add QueryableStateException

[jira] [Created] (FLINK-5675) Improve QueryableStateClient API

Ufuk Celebi created FLINK-5675: -- Summary: Improve QueryableStateClient API Key: FLINK-5675 URL: https://issues.apache.org/jira/browse/FLINK-5675 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-4178) CoStreamCheckpointingITCase deadlocks

[ https://issues.apache.org/jira/browse/FLINK-4178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4178. -- Resolution: Won't Fix Too much changed since this was reported. Closing as wont fix. >

[jira] [Closed] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure

[ https://issues.apache.org/jira/browse/FLINK-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5049. -- Resolution: Implemented Fix Version/s: 1.3.0 1.2.0 c89a622 (master), c8c86e7

[jira] [Commented] (FLINK-3903) Homebrew Installation

[ https://issues.apache.org/jira/browse/FLINK-3903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15842635#comment-15842635 ] Ufuk Celebi commented on FLINK-3903: No, just unassigned myself. Makes sense to wait until 1.2 is

[jira] [Updated] (FLINK-3903) Homebrew Installation

[ https://issues.apache.org/jira/browse/FLINK-3903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-3903: --- Assignee: (was: Ufuk Celebi) > Homebrew Installation > - > >

[jira] [Updated] (FLINK-4990) Remove JAR option from savepoint disposal

[ https://issues.apache.org/jira/browse/FLINK-4990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-4990: --- Assignee: (was: Ufuk Celebi) > Remove JAR option from savepoint disposal >

[jira] [Updated] (FLINK-4808) Allow skipping failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-4808: --- Assignee: (was: Ufuk Celebi) > Allow skipping failed checkpoints >

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

[ https://issues.apache.org/jira/browse/FLINK-5264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5264: --- Assignee: (was: Ufuk Celebi) > Improve error message when assigning uid to intermediate operator

[jira] [Updated] (FLINK-4511) Schedule periodic savepoints

[ https://issues.apache.org/jira/browse/FLINK-4511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-4511: --- Assignee: (was: Ufuk Celebi) > Schedule periodic savepoints > > >

[jira] [Closed] (FLINK-1099) Check that the GlobalBufferPool has all buffers available after a task crashed with an exception

[ https://issues.apache.org/jira/browse/FLINK-1099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-1099. -- Resolution: Fixed I think these are covered in the Local/NetworkBufferPool unit tests. > Check that

[jira] [Commented] (FLINK-5670) Local RocksDB directories not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-5670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15842588#comment-15842588 ] Ufuk Celebi commented on FLINK-5670: Looks like an easy fix. Big +1 to fix it for 1.2 as well. >

[jira] [Commented] (FLINK-5672) Job fails with java.lang.IllegalArgumentException: port out of range:-1

[ https://issues.apache.org/jira/browse/FLINK-5672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15842530#comment-15842530 ] Ufuk Celebi commented on FLINK-5672: Do you have the logs of the TMs? They log their data ports on

[jira] [Closed] (FLINK-5666) Blob files are not cleaned up from ZK storage directory

[ https://issues.apache.org/jira/browse/FLINK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5666. -- Resolution: Not A Problem Fix Version/s: 1.3.0 1.2.0 Added tests in 24db045

[jira] [Closed] (FLINK-5664) RocksDBBackend logging is noisy

[ https://issues.apache.org/jira/browse/FLINK-5664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5664. -- Resolution: Won't Fix > RocksDBBackend logging is noisy > --- > >

[jira] [Commented] (FLINK-5664) RocksDBBackend logging is noisy

[ https://issues.apache.org/jira/browse/FLINK-5664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15842433#comment-15842433 ] Ufuk Celebi commented on FLINK-5664: You are right, just checked the 1.1 code. I think it's good to

[jira] [Created] (FLINK-5670) Local RocksDB directories not cleaned up

Ufuk Celebi created FLINK-5670: -- Summary: Local RocksDB directories not cleaned up Key: FLINK-5670 URL: https://issues.apache.org/jira/browse/FLINK-5670 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-5665) Lingering files after failed checkpoint

[ https://issues.apache.org/jira/browse/FLINK-5665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5665. -- Resolution: Duplicate The checkpoints were in pending state w/o an ack (pending is the initial

[jira] [Commented] (FLINK-5666) Blob files are not cleaned up from ZK storage directory

[ https://issues.apache.org/jira/browse/FLINK-5666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15842425#comment-15842425 ] Ufuk Celebi commented on FLINK-5666: You are right, the library cache manager would have cleaned that

[jira] [Comment Edited] (FLINK-5667) Possible state data loss when task fails while checkpointing

[ https://issues.apache.org/jira/browse/FLINK-5667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15842420#comment-15842420 ] Ufuk Celebi edited comment on FLINK-5667 at 1/27/17 9:08 AM: - Very good catch!

[jira] [Commented] (FLINK-5667) Possible state data loss when task fails while checkpointing

[ https://issues.apache.org/jira/browse/FLINK-5667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15842420#comment-15842420 ] Ufuk Celebi commented on FLINK-5667: Very god catch! :-) > Possible state data loss when task fails

[jira] [Commented] (FLINK-5665) Lingering files after failed checkpoint

[ https://issues.apache.org/jira/browse/FLINK-5665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15840059#comment-15840059 ] Ufuk Celebi commented on FLINK-5665: This is most likely a duplicate of FLINK-5660, right

[jira] [Commented] (FLINK-5663) Checkpoint fails because of closed registry

[ https://issues.apache.org/jira/browse/FLINK-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15840038#comment-15840038 ] Ufuk Celebi commented on FLINK-5663: Out of 10 submission, 3 failed with this. > Checkpoint fails

[jira] [Created] (FLINK-5666) Blob files are not cleaned up from ZK storage directory

Ufuk Celebi created FLINK-5666: -- Summary: Blob files are not cleaned up from ZK storage directory Key: FLINK-5666 URL: https://issues.apache.org/jira/browse/FLINK-5666 Project: Flink Issue

[jira] [Created] (FLINK-5665) Lingering files after failed checkpoint

Ufuk Celebi created FLINK-5665: -- Summary: Lingering files after failed checkpoint Key: FLINK-5665 URL: https://issues.apache.org/jira/browse/FLINK-5665 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5664) RocksDBBackend logging is noisy

Ufuk Celebi created FLINK-5664: -- Summary: RocksDBBackend logging is noisy Key: FLINK-5664 URL: https://issues.apache.org/jira/browse/FLINK-5664 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5663) Checkpoint fails because of closed registry

Ufuk Celebi created FLINK-5663: -- Summary: Checkpoint fails because of closed registry Key: FLINK-5663 URL: https://issues.apache.org/jira/browse/FLINK-5663 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5660) Not properly cleaning PendingCheckpoints up

[ https://issues.apache.org/jira/browse/FLINK-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15839879#comment-15839879 ] Ufuk Celebi commented on FLINK-5660: We did fix that for 1.1.4, right? > Not properly cleaning

[jira] [Closed] (FLINK-5602) Migration with RocksDB job led to NPE for next checkpoint

[ https://issues.apache.org/jira/browse/FLINK-5602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5602. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in 80c9f80 (release-1.2),

[jira] [Closed] (FLINK-5626) Improve resource release in RocksDBKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5626. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in 5a435fc (release-1.2),

[jira] [Assigned] (FLINK-5628) CheckpointStatsTracker implements Serializable but isn't

[ https://issues.apache.org/jira/browse/FLINK-5628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5628: -- Assignee: Ufuk Celebi > CheckpointStatsTracker implements Serializable but isn't >

[jira] [Created] (FLINK-5618) Add queryable state documentation

Ufuk Celebi created FLINK-5618: -- Summary: Add queryable state documentation Key: FLINK-5618 URL: https://issues.apache.org/jira/browse/FLINK-5618 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5611) Add QueryableStateException type

Ufuk Celebi created FLINK-5611: -- Summary: Add QueryableStateException type Key: FLINK-5611 URL: https://issues.apache.org/jira/browse/FLINK-5611 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5610) Rename Installation and Setup to Project Setup

Ufuk Celebi created FLINK-5610: -- Summary: Rename Installation and Setup to Project Setup Key: FLINK-5610 URL: https://issues.apache.org/jira/browse/FLINK-5610 Project: Flink Issue Type:

[jira] [Created] (FLINK-5609) Add last update time to docs

Ufuk Celebi created FLINK-5609: -- Summary: Add last update time to docs Key: FLINK-5609 URL: https://issues.apache.org/jira/browse/FLINK-5609 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-5576) extend deserialization functions of KvStateRequestSerializer to detect unconsumed bytes

[ https://issues.apache.org/jira/browse/FLINK-5576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5576. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in 7a0e3d6 (release-1.2),

[jira] [Closed] (FLINK-5559) queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails

[ https://issues.apache.org/jira/browse/FLINK-5559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5559. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in ef13f48 fd63981 f592d4c

[jira] [Created] (FLINK-5607) Move location lookup retry out of KvStateLocationLookupService

Ufuk Celebi created FLINK-5607: -- Summary: Move location lookup retry out of KvStateLocationLookupService Key: FLINK-5607 URL: https://issues.apache.org/jira/browse/FLINK-5607 Project: Flink

[jira] [Created] (FLINK-5606) Remove magic number in key and namespace serialization

Ufuk Celebi created FLINK-5606: -- Summary: Remove magic number in key and namespace serialization Key: FLINK-5606 URL: https://issues.apache.org/jira/browse/FLINK-5606 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-5605) Make KvStateRequestSerializer package private

[ https://issues.apache.org/jira/browse/FLINK-5605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5605: -- Assignee: Ufuk Celebi > Make KvStateRequestSerializer package private >

[jira] [Created] (FLINK-5605) Make KvStateRequestSerializer package private

Ufuk Celebi created FLINK-5605: -- Summary: Make KvStateRequestSerializer package private Key: FLINK-5605 URL: https://issues.apache.org/jira/browse/FLINK-5605 Project: Flink Issue Type:

[jira] [Created] (FLINK-5604) Replace QueryableStateClient constructor

Ufuk Celebi created FLINK-5604: -- Summary: Replace QueryableStateClient constructor Key: FLINK-5604 URL: https://issues.apache.org/jira/browse/FLINK-5604 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-5509) Replace QueryableStateClient keyHashCode argument

[ https://issues.apache.org/jira/browse/FLINK-5509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5509: -- Assignee: Ufuk Celebi > Replace QueryableStateClient keyHashCode argument >

[jira] [Created] (FLINK-5603) Use Flink's futures in QueryableStateClient

Ufuk Celebi created FLINK-5603: -- Summary: Use Flink's futures in QueryableStateClient Key: FLINK-5603 URL: https://issues.apache.org/jira/browse/FLINK-5603 Project: Flink Issue Type:

[jira] [Closed] (FLINK-4220) ClientTest fails after port conflict

[ https://issues.apache.org/jira/browse/FLINK-4220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4220. -- Resolution: Cannot Reproduce > ClientTest fails after port conflict >

[jira] [Closed] (FLINK-5116) Missing RocksDB state backend factory

[ https://issues.apache.org/jira/browse/FLINK-5116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5116. -- Resolution: Won't Fix Implemented in >= 1.2 > Missing RocksDB state backend factory >

[jira] [Commented] (FLINK-5436) UDF state without CheckpointedRestoring can result in restarting loop

[ https://issues.apache.org/jira/browse/FLINK-5436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833467#comment-15833467 ] Ufuk Celebi commented on FLINK-5436: [~stefanrichte...@gmail.com] and [~aljoscha] should we address

[jira] [Closed] (FLINK-5530) race condition in AbstractRocksDBState#getSerializedValue

[ https://issues.apache.org/jira/browse/FLINK-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5530. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in d8222c1 (release-1.2),

[jira] [Created] (FLINK-5602) Migration with RocksDB job led to NPE for next checkpoint

Ufuk Celebi created FLINK-5602: -- Summary: Migration with RocksDB job led to NPE for next checkpoint Key: FLINK-5602 URL: https://issues.apache.org/jira/browse/FLINK-5602 Project: Flink Issue

[jira] [Created] (FLINK-5601) Window operator does not checkpoint watermarks

Ufuk Celebi created FLINK-5601: -- Summary: Window operator does not checkpoint watermarks Key: FLINK-5601 URL: https://issues.apache.org/jira/browse/FLINK-5601 Project: Flink Issue Type:

[jira] [Created] (FLINK-5600) Improve error message when triggering savepoint without specified directory

Ufuk Celebi created FLINK-5600: -- Summary: Improve error message when triggering savepoint without specified directory Key: FLINK-5600 URL: https://issues.apache.org/jira/browse/FLINK-5600 Project: Flink

[jira] [Created] (FLINK-5599) State interface docs often refer to keyed state only

Ufuk Celebi created FLINK-5599: -- Summary: State interface docs often refer to keyed state only Key: FLINK-5599 URL: https://issues.apache.org/jira/browse/FLINK-5599 Project: Flink Issue Type:

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