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

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-4960) Enable testing of different re-scaling scenarios in the AbstractStreamOperatorTestHarness to

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-4833) Unstable test OperatorStatsAccumulatorTest.testAccumulatorHeavyHitterCountMinSketch

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-4800) Refactor the ContinuousFileMonitoringFunction code and the related tests.

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-4700) Harden the TimeProvider test

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-4651) Re-register processing time timers at the WindowOperator upon recovery.

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-4496) Refactor the TimeServiceProvider to take a Trigerable instead of a Runnable.

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

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

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-4433) Refactor the StreamSource.

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-4407) Implement the trigger DSL

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-4397) Unstable test SlotCountExceedingParallelismTest.tearDown

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-4398) Unstable test KvStateServerHandlerTest.testSimpleQuery

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

[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

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

[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

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

[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

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

<    1   2   3