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

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

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

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

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

[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-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-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-5824) Fix String/byte conversion without explicit encodings

Ufuk Celebi created FLINK-5824: -- Summary: Fix String/byte conversion without explicit encodings Key: FLINK-5824 URL: https://issues.apache.org/jira/browse/FLINK-5824 Project: Flink Issue Type

[jira] [Created] (FLINK-5876) Mention Scala type fallacies for queryable state client serializers

Ufuk Celebi created FLINK-5876: -- Summary: Mention Scala type fallacies for queryable state client serializers Key: FLINK-5876 URL: https://issues.apache.org/jira/browse/FLINK-5876 Project: Flink

[jira] [Created] (FLINK-5923) Test instability in SavepointITCase testTriggerSavepointAndResume

Ufuk Celebi created FLINK-5923: -- Summary: Test instability in SavepointITCase testTriggerSavepointAndResume Key: FLINK-5923 URL: https://issues.apache.org/jira/browse/FLINK-5923 Project: Flink

[jira] [Created] (FLINK-5926) Show state backend information in web UI

Ufuk Celebi created FLINK-5926: -- Summary: Show state backend information in web UI Key: FLINK-5926 URL: https://issues.apache.org/jira/browse/FLINK-5926 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5928) Externalized checkpoints overwritting each other

Ufuk Celebi created FLINK-5928: -- Summary: Externalized checkpoints overwritting each other Key: FLINK-5928 URL: https://issues.apache.org/jira/browse/FLINK-5928 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5993) Add section about Azure deployment

Ufuk Celebi created FLINK-5993: -- Summary: Add section about Azure deployment Key: FLINK-5993 URL: https://issues.apache.org/jira/browse/FLINK-5993 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5999) MiniClusterITCase.runJobWithMultipleRpcServices fails

Ufuk Celebi created FLINK-5999: -- Summary: MiniClusterITCase.runJobWithMultipleRpcServices fails Key: FLINK-5999 URL: https://issues.apache.org/jira/browse/FLINK-5999 Project: Flink Issue Type

[jira] [Created] (FLINK-6127) Add MissingDeprecatedCheck to checkstyle

Ufuk Celebi created FLINK-6127: -- Summary: Add MissingDeprecatedCheck to checkstyle Key: FLINK-6127 URL: https://issues.apache.org/jira/browse/FLINK-6127 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6170) Some checkpoint metrics rely on latest stat snapshot

Ufuk Celebi created FLINK-6170: -- Summary: Some checkpoint metrics rely on latest stat snapshot Key: FLINK-6170 URL: https://issues.apache.org/jira/browse/FLINK-6170 Project: Flink Issue Type

[jira] [Created] (FLINK-6171) Some checkpoint metrics rely on latest stat snapshot

Ufuk Celebi created FLINK-6171: -- Summary: Some checkpoint metrics rely on latest stat snapshot Key: FLINK-6171 URL: https://issues.apache.org/jira/browse/FLINK-6171 Project: Flink Issue Type

[jira] [Created] (FLINK-6175) HistoryServerTest.testFullArchiveLifecycle fails

Ufuk Celebi created FLINK-6175: -- Summary: HistoryServerTest.testFullArchiveLifecycle fails Key: FLINK-6175 URL: https://issues.apache.org/jira/browse/FLINK-6175 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-6182) Fix possible NPE in SourceStreamTask

Ufuk Celebi created FLINK-6182: -- Summary: Fix possible NPE in SourceStreamTask Key: FLINK-6182 URL: https://issues.apache.org/jira/browse/FLINK-6182 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1404) Trigger recycling of buffers held by historic intermediate result partitions

Ufuk Celebi created FLINK-1404: -- Summary: Trigger recycling of buffers held by historic intermediate result partitions Key: FLINK-1404 URL: https://issues.apache.org/jira/browse/FLINK-1404 Project

[jira] [Created] (FLINK-1468) Config parse failure fails task manager startup w/o an error message

Ufuk Celebi created FLINK-1468: -- Summary: Config parse failure fails task manager startup w/o an error message Key: FLINK-1468 URL: https://issues.apache.org/jira/browse/FLINK-1468 Project: Flink

[jira] [Created] (FLINK-1469) Initialize network environment at task manager startup

Ufuk Celebi created FLINK-1469: -- Summary: Initialize network environment at task manager startup Key: FLINK-1469 URL: https://issues.apache.org/jira/browse/FLINK-1469 Project: Flink Issue Type

