[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] [Closed] (FLINK-2801) Rework Storm Compatibility Tests

[ https://issues.apache.org/jira/browse/FLINK-2801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2801. -- Resolution: Duplicate > Rework Storm Compatibility Tests > > >

[jira] [Assigned] (FLINK-2831) Failing Test: WrapperSetupHelperTest

[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2831: -- Assignee: Matthias J. Sax > Failing Test: WrapperSetupHelperTest >

[jira] [Created] (FLINK-2825) FlinkClient.killTopology fails due to missing leader session ID

Matthias J. Sax created FLINK-2825: -- Summary: FlinkClient.killTopology fails due to missing leader session ID Key: FLINK-2825 URL: https://issues.apache.org/jira/browse/FLINK-2825 Project: Flink

[jira] [Closed] (FLINK-2825) FlinkClient.killTopology fails due to missing leader session ID

[ https://issues.apache.org/jira/browse/FLINK-2825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2825. -- Resolution: Fixed > FlinkClient.killTopology fails due to missing leader session ID >

[jira] [Commented] (FLINK-2825) FlinkClient.killTopology fails due to missing leader session ID

[ https://issues.apache.org/jira/browse/FLINK-2825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14945959#comment-14945959 ] Matthias J. Sax commented on FLINK-2825: Fixed via b489c367385453404671d0136ea59a9e63434ea7 >

[jira] [Closed] (FLINK-2566) FlinkTopologyContext not populated completely

[ https://issues.apache.org/jira/browse/FLINK-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2566. -- Resolution: Fixed > FlinkTopologyContext not populated completely >

[jira] [Commented] (FLINK-2566) FlinkTopologyContext not populated completely

[ https://issues.apache.org/jira/browse/FLINK-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944902#comment-14944902 ] Matthias J. Sax commented on FLINK-2566: Fixed via 7a67a60f934123863ca96a95e30471c99bb8088a >

[jira] [Commented] (FLINK-2718) LeaserChangeCleanupTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-2718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944995#comment-14944995 ] Matthias J. Sax commented on FLINK-2718: Happened again:

[jira] [Updated] (FLINK-2718) LeaserChangeCleanupTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-2718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2718: --- Priority: Critical (was: Major) > LeaserChangeCleanupTest sometimes fails >

[jira] [Commented] (FLINK-2801) Rework Storm Compatibility Tests

[ https://issues.apache.org/jira/browse/FLINK-2801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14940923#comment-14940923 ] Matthias J. Sax commented on FLINK-2801: We need the STOP signal (FLINK-2111) to make this work

[jira] [Commented] (FLINK-2525) Add configuration support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14940920#comment-14940920 ] Matthias J. Sax commented on FLINK-2525: Fixed via 9fe285a77de5cd1a35ceb58f9295751fd3dd9e15

[jira] [Closed] (FLINK-2525) Add configuration support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2525. -- Resolution: Fixed > Add configuration support in Storm-compatibility >

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

[ https://issues.apache.org/jira/browse/FLINK-2764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2764. -- Resolution: Fixed > WebClient cannot display multiple Jobs >

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

[ https://issues.apache.org/jira/browse/FLINK-2764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14936011#comment-14936011 ] Matthias J. Sax commented on FLINK-2764: fixed via 622c1be8c61c3a9a37c30454c717c99982edd236 >

[jira] [Created] (FLINK-2770) KafkaITCase.testConcurrentProducerConsumerTopology fails

Matthias J. Sax created FLINK-2770: -- Summary: KafkaITCase.testConcurrentProducerConsumerTopology fails Key: FLINK-2770 URL: https://issues.apache.org/jira/browse/FLINK-2770 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] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

[ https://issues.apache.org/jira/browse/FLINK-2616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14746964#comment-14746964 ] Matthias J. Sax commented on FLINK-2616: Unfortunately not. It just hit me twice:

[jira] [Commented] (FLINK-2670) Unstable CombineTaskTest

[ https://issues.apache.org/jira/browse/FLINK-2670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14790690#comment-14790690 ] Matthias J. Sax commented on FLINK-2670: It's up to you. If you think it was a one-time hick-up

[jira] [Updated] (FLINK-2566) FlinkTopologyContext not populated completely

[ https://issues.apache.org/jira/browse/FLINK-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2566: --- Summary: FlinkTopologyContext not populated completely (was: FlinkTopologyContext no

[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-2671) Instable Test StreamCheckpointNotifierITCase

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

[jira] [Closed] (FLINK-2658) fieldsGrouping for multiple output streams fails

[ https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2658. -- Resolution: Fixed > fieldsGrouping for multiple output streams fails >

[jira] [Commented] (FLINK-2658) fieldsGrouping for multiple output streams fails

[ https://issues.apache.org/jira/browse/FLINK-2658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743723#comment-14743723 ] Matthias J. Sax commented on FLINK-2658: Resolved via ce68cbd91621b1a58cb34b33ab27762c6525cfa0 >

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

[ https://issues.apache.org/jira/browse/FLINK-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14741223#comment-14741223 ] Matthias J. Sax commented on FLINK-2566: The PR for this feature is almost ready. It depend on

[jira] [Created] (FLINK-2658) fieldsGrouping for multiple output streams fails

Matthias J. Sax created FLINK-2658: -- Summary: fieldsGrouping for multiple output streams fails Key: FLINK-2658 URL: https://issues.apache.org/jira/browse/FLINK-2658 Project: Flink Issue

[jira] [Assigned] (FLINK-2632) Web Client does not respect the class loader of submitted jobs

[ https://issues.apache.org/jira/browse/FLINK-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2632: -- Assignee: Matthias J. Sax > Web Client does not respect the class loader of submitted

[jira] [Commented] (FLINK-2657) Fix WebClient and CLI interaction

[ https://issues.apache.org/jira/browse/FLINK-2657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14739118#comment-14739118 ] Matthias J. Sax commented on FLINK-2657: I think this should be merged with FLINK-2370 ? > Fix

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

[ https://issues.apache.org/jira/browse/FLINK-2606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14736550#comment-14736550 ] Matthias J. Sax commented on FLINK-2606: I like the idea! > Extend StormFileSpout to handle HDFS

[jira] [Commented] (FLINK-2586) Unstable Storm Compatibility Tests

[ https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14737168#comment-14737168 ] Matthias J. Sax commented on FLINK-2586: Thanks for reporting. Can be resolved after FLINK-2111 is

[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] [Commented] (FLINK-2606) Extend StormFileSpout to handle HDFS

[ https://issues.apache.org/jira/browse/FLINK-2606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728711#comment-14728711 ] Matthias J. Sax commented on FLINK-2606: It just came to my mind, that there exists a storm-hdfs

[jira] [Closed] (FLINK-2475) Rename Flink Client log file

[ https://issues.apache.org/jira/browse/FLINK-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2475. -- Resolution: Fixed fixed via 9f96b32bf8a0c77accdd91b7cfada2f6e751c167 > Rename Flink Client log

[jira] [Created] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest

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

[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] [Closed] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE

[ https://issues.apache.org/jira/browse/FLINK-2610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2610. -- Resolution: Duplicate Not all features are supported yet. See here for details

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

[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2392: --- Labels: test-stability (was: ) > Instable test in flink-yarn-tests >

[jira] [Updated] (FLINK-2348) Instable (failing) Test

[ https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2348: --- Priority: Critical (was: Major) > Instable (failing) Test > --- > >

[jira] [Updated] (FLINK-2348) Instable (failing) Test

[ https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2348: --- Labels: test-stability (was: ) > Instable (failing) Test > --- > >

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

[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2392: --- Priority: Critical (was: Minor) > Instable test in flink-yarn-tests >

[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] [Commented] (FLINK-2596) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14720999#comment-14720999 ] Matthias J. Sax commented on FLINK-2596: Of course I did rebase. Furthermore in

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

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14720999#comment-14720999 ] Matthias J. Sax edited comment on FLINK-2596 at 8/29/15 7:16 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14720999#comment-14720999 ] Matthias J. Sax edited comment on FLINK-2596 at 8/29/15 7:18 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14720999#comment-14720999 ] Matthias J. Sax edited comment on FLINK-2596 at 8/29/15 7:19 AM:

[jira] [Updated] (FLINK-2475) Rename Flink Client log file

[ https://issues.apache.org/jira/browse/FLINK-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2475: --- Component/s: Start-Stop Scripts Rename Flink Client log file

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

[ https://issues.apache.org/jira/browse/FLINK-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2475: --- Description: Currently, JoManager and TaskManager log/out files are names as follows: -

[jira] [Assigned] (FLINK-2475) Rename Flink Client log file

[ https://issues.apache.org/jira/browse/FLINK-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2475: -- Assignee: Matthias J. Sax Rename Flink Client log file

[jira] [Updated] (FLINK-2475) Rename Flink Client log file

[ https://issues.apache.org/jira/browse/FLINK-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2475: --- Summary: Rename Flink Client log file (was: Rename Flink Client log and out file) Rename

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

[ https://issues.apache.org/jira/browse/FLINK-2564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2564. -- Failing Test: RandomSamplerTest --- Key: FLINK-2564

[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] [Updated] (FLINK-2596) Failing Test: RandomSamplerTest

[ https://issues.apache.org/jira/browse/FLINK-2596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2596: --- Component/s: Tests Failing Test: RandomSamplerTest ---

[jira] [Commented] (FLINK-2586) Unstable Storm Compatibility Tests

[ https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717104#comment-14717104 ] Matthias J. Sax commented on FLINK-2586: This is a know problem. The reasons why

[jira] [Updated] (FLINK-2571) Add task hooks support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2571: --- Component/s: (was: flink-contrib) Storm Compatibility Add task hooks

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

[ https://issues.apache.org/jira/browse/FLINK-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2566: --- Component/s: (was: flink-contrib) Storm Compatibility

[jira] [Commented] (FLINK-2586) Unstable Storm Compatibility Tests

[ https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717198#comment-14717198 ] Matthias J. Sax commented on FLINK-2586: You are right. It's not the kill thing.

[jira] [Updated] (FLINK-2338) Shut down Storm Topologies cleanly

[ https://issues.apache.org/jira/browse/FLINK-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2338: --- Component/s: (was: flink-contrib) Storm Compatibility Shut down Storm

[jira] [Updated] (FLINK-2525) Add configuration support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2525: --- Component/s: (was: flink-contrib) Storm Compatibility Add configuration

[jira] [Assigned] (FLINK-2586) Unstable Storm Compatibility Tests

[ https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2586: -- Assignee: Matthias J. Sax Unstable Storm Compatibility Tests

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

[ https://issues.apache.org/jira/browse/FLINK-2588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2588: --- Description: In Storm, topologies run forever and need to be terminate via

[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-2578) Failing-Test: TaskAsyncCallTest

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

[jira] [Updated] (FLINK-1540) JobManagerFailsITCase Startup timed out on travis

[ https://issues.apache.org/jira/browse/FLINK-1540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-1540: --- Priority: Critical (was: Major) JobManagerFailsITCase Startup timed out on travis

[jira] [Updated] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase

[ https://issues.apache.org/jira/browse/FLINK-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2474: --- Priority: Critical (was: Major) Occasional failures in PartitionedStateCheckpointingITCase

[jira] [Updated] (FLINK-2276) Travis build error

[ https://issues.apache.org/jira/browse/FLINK-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2276: --- Priority: Critical (was: Major) Travis build error --

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

[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2392: --- Description: The test YARNSessionFIFOITCase fails from time to time on an irregular basis.

[jira] [Updated] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously

[ https://issues.apache.org/jira/browse/FLINK-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2504: --- Priority: Critical (was: Major)

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

[ https://issues.apache.org/jira/browse/FLINK-2564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2564: --- Priority: Critical (was: Major) Failing Test: RandomSamplerTest

[jira] [Updated] (FLINK-2578) Failing-Test: TaskAsyncCallTest

[ https://issues.apache.org/jira/browse/FLINK-2578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2578: --- Labels: test-stability (was: ) Failing-Test: TaskAsyncCallTest

[jira] [Updated] (FLINK-2571) Add task hooks support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2571: --- Priority: Minor (was: Major) Add task hooks support in Storm-compatibility

[jira] [Updated] (FLINK-2571) Add task hooks support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2571: --- Affects Version/s: (was: 0.8.1) Add task hooks support in Storm-compatibility

[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] [Updated] (FLINK-2557) Manual type information via returns fails in DataSet API

[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2557: --- Summary: Manual type information via returns fails in DataSet API (was: Manal 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] [Updated] (FLINK-2557) Manual type information via returns fails in DataSet API

[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2557: --- Description: I changed the WordCount example as below and get an exception: Tokenizer is

[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] [Updated] (FLINK-2560) Flink-Avro Plugin cannot be handled by Eclipse

[ https://issues.apache.org/jira/browse/FLINK-2560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2560: --- Issue Type: Improvement (was: Bug) Flink-Avro Plugin cannot be handled by Eclipse

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

[ https://issues.apache.org/jira/browse/FLINK-2553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704937#comment-14704937 ] Matthias J. Sax commented on FLINK-2553: Yes. The problem is, that this example

[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] [Updated] (FLINK-2525) Add configuration support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2525: --- Affects Version/s: (was: 0.8.1) Add configuration support in Storm-compatibility

[jira] [Updated] (FLINK-2525) Add configuration support in Storm-compatibility

[ https://issues.apache.org/jira/browse/FLINK-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2525: --- Description: Spouts and Bolt are initialized by a call to `Spout.open(...)` and

[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] [Updated] (FLINK-2502) FiniteStormSpout documenation does not render correclty

[ https://issues.apache.org/jira/browse/FLINK-2502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2502: --- Description: The code examples do not render correctly, due to missing empty lines.

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

[ https://issues.apache.org/jira/browse/FLINK-2502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2502: --- Description: The code examples do not render correctly, due to missing empty lines.

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

[ https://issues.apache.org/jira/browse/FLINK-2502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2502: --- Attachment: screenshot.png FiniteStormSpout documenation does not render correclty

[jira] [Updated] (FLINK-2457) Integrate Tuple0

[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2457: --- Description: Tuple0 is not cleanly integrated: - missing serialization/deserialization

[jira] [Updated] (FLINK-2457) Integrate Tuple0

[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2457: --- Summary: Integrate Tuple0 (was: Tuple.getTupleClass cannot generate Tuple0) Integrate

[jira] [Updated] (FLINK-2457) Integrate Tuple0

[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2457: --- Description: Tuple.getTupleClass cannot generate Integrate Tuple0

[jira] [Updated] (FLINK-2457) Integrate Tuple0

[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2457: --- Environment: (was: Tuple.getTupleClass(int arity) cannot handle arity zero, ie, cannot

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

[ https://issues.apache.org/jira/browse/FLINK-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2475: --- Description: Currently, JoManager and TaskManager log/out files are names as follows: -

[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] [Updated] (FLINK-2467) Example WordCountStorm.jar is not packaged correctly

[ https://issues.apache.org/jira/browse/FLINK-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2467: --- Summary: Example WordCountStorm.jar is not packaged correctly (was: Example

[jira] [Updated] (FLINK-2467) Example WordCountStorm.jar is not packaged correctly

[ https://issues.apache.org/jira/browse/FLINK-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2467: --- Description: After moving storm compatibility to flink-contrib, WordCountStorm example is not

[jira] [Closed] (FLINK-2173) Python uses different tmp file than Flink

[ https://issues.apache.org/jira/browse/FLINK-2173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2173. -- Python uses different tmp file than Flink -

[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] [Assigned] (FLINK-2095) Screenshots missing in webcient documentation

[ https://issues.apache.org/jira/browse/FLINK-2095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2095: -- Assignee: Matthias J. Sax Screenshots missing in webcient documentation

[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] [Closed] (FLINK-2371) AccumulatorLiveITCase fails

[ https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2371. -- Fixed test passed 10 Travis runs for me without failing. Seems to be stable now.

[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

<    1   2   3   >