[jira] [Created] (FLINK-13103) Graceful Shutdown Handling by UDFs

Kostas Kloudas created FLINK-13103: -- Summary: Graceful Shutdown Handling by UDFs Key: FLINK-13103 URL: https://issues.apache.org/jira/browse/FLINK-13103 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-13275) Race condition in SourceStreamTaskTest.finishingIgnoresExceptions()

Kostas Kloudas created FLINK-13275: -- Summary: Race condition in SourceStreamTaskTest.finishingIgnoresExceptions() Key: FLINK-13275 URL: https://issues.apache.org/jira/browse/FLINK-13275 Project: Flin

[jira] [Created] (FLINK-13307) SourceStreamTaskTest test instability.

Kostas Kloudas created FLINK-13307: -- Summary: SourceStreamTaskTest test instability. Key: FLINK-13307 URL: https://issues.apache.org/jira/browse/FLINK-13307 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-13440) Add test that fails job when sync savepoint is discarded.

Kostas Kloudas created FLINK-13440: -- Summary: Add test that fails job when sync savepoint is discarded. Key: FLINK-13440 URL: https://issues.apache.org/jira/browse/FLINK-13440 Project: Flink

[jira] [Created] (FLINK-13605) AsyncDataStreamITCase. testUnorderedWait failed on Travis

Kostas Kloudas created FLINK-13605: -- Summary: AsyncDataStreamITCase. testUnorderedWait failed on Travis Key: FLINK-13605 URL: https://issues.apache.org/jira/browse/FLINK-13605 Project: Flink

[jira] [Created] (FLINK-13713) Remove legacy Package interface.

Kostas Kloudas created FLINK-13713: -- Summary: Remove legacy Package interface. Key: FLINK-13713 URL: https://issues.apache.org/jira/browse/FLINK-13713 Project: Flink Issue Type: Bug Affe

[jira] [Created] (FLINK-13714) Remove Package-related code.

Kostas Kloudas created FLINK-13714: -- Summary: Remove Package-related code. Key: FLINK-13714 URL: https://issues.apache.org/jira/browse/FLINK-13714 Project: Flink Issue Type: Sub-task Aff

[jira] [Created] (FLINK-13715) Remove Package-related english documentation.

Kostas Kloudas created FLINK-13715: -- Summary: Remove Package-related english documentation. Key: FLINK-13715 URL: https://issues.apache.org/jira/browse/FLINK-13715 Project: Flink Issue Type:

[jira] [Created] (FLINK-13716) Remove Package-related chinese documentation

Kostas Kloudas created FLINK-13716: -- Summary: Remove Package-related chinese documentation Key: FLINK-13716 URL: https://issues.apache.org/jira/browse/FLINK-13716 Project: Flink Issue Type:

[jira] [Created] (FLINK-13941) Prevent data-loss by not cleaning up small part files from S3.

Kostas Kloudas created FLINK-13941: -- Summary: Prevent data-loss by not cleaning up small part files from S3. Key: FLINK-13941 URL: https://issues.apache.org/jira/browse/FLINK-13941 Project: Flink

[jira] [Created] (FLINK-13946) Remove deactivated JobSession-related code.

Kostas Kloudas created FLINK-13946: -- Summary: Remove deactivated JobSession-related code. Key: FLINK-13946 URL: https://issues.apache.org/jira/browse/FLINK-13946 Project: Flink Issue Type: I

[jira] [Created] (FLINK-13954) Clean up ExecutionEnvironment / JobSubmission code paths

Kostas Kloudas created FLINK-13954: -- Summary: Clean up ExecutionEnvironment / JobSubmission code paths Key: FLINK-13954 URL: https://issues.apache.org/jira/browse/FLINK-13954 Project: Flink

[jira] [Created] (FLINK-13959) Consolidate DetachedEnvironment and ContextEnvironment

