Невозможно развернуть потоки в Spring Cloud Dataflow - PullRequest
Новая
       68

Невозможно развернуть потоки в Spring Cloud Dataflow

0 голосов
/ 02 апреля 2020

Проблема

Я был смог зарегистрировать приложения и развернуть их ранее, теперь я не могу. 

curl --request POST \
  --url http://10.30.7.244:31444//apps/source/http \
  --header 'content-type: application/x-www-form-urlencoded' \
  --data uri=docker:springcloudstream/http-source-rabbit:2.1.1.RELEASE \
  --data version=2.1.1.RELEASE \
  --data metadata-uri=maven://org.springframework.cloud.stream.app:http-source-rabbit:jar:metadata:2.1.1.RELEASE

# + more custom apps

curl --request POST \
  --url http://10.30.7.244:31444/streams/definitions \
  --header 'content-type: application/x-www-form-urlencoded' \
  --data name=my-stream \
  --data 'definition=http | my-proc1 | my-proc-2 | my-sink' \
  --data deploy=false

curl --request POST \
  --url http://thehost:31444/streams/deployments/my-stream \
  --header 'content-type: application/json' \
  --data '{
    "deployer.*.kubernetes.imagePullPolicy":"Always",
    "deployer.http.kubernetes.createNodePort" : "32125",

    "app.*.spring.profiles.active":"integ",


}'

Как это произошло

Мне удалось просто развернуть и развернуть вышеуказанный поток. Однако однажды я удалил его и попытался развернуть его слишком быстро, и он пожаловался на то, что входной http-порт недоступен, поскольку модуль еще не остановился. Я в основном уволен и перераспределен в течение 2 секунд, не уделяя этому много времени. Теперь я не могу выполнить развертывание из-за застрявших / потерянных метаданных развертывания в шкипере. Я получаю эту ошибку сейчас КАЖДЫЙ раз, когда я пытался развернуть свой поток: 

[
  {
    "logref": "SkipperException",
    "message": "Could not install AppDeployRequest [[AppDeploymentRequest@7afd79d6 commandlineArguments = list[[empty]], deploymentProperties = map['spring.cloud.deployer.group' -> 'my-app-to-era', 'spring.cloud.deployer.kubernetes.imagePullPolicy' -> 'Always'], definition = [AppDefinition@1fb86fe0 name = 'my-app-data-mapper-v14', properties = map['spring.metrics.export.triggers.application.includes' -> 'integration**', 'spring.cloud.dataflow.stream.app.label' -> 'my-app-data-mapper', 'spring.cloud.stream.metrics.key' -> 'my-app-to-era.my-app-data-mapper.${spring.cloud.application.guid}', 'spring.cloud.stream.bindings.input.group' -> 'my-app-to-era', 'spring.cloud.stream.bindings.output.producer.requiredGroups' -> 'my-app-to-era', 'spring.cloud.stream.metrics.properties' -> 'spring.application.name,spring.application.index,spring.cloud.application.*,spring.cloud.dataflow.*', 'spring.cloud.dataflow.stream.name' -> 'my-app-to-era', 'spring.cloud.stream.bindings.output.destination' -> 'my-app-to-era.my-app-data-mapper', 'spring.cloud.dataflow.stream.app.type' -> 'processor', 'spring.cloud.stream.bindings.input.destination' -> 'my-app-to-era.my-app-packet-builder', 'spring.profiles.active' -> 'integ']], resource = Docker Resource [docker:artifacts.dynatron.io/era-docker/stream-my-app-data-mapper:1.0.5-SNAPSHOT]]]  to platform [default].  Error Message = [Failure executing: POST at: https://10.152.183.1/api/v1/namespaces/default/services. Message: services \"my-app-to-era-my-app-data-mapper-v14\" already exists. Received status: Status(apiVersion=v1, code=409, details=StatusDetails(causes=[], group=null, kind=services, name=my-app-to-era-my-app-data-mapper-v14, retryAfterSeconds=null, uid=null, additionalProperties={}), kind=Status, message=services \"my-app-to-era-my-app-data-mapper-v14\" already exists, metadata=ListMeta(_continue=null, resourceVersion=null, selfLink=null, additionalProperties={}), reason=AlreadyExists, status=Failure, additionalProperties={}).]"
  }
]

Обойти

Если я отменил регистрацию приложений и перерегистрацию, это ничего не исправит. Но если я отменяю регистрацию приложений и регистрирую их с новыми именами, тогда это работает. Но раздражает необходимость продолжать это делать, поскольку оно используется в автоматизированной среде. Выполнение хакерских команд и переименований не является идеальным шагом вперед.

1 Ответ

0 голосов
/ 03 апреля 2020

В этом случае вы можете попробовать удалить релиз, застрявший на стороне шкипера. Для этого вы можете попробовать из оболочки Skipper: 

skipper:>release delete <release-name>
...