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

2018-10-17 Thread Kostas Kloudas (JIRA)
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.

2018-10-17 Thread Kostas Kloudas (JIRA)
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

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

2018-10-31 Thread Kostas Kloudas (JIRA)
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-10739) Unstable ProcessFailureCancelingITCase.testCancelingOnProcessFailure

2018-10-31 Thread Kostas Kloudas (JIRA)
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-10803) Add documentation about S3 support by the StreamingFileSink

2018-11-06 Thread Kostas Kloudas (JIRA)
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

2018-11-21 Thread Kostas Kloudas (JIRA)
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

2018-11-29 Thread Kostas Kloudas (JIRA)
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.

2018-12-10 Thread Kostas Kloudas (JIRA)
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-11458) Ensure sink commit side-effects when cancelling with savepoint.

2019-01-29 Thread Kostas Kloudas (JIRA)
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.

2019-02-11 Thread Kostas Kloudas (JIRA)
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

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

2019-02-11 Thread Kostas Kloudas (JIRA)
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-11575) Let the JobManager send the SUSPEND and DRAIN messages

2019-02-11 Thread Kostas Kloudas (JIRA)
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-11574) Make StreamTask properly handle the DRAIN message.

2019-02-11 Thread Kostas Kloudas (JIRA)
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

2019-02-20 Thread Kostas Kloudas (JIRA)
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-11668) Allow sources to advance time to max watermark on checkpoint.

2019-02-20 Thread Kostas Kloudas (JIRA)
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.

2019-02-20 Thread Kostas Kloudas (JIRA)
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-11671) Expose SUSPEND/TERMINATE to CLI

2019-02-20 Thread Kostas Kloudas (JIRA)
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

2019-02-20 Thread Kostas Kloudas (JIRA)
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

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

2019-03-20 Thread Kostas Kloudas (JIRA)
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.

2019-03-28 Thread Kostas Kloudas (JIRA)
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-12226) Add documentation about SUSPEND/TERMINATE

2019-04-17 Thread Kostas Kloudas (JIRA)
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-3683) Unstable tests: in the Kafka09ITCase, the testMultipleSourcesOnePartition() and the testOneToOneSources()

2016-03-30 Thread Kostas Kloudas (JIRA)
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

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

2016-04-08 Thread Kostas Kloudas (JIRA)
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

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

2016-04-25 Thread Kostas Kloudas (JIRA)
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

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

2016-04-27 Thread Kostas Kloudas (JIRA)
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.

2016-04-28 Thread Kostas Kloudas (JIRA)
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.

2016-05-10 Thread Kostas Kloudas (JIRA)
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

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

2016-05-10 Thread Kostas Kloudas (JIRA)
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

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

2016-05-23 Thread Kostas Kloudas (JIRA)
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

2016-05-28 Thread Kostas Kloudas (JIRA)
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

2016-06-13 Thread Kostas Kloudas (JIRA)
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

2016-06-27 Thread Kostas Kloudas (JIRA)
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

2016-06-27 Thread Kostas Kloudas (JIRA)
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

2016-07-12 Thread Kostas Kloudas (JIRA)
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.

2016-07-16 Thread Kostas Kloudas (JIRA)
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

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

2016-07-20 Thread Kostas Kloudas (JIRA)
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

[jira] [Created] (FLINK-4255) Unstable test WebRuntimeMonitorITCase.testNoEscape

2016-07-22 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4255: - Summary: Unstable test WebRuntimeMonitorITCase.testNoEscape Key: FLINK-4255 URL: https://issues.apache.org/jira/browse/FLINK-4255 Project: Flink Issue

