проблема с потоком данных весной для отмены развертывания потоков, развернутых на платформе docker с Kafka и Oracle - PullRequest
0 голосов
/ 19 февраля 2020

Мы ищем SCDF для развертывания наших приложений. На самом деле, я использую шкипер-сервер 2.3 dataflow-server 2.4 и кафку, развернутую в качестве докеров. Когда я нахожусь на локальном сервере, у нас нет никаких проблем, но когда мы развертываем на платформе docker, развертывание и уничтожение потоков в порядке. Но мы не можем их развернуть с помощью GUI и оболочки потока данных. В журнале есть такая трассировка:

skipper            | 2020-02-19 14:30:58.451  INFO 1 --- [eTaskExecutor-2] o.s.c.s.s.s.DeleteDeleteAction           : About to delete testStreamSftpDataflowlaunch1
skipper            | 2020-02-19 14:30:58.471  INFO 1 --- [eTaskExecutor-2] o.s.c.d.spi.local.LocalAppDeployer       : Un-deploying app with deploymentId testStreamSftpDataflowlaunch1.sftp-dataflow-v1 instance 0.
skipper            | 2020-02-19 14:31:28.525  INFO 1 --- [eTaskExecutor-2] o.s.s.support.LifecycleObjectSupport     : stopped org.springframework.statemachine.support.DefaultStateMachineExecutor@5a876edb
skipper            | 2020-02-19 14:31:28.525  INFO 1 --- [eTaskExecutor-2] o.s.s.support.LifecycleObjectSupport     : stopped DELETE_DELETE DELETE_EXIT  /  / uuid=cfb0fc42-6277-430a-9c39-05e3f14be373 / id=testStreamSftpDataflowlaunch1
skipper            | 2020-02-19 14:31:28.525  INFO 1 --- [eTaskExecutor-2] o.s.c.s.s.s.StateMachineConfiguration    : Entering state ObjectState [getIds()=[INITIAL], getClass()=class org.springframework.statemachine.state.ObjectState, hashCode()=1492058631, toString()=AbstractState [id=INITIAL, pseudoState=org.springframework.statemachine.state.DefaultPseudoState@6409e9d2, deferred=[], entryActions=[], exitActions=[org.springframework.cloud.skipper.server.statemachine.ResetVariablesAction@7139bd31], stateActions=[], regions=[], submachine=null]]
skipper            | 2020-02-19 14:31:28.525  INFO 1 --- [eTaskExecutor-2] o.s.c.s.s.s.SkipperStateMachineService   : setting future value org.springframework.cloud.skipper.domain.Release@7bab1e28

skipper |
---------

 2020-02-19 14:31:28.525  INFO 1 --- [eTaskExecutor-2] o.s.s.support.LifecycleObjectSupport     : started org.springframework.statemachine.support.DefaultStateMachineExecutor@5a876edb
skipper            | 2020-02-19 14:31:28.525  INFO 1 --- [eTaskExecutor-2] o.s.s.support.LifecycleObjectSupport     : started DELETE_DELETE DELETE_EXIT  /  / uuid=cfb0fc42-6277-430a-9c39-05e3f14be373 / id=testStreamSftpDataflowlaunch1

Однако поток уже доступен.

1 Ответ

0 голосов
/ 20 февраля 2020

DELETE_EXIT от конечного автомата Skipper подтверждает, что удаление выпуска (неиспользование потока) завершается успешно.

Похоже, есть некоторые проблемы, связанные с удалением приложений, которые являются частью потока. Не могли бы вы поделиться большим количеством журналов отладки (особенно на стороне разработчика), чтобы понять, что пошло не так, когда связанные приложения были развернуты сервером Skipper?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...