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

Question

Проблема

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

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 секунд, не уделяя этому много времени. Теперь я не могу выполнить развертывание из-за того, что кажется зависшим / потерянным в метаданных развертывания в skipper. Я получаю эту ошибку КАЖДЫЙ раз, когда пытаюсь развернуть свой поток:

[
  {
    "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={}).]"
  }
]

Работать вокруг

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

Answer 1

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

skipper:>release delete <release-name>