Kostas Kloudas created FLINK-13959: -- Summary: Consolidate DetachedEnvironment and ContextEnvironment Key: FLINK-13959 URL: https://issues.apache.org/jira/browse/FLINK-13959 Project: Flink Is

[jira] [Created] (FLINK-13972) Move PreviewPlanEnvironment to flink-tests

Kostas Kloudas created FLINK-13972: -- Summary: Move PreviewPlanEnvironment to flink-tests Key: FLINK-13972 URL: https://issues.apache.org/jira/browse/FLINK-13972 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-15926) Add DataStream.broadcast(StateDescriptor) to available transformations docs

Kostas Kloudas created FLINK-15926: -- Summary: Add DataStream.broadcast(StateDescriptor) to available transformations docs Key: FLINK-15926 URL: https://issues.apache.org/jira/browse/FLINK-15926 Proje

[jira] [Created] (FLINK-16369) Allow the StreamingFileSink to restore from a previous (old) savepoint.

Kostas Kloudas created FLINK-16369: -- Summary: Allow the StreamingFileSink to restore from a previous (old) savepoint. Key: FLINK-16369 URL: https://issues.apache.org/jira/browse/FLINK-16369 Project:

[jira] [Created] (FLINK-16654) Implement Application Mode according to FLIP-85

Kostas Kloudas created FLINK-16654: -- Summary: Implement Application Mode according to FLIP-85 Key: FLINK-16654 URL: https://issues.apache.org/jira/browse/FLINK-16654 Project: Flink Issue Typ

[jira] [Created] (FLINK-16655) Introduce the EmbeddedExecutor

Kostas Kloudas created FLINK-16655: -- Summary: Introduce the EmbeddedExecutor Key: FLINK-16655 URL: https://issues.apache.org/jira/browse/FLINK-16655 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16656) Introduce the DispatcherBootstrap

Kostas Kloudas created FLINK-16656: -- Summary: Introduce the DispatcherBootstrap Key: FLINK-16656 URL: https://issues.apache.org/jira/browse/FLINK-16656 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16657) Wire the EmbeddedExecutor to the Web Submission logic.

Kostas Kloudas created FLINK-16657: -- Summary: Wire the EmbeddedExecutor to the Web Submission logic. Key: FLINK-16657 URL: https://issues.apache.org/jira/browse/FLINK-16657 Project: Flink Is

[jira] [Created] (FLINK-16658) Wire the EmbeddedExecutor to the StandaloneClusterEntrypoint.

Kostas Kloudas created FLINK-16658: -- Summary: Wire the EmbeddedExecutor to the StandaloneClusterEntrypoint. Key: FLINK-16658 URL: https://issues.apache.org/jira/browse/FLINK-16658 Project: Flink

[jira] [Created] (FLINK-16660) Introduce the ApplicationDispatcherBootstrap

Kostas Kloudas created FLINK-16660: -- Summary: Introduce the ApplicationDispatcherBootstrap Key: FLINK-16660 URL: https://issues.apache.org/jira/browse/FLINK-16660 Project: Flink Issue Type:

[jira] [Created] (FLINK-16661) Introduce the YarnApplicationClusterEntrypoint

Kostas Kloudas created FLINK-16661: -- Summary: Introduce the YarnApplicationClusterEntrypoint Key: FLINK-16661 URL: https://issues.apache.org/jira/browse/FLINK-16661 Project: Flink Issue Type

[jira] [Created] (FLINK-14157) Temporarily remove S3 StreamingFileSink end-to-end test

Kostas Kloudas created FLINK-14157: -- Summary: Temporarily remove S3 StreamingFileSink end-to-end test Key: FLINK-14157 URL: https://issues.apache.org/jira/browse/FLINK-14157 Project: Flink I

[jira] [Created] (FLINK-14376) Introduce the Executor abstraction (FLIP-73)

Kostas Kloudas created FLINK-14376: -- Summary: Introduce the Executor abstraction (FLIP-73) Key: FLINK-14376 URL: https://issues.apache.org/jira/browse/FLINK-14376 Project: Flink Issue Type:

