Github user chtyim commented on a diff in the pull request:
https://github.com/apache/twill/pull/67#discussion_r174644467
--- Diff:
twill-yarn/src/main/java/org/apache/twill/internal/appmaster/ApplicationMasterMain.java
---
@@ -170,45 +167,7 @@ private ApplicationKafkaService(ZKClient zkClient,
String kafkaZKConnect) {
protected void startUp() throws Exception {
// Create the ZK node for Kafka to use. If the node already exists,
delete it to make sure there is
// no left over content from previous AM attempt.
- final SettableOperationFuture<String> completion =
SettableOperationFuture.create(kafkaZKPath,
-
Threads.SAME_THREAD_EXECUTOR);
- LOG.info("Preparing Kafka ZK path {}{}",
zkClient.getConnectString(), kafkaZKPath);
--- End diff --
oh yeah, accidentally removed.
---
