[jira] [Issue Comment Deleted] (FLINK-3955) Change Table.toSink() to Table.writeToSink()

2016-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-3955: --- Comment: was deleted (was: I am not sure if this name solve the issue. What about

[jira] [Commented] (FLINK-3955) Change Table.toSink() to Table.writeToSink()

2016-05-23 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15296356#comment-15296356 ] Matthias J. Sax commented on FLINK-3955: I am not sure if this name solve the issue. What about

[jira] [Commented] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction

2016-04-29 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15264146#comment-15264146 ] Matthias J. Sax commented on FLINK-3404: I think so. [~rmetzger] can you comment on this, as you

[jira] [Commented] (FLINK-3601) JobManagerTest times out on StopSignal test

2016-04-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15260002#comment-15260002 ] Matthias J. Sax commented on FLINK-3601: [~mxm] Are you working on this? If not, I could fix this.

[jira] [Commented] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase

2016-04-27 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1526#comment-1526 ] Matthias J. Sax commented on FLINK-3380: [~uce] Can this be closed? PR1611 was merged long ago. >

[jira] [Commented] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15228381#comment-15228381 ] Matthias J. Sax commented on FLINK-3523: fixed via 02ef68fb4adbd413fa159c35980412f280179cbf >

[jira] [Resolved] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-04-06 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved FLINK-3523. Resolution: Fixed > Storm SpoutSplitExample fails with a ClassCastException >

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

2016-04-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15221460#comment-15221460 ] Matthias J. Sax commented on FLINK-2392: Yes. See post above from03/Dec/15 > Instable test in

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

2016-04-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15221299#comment-15221299 ] Matthias J. Sax commented on FLINK-2392:

[jira] [Assigned] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException

2016-03-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-3523: -- Assignee: Matthias J. Sax > Storm SpoutSplitExample fails with a ClassCastException >

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

2016-03-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2338. -- Resolution: Fixed > Shut down "Storm Topologies" cleanly >

[jira] [Closed] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs

2016-03-31 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2111. -- > Add "stop" signal to cleanly shutdown streaming jobs >

[jira] [Created] (FLINK-3409) Integrate STOP with Savepoints

2016-02-15 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3409: -- Summary: Integrate STOP with Savepoints Key: FLINK-3409 URL: https://issues.apache.org/jira/browse/FLINK-3409 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3408) Make STOP signal reliable

2016-02-15 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3408: -- Summary: Make STOP signal reliable Key: FLINK-3408 URL: https://issues.apache.org/jira/browse/FLINK-3408 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3407) Extend TwitterSource with interface StoppableFunction

2016-02-15 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3407: -- Summary: Extend TwitterSource with interface StoppableFunction Key: FLINK-3407 URL: https://issues.apache.org/jira/browse/FLINK-3407 Project: Flink

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

2016-02-15 Thread Matthias J. Sax (JIRA)
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-3405) Extend NiFiSource with interface StoppableFunction

2016-02-15 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3405: -- Summary: Extend NiFiSource with interface StoppableFunction Key: FLINK-3405 URL: https://issues.apache.org/jira/browse/FLINK-3405 Project: Flink Issue

[jira] [Created] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction

2016-02-15 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3404: -- Summary: Extend Kafka consumers with interface StoppableFunction Key: FLINK-3404 URL: https://issues.apache.org/jira/browse/FLINK-3404 Project: Flink

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

2016-02-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15140840#comment-15140840 ] Matthias J. Sax commented on FLINK-3356: https://travis-ci.org/mjsax/flink/jobs/108263582 >

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

2016-02-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15140844#comment-15140844 ] Matthias J. Sax commented on FLINK-2915: https://travis-ci.org/apache/flink/jobs/108263590 >

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

2016-02-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136904#comment-15136904 ] Matthias J. Sax edited comment on FLINK-3035 at 2/8/16 12:52 PM: - The

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

2016-02-08 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136904#comment-15136904 ] Matthias J. Sax commented on FLINK-3035: The embedded-redis project seems not to be something

[jira] [Closed] (FLINK-1870) Reintroduce Indexed reader functionality to streaming