[jira] [Created] (FLINK-14377) Translate ProgramOptions relevant for job execution to ConfigOptions.

Kostas Kloudas created FLINK-14377: -- Summary: Translate ProgramOptions relevant for job execution to ConfigOptions. Key: FLINK-14377 URL: https://issues.apache.org/jira/browse/FLINK-14377 Project: Fl

[jira] [Created] (FLINK-14501) Move ClusteDescriptor/ClusterSpecification creation from the CustomCommandLine to a ClusterClientFactory

Kostas Kloudas created FLINK-14501: -- Summary: Move ClusteDescriptor/ClusterSpecification creation from the CustomCommandLine to a ClusterClientFactory Key: FLINK-14501 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-14502) Make ClusterDescriptor/ClusterSpecification creation configuration-based.

Kostas Kloudas created FLINK-14502: -- Summary: Make ClusterDescriptor/ClusterSpecification creation configuration-based. Key: FLINK-14502 URL: https://issues.apache.org/jira/browse/FLINK-14502 Project

[jira] [Created] (FLINK-14548) Many tests in the nightly fail during cancellation.

Kostas Kloudas created FLINK-14548: -- Summary: Many tests in the nightly fail during cancellation. Key: FLINK-14548 URL: https://issues.apache.org/jira/browse/FLINK-14548 Project: Flink Issue

[jira] [Created] (FLINK-14657) Generalize and move YarnConfigUtils from flink-yarn to flink-core

Kostas Kloudas created FLINK-14657: -- Summary: Generalize and move YarnConfigUtils from flink-yarn to flink-core Key: FLINK-14657 URL: https://issues.apache.org/jira/browse/FLINK-14657 Project: Flink

[jira] [Created] (FLINK-14745) Put job jars from PackagedProgram to Configuration

Kostas Kloudas created FLINK-14745: -- Summary: Put job jars from PackagedProgram to Configuration Key: FLINK-14745 URL: https://issues.apache.org/jira/browse/FLINK-14745 Project: Flink Issue

[jira] [Created] (FLINK-14758) Add Executor-related interfaces and utilities

Kostas Kloudas created FLINK-14758: -- Summary: Add Executor-related interfaces and utilities Key: FLINK-14758 URL: https://issues.apache.org/jira/browse/FLINK-14758 Project: Flink Issue Type:

[jira] [Created] (FLINK-14829) Add test that verifies that the CLI sets the correct classloader.

Kostas Kloudas created FLINK-14829: -- Summary: Add test that verifies that the CLI sets the correct classloader. Key: FLINK-14829 URL: https://issues.apache.org/jira/browse/FLINK-14829 Project: Flink

[jira] [Created] (FLINK-14850) Refactor Executor interface and introduce a minimal JobClient interface

Kostas Kloudas created FLINK-14850: -- Summary: Refactor Executor interface and introduce a minimal JobClient interface Key: FLINK-14850 URL: https://issues.apache.org/jira/browse/FLINK-14850 Project:

[jira] [Created] (FLINK-14851) Make the (Stream)ContextEnvironment use the Executors

Kostas Kloudas created FLINK-14851: -- Summary: Make the (Stream)ContextEnvironment use the Executors Key: FLINK-14851 URL: https://issues.apache.org/jira/browse/FLINK-14851 Project: Flink Iss

[jira] [Created] (FLINK-14972) Implement RemoteExecutor as a new Executor

Kostas Kloudas created FLINK-14972: -- Summary: Implement RemoteExecutor as a new Executor Key: FLINK-14972 URL: https://issues.apache.org/jira/browse/FLINK-14972 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-15033) Remove unused RemoteEnvirnment.executeRemotely() (FLINK-11048)

Kostas Kloudas created FLINK-15033: -- Summary: Remove unused RemoteEnvirnment.executeRemotely() (FLINK-11048) Key: FLINK-15033 URL: https://issues.apache.org/jira/browse/FLINK-15033 Project: Flink

[jira] [Created] (FLINK-15039) Remove default close() implementation from ClusterClient

Kostas Kloudas created FLINK-15039: -- Summary: Remove default close() implementation from ClusterClient Key: FLINK-15039 URL: https://issues.apache.org/jira/browse/FLINK-15039 Project: Flink

[jira] [Created] (FLINK-15041) Remove default close() implementation from JobClient

Kostas Kloudas created FLINK-15041: -- Summary: Remove default close() implementation from JobClient Key: FLINK-15041 URL: https://issues.apache.org/jira/browse/FLINK-15041 Project: Flink Issu

[jira] [Created] (FLINK-15042) Fix python compatibility by excluding the Env.executeAsync() (FLINK-14854)

Kostas Kloudas created FLINK-15042: -- Summary: Fix python compatibility by excluding the Env.executeAsync() (FLINK-14854) Key: FLINK-15042 URL: https://issues.apache.org/jira/browse/FLINK-15042 Projec

[jira] [Created] (FLINK-15118) Make flink-scala-shell use Executors

Kostas Kloudas created FLINK-15118: -- Summary: Make flink-scala-shell use Executors Key: FLINK-15118 URL: https://issues.apache.org/jira/browse/FLINK-15118 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-15119) Remove PlanExecutor and its subclasses

Kostas Kloudas created FLINK-15119: -- Summary: Remove PlanExecutor and its subclasses Key: FLINK-15119 URL: https://issues.apache.org/jira/browse/FLINK-15119 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-15120) Make FlinkYarnCli#isActive() & #getApplicationId() respect config APPLICATION_ID

Kostas Kloudas created FLINK-15120: -- Summary: Make FlinkYarnCli#isActive() & #getApplicationId() respect config APPLICATION_ID Key: FLINK-15120 URL: https://issues.apache.org/jira/browse/FLINK-15120

[jira] [Created] (FLINK-15179) Kubernetes should not have a CustomCommandLine.

Kostas Kloudas created FLINK-15179: -- Summary: Kubernetes should not have a CustomCommandLine. Key: FLINK-15179 URL: https://issues.apache.org/jira/browse/FLINK-15179 Project: Flink Issue Typ

[jira] [Created] (FLINK-15195) Remove unu

Kostas Kloudas created FLINK-15195: -- Summary: Remove unu Key: FLINK-15195 URL: https://issues.apache.org/jira/browse/FLINK-15195 Project: Flink Issue Type: Sub-task Reporter: Kos

[jira] [Created] (FLINK-15260) Uniformize Kubernetes executor name with the rest

Kostas Kloudas created FLINK-15260: -- Summary: Uniformize Kubernetes executor name with the rest Key: FLINK-15260 URL: https://issues.apache.org/jira/browse/FLINK-15260 Project: Flink Issue T

[jira] [Created] (FLINK-15273) Complete and Update Documentation

Kostas Kloudas created FLINK-15273: -- Summary: Complete and Update Documentation Key: FLINK-15273 URL: https://issues.apache.org/jira/browse/FLINK-15273 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15274) Update Filesystem documentation to reflect changes in shading

Kostas Kloudas created FLINK-15274: -- Summary: Update Filesystem documentation to reflect changes in shading Key: FLINK-15274 URL: https://issues.apache.org/jira/browse/FLINK-15274 Project: Flink

[jira] [Created] (FLINK-15275) Update CLI documentation to include only current valid options

Kostas Kloudas created FLINK-15275: -- Summary: Update CLI documentation to include only current valid options Key: FLINK-15275 URL: https://issues.apache.org/jira/browse/FLINK-15275 Project: Flink

[jira] [Created] (FLINK-15276) Update CLI documentation to reflect the addition of the ExecutorCLI