[jira] [Created] (FLINK-1472) Web frontend config overview shows wrong value

Ufuk Celebi created FLINK-1472: -- Summary: Web frontend config overview shows wrong value Key: FLINK-1472 URL: https://issues.apache.org/jira/browse/FLINK-1472 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1496) Events at unitialized input channels are lost

Ufuk Celebi created FLINK-1496: -- Summary: Events at unitialized input channels are lost Key: FLINK-1496 URL: https://issues.apache.org/jira/browse/FLINK-1496 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-1505) Separate buffer reader and channel consumption logic

Ufuk Celebi created FLINK-1505: -- Summary: Separate buffer reader and channel consumption logic Key: FLINK-1505 URL: https://issues.apache.org/jira/browse/FLINK-1505 Project: Flink Issue Type

[jira] [Created] (FLINK-1506) Add buffer/event wrapper for runtime results

Ufuk Celebi created FLINK-1506: -- Summary: Add buffer/event wrapper for runtime results Key: FLINK-1506 URL: https://issues.apache.org/jira/browse/FLINK-1506 Project: Flink Issue Type

[jira] [Created] (FLINK-1507) Allow to configure produced intermediate result type via ExecutionConfig

Ufuk Celebi created FLINK-1507: -- Summary: Allow to configure produced intermediate result type via ExecutionConfig Key: FLINK-1507 URL: https://issues.apache.org/jira/browse/FLINK-1507 Project: Flink

[jira] [Created] (FLINK-1518) Laggy task cancelling on task managers

Ufuk Celebi created FLINK-1518: -- Summary: Laggy task cancelling on task managers Key: FLINK-1518 URL: https://issues.apache.org/jira/browse/FLINK-1518 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1519) Web frontend task state mismatch when cancelling

Ufuk Celebi created FLINK-1519: -- Summary: Web frontend task state mismatch when cancelling Key: FLINK-1519 URL: https://issues.apache.org/jira/browse/FLINK-1519 Project: Flink Issue Type

[jira] [Created] (FLINK-35038) Bump test dependency org.yaml:snakeyaml to 2.2

Ufuk Celebi created FLINK-35038: --- Summary: Bump test dependency org.yaml:snakeyaml to 2.2 Key: FLINK-35038 URL: https://issues.apache.org/jira/browse/FLINK-35038 Project: Flink Issue Type

[jira] [Created] (FLINK-35239) 1.19 docs show outdated warning

Ufuk Celebi created FLINK-35239: --- Summary: 1.19 docs show outdated warning Key: FLINK-35239 URL: https://issues.apache.org/jira/browse/FLINK-35239 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35480) Add FIELD function in SQL & Table API

Ufuk Celebi created FLINK-35480: --- Summary: Add FIELD function in SQL & Table API Key: FLINK-35480 URL: https://issues.apache.org/jira/browse/FLINK-35480 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-35481) Add HISTOGRAM function in SQL & Table API

Ufuk Celebi created FLINK-35481: --- Summary: Add HISTOGRAM function in SQL & Table API Key: FLINK-35481 URL: https://issues.apache.org/jira/browse/FLINK-35481 Project: Flink Issue

[jira] [Created] (FLINK-35509) Slack community invite link has expired

Ufuk Celebi created FLINK-35509: --- Summary: Slack community invite link has expired Key: FLINK-35509 URL: https://issues.apache.org/jira/browse/FLINK-35509 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21928) DuplicateJobSubmissionException after JobManager failover

Ufuk Celebi created FLINK-21928: --- Summary: DuplicateJobSubmissionException after JobManager failover Key: FLINK-21928 URL: https://issues.apache.org/jira/browse/FLINK-21928 Project: Flink

[jira] [Created] (FLINK-17500) Deploy JobGraph form file in StandaloneClusterEntrypoint

Ufuk Celebi created FLINK-17500: --- Summary: Deploy JobGraph form file in StandaloneClusterEntrypoint Key: FLINK-17500 URL: https://issues.apache.org/jira/browse/FLINK-17500 Project: Flink Issue

[jira] [Created] (FLINK-6952) Add link to Javadocs

Ufuk Celebi created FLINK-6952: -- Summary: Add link to Javadocs Key: FLINK-6952 URL: https://issues.apache.org/jira/browse/FLINK-6952 Project: Flink Issue Type: Improvement Components

