Можно ли выполнить секционированное задание Spring Cloud Task в потоке данных Spring Cloud?

Я пытаюсь настроить и выполнить пример Spring Cloud Tasks Sample секционированного пакетного задания (https://github.com/spring-cloud/spring-cloud-task/tree/master/spring-cloud-task-samples/partitioned-batch-job) в Spring Cloud Data Flow Server.

Но по какой-то причине в разделенных задачах есть ошибки:

Выполнение задания для этого задания уже выполняется: JobInstance: id = 2, version = 0, Job = [partitionedJob]

Несовместимо ли задание разделения с сервером Spring Cloud Dataflow?


spring-cloud-dataflow spring-cloud-task
person J.D.    schedule 21.11.2016    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Да, образец пакетного задания с разделением на разделы совместим с сервером Spring Cloud Data Flow и работает "из коробки", если:

  • Источник данных - H2 или Mysql.
  • И вы используете Spring Cloud Data Flow Server Local

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

person Glenn Renfro    schedule 21.11.2016
comment
Я пробовал версию Spring Cloud Task 1.0.3.RELEASE и пытаюсь развернуть ее на локальном сервере Spring Cloud DataFlow 1.0.1.RELEASE. Исключение из журналов секционированного задания: Вызвано: org.springframework.batch.core.repository.JobExecutionAlreadyRunningException: выполнение задания для этого задания уже выполняется: JobInstance: id = 4, version = 0, Job = [partitionedJob ] - person J.D.; 22.11.2016
comment
Спасибо за предоставленную версию. В этом случае похоже, что в первый раз, когда это задание было запущено, оно не было завершено (возможно, убито ctrl-c). Это можно подтвердить, используя пользовательский интерфейс Spring Cloud Data Flow, посмотрев на выполнение заданий на вкладке заданий и увидев, что первое задание все еще находится в состоянии запущено. Чтобы обойти это, вы можете сделать одно из двух: * - person Glenn Renfro; 22.11.2016
comment
* Обрезать или удалить таблицы пакетов в репо. Или просто удалите эти записи о вакансиях. * Измените имя работы с partitionedJob на другое имя. Его можно найти здесь: github.com/spring-cloud/spring-cloud-task/blob/1.0.3.RELEASE/ - person Glenn Renfro; 22.11.2016