diff options
Diffstat (limited to 'bigtop-packages/src/charm/zeppelin/layer-zeppelin/lib/charms/layer/bigtop_zeppelin.py')
-rw-r--r-- | bigtop-packages/src/charm/zeppelin/layer-zeppelin/lib/charms/layer/bigtop_zeppelin.py | 27 |
1 files changed, 13 insertions, 14 deletions
diff --git a/bigtop-packages/src/charm/zeppelin/layer-zeppelin/lib/charms/layer/bigtop_zeppelin.py b/bigtop-packages/src/charm/zeppelin/layer-zeppelin/lib/charms/layer/bigtop_zeppelin.py index 0bb545a7..44512d29 100644 --- a/bigtop-packages/src/charm/zeppelin/layer-zeppelin/lib/charms/layer/bigtop_zeppelin.py +++ b/bigtop-packages/src/charm/zeppelin/layer-zeppelin/lib/charms/layer/bigtop_zeppelin.py @@ -56,11 +56,22 @@ class Zeppelin(object): self._add_override('zeppelin::server::server_port', self.dist_config.port('zeppelin')) self._add_override('zeppelin::server::web_socket_port', - self.dist_config.port('zeppelin_web')) + self.dist_config.port('zeppelin_websocket')) # Default spark to local mode on initial install. This will be # reconfigured if/when hadoop or spark relations are made. - self._add_override('zeppelin::server::spark_master_url', 'local[*]') + local_master = 'local[*]' + self._add_override('zeppelin::server::spark_master_url', local_master) + + # The spark-client role expects hdfs by default. Since we want to + # keep Hadoop optional, ensure we remove hadoopy bits from our + # local spark config. This has no effect if/when a remote spark joins, + # and since there is no spark history server running, the event dirs + # are not important -- they just need not be 'hdfs:///blah'. + events_log_dir = 'file:///tmp' + self._add_override('spark::common::master_url', local_master) + self._add_override('spark::common::event_log_dir', events_log_dir) + self._add_override('spark::common::history_log_dir', events_log_dir) ########## # BUG: BIGTOP-2742 @@ -116,18 +127,6 @@ class Zeppelin(object): bigtop.trigger_puppet() self.wait_for_api(30) - def setup_etc_env(self): - ''' - Write some niceties to /etc/environment - ''' - # Configure system-wide bits - zeppelin_bin = self.dist_config.path('zeppelin') / 'bin' - zeppelin_conf = self.dist_config.path('zeppelin_conf') - with utils.environment_edit_in_place('/etc/environment') as env: - if zeppelin_bin not in env['PATH']: - env['PATH'] = ':'.join([env['PATH'], zeppelin_bin]) - env['ZEPPELIN_CONF_DIR'] = zeppelin_conf - def reconfigure_zeppelin(self): ''' Configure zeppelin based on current environment |