[jira] [Created] (FLINK-6985) Remove minor version from docs title

Ufuk Celebi created FLINK-6985: -- Summary: Remove minor version from docs title Key: FLINK-6985 URL: https://issues.apache.org/jira/browse/FLINK-6985 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure

Ufuk Celebi created FLINK-7067: -- Summary: Cancel with savepoint does not restart checkpoint scheduler on failure Key: FLINK-7067 URL: https://issues.apache.org/jira/browse/FLINK-7067 Project: Flink

[jira] [Created] (FLINK-7127) Remove unnecessary null check or add null check

Ufuk Celebi created FLINK-7127: -- Summary: Remove unnecessary null check or add null check Key: FLINK-7127 URL: https://issues.apache.org/jira/browse/FLINK-7127 Project: Flink Issue Type

[jira] [Created] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size

Ufuk Celebi created FLINK-7258: -- Summary: IllegalArgumentException in Netty bootstrap with large memory state segment size Key: FLINK-7258 URL: https://issues.apache.org/jira/browse/FLINK-7258 Project

[jira] [Created] (FLINK-7462) Add very obvious warning about outdated docs

Ufuk Celebi created FLINK-7462: -- Summary: Add very obvious warning about outdated docs Key: FLINK-7462 URL: https://issues.apache.org/jira/browse/FLINK-7462 Project: Flink Issue Type

[jira] [Created] (FLINK-7595) Removing stateless task from task chain breaks savepoint restore

Ufuk Celebi created FLINK-7595: -- Summary: Removing stateless task from task chain breaks savepoint restore Key: FLINK-7595 URL: https://issues.apache.org/jira/browse/FLINK-7595 Project: Flink

[jira] [Created] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration

Ufuk Celebi created FLINK-7643: -- Summary: HadoopFileSystem always reloads GlobalConfiguration Key: FLINK-7643 URL: https://issues.apache.org/jira/browse/FLINK-7643 Project: Flink Issue Type

[jira] [Created] (FLINK-7665) Use wait/notify in ContinuousFileReaderOperator

Ufuk Celebi created FLINK-7665: -- Summary: Use wait/notify in ContinuousFileReaderOperator Key: FLINK-7665 URL: https://issues.apache.org/jira/browse/FLINK-7665 Project: Flink Issue Type

[jira] [Created] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks

Ufuk Celebi created FLINK-7666: -- Summary: ContinuousFileReaderOperator swallows chained watermarks Key: FLINK-7666 URL: https://issues.apache.org/jira/browse/FLINK-7666 Project: Flink Issue

[jira] [Created] (FLINK-7674) NullPointerException in ContinuousFileMonitoringFunction close

Ufuk Celebi created FLINK-7674: -- Summary: NullPointerException in ContinuousFileMonitoringFunction close Key: FLINK-7674 URL: https://issues.apache.org/jira/browse/FLINK-7674 Project: Flink

[jira] [Created] (FLINK-7676) ContinuousFileMonitoringFunction fails with GoogleHadoopFileSystem

Ufuk Celebi created FLINK-7676: -- Summary: ContinuousFileMonitoringFunction fails with GoogleHadoopFileSystem Key: FLINK-7676 URL: https://issues.apache.org/jira/browse/FLINK-7676 Project: Flink

[jira] [Created] (FLINK-7677) Add side outputs to ProcessWindowFunction

Ufuk Celebi created FLINK-7677: -- Summary: Add side outputs to ProcessWindowFunction Key: FLINK-7677 URL: https://issues.apache.org/jira/browse/FLINK-7677 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-8138) Race in TaskAsyncCallTest leads to test time out

Ufuk Celebi created FLINK-8138: -- Summary: Race in TaskAsyncCallTest leads to test time out Key: FLINK-8138 URL: https://issues.apache.org/jira/browse/FLINK-8138 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8253) flink-docs-stable still points to 1.3

Ufuk Celebi created FLINK-8253: -- Summary: flink-docs-stable still points to 1.3 Key: FLINK-8253 URL: https://issues.apache.org/jira/browse/FLINK-8253 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8304) Document Kubernetes and Flink HA setup

Ufuk Celebi created FLINK-8304: -- Summary: Document Kubernetes and Flink HA setup Key: FLINK-8304 URL: https://issues.apache.org/jira/browse/FLINK-8304 Project: Flink Issue Type: Improvement

<    5   6   7   8   9   10