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

[jira] [Closed] (FLINK-5528) tests: reduce the retry delay in QueryableStateITCase

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

[jira] [Closed] (FLINK-5468) Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException

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

[jira] [Closed] (FLINK-5561) DataInputDeserializer#available returns one too few

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

[jira] [Closed] (FLINK-5515) fix unused kvState.getSerializedValue call in KvStateServerHandler

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

[jira] [Created] (FLINK-5587) AsyncWaitOperatorTest timed out on Travis

Ufuk Celebi created FLINK-5587: -- Summary: AsyncWaitOperatorTest timed out on Travis Key: FLINK-5587 URL: https://issues.apache.org/jira/browse/FLINK-5587 Project: Flink Issue Type: Test

[jira] [Closed] (FLINK-5507) remove queryable list state sink

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

[jira] [Closed] (FLINK-5482) QueryableStateClient does not recover from a failed lookup due to a non-running job

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

[jira] [Closed] (FLINK-5556) BarrierBuffer resets bytes written on spiller roll over

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

[jira] [Closed] (FLINK-5574) Add checkpoint statistics docs

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

[jira] [Created] (FLINK-5574) Add checkpoint statistics docs

Ufuk Celebi created FLINK-5574: -- Summary: Add checkpoint statistics docs Key: FLINK-5574 URL: https://issues.apache.org/jira/browse/FLINK-5574 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-5560) Header in checkpoint stats summary misaligned

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

[jira] [Closed] (FLINK-5377) Improve savepoint docs

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

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

