[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 {{Table.toD

[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&focusedCommentId=15296356#comment-15296356 ] Matthias J. Sax commented on FLINK-3955: I am not sure if this name solve the issu

[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&focusedCommentId=15264146#comment-15264146 ] Matthias J. Sax commented on FLINK-3404: I think so. [~rmetzger] can you comment o

[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&focusedCommentId=15260002#comment-15260002 ] Matthias J. Sax commented on FLINK-3601: [~mxm] Are you working on this? If not, I

[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&focusedCommentId=1526#comment-1526 ] Matthias J. Sax commented on FLINK-3380: [~uce] Can this be closed? PR1611 was mer

[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&focusedCommentId=15228381#comment-15228381 ] Matthias J. Sax commented on FLINK-3523: fixed via 02ef68fb4adbd413fa159c35980412f

[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&focusedCommentId=15221460#comment-15221460 ] Matthias J. Sax commented on FLINK-2392: Yes. See post above from03/Dec/15 > Inst

[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&focusedCommentId=15221299#comment-15221299 ] Matthias J. Sax commented on FLINK-2392: https://s3.amazonaws.com/archive.travis-c

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

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

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

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

[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&focusedCommentId=15140844#comment-15140844 ] Matthias J. Sax commented on FLINK-2915: https://travis-ci.org/apache/flink/jobs/1

[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&focusedCommentId=15140840#comment-15140840 ] Matthias J. Sax commented on FLINK-3356: https://travis-ci.org/mjsax/flink/jobs/10

[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&focusedCommentId=15136904#comment-15136904 ] Matthias J. Sax edited comment on FLINK-3035 at 2/8/16 12:52 PM: ---

[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&focusedCommentId=15136904#comment-15136904 ] Matthias J. Sax commented on FLINK-3035: The embedded-redis project seems not to b

[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] [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] [Commented] (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:comment-tabpanel&focusedCommentId=15136377#comment-15136377 ] Matthias J. Sax commented on FLINK-2721: Fixed via 7eb6edd573211f6f65449ad5ed13eb5

[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&focusedCommentId=15136374#comment-15136374 ] Matthias J. Sax commented on FLINK-2915: One more: https://travis-ci.org/mjsax/fli

[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&focusedCommentId=15136372#comment-15136372 ] Matthias J. Sax commented on FLINK-2504: Again: https://travis-ci.org/mjsax/flink/

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

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

[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] [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 docs

[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] [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 docs

[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 docs.

[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] [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] [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&focusedCommentId=15128050#comment-15128050 ] Matthias J. Sax commented on FLINK-3035: [~sbcd90], maybe you are interested in th

[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&focusedCommentId=15128048#comment-15128048 ] Matthias J. Sax commented on FLINK-3033: [~sbcd90], if the PR gets opened, please

[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&focusedCommentId=15128045#comment-15128045 ] Matthias J. Sax commented on FLINK-3034: [~sbcd90], if the PR gets opened, please

[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&focusedCommentId=15125952#comment-15125952 ] Matthias J. Sax commented on FLINK-3034: @ [~neo20iitkgp] please assign the JIRA t

[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&focusedCommentId=15125950#comment-15125950 ] Matthias J. Sax commented on FLINK-3033: [~neo20iitkgp] please assign the JIRA to

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

2016-01-19 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 Fix Version/s: (was: 0.10.0) > Failing Test: WrapperSetupHelper

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

2016-01-19 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15106781#comment-15106781 ] Matthias J. Sax commented on FLINK-2831: Fixed via 046f044df47d2711e614455f047c760

[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&focusedCommentId=15105812#comment-15105812 ] Matthias J. Sax commented on FLINK-3238: Also happend for `EventTimeAllWindowCheck

[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] [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] [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&focusedCommentId=15101497#comment-15101497 ] Matthias J. Sax commented on FLINK-2586: Fixed via d1c93d286b95f069f6ba0a4e60e3a34

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

2016-01-14 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15098120#comment-15098120 ] Matthias J. Sax commented on FLINK-2606: HdfsSpout in Storm is WIP: https://issues

[jira] [Assigned] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility

2016-01-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned FLINK-2720: -- Assignee: Matthias J. Sax (was: Huang Wei) > Add Storm-CountMetric in flink-stormcompa

[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 88636799ee68cae80b093436ff2e5eace0675b

[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&focusedCommentId=15094306#comment-15094306 ] Matthias J. Sax commented on FLINK-3175: Happened again: https://travis-ci.org/mjs

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

[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&focusedCommentId=15091516#comment-15091516 ] Matthias J. Sax commented on FLINK-3212: Again: this time, test hung for 300 secon

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

[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&focusedCommentId=15076284#comment-15076284 ] Matthias J. Sax commented on FLINK-3189: The JIRA text was not correct. I juts upd

[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, whi

[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&focusedCommentId=15072651#comment-15072651 ] Matthias J. Sax commented on FLINK-2837: Sorry. :( I thought a PR is only require

[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] [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&focusedCommentId=15072627#comment-15072627 ] Matthias J. Sax commented on FLINK-2837: Fixed via f7b113d965fd30db993cac99b63194d

[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&focusedCommentId=15072624#comment-15072624 ] Matthias J. Sax commented on FLINK-3072: Again: https://s3.amazonaws.com/archive.t

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

[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] [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&focusedCommentId=15046511#comment-15046511 ] Matthias J. Sax commented on FLINK-3096: https://travis-ci.org/mjsax/flink/jobs/95

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

[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&focusedCommentId=15041549#comment-15041549 ] Matthias J. Sax commented on FLINK-3096: Happend again: https://s3.amazonaws.com/

[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&focusedCommentId=15036840#comment-15036840 ] Matthias J. Sax commented on FLINK-2392: One more: https://s3.amazonaws.com/archiv

[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&focusedCommentId=15036835#comment-15036835 ] Matthias J. Sax commented on FLINK-3072: Happened again. Yes, I did rebase to curr

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

[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&focusedCommentId=15024633#comment-15024633 ] Matthias J. Sax commented on FLINK-3072: Similar here: https://s3.amazonaws.com/a

[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&focusedCommentId=15024419#comment-15024419 ] Matthias J. Sax commented on FLINK-2861: Fixed via 4c46b2feee2c1ecda21e5ba62d02dfd

[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] [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 mult

[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&focusedCommentId=15021102#comment-15021102 ] Matthias J. Sax commented on FLINK-2837: No. Go ahead with your PR. > FlinkTopolo

[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] [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-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] [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 Co

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

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

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

[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] [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&focusedCommentId=15006563#comment-15006563 ] Matthias J. Sax commented on FLINK-3017: Fixed via feb6994ffca04e4b7ad6174ca08048e

[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&focusedCommentId=15000435#comment-15000435 ] Matthias J. Sax commented on FLINK-2671: Occurred again: https://travis-ci.org/apa

[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&focusedCommentId=14996328#comment-14996328 ] Matthias J. Sax commented on FLINK-2752: Some improvements via c607549537894d3

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

[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&focusedCommentId=14987339#comment-14987339 ] Matthias J. Sax commented on FLINK-2735: https://travis-ci.org/mjsax/flink/jobs/88

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

[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&focusedCommentId=14982244#comment-14982244 ] Matthias J. Sax commented on FLINK-2571: Are you working on this? Or is anything b

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

[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&focusedCommentId=14972624#comment-14972624 ] Matthias J. Sax commented on FLINK-2862: Resolved via fa88d9eb1b88641d6ca03b38e205

[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] [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, Failure

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

  1   2   3   >