Аргументы не передаются при вызове задачи из потока в облачном потоке данных - PullRequest
Новая
       13

Аргументы не передаются при вызове задачи из потока в облачном потоке данных

0 голосов
/ 25 января 2019

Я пытаюсь запустить свою компонентную задачу из потока, но не могу передать информацию самой задаче.

Это мой код в потоковом приложении 

      Map<String, String> environmentProperties = new HashMap<>();
      environmentProperties.put("graph", "my-composed-task");


      List<String> commandLineParameter = new ArrayList<>();
      commandLineParameter.add("--increment-instance-enabled=true");

      Map<String, String> deploymentProperties = new HashMap<>();

      TaskLaunchRequest taskLaunchRequest = new TaskLaunchRequest(
                    springCloudHttpSourceProperties.getUri(),
                    commandLineParameter,
                    environmentProperties,
                    deploymentProperties,
                    springCloudHttpSourceProperties.getTaskName()
       );

       log.info("" + taskLaunchRequest);

       this.sink.input().send(new GenericMessage<>(taskLaunchRequest));

Кажется, что свойство графика работает очень хорошо, однако командная строка с включенным экземпляром --increment, похоже, не проходит.

В журнале моего сервера я вижу вызов, который выполняется без параметра командной строки: 

Co.s.c.d.spi.local.LocalTaskLauncher: Command to be executed: /opt/openjdk/bin/java -jar /root/.m2/repository/org/springframework/cloud/task/app/composedtaskrunner-task/2.0.2.RELEASE/composedtaskrunner-task-2.0.2.RELEASE.jar --spring.cloud.task.executionid=1

Но, например, если я запускаю эту задачу, используя оболочку или сам интерфейс используя команду: 

task launch my-composed-task --arguments "--increment-instance-enabled=true"

кажется, что все передано: 

Co.s.c.d.spi.local.LocalTaskLauncher: Command to be executed: /opt/openjdk/bin/java -jar /root/.m2/repository/org/springframework/cloud/task/app/composedtaskrunner-task/2.0.2.RELEASE/composedtaskrunner-task-2.0.2.RELEASE.jar --increment-instance-enabled=true --spring.cloud.task.executionid=1

Я использую 2.0.2. ВЫПУСК СОСТАВЛЕННОЙ ТАСКРАННЕРА.

Я делаю что-то не так или есть ошибка в облачном потоке, о которой я не знаю?

...