[ https://issues.apache.org/jira/browse/FLINK-5415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829692#comment-15829692 ] Ufuk Celebi commented on FLINK-5415:

[jira] [Created] (FLINK-5560) Header in checkpoint stats summary misaligned

Ufuk Celebi created FLINK-5560: -- Summary: Header in checkpoint stats summary misaligned Key: FLINK-5560 URL: https://issues.apache.org/jira/browse/FLINK-5560 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5556) BarrierBuffer resets bytes written on spiller roll over

Ufuk Celebi created FLINK-5556: -- Summary: BarrierBuffer resets bytes written on spiller roll over Key: FLINK-5556 URL: https://issues.apache.org/jira/browse/FLINK-5556 Project: Flink Issue

[jira] [Closed] (FLINK-5484) Kryo serialization changed between 1.1 and 1.2

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

[jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15828174#comment-15828174 ] Ufuk Celebi commented on FLINK-2608: Reverted in a7644b1 (release-1.2), 586f818 (master). >

[jira] [Reopened] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat

[ https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reopened FLINK-2608: Have to reopen this because we can't update our Chill dependency without breaking savepoint

[jira] [Created] (FLINK-5510) Replace Scala Future with FlinkFuture in QueryableStateClient

Ufuk Celebi created FLINK-5510: -- Summary: Replace Scala Future with FlinkFuture in QueryableStateClient Key: FLINK-5510 URL: https://issues.apache.org/jira/browse/FLINK-5510 Project: Flink

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

Ufuk Celebi created FLINK-5509: -- Summary: Replace QueryableStateClient keyHashCode argument Key: FLINK-5509 URL: https://issues.apache.org/jira/browse/FLINK-5509 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5507) remove queryable list state sink

[ https://issues.apache.org/jira/browse/FLINK-5507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15823895#comment-15823895 ] Ufuk Celebi commented on FLINK-5507: +1 Would you like to do that and open a PR? > remove queryable

[jira] [Created] (FLINK-5484) Kryo serialization changed between 1.1 and 1.2

Ufuk Celebi created FLINK-5484: -- Summary: Kryo serialization changed between 1.1 and 1.2 Key: FLINK-5484 URL: https://issues.apache.org/jira/browse/FLINK-5484 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-5467) Stateless chained tasks set legacy operator state

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

[jira] [Created] (FLINK-5477) Summary columns not aligned correctly

Ufuk Celebi created FLINK-5477: -- Summary: Summary columns not aligned correctly Key: FLINK-5477 URL: https://issues.apache.org/jira/browse/FLINK-5477 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-5444) Flink UI uses absolute URLs.

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

[jira] [Closed] (FLINK-5466) Make production environment default in gulpfile

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

[jira] [Created] (FLINK-5467) Stateless chained tasks set legacy operator state

Ufuk Celebi created FLINK-5467: -- Summary: Stateless chained tasks set legacy operator state Key: FLINK-5467 URL: https://issues.apache.org/jira/browse/FLINK-5467 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5466) Make production environment default in gulpfile

Ufuk Celebi created FLINK-5466: -- Summary: Make production environment default in gulpfile Key: FLINK-5466 URL: https://issues.apache.org/jira/browse/FLINK-5466 Project: Flink Issue Type:

[jira] [Created] (FLINK-5448) Fix typo in StateAssignmentOperation Exception

Ufuk Celebi created FLINK-5448: -- Summary: Fix typo in StateAssignmentOperation Exception Key: FLINK-5448 URL: https://issues.apache.org/jira/browse/FLINK-5448 Project: Flink Issue Type:

[jira] [Created] (FLINK-5440) Misleading error message when migrating and scaling down from savepoint

Ufuk Celebi created FLINK-5440: -- Summary: Misleading error message when migrating and scaling down from savepoint Key: FLINK-5440 URL: https://issues.apache.org/jira/browse/FLINK-5440 Project: Flink

[jira] [Created] (FLINK-5439) Adjust max parallelism when migrating

Ufuk Celebi created FLINK-5439: -- Summary: Adjust max parallelism when migrating Key: FLINK-5439 URL: https://issues.apache.org/jira/browse/FLINK-5439 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5438) Typo in JobGraph generator Exception

Ufuk Celebi created FLINK-5438: -- Summary: Typo in JobGraph generator Exception Key: FLINK-5438 URL: https://issues.apache.org/jira/browse/FLINK-5438 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5437) Make CheckpointedRestoring error message more detailed

Ufuk Celebi created FLINK-5437: -- Summary: Make CheckpointedRestoring error message more detailed Key: FLINK-5437 URL: https://issues.apache.org/jira/browse/FLINK-5437 Project: Flink Issue Type:

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

Ufuk Celebi created FLINK-5436: -- Summary: UDF state without CheckpointedRestoring can result in restarting loop Key: FLINK-5436 URL: https://issues.apache.org/jira/browse/FLINK-5436 Project: Flink

[jira] [Closed] (FLINK-5102) Connection establishment does not react to interrupt

[ https://issues.apache.org/jira/browse/FLINK-5102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5102. -- Resolution: Cannot Reproduce > Connection establishment does not react to interrupt >

[jira] [Closed] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab

[ https://issues.apache.org/jira/browse/FLINK-5306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5306. -- Resolution: Implemented Fix Version/s: 1.3.0 1.2.0 Implemented in 579bc96,

[jira] [Closed] (FLINK-4410) Report more information about operator checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4410. -- Resolution: Implemented Fix Version/s: 1.3.0 All sub tasks have been implemented. > Report more

[jira] [Closed] (FLINK-4698) Visualize additional checkpoint information

[ https://issues.apache.org/jira/browse/FLINK-4698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4698. -- Resolution: Implemented Fix Version/s: 1.3.0 Implemented in 27df801 (master), 3f2e996

[jira] [Closed] (FLINK-4697) Gather more detailed checkpoint stats in CheckpointStatsTracker

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

[jira] [Closed] (FLINK-5066) add more efficient isEvent check to EventSerializer

[ https://issues.apache.org/jira/browse/FLINK-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5066. -- Resolution: Fixed Fix Version/s: 1.3.0 Implemented in 9457465 (master). > add more efficient

[jira] [Closed] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent

[ https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5059. -- Resolution: Implemented Fix Version/s: 1.3.0 Fixed in 9cff8c9 (master). > only serialise events

[jira] [Created] (FLINK-5428) Decrease restart delay in RecoveryITCase

Ufuk Celebi created FLINK-5428: -- Summary: Decrease restart delay in RecoveryITCase Key: FLINK-5428 URL: https://issues.apache.org/jira/browse/FLINK-5428 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-4131) Confusing error for out dated RequestPartitionState

[ https://issues.apache.org/jira/browse/FLINK-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4131. -- Resolution: Duplicate > Confusing error for out dated RequestPartitionState >

[jira] [Closed] (FLINK-5180) Include blocked on bounded queue length in back pressure stats

[ https://issues.apache.org/jira/browse/FLINK-5180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5180. -- Resolution: Invalid > Include blocked on bounded queue length in back pressure stats >

[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 ] Ufuk Celebi updated FLINK-4651: --- Fix Version/s: (was: 1.1.4) 1.1.5 > Re-register processing time timers at the

[jira] [Updated] (FLINK-5322) Clean up yarn configuration documentation

[ https://issues.apache.org/jira/browse/FLINK-5322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5322: --- Fix Version/s: (was: 1.1.4) 1.1.5 > Clean up yarn configuration documentation

[jira] [Updated] (FLINK-5210) Failing performCheckpoint method causes task to fail

[ https://issues.apache.org/jira/browse/FLINK-5210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5210: --- Fix Version/s: (was: 1.1.4) 1.1.5 > Failing performCheckpoint method causes

[jira] [Updated] (FLINK-5227) Add warning to include flink-table in job fat jars

[ https://issues.apache.org/jira/browse/FLINK-5227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5227: --- Fix Version/s: (was: 1.1.4) 1.1.5 > Add warning to include flink-table in job

[jira] [Updated] (FLINK-5302) Log failure cause at Execution

[ https://issues.apache.org/jira/browse/FLINK-5302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5302: --- Fix Version/s: (was: 1.1.4) (was: 1.2.0) > Log failure cause at Execution

[jira] [Updated] (FLINK-5233) Upgrade Jackson version because of class loader leak

[ https://issues.apache.org/jira/browse/FLINK-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5233: --- Fix Version/s: (was: 1.1.4) > Upgrade Jackson version because of class loader leak >

[jira] [Updated] (FLINK-5375) Fix watermark documentation

[ https://issues.apache.org/jira/browse/FLINK-5375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5375: --- Fix Version/s: (was: 1.1.4) 1.1.5 > Fix watermark documentation >

[jira] [Created] (FLINK-5377) Improve savepoint docs

Ufuk Celebi created FLINK-5377: -- Summary: Improve savepoint docs Key: FLINK-5377 URL: https://issues.apache.org/jira/browse/FLINK-5377 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-5352) Restore RocksDB 1.1.3 memory behavior

[ https://issues.apache.org/jira/browse/FLINK-5352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5352. -- Resolution: Fixed Fixed in a8b415f, a874ad8 (release-1.1). > Restore RocksDB 1.1.3 memory behavior >

[jira] [Closed] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

[ https://issues.apache.org/jira/browse/FLINK-5326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5326. -- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 Fixed in 04db15a, 9ed7752

[jira] [Commented] (FLINK-5328) ConnectedComponentsITCase testJobWithoutObjectReuse fails

[ https://issues.apache.org/jira/browse/FLINK-5328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745056#comment-15745056 ] Ufuk Celebi commented on FLINK-5328: The attached logs also show this: {code} 12:00:31,315 ERROR

[jira] [Updated] (FLINK-5328) ConnectedComponentsITCase testJobWithoutObjectReuse fails

[ https://issues.apache.org/jira/browse/FLINK-5328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5328: --- Attachment: connectedComponentsFailure.txt > ConnectedComponentsITCase testJobWithoutObjectReuse

[jira] [Created] (FLINK-5328) ConnectedComponentsITCase testJobWithoutObjectReuse fails

Ufuk Celebi created FLINK-5328: -- Summary: ConnectedComponentsITCase testJobWithoutObjectReuse fails Key: FLINK-5328 URL: https://issues.apache.org/jira/browse/FLINK-5328 Project: Flink Issue

[jira] [Updated] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

[ https://issues.apache.org/jira/browse/FLINK-5326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5326: --- Affects Version/s: 1.2.0 > IllegalStateException: Bug in Netty consumer logic: reader queue got

[jira] [Commented] (FLINK-5326) IllegalStateException: Bug in Netty consumer logic: reader queue got notified by partition about available data, but none was available

[ https://issues.apache.org/jira/browse/FLINK-5326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744744#comment-15744744 ] Ufuk Celebi commented on FLINK-5326: No, 1.2.0 too. > IllegalStateException: Bug in Netty consumer

[jira] [Closed] (FLINK-5007) Retain externalized checkpoint on suspension

[ https://issues.apache.org/jira/browse/FLINK-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5007. -- Resolution: Fixed Fixed in 38ab716 (master). > Retain externalized checkpoint on suspension >

[jira] [Closed] (FLINK-5088) Add option to limit subpartition queue length

[ https://issues.apache.org/jira/browse/FLINK-5088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5088. -- Resolution: Won't Fix > Add option to limit subpartition queue length >

[jira] [Closed] (FLINK-5114) PartitionState update with finished execution fails

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

[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: --- Priority: Major (was: Blocker) > Improve error message when assigning uid to intermediate operator >

[jira] [Closed] (FLINK-4797) Add Flink 1.1 savepoint backwards compatability

[ https://issues.apache.org/jira/browse/FLINK-4797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4797. -- Resolution: Duplicate > Add Flink 1.1 savepoint backwards compatability >

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15741496#comment-15741496 ] Ufuk Celebi commented on FLINK-5041: This issue/sub tasks of this issue duplicate FLINK-4797. Should

[jira] [Commented] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab

[ https://issues.apache.org/jira/browse/FLINK-5306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15735100#comment-15735100 ] Ufuk Celebi commented on FLINK-5306: No, didn't open an issue yet, but I'll make this a sub task. >

[jira] [Commented] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab

[ https://issues.apache.org/jira/browse/FLINK-5306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15735071#comment-15735071 ] Ufuk Celebi commented on FLINK-5306: I planned to make this part of the stats refactoring. Stay

[jira] [Assigned] (FLINK-5306) Display checkpointing configuration details in web UI "Configuration" tab

[ https://issues.apache.org/jira/browse/FLINK-5306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5306: -- Assignee: Ufuk Celebi > Display checkpointing configuration details in web UI "Configuration"

[jira] [Created] (FLINK-5302) Log failure cause at Execution

Ufuk Celebi created FLINK-5302: -- Summary: Log failure cause at Execution Key: FLINK-5302 URL: https://issues.apache.org/jira/browse/FLINK-5302 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-3902) Discarded FileSystem checkpoints are lingering around

[ https://issues.apache.org/jira/browse/FLINK-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-3902. -- Resolution: Not A Bug This is actually an artifact of the way we try to delete fiiles and how this

[jira] [Commented] (FLINK-5278) Improve Task and checkpoint logging

[ https://issues.apache.org/jira/browse/FLINK-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729286#comment-15729286 ] Ufuk Celebi commented on FLINK-5278: Merged in b046038 (release-1.1). Merge for master pending. >

[jira] [Created] (FLINK-5279) Improve error message when trying to access keyed state in non-keyed operator

Ufuk Celebi created FLINK-5279: -- Summary: Improve error message when trying to access keyed state in non-keyed operator Key: FLINK-5279 URL: https://issues.apache.org/jira/browse/FLINK-5279 Project:

[jira] [Closed] (FLINK-5274) LocalInputChannel throws NPE if partition reader is released

[ https://issues.apache.org/jira/browse/FLINK-5274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5274. -- Resolution: Fixed Fix Version/s: 1.1.4 1.2.0 555a687 (master), 1b472d2

[jira] [Closed] (FLINK-5275) InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled

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

[jira] [Closed] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts

[ https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5276. -- Resolution: Fixed Fixed in 75b48e (release-1.1) > ExecutionVertex archiving can throw NPE with many

[jira] [Assigned] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts

[ https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-5276: -- Assignee: Ufuk Celebi (was: Stefan Richter) > ExecutionVertex archiving can throw NPE with

[jira] [Updated] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts

[ https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5276: --- Fix Version/s: (was: 1.2.0) > ExecutionVertex archiving can throw NPE with many previous attempts

[jira] [Updated] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts

[ https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5276: --- Description: I saw a NPE while archiving a ExecutionVertex: {code} execution graph

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15728721#comment-15728721 ] Ufuk Celebi commented on FLINK-5041: Subtasks FLINK-5042 and FLINK-5043 implemented in in af3bf83

[jira] [Closed] (FLINK-5043) Converting keyed state from Flink 1.1 backend implementations to their new counterparts in 1.2

[ https://issues.apache.org/jira/browse/FLINK-5043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5043. -- Resolution: Implemented Fix Version/s: 1.2.0 Implemented in af3bf83 (master). > Converting

[jira] [Closed] (FLINK-5042) Convert old savepoints to new savepoints

[ https://issues.apache.org/jira/browse/FLINK-5042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5042. -- Resolution: Implemented Fix Version/s: 1.2.0 Implemented in af3bf83 (master). > Convert old

[jira] [Created] (FLINK-5276) ExecutionVertex archiving can throw NPE with many previous attempts

Ufuk Celebi created FLINK-5276: -- Summary: ExecutionVertex archiving can throw NPE with many previous attempts Key: FLINK-5276 URL: https://issues.apache.org/jira/browse/FLINK-5276 Project: Flink

[jira] [Created] (FLINK-5275) InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled

Ufuk Celebi created FLINK-5275: -- Summary: InputChanelDeploymentDescriptors throws misleading Exception if producer failed/cancelled Key: FLINK-5275 URL: https://issues.apache.org/jira/browse/FLINK-5275

[jira] [Created] (FLINK-5274) LocalInputChannel throws NPE if partition reader is released

Ufuk Celebi created FLINK-5274: -- Summary: LocalInputChannel throws NPE if partition reader is released Key: FLINK-5274 URL: https://issues.apache.org/jira/browse/FLINK-5274 Project: Flink

[jira] [Closed] (FLINK-5179) MetricRegistry life-cycle issues with HA

[ https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5179. -- Resolution: Fixed Fixed in e5f4e3d (master). > MetricRegistry life-cycle issues with HA >

[jira] [Closed] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics

[ https://issues.apache.org/jira/browse/FLINK-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5261. -- Resolution: Fixed Fixed in f7f7b48 (master). > ScheduledDropwizardReporter does not properly clean up

[jira] [Commented] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-5147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725708#comment-15725708 ] Ufuk Celebi commented on FLINK-5147: Ocurred again

[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: --- Description: Currently when trying to assign uid to an intermediate operator in a chain, the error

[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: --- Summary: Improve error message when assigning uid to intermediate operator (was: Improve error

[jira] [Assigned] (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 reassigned FLINK-5264: -- Assignee: Ufuk Celebi > Improve error message when assigning uid to intermediate operator. >

[jira] [Created] (FLINK-5263) Add docs about JVM sharing between tasks

Ufuk Celebi created FLINK-5263: -- Summary: Add docs about JVM sharing between tasks Key: FLINK-5263 URL: https://issues.apache.org/jira/browse/FLINK-5263 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure

[ https://issues.apache.org/jira/browse/FLINK-5248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5248. -- Resolution: Fixed > SavepointITCase doesn't catch savepoint restore failure >

[jira] [Closed] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure

[ https://issues.apache.org/jira/browse/FLINK-5248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5248. -- Resolution: Fixed Fixed in 4dee8fe (master), a5065e3 (release-1.1). > SavepointITCase doesn't catch

[jira] [Updated] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure

[ https://issues.apache.org/jira/browse/FLINK-5248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5248: --- Fix Version/s: 1.1.4 1.2.0 > SavepointITCase doesn't catch savepoint restore

[jira] [Reopened] (FLINK-5248) SavepointITCase doesn't catch savepoint restore failure

[ https://issues.apache.org/jira/browse/FLINK-5248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reopened FLINK-5248: > SavepointITCase doesn't catch savepoint restore failure >

[jira] [Created] (FLINK-5260) Add docs about how to react to cancellation

Ufuk Celebi created FLINK-5260: -- Summary: Add docs about how to react to cancellation Key: FLINK-5260 URL: https://issues.apache.org/jira/browse/FLINK-5260 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-5048: --- Fix Version/s: (was: 1.1.4) 1.1.5 > Kafka Consumer (0.9/0.10) threading model

[jira] [Commented] (FLINK-5048) Kafka Consumer (0.9/0.10) threading model leads problematic cancellation behavior

[ https://issues.apache.org/jira/browse/FLINK-5048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15721966#comment-15721966 ] Ufuk Celebi commented on FLINK-5048: Talked to [~rmetzger] about this and we would like to not block

[jira] [Commented] (FLINK-5233) Upgrade Jackson version because of class loader leak

[ https://issues.apache.org/jira/browse/FLINK-5233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15721962#comment-15721962 ] Ufuk Celebi commented on FLINK-5233: Talked to [~rmetzger] about this. He couldn't reproduce this yet.

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