[jira] [Created] (FLINK-20240) Add setter in the environment for the `execution.runtime-mode`

Kostas Kloudas created FLINK-20240: -- Summary: Add setter in the environment for the `execution.runtime-mode` Key: FLINK-20240 URL: https://issues.apache.org/jira/browse/FLINK-20240 Project: Flink

[jira] [Created] (FLINK-20141) Add documentation about the FileSink

Kostas Kloudas created FLINK-20141: -- Summary: Add documentation about the FileSink Key: FLINK-20141 URL: https://issues.apache.org/jira/browse/FLINK-20141 Project: Flink Issue Type:

[jira] [Created] (FLINK-20020) Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract.

Kostas Kloudas created FLINK-20020: -- Summary: Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract. Key: FLINK-20020 URL: https://issues.apache.org/jira/browse/FLINK-20020

[jira] [Created] (FLINK-19993) Remove the flink-connector-filesystem module

Kostas Kloudas created FLINK-19993: -- Summary: Remove the flink-connector-filesystem module Key: FLINK-19993 URL: https://issues.apache.org/jira/browse/FLINK-19993 Project: Flink Issue Type:

[jira] [Created] (FLINK-19815) Disable CoFeedbackTransformation for BATCH mode

Kostas Kloudas created FLINK-19815: -- Summary: Disable CoFeedbackTransformation for BATCH mode Key: FLINK-19815 URL: https://issues.apache.org/jira/browse/FLINK-19815 Project: Flink Issue

[jira] [Created] (FLINK-19814) Disable FeedbackTransformation for BATCH mode

Kostas Kloudas created FLINK-19814: -- Summary: Disable FeedbackTransformation for BATCH mode Key: FLINK-19814 URL: https://issues.apache.org/jira/browse/FLINK-19814 Project: Flink Issue

[jira] [Created] (FLINK-19732) Disable Checkpointing when in BATCH mode

Kostas Kloudas created FLINK-19732: -- Summary: Disable Checkpointing when in BATCH mode Key: FLINK-19732 URL: https://issues.apache.org/jira/browse/FLINK-19732 Project: Flink Issue Type:

[jira] [Created] (FLINK-19730) Create the CoFeedbackTransformation translator

Kostas Kloudas created FLINK-19730: -- Summary: Create the CoFeedbackTransformation translator Key: FLINK-19730 URL: https://issues.apache.org/jira/browse/FLINK-19730 Project: Flink Issue

[jira] [Created] (FLINK-19729) Create the FeedbackTransformation translator

Kostas Kloudas created FLINK-19729: -- Summary: Create the FeedbackTransformation translator Key: FLINK-19729 URL: https://issues.apache.org/jira/browse/FLINK-19729 Project: Flink Issue Type:

[jira] [Created] (FLINK-19583) Expose the execution.runtime-mode to the users

Kostas Kloudas created FLINK-19583: -- Summary: Expose the execution.runtime-mode to the users Key: FLINK-19583 URL: https://issues.apache.org/jira/browse/FLINK-19583 Project: Flink Issue

[jira] [Created] (FLINK-19579) Create the SideOutputTransformation translator

Kostas Kloudas created FLINK-19579: -- Summary: Create the SideOutputTransformation translator Key: FLINK-19579 URL: https://issues.apache.org/jira/browse/FLINK-19579 Project: Flink Issue

[jira] [Created] (FLINK-19577) Create the UnionTransformation translator

Kostas Kloudas created FLINK-19577: -- Summary: Create the UnionTransformation translator Key: FLINK-19577 URL: https://issues.apache.org/jira/browse/FLINK-19577 Project: Flink Issue Type:

[jira] [Created] (FLINK-19578) Create the PartitionTransformation translator

Kostas Kloudas created FLINK-19578: -- Summary: Create the PartitionTransformation translator Key: FLINK-19578 URL: https://issues.apache.org/jira/browse/FLINK-19578 Project: Flink Issue

[jira] [Created] (FLINK-19575) Create the LegacySourceTransformation translator

Kostas Kloudas created FLINK-19575: -- Summary: Create the LegacySourceTransformation translator Key: FLINK-19575 URL: https://issues.apache.org/jira/browse/FLINK-19575 Project: Flink Issue

[jira] [Created] (FLINK-19576) Create the SinkTransformation translator

