[jira] [Created] (FLINK-3406) Extend RabbitMQ source with interface StoppableFunction

Matthias J. Sax created FLINK-3406: -- Summary: Extend RabbitMQ source with interface StoppableFunction Key: FLINK-3406 URL: https://issues.apache.org/jira/browse/FLINK-3406 Project: Flink

[jira] [Created] (FLINK-3356) JobClientActorRecoveryITCase.testJobClientRecovery

Matthias J. Sax created FLINK-3356: -- Summary: JobClientActorRecoveryITCase.testJobClientRecovery Key: FLINK-3356 URL: https://issues.apache.org/jira/browse/FLINK-3356 Project: Flink Issue

[jira] [Created] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow

Matthias J. Sax created FLINK-3344: -- Summary: EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow Key: FLINK-3344 URL: https://issues.apache.org/jira/browse/FLINK-3344 Project:

[jira] [Created] (FLINK-3323) Nifi connector not documented

Matthias J. Sax created FLINK-3323: -- Summary: Nifi connector not documented Key: FLINK-3323 URL: https://issues.apache.org/jira/browse/FLINK-3323 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3238) EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow()

Matthias J. Sax created FLINK-3238: -- Summary: EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow() Key: FLINK-3238 URL: https://issues.apache.org/jira/browse/FLINK-3238 Project: Flink

[jira] [Created] (FLINK-3214) WindowCheckpointingITCase

Matthias J. Sax created FLINK-3214: -- Summary: WindowCheckpointingITCase Key: FLINK-3214 URL: https://issues.apache.org/jira/browse/FLINK-3214 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3212) JobManagerCheckpointRecoveryITCase

Matthias J. Sax created FLINK-3212: -- Summary: JobManagerCheckpointRecoveryITCase Key: FLINK-3212 URL: https://issues.apache.org/jira/browse/FLINK-3212 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3199) KafkaITCase.testOneToOneSources

Matthias J. Sax created FLINK-3199: -- Summary: KafkaITCase.testOneToOneSources Key: FLINK-3199 URL: https://issues.apache.org/jira/browse/FLINK-3199 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3142) CheckpointCoordinatorTest fails

Matthias J. Sax created FLINK-3142: -- Summary: CheckpointCoordinatorTest fails Key: FLINK-3142 URL: https://issues.apache.org/jira/browse/FLINK-3142 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3048) DataSinkTaskTest.testCancelDataSinkTask

Matthias J. Sax created FLINK-3048: -- Summary: DataSinkTaskTest.testCancelDataSinkTask Key: FLINK-3048 URL: https://issues.apache.org/jira/browse/FLINK-3048 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3034) Redis SInk Connector

Matthias J. Sax created FLINK-3034: -- Summary: Redis SInk Connector Key: FLINK-3034 URL: https://issues.apache.org/jira/browse/FLINK-3034 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-3031) Consistent Shutdown of Streaming Jobs

Matthias J. Sax created FLINK-3031: -- Summary: Consistent Shutdown of Streaming Jobs Key: FLINK-3031 URL: https://issues.apache.org/jira/browse/FLINK-3031 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3033) Redis Source Connector

Matthias J. Sax created FLINK-3033: -- Summary: Redis Source Connector Key: FLINK-3033 URL: https://issues.apache.org/jira/browse/FLINK-3033 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-3035) Redis as State Backend

Matthias J. Sax created FLINK-3035: -- Summary: Redis as State Backend Key: FLINK-3035 URL: https://issues.apache.org/jira/browse/FLINK-3035 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase

Matthias J. Sax created FLINK-2915: -- Summary: JobManagerProcessFailureBatchRecoveryITCase Key: FLINK-2915 URL: https://issues.apache.org/jira/browse/FLINK-2915 Project: Flink Issue Type:

[jira] [Created] (FLINK-2911) AccumulatingAlignedProcessingTimeWindowOperatorTest.checkpointRestoreWithPendingWindowTumbling

Matthias J. Sax created FLINK-2911: -- Summary: AccumulatingAlignedProcessingTimeWindowOperatorTest.checkpointRestoreWithPendingWindowTumbling Key: FLINK-2911 URL: https://issues.apache.org/jira/browse/FLINK-2911

[jira] [Created] (FLINK-2845) TimestampITCase.testWatermarkPropagation

Matthias J. Sax created FLINK-2845: -- Summary: TimestampITCase.testWatermarkPropagation Key: FLINK-2845 URL: https://issues.apache.org/jira/browse/FLINK-2845 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2835) Update Documenation for new Streaming API

Matthias J. Sax created FLINK-2835: -- Summary: Update Documenation for new Streaming API Key: FLINK-2835 URL: https://issues.apache.org/jira/browse/FLINK-2835 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-2836) Cyclic Topologies not supported