Kostas Kloudas created FLINK-15276: -- Summary: Update CLI documentation to reflect the addition of the ExecutorCLI Key: FLINK-15276 URL: https://issues.apache.org/jira/browse/FLINK-15276 Project: Flin

[jira] [Created] (FLINK-15278) Update StreamingFileSink documentation

Kostas Kloudas created FLINK-15278: -- Summary: Update StreamingFileSink documentation Key: FLINK-15278 URL: https://issues.apache.org/jira/browse/FLINK-15278 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-15279) Document new `executeAsync()` method and the newly introduced `JobClient`

Kostas Kloudas created FLINK-15279: -- Summary: Document new `executeAsync()` method and the newly introduced `JobClient` Key: FLINK-15279 URL: https://issues.apache.org/jira/browse/FLINK-15279 Project

[jira] [Created] (FLINK-15292) Rename Executor interface to PipelineExecutor

Kostas Kloudas created FLINK-15292: -- Summary: Rename Executor interface to PipelineExecutor Key: FLINK-15292 URL: https://issues.apache.org/jira/browse/FLINK-15292 Project: Flink Issue Type:

[jira] [Created] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

Kostas Kloudas created FLINK-15687: -- Summary: Potential test instabilities due to concurrent access to TaskSlotTable. Key: FLINK-15687 URL: https://issues.apache.org/jira/browse/FLINK-15687 Project:

[jira] [Created] (FLINK-15805) StreamingFileSink on S3 fails when firing processing time timers after recovery.

Kostas Kloudas created FLINK-15805: -- Summary: StreamingFileSink on S3 fails when firing processing time timers after recovery. Key: FLINK-15805 URL: https://issues.apache.org/jira/browse/FLINK-15805

[jira] [Created] (FLINK-9903) Add support for bulk writers.

Kostas Kloudas created FLINK-9903: - Summary: Add support for bulk writers. Key: FLINK-9903 URL: https://issues.apache.org/jira/browse/FLINK-9903 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9921) Update the rolling policy interface.

Kostas Kloudas created FLINK-9921: - Summary: Update the rolling policy interface. Key: FLINK-9921 URL: https://issues.apache.org/jira/browse/FLINK-9921 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9994) IntervalJoinOperator#Context#getTimestamp does not return the Max timestamp.

Kostas Kloudas created FLINK-9994: - Summary: IntervalJoinOperator#Context#getTimestamp does not return the Max timestamp. Key: FLINK-9994 URL: https://issues.apache.org/jira/browse/FLINK-9994 Project:

[jira] [Created] (FLINK-10027) Add logging to the StreamingFileSink

Kostas Kloudas created FLINK-10027: -- Summary: Add logging to the StreamingFileSink Key: FLINK-10027 URL: https://issues.apache.org/jira/browse/FLINK-10027 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10029) Refactor the code for better separation of concerns.

Kostas Kloudas created FLINK-10029: -- Summary: Refactor the code for better separation of concerns. Key: FLINK-10029 URL: https://issues.apache.org/jira/browse/FLINK-10029 Project: Flink Issu

[jira] [Created] (FLINK-10097) More tests to increase StreamingFileSink test coverage

Kostas Kloudas created FLINK-10097: -- Summary: More tests to increase StreamingFileSink test coverage Key: FLINK-10097 URL: https://issues.apache.org/jira/browse/FLINK-10097 Project: Flink Is

[jira] [Created] (FLINK-10522) Check if RecoverableWriter supportsResume and accordingly.

Kostas Kloudas created FLINK-10522: -- Summary: Check if RecoverableWriter supportsResume and accordingly. Key: FLINK-10522 URL: https://issues.apache.org/jira/browse/FLINK-10522 Project: Flink

[jira] [Created] (FLINK-10529) Add flink-s3-fs-base to the connectors in the travis stage file.

Kostas Kloudas created FLINK-10529: -- Summary: Add flink-s3-fs-base to the connectors in the travis stage file. Key: FLINK-10529 URL: https://issues.apache.org/jira/browse/FLINK-10529 Project: Flink

[jira] [Created] (FLINK-10530) ProcessFailureCancelingITCase.testCancelingOnProcessFailure failed on Travis.

Kostas Kloudas created FLINK-10530: -- Summary: ProcessFailureCancelingITCase.testCancelingOnProcessFailure failed on Travis. Key: FLINK-10530 URL: https://issues.apache.org/jira/browse/FLINK-10530 Pro

[jira] [Created] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

Kostas Kloudas created FLINK-10583: -- Summary: Add support for state retention to the Processing Time versioned joins. Key: FLINK-10583 URL: https://issues.apache.org/jira/browse/FLINK-10583 Project:

[jira] [Created] (FLINK-10584) Add support for state retention to the Event Time versioned joins.

Kostas Kloudas created FLINK-10584: -- Summary: Add support for state retention to the Event Time versioned joins. Key: FLINK-10584 URL: https://issues.apache.org/jira/browse/FLINK-10584 Project: Flink

[jira] [Created] (FLINK-10733) Misleading clean_log_files() in common.sh

Kostas Kloudas created FLINK-10733: -- Summary: Misleading clean_log_files() in common.sh Key: FLINK-10733 URL: https://issues.apache.org/jira/browse/FLINK-10733 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-10739) Unstable ProcessFailureCancelingITCase.testCancelingOnProcessFailure

Kostas Kloudas created FLINK-10739: -- Summary: Unstable ProcessFailureCancelingITCase.testCancelingOnProcessFailure Key: FLINK-10739 URL: https://issues.apache.org/jira/browse/FLINK-10739 Project: Fli

[jira] [Created] (FLINK-10803) Add documentation about S3 support by the StreamingFileSink

Kostas Kloudas created FLINK-10803: -- Summary: Add documentation about S3 support by the StreamingFileSink Key: FLINK-10803 URL: https://issues.apache.org/jira/browse/FLINK-10803 Project: Flink

[jira] [Created] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects

Kostas Kloudas created FLINK-10963: -- Summary: Cleanup small objects uploaded to S3 as independent objects Key: FLINK-10963 URL: https://issues.apache.org/jira/browse/FLINK-10963 Project: Flink

[jira] [Created] (FLINK-11027) JobManagerHAProcessFailureRecoveryITCase#testDispatcherProcessFailure failed on Travis

Kostas Kloudas created FLINK-11027: -- Summary: JobManagerHAProcessFailureRecoveryITCase#testDispatcherProcessFailure failed on Travis Key: FLINK-11027 URL: https://issues.apache.org/jira/browse/FLINK-11027

[jira] [Created] (FLINK-11116) Clean-up temporary files that upon recovery, they belong to no checkpoint.

Kostas Kloudas created FLINK-6: -- Summary: Clean-up temporary files that upon recovery, they belong to no checkpoint. Key: FLINK-6 URL: https://issues.apache.org/jira/browse/FLINK-6 Projec

[jira] [Created] (FLINK-11458) Ensure sink commit side-effects when cancelling with savepoint.

Kostas Kloudas created FLINK-11458: -- Summary: Ensure sink commit side-effects when cancelling with savepoint. Key: FLINK-11458 URL: https://issues.apache.org/jira/browse/FLINK-11458 Project: Flink

[jira] [Created] (FLINK-11572) Add new types of CheckpointBarriers.

Kostas Kloudas created FLINK-11572: -- Summary: Add new types of CheckpointBarriers. Key: FLINK-11572 URL: https://issues.apache.org/jira/browse/FLINK-11572 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11573) Make StreamTask properly handle the SUSPEND message.

Kostas Kloudas created FLINK-11573: -- Summary: Make StreamTask properly handle the SUSPEND message. Key: FLINK-11573 URL: https://issues.apache.org/jira/browse/FLINK-11573 Project: Flink Issu

[jira] [Created] (FLINK-11575) Let the JobManager send the SUSPEND and DRAIN messages

Kostas Kloudas created FLINK-11575: -- Summary: Let the JobManager send the SUSPEND and DRAIN messages Key: FLINK-11575 URL: https://issues.apache.org/jira/browse/FLINK-11575 Project: Flink Is

[jira] [Created] (FLINK-11574) Make StreamTask properly handle the DRAIN message.

Kostas Kloudas created FLINK-11574: -- Summary: Make StreamTask properly handle the DRAIN message. Key: FLINK-11574 URL: https://issues.apache.org/jira/browse/FLINK-11574 Project: Flink Issue

[jira] [Created] (FLINK-11667) Add Synchronous Checkpoint handling in StreamTask

Kostas Kloudas created FLINK-11667: -- Summary: Add Synchronous Checkpoint handling in StreamTask Key: FLINK-11667 URL: https://issues.apache.org/jira/browse/FLINK-11667 Project: Flink Issue T

[jira] [Created] (FLINK-11668) Allow sources to advance time to max watermark on checkpoint.

Kostas Kloudas created FLINK-11668: -- Summary: Allow sources to advance time to max watermark on checkpoint. Key: FLINK-11668 URL: https://issues.apache.org/jira/browse/FLINK-11668 Project: Flink

[jira] [Created] (FLINK-11669) Add Synchronous Checkpoint Triggering RPCs.

Kostas Kloudas created FLINK-11669: -- Summary: Add Synchronous Checkpoint Triggering RPCs. Key: FLINK-11669 URL: https://issues.apache.org/jira/browse/FLINK-11669 Project: Flink Issue Type: S

[jira] [Created] (FLINK-11671) Expose SUSPEND/TERMINATE to CLI

Kostas Kloudas created FLINK-11671: -- Summary: Expose SUSPEND/TERMINATE to CLI Key: FLINK-11671 URL: https://issues.apache.org/jira/browse/FLINK-11671 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11670) Add SUSPEND/TERMINATE calls to REST API

Kostas Kloudas created FLINK-11670: -- Summary: Add SUSPEND/TERMINATE calls to REST API Key: FLINK-11670 URL: https://issues.apache.org/jira/browse/FLINK-11670 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-11984) StreamingFileSink docs do not mention S3 savepoint caveats.

Kostas Kloudas created FLINK-11984: -- Summary: StreamingFileSink docs do not mention S3 savepoint caveats. Key: FLINK-11984 URL: https://issues.apache.org/jira/browse/FLINK-11984 Project: Flink

[jira] [Created] (FLINK-12051) TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() failed locally.

Kostas Kloudas created FLINK-12051: -- Summary: TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() failed locally. Key: FLINK-12051 URL: https://issues.apache.org/jira/browse/FLINK-12051 P

[jira] [Created] (FLINK-12226) Add documentation about SUSPEND/TERMINATE

Kostas Kloudas created FLINK-12226: -- Summary: Add documentation about SUSPEND/TERMINATE Key: FLINK-12226 URL: https://issues.apache.org/jira/browse/FLINK-12226 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-3683) Unstable tests: in the Kafka09ITCase, the testMultipleSourcesOnePartition() and the testOneToOneSources()

Kostas Kloudas created FLINK-3683: - Summary: Unstable tests: in the Kafka09ITCase, the testMultipleSourcesOnePartition() and the testOneToOneSources() Key: FLINK-3683 URL: https://issues.apache.org/jira/browse/FLI

[jira] [Created] (FLINK-3717) Add functionality to get the current offset of a source with a FileInputFormat

Kostas Kloudas created FLINK-3717: - Summary: Add functionality to get the current offset of a source with a FileInputFormat Key: FLINK-3717 URL: https://issues.apache.org/jira/browse/FLINK-3717 Projec

[jira] [Created] (FLINK-3808) Refactor the whole file monitoring source to take a fileInputFormat as an argument.

Kostas Kloudas created FLINK-3808: - Summary: Refactor the whole file monitoring source to take a fileInputFormat as an argument. Key: FLINK-3808 URL: https://issues.apache.org/jira/browse/FLINK-3808 P

[jira] [Created] (FLINK-3826) Broken test: StreamCheckpointingITCase

Kostas Kloudas created FLINK-3826: - Summary: Broken test: StreamCheckpointingITCase Key: FLINK-3826 URL: https://issues.apache.org/jira/browse/FLINK-3826 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3843) StreamFaultToleranceTestBase hangs in case of test failure.

Kostas Kloudas created FLINK-3843: - Summary: StreamFaultToleranceTestBase hangs in case of test failure. Key: FLINK-3843 URL: https://issues.apache.org/jira/browse/FLINK-3843 Project: Flink

[jira] [Created] (FLINK-3889) Make File Monitoring Function checkpointable.

Kostas Kloudas created FLINK-3889: - Summary: Make File Monitoring Function checkpointable. Key: FLINK-3889 URL: https://issues.apache.org/jira/browse/FLINK-3889 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-3896) Allow a StreamTask to be Externally Cancelled.

Kostas Kloudas created FLINK-3896: - Summary: Allow a StreamTask to be Externally Cancelled. Key: FLINK-3896 URL: https://issues.apache.org/jira/browse/FLINK-3896 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-3956) Make FileInputFormats in Streaming independent from the Configuration object

Kostas Kloudas created FLINK-3956: - Summary: Make FileInputFormats in Streaming independent from the Configuration object Key: FLINK-3956 URL: https://issues.apache.org/jira/browse/FLINK-3956 Project:

[jira] [Created] (FLINK-3986) Rename the readFileStream(String filePath, long intervalMillis, WatchType watchType) from the StreamExecutionEnvironment

Kostas Kloudas created FLINK-3986: - Summary: Rename the readFileStream(String filePath, long intervalMillis, WatchType watchType) from the StreamExecutionEnvironment Key: FLINK-3986 URL: https://issues.apache.org/

[jira] [Created] (FLINK-4065) Unstable Kafka09ITCase.testMultipleSourcesOnePartition test

Kostas Kloudas created FLINK-4065: - Summary: Unstable Kafka09ITCase.testMultipleSourcesOnePartition test Key: FLINK-4065 URL: https://issues.apache.org/jira/browse/FLINK-4065 Project: Flink

[jira] [Created] (FLINK-4124) Unstable test WrapperSetupHelperTest.testCreateTopologyContext

Kostas Kloudas created FLINK-4124: - Summary: Unstable test WrapperSetupHelperTest.testCreateTopologyContext Key: FLINK-4124 URL: https://issues.apache.org/jira/browse/FLINK-4124 Project: Flink

[jira] [Created] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection

Kostas Kloudas created FLINK-4126: - Summary: Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection Key: FLINK-4126 URL: https://issues.apache.org/jira/browse/FLINK-4126 Project: Flink

[jira] [Created] (FLINK-4199) Wrong client behavior when submitting job to non-existing cluster

Kostas Kloudas created FLINK-4199: - Summary: Wrong client behavior when submitting job to non-existing cluster Key: FLINK-4199 URL: https://issues.apache.org/jira/browse/FLINK-4199 Project: Flink

[jira] [Created] (FLINK-4224) Exception after successful execution when submitting job through the web interface.

Kostas Kloudas created FLINK-4224: - Summary: Exception after successful execution when submitting job through the web interface. Key: FLINK-4224 URL: https://issues.apache.org/jira/browse/FLINK-4224 P

[jira] [Created] (FLINK-4237) ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails due to Timeout Futures

Kostas Kloudas created FLINK-4237: - Summary: ClassLoaderITCase.testDisposeSavepointWithCustomKvState fails due to Timeout Futures Key: FLINK-4237 URL: https://issues.apache.org/jira/browse/FLINK-4237

  1   2   3   >