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
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: Sub-task
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
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:
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 Typ
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 Type:
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: Sub-
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 Type
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:
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 Type
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 Type
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: Sub
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 Type:
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 Ty
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: Sub-
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 T
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: Su
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:
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
Project:
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
Issue
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
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: F
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: Sub-ta
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 Type:
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:
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
Kostas Kloudas created FLINK-17620:
--
Summary: Rename StandaloneJobClusterEntryPoint to
StandaloneApplicationClusterEntryPoint
Key: FLINK-17620
URL: https://issues.apache.org/jira/browse/FLINK-17620
P
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
Iss
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
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:
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
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
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
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
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
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:
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
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
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:
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:
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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:
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
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
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
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
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
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
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:
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
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
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
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
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
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
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:
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:
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
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
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
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
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
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
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
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
Kostas Kloudas created FLINK-12051:
--
Summary:
TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() failed locally.
Key: FLINK-12051
URL: https://issues.apache.org/jira/browse/FLINK-12051
P
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
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
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
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
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
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
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
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
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
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
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
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
Kostas Kloudas created FLINK-11027:
--
Summary:
JobManagerHAProcessFailureRecoveryITCase#testDispatcherProcessFailure failed on
Travis
Key: FLINK-11027
URL: https://issues.apache.org/jira/browse/FLINK-11027
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
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
1 - 100 of 241 matches
Mail list logo