Matthias J. Sax created FLINK-2836: -- Summary: Cyclic Topologies not supported Key: FLINK-2836 URL: https://issues.apache.org/jira/browse/FLINK-2836 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2837) FlinkTopologyBuilder cannot handle multiple input streams

Matthias J. Sax created FLINK-2837: -- Summary: FlinkTopologyBuilder cannot handle multiple input streams Key: FLINK-2837 URL: https://issues.apache.org/jira/browse/FLINK-2837 Project: Flink

[jira] [Created] (FLINK-2764) WebClient cannot display multiple Jobs

Matthias J. Sax created FLINK-2764: -- Summary: WebClient cannot display multiple Jobs Key: FLINK-2764 URL: https://issues.apache.org/jira/browse/FLINK-2764 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2721) Add Tuple meta information

Matthias J. Sax created FLINK-2721: -- Summary: Add Tuple meta information Key: FLINK-2721 URL: https://issues.apache.org/jira/browse/FLINK-2721 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-2670) Instable Test S3FileSystemTest

Matthias J. Sax created FLINK-2670: -- Summary: Instable Test S3FileSystemTest Key: FLINK-2670 URL: https://issues.apache.org/jira/browse/FLINK-2670 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2620) StreamPartitioner is not properly initialized for shuffle and rebalance

Matthias J. Sax created FLINK-2620: -- Summary: StreamPartitioner is not properly initialized for shuffle and rebalance Key: FLINK-2620 URL: https://issues.apache.org/jira/browse/FLINK-2620 Project:

[jira] [Created] (FLINK-2606) Extend StormFileSpout to handle HDFS

Matthias J. Sax created FLINK-2606: -- Summary: Extend StormFileSpout to handle HDFS Key: FLINK-2606 URL: https://issues.apache.org/jira/browse/FLINK-2606 Project: Flink Issue Type: New

[jira] [Created] (FLINK-2599) Failing Test: SlotCountExceedingParallelismTest

Matthias J. Sax created FLINK-2599: -- Summary: Failing Test: SlotCountExceedingParallelismTest Key: FLINK-2599 URL: https://issues.apache.org/jira/browse/FLINK-2599 Project: Flink Issue

[jira] [Created] (FLINK-2596) Failing Test: RandomSamplerTest

Matthias J. Sax created FLINK-2596: -- Summary: Failing Test: RandomSamplerTest Key: FLINK-2596 URL: https://issues.apache.org/jira/browse/FLINK-2596 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2588) Implement KillOptions

Matthias J. Sax created FLINK-2588: -- Summary: Implement KillOptions Key: FLINK-2588 URL: https://issues.apache.org/jira/browse/FLINK-2588 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2564) Failing Test: RandomSamplerTest

Matthias J. Sax created FLINK-2564: -- Summary: Failing Test: RandomSamplerTest Key: FLINK-2564 URL: https://issues.apache.org/jira/browse/FLINK-2564 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2566) FlinkTopologyContext no populated completely

Matthias J. Sax created FLINK-2566: -- Summary: FlinkTopologyContext no populated completely Key: FLINK-2566 URL: https://issues.apache.org/jira/browse/FLINK-2566 Project: Flink Issue Type:

[jira] [Created] (FLINK-2557) Manal type information via returns fails in DataSet API

Matthias J. Sax created FLINK-2557: -- Summary: Manal type information via returns fails in DataSet API Key: FLINK-2557 URL: https://issues.apache.org/jira/browse/FLINK-2557 Project: Flink

[jira] [Created] (FLINK-2560) Flink-Avro Plugin cannot be handled by Eclipse

Matthias J. Sax created FLINK-2560: -- Summary: Flink-Avro Plugin cannot be handled by Eclipse Key: FLINK-2560 URL: https://issues.apache.org/jira/browse/FLINK-2560 Project: Flink Issue Type:

[jira] [Created] (FLINK-2553) Example Jars not build correctly

Matthias J. Sax created FLINK-2553: -- Summary: Example Jars not build correctly Key: FLINK-2553 URL: https://issues.apache.org/jira/browse/FLINK-2553 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2502) FiniteStormSpout documenation does not render correclty

Matthias J. Sax created FLINK-2502: -- Summary: FiniteStormSpout documenation does not render correclty Key: FLINK-2502 URL: https://issues.apache.org/jira/browse/FLINK-2502 Project: Flink

[jira] [Created] (FLINK-2475) Rename Flink Client log and out file

Matthias J. Sax created FLINK-2475: -- Summary: Rename Flink Client log and out file Key: FLINK-2475 URL: https://issues.apache.org/jira/browse/FLINK-2475 Project: Flink Issue Type:

[jira] [Created] (FLINK-2467) Example WordCountStorm.jar in not packaged correclty

Matthias J. Sax created FLINK-2467: -- Summary: Example WordCountStorm.jar in not packaged correclty Key: FLINK-2467 URL: https://issues.apache.org/jira/browse/FLINK-2467 Project: Flink Issue

[jira] [Created] (FLINK-2469) JobManager crashes on Cancel

Matthias J. Sax created FLINK-2469: -- Summary: JobManager crashes on Cancel Key: FLINK-2469 URL: https://issues.apache.org/jira/browse/FLINK-2469 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2457) Tuple.getTupleClass cannot generate Tuple0

Matthias J. Sax created FLINK-2457: -- Summary: Tuple.getTupleClass cannot generate Tuple0 Key: FLINK-2457 URL: https://issues.apache.org/jira/browse/FLINK-2457 Project: Flink Issue Type:

[jira] [Created] (FLINK-2392) Instable test in flink-yarn-tests

Matthias J. Sax created FLINK-2392: -- Summary: Instable test in flink-yarn-tests Key: FLINK-2392 URL: https://issues.apache.org/jira/browse/FLINK-2392 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2371) AccumulatorLiveITCase fails

Matthias J. Sax created FLINK-2371: -- Summary: AccumulatorLiveITCase fails Key: FLINK-2371 URL: https://issues.apache.org/jira/browse/FLINK-2371 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2370) Unify Client Code

Matthias J. Sax created FLINK-2370: -- Summary: Unify Client Code Key: FLINK-2370 URL: https://issues.apache.org/jira/browse/FLINK-2370 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2349) Instable (failing) Test

Matthias J. Sax created FLINK-2349: -- Summary: Instable (failing) Test Key: FLINK-2349 URL: https://issues.apache.org/jira/browse/FLINK-2349 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2304) Add named attribute access to Storm compatibility layer

Matthias J. Sax created FLINK-2304: -- Summary: Add named attribute access to Storm compatibility layer Key: FLINK-2304 URL: https://issues.apache.org/jira/browse/FLINK-2304 Project: Flink

[jira] [Created] (FLINK-2306) Add support for named streams in Storm compatibility layer

Matthias J. Sax created FLINK-2306: -- Summary: Add support for named streams in Storm compatibility layer Key: FLINK-2306 URL: https://issues.apache.org/jira/browse/FLINK-2306 Project: Flink

[jira] [Created] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators'

Matthias J. Sax created FLINK-2275: -- Summary: Migrate test from package 'org.apache.flink.test.javaApiOperators' Key: FLINK-2275 URL: https://issues.apache.org/jira/browse/FLINK-2275 Project: Flink

[jira] [Created] (FLINK-2175) Allow multiple jobs in single jar file

Matthias J. Sax created FLINK-2175: -- Summary: Allow multiple jobs in single jar file Key: FLINK-2175 URL: https://issues.apache.org/jira/browse/FLINK-2175 Project: Flink Issue Type:

[jira] [Created] (FLINK-2176) Add support for ProgramDesctiption interface in clients

Matthias J. Sax created FLINK-2176: -- Summary: Add support for ProgramDesctiption interface in clients Key: FLINK-2176 URL: https://issues.apache.org/jira/browse/FLINK-2176 Project: Flink

[jira] [Created] (FLINK-2173) Python used diffente tmp file than Flink

Matthias J. Sax created FLINK-2173: -- Summary: Python used diffente tmp file than Flink Key: FLINK-2173 URL: https://issues.apache.org/jira/browse/FLINK-2173 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2174) Allow comments in 'slaves' file

Matthias J. Sax created FLINK-2174: -- Summary: Allow comments in 'slaves' file Key: FLINK-2174 URL: https://issues.apache.org/jira/browse/FLINK-2174 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2111) Add terminate signal to cleanly stop streaming jobs

Matthias J. Sax created FLINK-2111: -- Summary: Add terminate signal to cleanly stop streaming jobs Key: FLINK-2111 URL: https://issues.apache.org/jira/browse/FLINK-2111 Project: Flink Issue

[jira] [Created] (FLINK-2112) Wrong package statement in KafkaITCase and KafkaLocalSystemTime

Matthias J. Sax created FLINK-2112: -- Summary: Wrong package statement in KafkaITCase and KafkaLocalSystemTime Key: FLINK-2112 URL: https://issues.apache.org/jira/browse/FLINK-2112 Project: Flink

[jira] [Created] (FLINK-2068) WebUI support multiple jobs per jar file

Matthias J. Sax created FLINK-2068: -- Summary: WebUI support multiple jobs per jar file Key: FLINK-2068 URL: https://issues.apache.org/jira/browse/FLINK-2068 Project: Flink Issue Type: