[jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD

[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013142#comment-15013142 ] Till Rohrmann commented on FLINK-1994: -- Hi Trevor, would be great to add tests and docs, otherwise

[jira] [Created] (FLINK-3052) Optimizer does not push properties out of bulk iterations

Till Rohrmann created FLINK-3052: Summary: Optimizer does not push properties out of bulk iterations Key: FLINK-3052 URL: https://issues.apache.org/jira/browse/FLINK-3052 Project: Flink

[jira] [Resolved] (FLINK-2860) The mlr object from the FlinkML Getting Started code example uses an undefined argument

[ https://issues.apache.org/jira/browse/FLINK-2860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2860. -- Resolution: Fixed Fixed via 09433032d8ecb13c66204d8912225af919577b4e > The mlr object from the

[jira] [Closed] (FLINK-3021) Job submission times out due to classloading issue on JobManager

[ https://issues.apache.org/jira/browse/FLINK-3021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3021. Resolution: Fixed Fixed via 177df41bf94ba18b0174a5973ee12efc195ec17e > Job submission times out

[jira] [Resolved] (FLINK-3041) Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal'

[ https://issues.apache.org/jira/browse/FLINK-3041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3041. -- Resolution: Fixed Added via dc61c7a955f0192ca8c86470cd3e22eb1f5dc2dd > Twitter Streaming

[jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD

[ https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013790#comment-15013790 ] Till Rohrmann commented on FLINK-1994: -- That would be one way to test it. Maybe it's also possible to

[jira] [Resolved] (FLINK-3064) Missing size check in GroupReduceOperatorBase leads to NPE

[ https://issues.apache.org/jira/browse/FLINK-3064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3064. -- Resolution: Fixed Fixed via d2b4391f4e42a96a8b3c852e303aba170de15727 > Missing size check in

[jira] [Commented] (FLINK-1581) Configure DeathWatch parameters properly

[ https://issues.apache.org/jira/browse/FLINK-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15093683#comment-15093683 ] Till Rohrmann commented on FLINK-1581: -- I guess this could be handled by the {{RestartStrategies}}

[jira] [Commented] (FLINK-3213) Union of two streams with different parallelism should adjust parallelism automatically

[ https://issues.apache.org/jira/browse/FLINK-3213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15093700#comment-15093700 ] Till Rohrmann commented on FLINK-3213: -- The linked example code does not reproduce the mentioned

[jira] [Closed] (FLINK-1581) Configure DeathWatch parameters properly

[ https://issues.apache.org/jira/browse/FLINK-1581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-1581. Resolution: Not A Problem > Configure DeathWatch parameters properly >

[jira] [Created] (FLINK-4042) TwitterStream example does not work

Till Rohrmann created FLINK-4042: Summary: TwitterStream example does not work Key: FLINK-4042 URL: https://issues.apache.org/jira/browse/FLINK-4042 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING

Till Rohrmann created FLINK-4046: Summary: Failing a restarting job can get stuck in JobStatus.FAILING Key: FLINK-4046 URL: https://issues.apache.org/jira/browse/FLINK-4046 Project: Flink

[jira] [Commented] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

[ https://issues.apache.org/jira/browse/FLINK-3990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322571#comment-15322571 ] Till Rohrmann commented on FLINK-3990: -- This log should be an instance of this issue:

[jira] [Assigned] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2733: Assignee: Till Rohrmann > ZooKeeperLeaderElectionTest.testZooKeeperReelection fails >

[jira] [Commented] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316557#comment-15316557 ] Till Rohrmann commented on FLINK-2733: -- Another instance:

[jira] [Assigned] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement

[ https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2832: Assignee: Till Rohrmann > Failing test:

[jira] [Commented] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316636#comment-15316636 ] Till Rohrmann commented on FLINK-2733: -- The problem seems to be a connection loss to the

[jira] [Commented] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement

[ https://issues.apache.org/jira/browse/FLINK-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316536#comment-15316536 ] Till Rohrmann commented on FLINK-2832: -- Here is another instance of the failure (this time the

[jira] [Updated] (FLINK-1736) Add CountVectorizer to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1736: - Assignee: ROSHANI NAGMOTE (was: Alexander Alexandrov) > Add CountVectorizer to machine learning

[jira] [Created] (FLINK-4056) SavepointITCase.testCheckpointHasBeenRemoved failed on Travis

Till Rohrmann created FLINK-4056: Summary: SavepointITCase.testCheckpointHasBeenRemoved failed on Travis Key: FLINK-4056 URL: https://issues.apache.org/jira/browse/FLINK-4056 Project: Flink

[jira] [Created] (FLINK-4055) EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow fails on Travis

Till Rohrmann created FLINK-4055: Summary: EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow fails on Travis Key: FLINK-4055 URL: https://issues.apache.org/jira/browse/FLINK-4055

[jira] [Commented] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

[ https://issues.apache.org/jira/browse/FLINK-3990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15324372#comment-15324372 ] Till Rohrmann commented on FLINK-3990: -- Another instance:

[jira] [Commented] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

[ https://issues.apache.org/jira/browse/FLINK-3990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322591#comment-15322591 ] Till Rohrmann commented on FLINK-3990: -- But the issue that the JVM dies seems to also happens with

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

[ https://issues.apache.org/jira/browse/FLINK-3212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15324382#comment-15324382 ] Till Rohrmann commented on FLINK-3212: -- Another instance:

[jira] [Created] (FLINK-4060) WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis

Till Rohrmann created FLINK-4060: Summary: WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis Key: FLINK-4060 URL: https://issues.apache.org/jira/browse/FLINK-4060 Project:

[jira] [Updated] (FLINK-4060) WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-4060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4060: - Labels: test-stability (was: ) > WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed

[jira] [Commented] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram still fails :(

[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327077#comment-15327077 ] Till Rohrmann commented on FLINK-3516: -- Another instance:

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

[ https://issues.apache.org/jira/browse/FLINK-3238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15329611#comment-15329611 ] Till Rohrmann commented on FLINK-3238: -- Another instance:

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

[ https://issues.apache.org/jira/browse/FLINK-3238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3238: - Priority: Critical (was: Major) > EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow()

[jira] [Commented] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15331478#comment-15331478 ] Till Rohrmann commented on FLINK-2733: -- I think my analysis was not correct. I checked and of course

[jira] [Created] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis

Till Rohrmann created FLINK-4072: Summary: EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis Key: FLINK-4072 URL: https://issues.apache.org/jira/browse/FLINK-4072 Project:

[jira] [Created] (FLINK-4071) JobManagerHAJobGraphRecoveryITCase.testJobManagerCleanUp failed on Travis

Till Rohrmann created FLINK-4071: Summary: JobManagerHAJobGraphRecoveryITCase.testJobManagerCleanUp failed on Travis Key: FLINK-4071 URL: https://issues.apache.org/jira/browse/FLINK-4071 Project:

[jira] [Created] (FLINK-4073) YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis

Till Rohrmann created FLINK-4073: Summary: YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis Key: FLINK-4073 URL: https://issues.apache.org/jira/browse/FLINK-4073 Project:

[jira] [Updated] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

[ https://issues.apache.org/jira/browse/FLINK-3706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-3706: - Priority: Critical (was: Major) > YARNSessionCapacitySchedulerITCase.testNonexistingQueue

[jira] [Created] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

Till Rohrmann created FLINK-4075: Summary: ContinuousFileProcessingCheckpointITCase failed on Travis Key: FLINK-4075 URL: https://issues.apache.org/jira/browse/FLINK-4075 Project: Flink

[jira] [Assigned] (FLINK-3317) Add timeout handler to CEP operator

[ https://issues.apache.org/jira/browse/FLINK-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3317: Assignee: Till Rohrmann > Add timeout handler to CEP operator >

[jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable

[ https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15344568#comment-15344568 ] Till Rohrmann commented on FLINK-3704: -- Another instance:

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

[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333425#comment-15333425 ] Till Rohrmann commented on FLINK-2392: -- More instances of failing yarn tests:

[jira] [Assigned] (FLINK-3951) Add Histogram Metric Type

[ https://issues.apache.org/jira/browse/FLINK-3951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3951: Assignee: Till Rohrmann > Add Histogram Metric Type > - > >

[jira] [Commented] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-4075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333420#comment-15333420 ] Till Rohrmann commented on FLINK-4075: -- Another instance:

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

[ https://issues.apache.org/jira/browse/FLINK-3344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333416#comment-15333416 ] Till Rohrmann commented on FLINK-3344: -- Another instance, but this time the error was: {{Caused by:

[jira] [Closed] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

[ https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-2733. Resolution: Fixed Fixed via 1a6bab3ef76805685044cf4521e32315169f9033 >

[jira] [Created] (FLINK-4112) Replace SuppressRestartException with disabling RestartStrategy

Till Rohrmann created FLINK-4112: Summary: Replace SuppressRestartException with disabling RestartStrategy Key: FLINK-4112 URL: https://issues.apache.org/jira/browse/FLINK-4112 Project: Flink

[jira] [Assigned] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING

[ https://issues.apache.org/jira/browse/FLINK-4046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4046: Assignee: Till Rohrmann > Failing a restarting job can get stuck in JobStatus.FAILING >

[jira] [Closed] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING

[ https://issues.apache.org/jira/browse/FLINK-4046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4046. Resolution: Fixed Fixed via cfe629340205586d54115143ee30428c1f772abc > Failing a restarting job

[jira] [Closed] (FLINK-3800) ExecutionGraphs can become orphans

[ https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3800. Resolution: Fixed Fixed via 6420c1c264ed3ce0c32ba164c2cdb85ccdccf265 > ExecutionGraphs can become

[jira] [Created] (FLINK-4094) Off heap memory deallocation might not work properly

Till Rohrmann created FLINK-4094: Summary: Off heap memory deallocation might not work properly Key: FLINK-4094 URL: https://issues.apache.org/jira/browse/FLINK-4094 Project: Flink Issue

[jira] [Updated] (FLINK-4094) Off heap memory deallocation might not properly work

[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4094: - Summary: Off heap memory deallocation might not properly work (was: Off heap memory deallocation

[jira] [Closed] (FLINK-3317) Add timeout handler to CEP operator

[ https://issues.apache.org/jira/browse/FLINK-3317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3317. Resolution: Fixed Added via 57ef6c315ee7aa467d922dd4d1213dfd8bc74fb0 > Add timeout handler to CEP

[jira] [Commented] (FLINK-3813) YARNSessionFIFOITCase.testDetachedMode failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-3813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333424#comment-15333424 ] Till Rohrmann commented on FLINK-3813: -- Another instance:

[jira] [Created] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

Till Rohrmann created FLINK-4084: Summary: Add configDir parameter to CliFrontend and flink shell script Key: FLINK-4084 URL: https://issues.apache.org/jira/browse/FLINK-4084 Project: Flink

[jira] [Commented] (FLINK-3827) Flink modules include unused dependencies

[ https://issues.apache.org/jira/browse/FLINK-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15334076#comment-15334076 ] Till Rohrmann commented on FLINK-3827: -- I don't really know what the status of this issue is. We

[jira] [Resolved] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data

[ https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-2259. -- Resolution: Fixed Added via bce3550936d9984298cba9f4dd45e9965fc45762 > Support training

[jira] [Created] (FLINK-3216) Define pattern specification

Till Rohrmann created FLINK-3216: Summary: Define pattern specification Key: FLINK-3216 URL: https://issues.apache.org/jira/browse/FLINK-3216 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3217) Implement NFA for pattern detection

Till Rohrmann created FLINK-3217: Summary: Implement NFA for pattern detection Key: FLINK-3217 URL: https://issues.apache.org/jira/browse/FLINK-3217 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-3215) Add CEP library to Flink

Till Rohrmann created FLINK-3215: Summary: Add CEP library to Flink Key: FLINK-3215 URL: https://issues.apache.org/jira/browse/FLINK-3215 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-1733) Add PCA to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15101580#comment-15101580 ] Till Rohrmann commented on FLINK-1733: -- Hi [~thang], welcome to the Flink community :-) Great to hear

[jira] [Created] (FLINK-3241) Scala 2.11 Flink binaries pull in Scala 2.10 dependencies

Till Rohrmann created FLINK-3241: Summary: Scala 2.11 Flink binaries pull in Scala 2.10 dependencies Key: FLINK-3241 URL: https://issues.apache.org/jira/browse/FLINK-3241 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-2831: -- Found an instance of {{WrapperSetupHelperTest}} which produced a dead lock:

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

[ https://issues.apache.org/jira/browse/FLINK-2831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2831: - Affects Version/s: 1.0.0 > Failing Test: WrapperSetupHelperTest >

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

[ https://issues.apache.org/jira/browse/FLINK-2911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105304#comment-15105304 ] Till Rohrmann commented on FLINK-2911: -- I found another occurrence:

[jira] [Commented] (FLINK-3245) KMeans Data Generator writes not the same centroids as it was used for the dataset

[ https://issues.apache.org/jira/browse/FLINK-3245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15104984#comment-15104984 ] Till Rohrmann commented on FLINK-3245: -- Agreed to what the k-means algorithm does [~fhueske] but I

[jira] [Updated] (FLINK-1733) Add PCA to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-1733: - Assignee: Thang Nguyen (was: Raghav Chalapathy) > Add PCA to machine learning library >

[jira] [Resolved] (FLINK-4113) Always copy first value in ChainedAllReduceDriver

[ https://issues.apache.org/jira/browse/FLINK-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4113. -- Resolution: Fixed Fixed via a6feea32a328f3f3216960298d6c8a5d3f30a234 > Always copy first value

[jira] [Closed] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection

[ https://issues.apache.org/jira/browse/FLINK-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4126. Resolution: Fixed Fixed via dbe41f48745bf52458291290bd2aa0fdc8d18560 > Unstable test

[jira] [Assigned] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection

[ https://issues.apache.org/jira/browse/FLINK-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-4126: Assignee: Till Rohrmann > Unstable test

[jira] [Commented] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection

[ https://issues.apache.org/jira/browse/FLINK-4126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354812#comment-15354812 ] Till Rohrmann commented on FLINK-4126: -- The problem is that the test case times out. Increasing the

[jira] [Reopened] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine

[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-3347: -- > TaskManager ActorSystems need to restart themselves in case they notice > quarantine >

[jira] [Commented] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine

[ https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15134301#comment-15134301 ] Till Rohrmann commented on FLINK-3347: -- Haha, I just closed FLINK-3345 as a duplicate of this one.

[jira] [Created] (FLINK-3346) Replace Akka death watch with own heartbeats

Till Rohrmann created FLINK-3346: Summary: Replace Akka death watch with own heartbeats Key: FLINK-3346 URL: https://issues.apache.org/jira/browse/FLINK-3346 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3374) CEPITCase testSimplePatternEventTime fails

[ https://issues.apache.org/jira/browse/FLINK-3374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15138575#comment-15138575 ] Till Rohrmann commented on FLINK-3374: -- Is this reproducible? Looks to me as if the testing file

[jira] [Commented] (FLINK-3374) CEPITCase testSimplePatternEventTime fails

[ https://issues.apache.org/jira/browse/FLINK-3374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15138626#comment-15138626 ] Till Rohrmann commented on FLINK-3374: -- Probably because it uses {{WriteMode.OVERWRITE}}. >

[jira] [Assigned] (FLINK-3374) CEPITCase testSimplePatternEventTime fails

[ https://issues.apache.org/jira/browse/FLINK-3374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3374: Assignee: Till Rohrmann > CEPITCase testSimplePatternEventTime fails >

[jira] [Commented] (FLINK-3374) CEPITCase testSimplePatternEventTime fails

[ https://issues.apache.org/jira/browse/FLINK-3374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15138617#comment-15138617 ] Till Rohrmann commented on FLINK-3374: -- Hmm I just saw that the CEPITCase creates a file under the

[jira] [Commented] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML

[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132412#comment-15132412 ] Till Rohrmann commented on FLINK-3330: -- I just tried this as a fix and it seems to solve the problem.

[jira] [Commented] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML

[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132411#comment-15132411 ] Till Rohrmann commented on FLINK-3330: -- Hi [~chiwanpark], yes the problem is that the

[jira] [Closed] (FLINK-3345) Restart TaskManager in case of a Akka quarantine event

[ https://issues.apache.org/jira/browse/FLINK-3345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3345. Resolution: Duplicate Duplicate of issue FLINK-3347 > Restart TaskManager in case of a Akka

[jira] [Closed] (FLINK-3330) Add SparseVector support to GradientDescent in FlinkML

[ https://issues.apache.org/jira/browse/FLINK-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-3330. Resolution: Fixed Fixed via fe0c3b539b320fd065b329f34f81be49b4bdab1a > Add SparseVector support to

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15134250#comment-15134250 ] Till Rohrmann commented on FLINK-1731: -- There are still some unresolved issues with the

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121750#comment-15121750 ] Till Rohrmann commented on FLINK-2678: -- Done. Great that you're picking this issue up :-) > DataSet

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123279#comment-15123279 ] Till Rohrmann commented on FLINK-2678: -- It should work for arbitrary dimensional arrays and not only

[jira] [Commented] (FLINK-3300) Concurrency Bug in Yarn JobManager

[ https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123269#comment-15123269 ] Till Rohrmann commented on FLINK-3300: -- +1 for actor messages > Concurrency Bug in Yarn JobManager >

[jira] [Resolved] (FLINK-3313) Kafka08ITCase.testOneSourceMultiplePartitions fails with EOFException

[ https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3313. -- Resolution: Fixed Fixed via 4f8b9bb5e7f826a31e79b9c5670fb7225df6b984 >

[jira] [Assigned] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3325: Assignee: Till Rohrmann > Unclosed InputStream in CEPPatternOperator#restoreState() >

[jira] [Resolved] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3325. -- Resolution: Fixed Fixed via 077dd55885fc91b7dd4c96c07ee6853a97db1a49 > Unclosed InputStream in

[jira] [Commented] (FLINK-3316) Links to Gelly and FlinkML libraries on main site broken

[ https://issues.apache.org/jira/browse/FLINK-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128374#comment-15128374 ] Till Rohrmann commented on FLINK-3316: -- In fact, all links in the first paragraph on the landing page

[jira] [Assigned] (FLINK-3316) Links to Gelly and FlinkML libraries on main site broken

[ https://issues.apache.org/jira/browse/FLINK-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3316: Assignee: Till Rohrmann > Links to Gelly and FlinkML libraries on main site broken >

[jira] [Resolved] (FLINK-3316) Links to Gelly and FlinkML libraries on main site broken

[ https://issues.apache.org/jira/browse/FLINK-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3316. -- Resolution: Fixed Fixed via ffe31bf53ca28a842d4a352a568f288251d56490 > Links to Gelly and

[jira] [Commented] (FLINK-3313) Kafka08ITCase.testOneSourceMultiplePartitions fails with EOFException

[ https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128491#comment-15128491 ] Till Rohrmann commented on FLINK-3313: -- The problem ist that the

[jira] [Assigned] (FLINK-3313) Kafka08ITCase.testOneSourceMultiplePartitions fails with EOFException

[ https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-3313: Assignee: Till Rohrmann > Kafka08ITCase.testOneSourceMultiplePartitions fails with

[jira] [Created] (FLINK-3317) Add timeout handler to CEP operator

Till Rohrmann created FLINK-3317: Summary: Add timeout handler to CEP operator Key: FLINK-3317 URL: https://issues.apache.org/jira/browse/FLINK-3317 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3318) Add support for quantifiers to CEP's pattern API

Till Rohrmann created FLINK-3318: Summary: Add support for quantifiers to CEP's pattern API Key: FLINK-3318 URL: https://issues.apache.org/jira/browse/FLINK-3318 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121490#comment-15121490 ] Till Rohrmann commented on FLINK-2678: -- Hi [~sbcd90], as far as I know, there is nobody working on

[jira] [Resolved] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows

[ https://issues.apache.org/jira/browse/FLINK-3426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3426. -- Resolution: Fixed Fixed via dc4d147d202c8b59e30b7a73c626d2ba9473dad2 >

[jira] [Resolved] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration

[ https://issues.apache.org/jira/browse/FLINK-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-3418. -- Resolution: Fixed Fixed via 7ddc078e68d645bac2829de9634e3373a59be551 > RocksDB

[jira] [Commented] (FLINK-3496) Flink-ml tests fail on Windows

[ https://issues.apache.org/jira/browse/FLINK-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15163052#comment-15163052 ] Till Rohrmann commented on FLINK-3496: -- Could you try to run the command {{cmd.exe /X /C "java

[jira] [Comment Edited] (FLINK-3496) Flink-ml tests fail on Windows

[ https://issues.apache.org/jira/browse/FLINK-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15163052#comment-15163052 ] Till Rohrmann edited comment on FLINK-3496 at 2/24/16 2:20 PM: --- Could you

[jira] [Commented] (FLINK-3496) Flink-ml tests fail on Windows

[ https://issues.apache.org/jira/browse/FLINK-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15163027#comment-15163027 ] Till Rohrmann commented on FLINK-3496: -- Do you have some more information which file cannot be found?

[jira] [Comment Edited] (FLINK-3496) Flink-ml tests fail on Windows

[ https://issues.apache.org/jira/browse/FLINK-3496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15163052#comment-15163052 ] Till Rohrmann edited comment on FLINK-3496 at 2/24/16 2:20 PM: --- Could you

[jira] [Commented] (FLINK-3485) The SerializedListAccumulator value doest seem to be right

[ https://issues.apache.org/jira/browse/FLINK-3485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15162667#comment-15162667 ] Till Rohrmann commented on FLINK-3485: -- Could give us please a little bit more context. I don't

<    1   2   3   4   5   6   7   8   9   10   >