[jira] [Created] (FLINK-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery

2016-08-15 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4398: - Summary: Unstable test KvStateServerHandlerTest.testSimpleQuery Key: FLINK-4398 URL: https://issues.apache.org/jira/browse/FLINK-4398 Project: Flink Issue

[jira] [Created] (FLINK-4397) Unstable test SlotCountExceedingParallelismTest.tearDown

2016-08-15 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4397: - Summary: Unstable test SlotCountExceedingParallelismTest.tearDown Key: FLINK-4397 URL: https://issues.apache.org/jira/browse/FLINK-4397 Project: Flink

[jira] [Created] (FLINK-4407) Implement the trigger DSL

2016-08-17 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4407: - Summary: Implement the trigger DSL Key: FLINK-4407 URL: https://issues.apache.org/jira/browse/FLINK-4407 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4433) Refactor the StreamSource.

2016-08-19 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4433: - Summary: Refactor the StreamSource. Key: FLINK-4433 URL: https://issues.apache.org/jira/browse/FLINK-4433 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4494) Expose the TimeServiceProvider from the Task to each Operator.

2016-08-25 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4494: - Summary: Expose the TimeServiceProvider from the Task to each Operator. Key: FLINK-4494 URL: https://issues.apache.org/jira/browse/FLINK-4494 Project: Flink

[jira] [Created] (FLINK-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

2016-08-25 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4496: - Summary: Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable. Key: FLINK-4496 URL: https://issues.apache.org/jira/browse/FLINK-4496 Project

[jira] [Created] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

2016-09-21 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4651: - Summary: Re-register processing time timers at the WindowOperator upon recovery. Key: FLINK-4651 URL: https://issues.apache.org/jira/browse/FLINK-4651 Project

[jira] [Created] (FLINK-4700) Harden the TimeProvider test

2016-09-27 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4700: - Summary: Harden the TimeProvider test Key: FLINK-4700 URL: https://issues.apache.org/jira/browse/FLINK-4700 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4800) Refactor the ContinuousFileMonitoringFunction code and the related tests.

2016-10-11 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4800: - Summary: Refactor the ContinuousFileMonitoringFunction code and the related tests. Key: FLINK-4800 URL: https://issues.apache.org/jira/browse/FLINK-4800 Project

[jira] [Created] (FLINK-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch

2016-10-15 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4833: - Summary: Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch Key: FLINK-4833 URL: https://issues.apache.org/jira/browse/FLINK-4833

[jira] [Created] (FLINK-4939) GenericWriteAheadSink: Decouple the subtask that created a pending checkpoint from the one that commits it.

2016-10-27 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4939: - Summary: GenericWriteAheadSink: Decouple the subtask that created a pending checkpoint from the one that commits it. Key: FLINK-4939 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-4960) Enable testing of different re-scaling scenarios in the AbstractStreamOperatorTestHarness to

2016-10-28 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4960: - Summary: Enable testing of different re-scaling scenarios in the AbstractStreamOperatorTestHarness to Key: FLINK-4960 URL: https://issues.apache.org/jira/browse/FLINK-4960

[jira] [Created] (FLINK-5020) Make the GenericWriteAheadSink rescalable.

2016-11-04 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5020: - Summary: Make the GenericWriteAheadSink rescalable. Key: FLINK-5020 URL: https://issues.apache.org/jira/browse/FLINK-5020 Project: Flink Issue Type

[jira] [Created] (FLINK-5021) Make the ContinuousFileReaderOperator rescalable.

2016-11-04 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5021: - Summary: Make the ContinuousFileReaderOperator rescalable. Key: FLINK-5021 URL: https://issues.apache.org/jira/browse/FLINK-5021 Project: Flink Issue Type

[jira] [Created] (FLINK-5054) Make the BucketingSink rescalable.

2016-11-11 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5054: - Summary: Make the BucketingSink rescalable. Key: FLINK-5054 URL: https://issues.apache.org/jira/browse/FLINK-5054 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5056) BucketingSink deletes valid data when checkpoint notification is slow.

2016-11-11 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5056: - Summary: BucketingSink deletes valid data when checkpoint notification is slow. Key: FLINK-5056 URL: https://issues.apache.org/jira/browse/FLINK-5056 Project

[jira] [Created] (FLINK-5096) Make the RollingSink rescalable.

2016-11-18 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5096: - Summary: Make the RollingSink rescalable. Key: FLINK-5096 URL: https://issues.apache.org/jira/browse/FLINK-5096 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5110) Remove the AbstractAlignedProcessingTimeWindowOperator.

2016-11-21 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5110: - Summary: Remove the AbstractAlignedProcessingTimeWindowOperator. Key: FLINK-5110 URL: https://issues.apache.org/jira/browse/FLINK-5110 Project: Flink

[jira] [Created] (FLINK-5111) Change the assignToKeyGroup() method to not use Object.hashCode()

2016-11-21 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5111: - Summary: Change the assignToKeyGroup() method to not use Object.hashCode() Key: FLINK-5111 URL: https://issues.apache.org/jira/browse/FLINK-5111 Project: Flink

[jira] [Created] (FLINK-5113) Make all the testing Functions implement the CheckpointedFucntion interface.

2016-11-21 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5113: - Summary: Make all the testing Functions implement the CheckpointedFucntion interface. Key: FLINK-5113 URL: https://issues.apache.org/jira/browse/FLINK-5113 Project

[jira] [Created] (FLINK-5117) Make the state of the AbstractAlignedProcessingTimeWindowOperator compatible with the WindowOperator.

2016-11-21 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5117: - Summary: Make the state of the AbstractAlignedProcessingTimeWindowOperator compatible with the WindowOperator. Key: FLINK-5117 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-5163) Make the production functions rescalable (apart from the Rolling/Bucketing Sinks)

2016-11-25 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5163: - Summary: Make the production functions rescalable (apart from the Rolling/Bucketing Sinks) Key: FLINK-5163 URL: https://issues.apache.org/jira/browse/FLINK-5163

[jira] [Created] (FLINK-5174) Fix memory leak in the CEP library.

2016-11-28 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5174: - Summary: Fix memory leak in the CEP library. Key: FLINK-5174 URL: https://issues.apache.org/jira/browse/FLINK-5174 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5264) Improve error message when assigning uid to intermediate operator.

2016-12-05 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5264: - Summary: Improve error message when assigning uid to intermediate operator. Key: FLINK-5264 URL: https://issues.apache.org/jira/browse/FLINK-5264 Project: Flink

[jira] [Created] (FLINK-5292) Make the remaining operators backwards compatible.

2016-12-08 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5292: - Summary: Make the remaining operators backwards compatible. Key: FLINK-5292 URL: https://issues.apache.org/jira/browse/FLINK-5292 Project: Flink Issue

[jira] [Created] (FLINK-5293) Make the Kafka consumer backwards compatible.

2016-12-08 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5293: - Summary: Make the Kafka consumer backwards compatible. Key: FLINK-5293 URL: https://issues.apache.org/jira/browse/FLINK-5293 Project: Flink Issue Type

[jira] [Created] (FLINK-5294) Make the WindowOperator backwards compatible.

2016-12-08 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5294: - Summary: Make the WindowOperator backwards compatible. Key: FLINK-5294 URL: https://issues.apache.org/jira/browse/FLINK-5294 Project: Flink Issue Type

[jira] [Created] (FLINK-5295) Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible.

2016-12-08 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5295: - Summary: Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible. Key: FLINK-5295 URL: https://issues.apache.org/jira/browse/FLINK-5295

[jira] [Created] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

2016-12-08 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5296: - Summary: Expose the old AlignedWindowOperators to the user through explicit commands. Key: FLINK-5296 URL: https://issues.apache.org/jira/browse/FLINK-5296 Project

[jira] [Created] (FLINK-5316) Make the GenericWriteAheadSink backwards compatible.

2016-12-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5316: - Summary: Make the GenericWriteAheadSink backwards compatible. Key: FLINK-5316 URL: https://issues.apache.org/jira/browse/FLINK-5316 Project: Flink Issue

[jira] [Created] (FLINK-5317) Make the continuous file processing code backwards compatible,

2016-12-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5317: - Summary: Make the continuous file processing code backwards compatible, Key: FLINK-5317 URL: https://issues.apache.org/jira/browse/FLINK-5317 Project: Flink

[jira] [Created] (FLINK-5318) Make the Rolling/Bucketing sink backwards compatible.

2016-12-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5318: - Summary: Make the Rolling/Bucketing sink backwards compatible. Key: FLINK-5318 URL: https://issues.apache.org/jira/browse/FLINK-5318 Project: Flink Issue

[jira] [Created] (FLINK-5420) Make the CEP library rescalable.

2017-01-06 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5420: - Summary: Make the CEP library rescalable. Key: FLINK-5420 URL: https://issues.apache.org/jira/browse/FLINK-5420 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5422) Check for name collisions in the Rolling/BucketingSink

2017-01-06 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5422: - Summary: Check for name collisions in the Rolling/BucketingSink Key: FLINK-5422 URL: https://issues.apache.org/jira/browse/FLINK-5422 Project: Flink Issue

[jira] [Created] (FLINK-5443) Create a path to migrate from the Rolling to the BucketingSink.

2017-01-11 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5443: - Summary: Create a path to migrate from the Rolling to the BucketingSink. Key: FLINK-5443 URL: https://issues.apache.org/jira/browse/FLINK-5443 Project: Flink

[jira] [Created] (FLINK-5502) Add documentation about migrating from 1.1 to 1.2

2017-01-16 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5502: - Summary: Add documentation about migrating from 1.1 to 1.2 Key: FLINK-5502 URL: https://issues.apache.org/jira/browse/FLINK-5502 Project: Flink Issue Type

[jira] [Created] (FLINK-5532) Make the marker windowassignes for the fast aligned windows non-extendable.

2017-01-17 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5532: - Summary: Make the marker windowassignes for the fast aligned windows non-extendable. Key: FLINK-5532 URL: https://issues.apache.org/jira/browse/FLINK-5532 Project

[jira] [Created] (FLINK-5762) Execute initializeState() and open() "atomically"

2017-02-09 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5762: - Summary: Execute initializeState() and open() "atomically" Key: FLINK-5762 URL: https://issues.apache.org/jira/browse/FLINK-5762 Project: Flink

[jira] [Created] (FLINK-5845) CEP: unify key and non-keyed operators

2017-02-20 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5845: - Summary: CEP: unify key and non-keyed operators Key: FLINK-5845 URL: https://issues.apache.org/jira/browse/FLINK-5845 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5846) CEP: make the operators backwards compatible.

2017-02-20 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5846: - Summary: CEP: make the operators backwards compatible. Key: FLINK-5846 URL: https://issues.apache.org/jira/browse/FLINK-5846 Project: Flink Issue Type

[jira] [Created] (FLINK-5864) CEP: fix duplicate output patterns problem.

2017-02-21 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5864: - Summary: CEP: fix duplicate output patterns problem. Key: FLINK-5864 URL: https://issues.apache.org/jira/browse/FLINK-5864 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5871) Enforce uniqueness of pattern names in CEP.

2017-02-21 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5871: - Summary: Enforce uniqueness of pattern names in CEP. Key: FLINK-5871 URL: https://issues.apache.org/jira/browse/FLINK-5871 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5932) Order of legacy vs new state initialization in the AbstractStreamOperator.

2017-02-28 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5932: - Summary: Order of legacy vs new state initialization in the AbstractStreamOperator. Key: FLINK-5932 URL: https://issues.apache.org/jira/browse/FLINK-5932 Project

[jira] [Created] (FLINK-5937) Add documentation about the task lifecycle.

2017-02-28 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5937: - Summary: Add documentation about the task lifecycle. Key: FLINK-5937 URL: https://issues.apache.org/jira/browse/FLINK-5937 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5951) Register legacy windowOp timers with timer service in the restoreState().

2017-03-02 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5951: - Summary: Register legacy windowOp timers with timer service in the restoreState(). Key: FLINK-5951 URL: https://issues.apache.org/jira/browse/FLINK-5951 Project

[jira] [Created] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService

2017-03-09 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6007: - Summary: ConcurrentModificationException in WatermarkCallbackService Key: FLINK-6007 URL: https://issues.apache.org/jira/browse/FLINK-6007 Project: Flink

[jira] [Created] (FLINK-6032) CEP-Clean up the operator state when not needed.

2017-03-13 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6032: - Summary: CEP-Clean up the operator state when not needed. Key: FLINK-6032 URL: https://issues.apache.org/jira/browse/FLINK-6032 Project: Flink Issue Type

[jira] [Created] (FLINK-6123) Add support for the NOT pattern.

2017-03-20 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6123: - Summary: Add support for the NOT pattern. Key: FLINK-6123 URL: https://issues.apache.org/jira/browse/FLINK-6123 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6197) Add support for iterative conditions.

2017-03-27 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6197: - Summary: Add support for iterative conditions. Key: FLINK-6197 URL: https://issues.apache.org/jira/browse/FLINK-6197 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6198) Update the documentation of the CEP library to include all the new features.

2017-03-27 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6198: - Summary: Update the documentation of the CEP library to include all the new features. Key: FLINK-6198 URL: https://issues.apache.org/jira/browse/FLINK-6198 Project

[jira] [Created] (FLINK-6205) Put late elements in side output.

2017-03-28 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6205: - Summary: Put late elements in side output. Key: FLINK-6205 URL: https://issues.apache.org/jira/browse/FLINK-6205 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6215) Make the StatefulSequenceSource scalable.

2017-03-29 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6215: - Summary: Make the StatefulSequenceSource scalable. Key: FLINK-6215 URL: https://issues.apache.org/jira/browse/FLINK-6215 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6245) Fix late side output documentation in Window documents.

2017-04-03 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6245: - Summary: Fix late side output documentation in Window documents. Key: FLINK-6245 URL: https://issues.apache.org/jira/browse/FLINK-6245 Project: Flink

[jira] [Created] (FLINK-6248) Make the optional() available to all offered patterns.

2017-04-03 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6248: - Summary: Make the optional() available to all offered patterns. Key: FLINK-6248 URL: https://issues.apache.org/jira/browse/FLINK-6248 Project: Flink Issue

[jira] [Created] (FLINK-6256) Fix documentation of ProcessFunction.

2017-04-03 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6256: - Summary: Fix documentation of ProcessFunction. Key: FLINK-6256 URL: https://issues.apache.org/jira/browse/FLINK-6256 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6265) Fix consecutive() for times() pattern.

2017-04-04 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6265: - Summary: Fix consecutive() for times() pattern. Key: FLINK-6265 URL: https://issues.apache.org/jira/browse/FLINK-6265 Project: Flink Issue Type: Bug

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

2020-09-24 Thread Kostas Kloudas (Jira)
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-19485) Consider runtime-mode when creating the StreamGraph

2020-10-01 Thread Kostas Kloudas (Jira)
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-19571) Port Transformation translation logic to StreamGraphTranslator framework

2020-10-12 Thread Kostas Kloudas (Jira)
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

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

2020-10-12 Thread Kostas Kloudas (Jira)
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-19573) Create the MultipleInputTransformation translator

2020-10-12 Thread Kostas Kloudas (Jira)
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

2020-10-12 Thread Kostas Kloudas (Jira)
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-19576) Create the SinkTransformation translator

2020-10-12 Thread Kostas Kloudas (Jira)
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

<    1   2   3   4   5   >