2016-02-07 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-1870. -- Resolution: Not A Problem > Reintroduce Indexed reader functionality to streaming >

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

2016-02-07 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136372#comment-15136372 ] Matthias J. Sax commented on FLINK-2504: Again: https://travis-ci.org/mjsax/flink/jobs/107597700

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

2016-02-07 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136374#comment-15136374 ] Matthias J. Sax commented on FLINK-2915: One more:

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

2016-02-07 Thread Matthias J. Sax (JIRA)
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] [Closed] (FLINK-2721) Add Tuple meta information

2016-02-07 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2721. -- Resolution: Fixed > Add Tuple meta information > -- > >

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

2016-02-05 Thread Matthias J. Sax (JIRA)
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-3324) Flume connector not documented

2016-02-03 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3324: -- Summary: Flume connector not documented Key: FLINK-3324 URL: https://issues.apache.org/jira/browse/FLINK-3324 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-3324) Flume connector not documented

2016-02-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-3324: --- Description: Add Flume-connector documentation to the "Data Stream / Connectors" web page

[jira] [Updated] (FLINK-3324) Flume connector not documented

2016-02-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-3324: --- Component/s: Streaming Connectors > Flume connector not documented >

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

2016-02-03 Thread Matthias J. Sax (JIRA)
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] [Updated] (FLINK-3323) Nifi connector not documented

2016-02-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-3323: --- Description: Add Nifi-connector documentation to the "Data Stream / Connectors" web page

[jira] [Updated] (FLINK-3324) Flume connector not documented

2016-02-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-3324: --- Description: Add Flume-connector documentation to the "Data Stream / Connectors" web page

[jira] [Updated] (FLINK-3324) Flume connector not documented

2016-02-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-3324: --- Component/s: (was: Streaming Connectors) > Flume connector not documented >

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

2016-02-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128045#comment-15128045 ] Matthias J. Sax commented on FLINK-3034: [~sbcd90], if the PR gets opened, please help to review.

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

2016-02-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128050#comment-15128050 ] Matthias J. Sax commented on FLINK-3035: [~sbcd90], maybe you are interested in this ticket ;) >

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

2016-02-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128048#comment-15128048 ] Matthias J. Sax commented on FLINK-3033: [~sbcd90], if the PR gets opened, please help to review.

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

2016-02-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15125950#comment-15125950 ] Matthias J. Sax commented on FLINK-3033: [~neo20iitkgp] please assign the JIRA to yourself and

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

2016-02-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15125952#comment-15125952 ] Matthias J. Sax commented on FLINK-3034: @ [~neo20iitkgp] please assign the JIRA to yourself and

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

2016-01-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105812#comment-15105812 ] Matthias J. Sax commented on FLINK-3238: Also happend for

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

2016-01-15 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15101497#comment-15101497 ] Matthias J. Sax commented on FLINK-2586: Fixed via d1c93d286b95f069f6ba0a4e60e3a34655a395e3 >

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

2016-01-15 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved FLINK-2586. Resolution: Fixed > Unstable Storm Compatibility Tests > --

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

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

[jira] [Closed] (FLINK-2847) Fix flaky test in StormTestBase.testJob

2016-01-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2847. -- Resolution: Duplicate StormTestBase was deleted by commit

[jira] [Commented] (FLINK-3175) KafkaITCase.testOffsetAutocommitTest

2016-01-12 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15094306#comment-15094306 ] Matthias J. Sax commented on FLINK-3175: Happened again:

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

2016-01-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15091516#comment-15091516 ] Matthias J. Sax commented on FLINK-3212: Again: this time, test hung for 300 seconds and build got

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

2016-01-10 Thread Matthias J. Sax (JIRA)
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

2016-01-10 Thread Matthias J. Sax (JIRA)
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

2016-01-04 Thread Matthias J. Sax (JIRA)
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] [Commented] (FLINK-3189) Error while parsing job arguments passed by CLI

2016-01-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15076284#comment-15076284 ] Matthias J. Sax commented on FLINK-3189: The JIRA text was not correct. I juts updated it. The

