Skip to content

Commit 08f737d

Browse files
author
Brendan Doyle
committed
attempt to fix standalone server startup test
1 parent b9d1c12 commit 08f737d

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

core/monitoring/user-events/src/test/scala/org/apache/openwhisk/core/monitoring/metrics/KafkaSpecBase.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ abstract class KafkaSpecBase
3636
implicit val timeoutConfig: PatienceConfig = PatienceConfig(5.minute)
3737
override val sleepAfterProduce: FiniteDuration = 10.seconds
3838
override protected val topicCreationTimeout = 120.seconds
39+
override protected val producerPublishTimeout: FiniteDuration = 60.seconds
3940

4041
lazy implicit val embeddedKafkaConfig: EmbeddedKafkaConfig = EmbeddedKafkaConfig(kafkaPort, zooKeeperPort)
4142

core/standalone/src/main/scala/org/apache/openwhisk/standalone/KafkaLauncher.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -105,6 +105,7 @@ class KafkaLauncher(
105105

106106
private def createDir(name: String) = {
107107
val dir = new File(workDir, name)
108+
FileUtils.forceDelete(dir)
108109
FileUtils.forceMkdir(dir)
109110
Directory(dir)
110111
}

0 commit comments

Comments
 (0)