diff --git a/apps/efka/src/efka_agent.erl b/apps/efka/src/efka_agent.erl index 1c45959..5752770 100644 --- a/apps/efka/src/efka_agent.erl +++ b/apps/efka/src/efka_agent.erl @@ -261,7 +261,7 @@ handle_info({server_push_message, PacketId, <>}, State = #state{transport_pid = TransportPid, inflight = Inflight}) -> - #service_config{service_id = ServiceId, config_json = ConfigJson, timeout = Timeout} = message_pb:decode_msg(ParamsBin, service_params), + #service_config{service_id = ServiceId, config_json = ConfigJson, timeout = Timeout} = message_pb:decode_msg(ParamsBin, service_config), case efka_micro_service:get_pid(ServiceId) of undefined -> diff --git a/apps/efka/src/efka_service_sup.erl b/apps/efka/src/efka_service_sup.erl index 898d82a..77ddcd9 100644 --- a/apps/efka/src/efka_service_sup.erl +++ b/apps/efka/src/efka_service_sup.erl @@ -49,6 +49,7 @@ init([]) -> service_model:insert(#micro_service{ service_id = <<"test1234">>, + tar_url = <<"http://118.178.229.213:3000/anlicheng/ekfa/archive1/main.tar.gz">>, %% 工作目录 root_dir = <<"/usr/local/code/tmp/test/">>, params = <<"">>,