[jira] [Updated] (FLINK-3189) Error while parsing job arguments passed by CLI

2016-01-01 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-3189: --- Description: Flink CLI treats job arguments provided in format "-" as its own parameters,

[jira] [Commented] (FLINK-3072) DbStateBackendTest

2015-12-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15072624#comment-15072624 ] Matthias J. Sax commented on FLINK-3072: Again:

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

2015-12-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15072651#comment-15072651 ] Matthias J. Sax commented on FLINK-2837: Sorry. :( I thought a PR is only required for committers

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

2015-12-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15072627#comment-15072627 ] Matthias J. Sax commented on FLINK-2837: Fixed via f7b113d965fd30db993cac99b63194dcd7869ad4 >

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

2015-12-28 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2837. -- Resolution: Fixed > FlinkTopologyBuilder cannot handle multiple input streams >

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

2015-12-26 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2837: -- Assignee: Matthias J. Sax (was: Maximilian Michels) > FlinkTopologyBuilder cannot

[jira] [Created] (FLINK-3175) KafkaITCase.testOffsetAutocommitTest

2015-12-15 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3175: -- Summary: KafkaITCase.testOffsetAutocommitTest Key: FLINK-3175 URL: https://issues.apache.org/jira/browse/FLINK-3175 Project: Flink Issue Type: Bug

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

2015-12-07 Thread Matthias J. Sax (JIRA)
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] [Commented] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints

2015-12-07 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15046511#comment-15046511 ] Matthias J. Sax commented on FLINK-3096: https://travis-ci.org/mjsax/flink/jobs/95439204 >

[jira] [Commented] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints

2015-12-04 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15041549#comment-15041549 ] Matthias J. Sax commented on FLINK-3096: Happend again:

[jira] [Reopened] (FLINK-3072) DbStateBackendTest

2015-12-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened FLINK-3072: > DbStateBackendTest > -- > > Key: FLINK-3072 >

[jira] [Commented] (FLINK-3072) DbStateBackendTest

2015-12-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15036835#comment-15036835 ] Matthias J. Sax commented on FLINK-3072: Happened again. Yes, I did rebase to current master ;)

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

2015-12-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15036840#comment-15036840 ] Matthias J. Sax commented on FLINK-2392: One more:

[jira] [Created] (FLINK-3072) DbStateBackendTest

2015-11-24 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3072: -- Summary: DbStateBackendTest Key: FLINK-3072 URL: https://issues.apache.org/jira/browse/FLINK-3072 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-3072) DbStateBackendTest

2015-11-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15024633#comment-15024633 ] Matthias J. Sax commented on FLINK-3072: Similar here:

[jira] [Commented] (FLINK-2861) Fields grouping on split streams fails

2015-11-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15024419#comment-15024419 ] Matthias J. Sax commented on FLINK-2861: Fixed via 4c46b2feee2c1ecda21e5ba62d02dfd7df73e256 >

[jira] [Resolved] (FLINK-2861) Fields grouping on split streams fails

2015-11-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved FLINK-2861. Resolution: Fixed > Fields grouping on split streams fails >

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

2015-11-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15021102#comment-15021102 ] Matthias J. Sax commented on FLINK-2837: No. Go ahead with your PR. > FlinkTopologyBuilder cannot

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

2015-11-22 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2837: --- Assignee: Maximilian Michels (was: Matthias J. Sax) > FlinkTopologyBuilder cannot handle

[jira] [Created] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

2015-11-20 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3053: -- Summary: SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure Key: FLINK-3053 URL: https://issues.apache.org/jira/browse/FLINK-3053 Project:

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

2015-11-19 Thread Matthias J. Sax (JIRA)
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] [Assigned] (FLINK-2861) Fields grouping on split streams fails

2015-11-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2861: -- Assignee: Matthias J. Sax > Fields grouping on split streams fails >

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

2015-11-17 Thread Matthias J. Sax (JIRA)
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-3034) Redis SInk Connector

2015-11-17 Thread Matthias J. Sax (JIRA)
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] [Updated] (FLINK-3033) Redis Source Connector

