From 0c90e2048fc3c29a793f4c0e6d0b6de39d6e8e96 Mon Sep 17 00:00:00 2001 From: "Joshua E. Jodesty" Date: Wed, 2 Oct 2019 11:33:24 -0400 Subject: [PATCH] fixed bootstrap & parameterized private_ip --- distroduce/messaging_sim.py | 1 - 1 file changed, 1 deletion(-) diff --git a/distroduce/messaging_sim.py b/distroduce/messaging_sim.py index 05d55e2..1040b18 100644 --- a/distroduce/messaging_sim.py +++ b/distroduce/messaging_sim.py @@ -77,7 +77,6 @@ if __name__ == "__main__": policy_ops=[lambda a, b: a + b] ) - # parmeterize localhost, PRIVATE_IP=`hostname -I | xargs` kafkaConfig = {'send_topic': 'test', 'producer_config': {'bootstrap_servers': f'{sys.argv[1]}:9092', 'acks': 'all'}} dist_proc_ctx = ExecutionContext(context=exec_mode.dist_proc, method=distributed_produce, kafka_config=kafkaConfig) run = Executor(exec_context=dist_proc_ctx, configs=configs, spark_context=sc)