Kostas Kloudas created FLINK-19576: -- Summary: Create the SinkTransformation translator Key: FLINK-19576 URL: https://issues.apache.org/jira/browse/FLINK-19576 Project: Flink Issue Type:

[jira] [Created] (FLINK-19573) Create the MultipleInputTransformation translator

Kostas Kloudas created FLINK-19573: -- Summary: Create the MultipleInputTransformation translator Key: FLINK-19573 URL: https://issues.apache.org/jira/browse/FLINK-19573 Project: Flink Issue

[jira] [Created] (FLINK-19574) Create the SourceTransformation translator

Kostas Kloudas created FLINK-19574: -- Summary: Create the SourceTransformation translator Key: FLINK-19574 URL: https://issues.apache.org/jira/browse/FLINK-19574 Project: Flink Issue Type:

[jira] [Created] (FLINK-19572) Create the TwoInputTransformation translator

Kostas Kloudas created FLINK-19572: -- Summary: Create the TwoInputTransformation translator Key: FLINK-19572 URL: https://issues.apache.org/jira/browse/FLINK-19572 Project: Flink Issue Type:

[jira] [Created] (FLINK-19571) Port Transformation translation logic to StreamGraphTranslator framework

Kostas Kloudas created FLINK-19571: -- Summary: Port Transformation translation logic to StreamGraphTranslator framework Key: FLINK-19571 URL: https://issues.apache.org/jira/browse/FLINK-19571

[jira] [Created] (FLINK-19485) Consider runtime-mode when creating the StreamGraph

Kostas Kloudas created FLINK-19485: -- Summary: Consider runtime-mode when creating the StreamGraph Key: FLINK-19485 URL: https://issues.apache.org/jira/browse/FLINK-19485 Project: Flink

[jira] [Created] (FLINK-19392) Detect the execution mode based on the sources in the job.

Kostas Kloudas created FLINK-19392: -- Summary: Detect the execution mode based on the sources in the job. Key: FLINK-19392 URL: https://issues.apache.org/jira/browse/FLINK-19392 Project: Flink

[jira] [Created] (FLINK-18519) Propagate exception to client when execution fails for REST submission

Kostas Kloudas created FLINK-18519: -- Summary: Propagate exception to client when execution fails for REST submission Key: FLINK-18519 URL: https://issues.apache.org/jira/browse/FLINK-18519 Project:

[jira] [Created] (FLINK-18469) Add Application Mode to release notes.

Kostas Kloudas created FLINK-18469: -- Summary: Add Application Mode to release notes. Key: FLINK-18469 URL: https://issues.apache.org/jira/browse/FLINK-18469 Project: Flink Issue Type:

[jira] [Created] (FLINK-18084) Create documentation for the Application Mode

Kostas Kloudas created FLINK-18084: -- Summary: Create documentation for the Application Mode Key: FLINK-18084 URL: https://issues.apache.org/jira/browse/FLINK-18084 Project: Flink Issue

[jira] [Created] (FLINK-17729) Make mandatory to have lib/, plugin/ and dist in yarn.provided.lib.dirs

Kostas Kloudas created FLINK-17729: -- Summary: Make mandatory to have lib/, plugin/ and dist in yarn.provided.lib.dirs Key: FLINK-17729 URL: https://issues.apache.org/jira/browse/FLINK-17729 Project:

[jira] [Created] (FLINK-17639) Document which FileSystems are supported by the StreamingFileSink

Kostas Kloudas created FLINK-17639: -- Summary: Document which FileSystems are supported by the StreamingFileSink Key: FLINK-17639 URL: https://issues.apache.org/jira/browse/FLINK-17639 Project: Flink

[jira] [Created] (FLINK-17620) Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint

Kostas Kloudas created FLINK-17620: -- Summary: Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint Key: FLINK-17620 URL: https://issues.apache.org/jira/browse/FLINK-17620

[jira] [Created] (FLINK-17515) Move file uploading functionality to a separate class

Kostas Kloudas created FLINK-17515: -- Summary: Move file uploading functionality to a separate class Key: FLINK-17515 URL: https://issues.apache.org/jira/browse/FLINK-17515 Project: Flink

[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

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

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

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

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

[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

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

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

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

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

[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

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

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

[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

[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

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

[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

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

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

[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

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

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

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

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

[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

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

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

[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

[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

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

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

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

[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

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

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

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

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

[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

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

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

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

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

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

  1   2   3   >