2015-11-17 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-3033: --- Description: Flink does not provide a source connector for Redis. See FLINK-3034

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

2015-11-17 Thread Matthias J. Sax (JIRA)
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

2015-11-17 Thread Matthias J. Sax (JIRA)
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] [Commented] (FLINK-3017) Broken 'Slots' link on Streaming Programming Guide

2015-11-16 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006563#comment-15006563 ] Matthias J. Sax commented on FLINK-3017: Fixed via feb6994ffca04e4b7ad6174ca08048ea452e19f6

[jira] [Closed] (FLINK-3017) Broken 'Slots' link on Streaming Programming Guide

2015-11-16 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-3017. -- > Broken 'Slots' link on Streaming Programming Guide >

[jira] [Commented] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase

2015-11-11 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15000435#comment-15000435 ] Matthias J. Sax commented on FLINK-2671: Occurred again:

[jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-11-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14996328#comment-14996328 ] Matthias J. Sax commented on FLINK-2752: Some improvements via

[jira] [Updated] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-11-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2752: --- Assignee: (was: Matthias J. Sax) > Documentation is not easily differentiable from the

[jira] [Assigned] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage

2015-11-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2752: -- Assignee: Matthias J. Sax > Documentation is not easily differentiable from the Flink

[jira] [Commented] (FLINK-2735) KafkaProducerITCase.testCustomPartitioning sporadically fails

2015-11-03 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14987339#comment-14987339 ] Matthias J. Sax commented on FLINK-2735: https://travis-ci.org/mjsax/flink/jobs/88997932 >

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

2015-10-30 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14982244#comment-14982244 ] Matthias J. Sax commented on FLINK-2571: Are you working on this? Or is anything blocking your

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

2015-10-25 Thread Matthias J. Sax (JIRA)
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] [Resolved] (FLINK-2862) FlinkTopologyBuilder should use proper generic types

2015-10-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved FLINK-2862. Resolution: Fixed > FlinkTopologyBuilder should use proper generic types >

[jira] [Commented] (FLINK-2862) FlinkTopologyBuilder should use proper generic types

2015-10-24 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14972624#comment-14972624 ] Matthias J. Sax commented on FLINK-2862: Resolved via fa88d9eb1b88641d6ca03b38e2058d30971c7a2f >

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

2015-10-24 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-2911: -- Summary: AccumulatingAlignedProcessingTimeWindowOperatorTest.checkpointRestoreWithPendingWindowTumbling Key: FLINK-2911 URL: https://issues.apache.org/jira/browse/FLINK-2911

[jira] [Assigned] (FLINK-2862) FlinkTopologyBuilder should use proper generic types

2015-10-20 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2862: -- Assignee: Matthias J. Sax > FlinkTopologyBuilder should use proper generic types >

[jira] [Closed] (FLINK-2847) Fix flaky test in StormTestBase.testJob

2015-10-10 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2847. -- Resolution: Fixed > Fix flaky test in StormTestBase.testJob >

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

2015-10-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950060#comment-14950060 ] Matthias J. Sax edited comment on FLINK-2831 at 10/9/15 9:14 AM: - The last

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

2015-10-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950060#comment-14950060 ] Matthias J. Sax commented on FLINK-2831: It's a stupid test and it does have an issue... I will

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

2015-10-09 Thread Matthias J. Sax (JIRA)
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] [Updated] (FLINK-2845) TimestampITCase.testWatermarkPropagation

2015-10-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated FLINK-2845: --- Description: https://travis-ci.org/apache/flink/jobs/84479912 {noformat} Tests run: 8,

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

2015-10-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950200#comment-14950200 ] Matthias J. Sax commented on FLINK-2831: Fixed via 998be1bbbc823e1299dcb6bfe56774ec2f7286ab >

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

2015-10-09 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved FLINK-2831. Resolution: Fixed > Failing Test: WrapperSetupHelperTest >

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

2015-10-08 Thread Matthias J. Sax (JIRA)
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

2015-10-08 Thread Matthias J. Sax (JIRA)
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

  1   2   3   >