This is an automated email from the ASF dual-hosted git repository.
nwang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
The following commit(s) were added to refs/heads/master by this push:
new 6ce013c Log topology and component config during 'heron submit'
(#3285)
6ce013c is described below
commit 6ce013cf262b8d413aec8c6e628ce363ef717ff1
Author: Ning Wang <[email protected]>
AuthorDate: Mon Jun 10 08:56:03 2019 -0700
Log topology and component config during 'heron submit' (#3285)
---
heron/tools/cli/src/python/submit.py | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/heron/tools/cli/src/python/submit.py
b/heron/tools/cli/src/python/submit.py
index cf43f7f..ca7d5e6 100644
--- a/heron/tools/cli/src/python/submit.py
+++ b/heron/tools/cli/src/python/submit.py
@@ -234,6 +234,14 @@ def launch_topologies(cl_args, topology_file, tmp_dir):
err_context = "Cannot load topology definition '%s': %s" % (defn_file, e)
return SimpleResult(Status.HeronError, err_context)
+ # log topology and components configurations
+ Log.debug("Topology config: %s", topology_defn.topology_config)
+ Log.debug("Component config:")
+ for spout in topology_defn.spouts:
+ Log.debug("%s => %s", spout.comp.name, spout.comp.config)
+ for bolt in topology_defn.bolts:
+ Log.debug("%s => %s", bolt.comp.name, bolt.comp.config)
+
# launch the topology
Log.info("Launching topology: \'%s\'%s", topology_defn.name,
launch_mode_msg(cl_args))
