Skip to content

Commit 5dc416a

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

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
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: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,8 @@ class KafkaLauncher(
6868
val t = Try {
6969
createDir("zookeeper")
7070
createDir("kafka")
71-
EmbeddedKafka.startZooKeeper(FileSystems.getDefault.getPath("zookeeper"))
72-
EmbeddedKafka.startKafka(FileSystems.getDefault.getPath("kafka"))
71+
EmbeddedKafka.startZooKeeper(FileSystems.getDefault.getPath(workDir.getPath,"zookeeper"))
72+
EmbeddedKafka.startKafka(FileSystems.getDefault.getPath(workDir.getPath,"kafka"))
7373
}
7474

7575
Future

0 commit comments

Comments
 (0)