Вопросы по теме 'spring-xd'

Как обеспечивается безопасность в Spring XD?
Просто бегло взглянув на Spring XD, я просмотрел документацию и задал несколько вопросов относительно безопасности. Во-первых, я заметил, что транспортом по умолчанию для связи является Redis, который предпочитает жить в доверенном сегменте сети....
409 просмотров
schedule 28.01.2023

Будет ли ActiveMQ поддерживаться в Spring XD в качестве транспорта в будущем?
Мы используем ActiveMQ в качестве стандартной платформы обмена сообщениями. XD уже поддерживает ActiveMQ в качестве источника JMS. Платформа обмена сообщениями в качестве транспорта помогает обрабатывать сбои приемника, помещая полезную нагрузку в...
229 просмотров
schedule 05.12.2022

Сбой контейнера пряжи администратора пряжи spring-xd
Версия: весна-xd-1.0.1 Распределенный режим: пряжа Версия Hadoop: cdh5 Я изменил config/servers.yml так, чтобы он указывал на нужный applicationDir, zookeeper, hdfs, resourcemanager, redis, mysqldb. Однако после нажатия, когда я запускаю...
364 просмотров
schedule 16.05.2022

Импорт jdbc в HDFS с использованием весеннего пакетного задания
Я могу импортировать данные из моего MS sql в HDFS, используя задания JDBCHDFC Spring Batch. Но если эти контейнеры терпят неудачу, задание не переходит в другой контейнер. Как мне поступить, чтобы сделать работу отказоустойчивой. Я использую выпуск...
122 просмотров

Spring-xd — ошибка при попытке потоковой передачи данных с помощью Twittersearch
Я создал поток, который записывает твиты в файл с помощью этого весеннего кода xd: stream create --name javatweets --definition "twittersearch --query=java --consumerKey=<my_key> --consumerSecret=<my_secret> | file" --deploy К...
179 просмотров
schedule 22.02.2023

spring xd job для создания таблицы куста
Я пытаюсь создать задание для spring xd, чтобы можно было создать таблицу кустов. Я пробовал следующее, но это не работает. Любая помощь ? <hdp:configuration> fs.default.name=hdfs://sandbox:8020 </hdp:configuration>...
758 просмотров

Проблема с файловым приемником и выражением имени файла
Попытка настроить простой процесс копирования файлов в spring-xd: stream create --name mystrea --definition "file --dir=/path/source --fixedDelay=5 | sink:file --dir=/path/dest --binary=true --name=headers['file_name']" Кажется, это создает...
285 просмотров
schedule 03.08.2023

Spring XD: как решить, когда использовать потоки или пакетные задания?
В настоящее время мы разрабатываем приложение, которое читает файлы из файловой системы/ftp/http и загружает эти файлы в mongodb. После этого мы хотим проанализировать эти файлы и записать проанализированные документы в mongodb. Требования к этому...
602 просмотров
schedule 07.07.2023

отправка пользовательского объекта из spring-xd в gemfire
Здравствуйте, у меня проблема с записью объекта, который я определил из sprint-xd в gemfire. если развернуть мой класс и если я напишу следующую команду в консоль gemfire, я смогу создать новую запись в регионе, которая содержит объект класса...
217 просмотров
schedule 13.07.2022

Оптимизация gradle для проекта spring-xd с временной зависимостью от scala
Я работаю над проектом, который содержит серию подпроектов модулей для Spring XD, которые имеют временную зависимость от немодульного подпроекта, который использует Scala: ext { springXdVersion = '1.1.0.RELEASE' moduleProjects =...
81 просмотров
schedule 01.01.2023

Команда удаления модуля SpringXD не удаляет загруженный файл .jar
Проблема Команда удаления модуля SpringXD удаляет модуль из SpringXD DIRT (команда списка модулей не показывает модуль удаления), но не удаляет загруженный файл .jar в каталоге /xd/custom-modules/job. Причина в том, что файл .jar используется...
918 просмотров
schedule 10.12.2022

Каковы минимальные технические характеристики компьютера, необходимые для процессов администрирования и контейнера?
В справочном материале просто указано, что JDK7 требуется для Spring XD . Каковы минимальные требования (ОЗУ, ЦП, диск) для хостов, предназначенных для запуска Spring XD Admin? Каковы минимальные требования (ОЗУ, ЦП, диск) для хостов,...
190 просмотров
schedule 28.05.2022

Развертывание прямой привязки с Kafka в качестве шины сообщений
Я пытаюсь использовать прямую привязку к следующему потоку. stream create --definition "time | log" --name ticktock stream deploy ticktock --properties module.*.count=0 Развертывание завершается с ошибкой с этим исключением как на узле...
107 просмотров
schedule 20.12.2022

Зависимости Maven для разработки пользовательских модулей Spring XD
При разработке пользовательских модулей Spring XD вам необходимо указать spring-xd-module-parent в качестве родительского проекта, однако самая последняя версия Spring XD в maven Central — 1.0.4, а не 1.2.1. Является ли это упущением или мне нужно...
206 просмотров
schedule 23.05.2023

Spring XD, Reactor Streams: конфигурация без XML?
На http://docs.spring.io/spring-xd/docs/1.2.1.RELEASE/reference/html/#reactor-streams документировано, как Reactor Stream реализован в Spring XD. В соответствии с этой документацией я создал собственное приложение:...
328 просмотров

Кластер искры + Spring XD
Я пытаюсь запустить процессор Spark на Spring XD для потоковой передачи. Модуль процессора spark в Spring XD работает, когда spark указывает на локальный. Процессор не запускается, когда мы указываем искру на автономную искру (работающую на той же...
667 просмотров
schedule 21.04.2023

Как включить административные функции для уведомления о статусе пакетного задания в распределенной системе выполнения Spring XD
У нас есть небольшой кластер. В котором распределенная архитектура времени выполнения spring xd является компонентом для ETL. Мы запланировали пакетное задание в нем с помощью cron. Но когда задание завершается сбоем или прерывается, мы не получаем...
112 просмотров

Требования к порту пряжи Spring xd
Я настраиваю Spring xd на пряже. Для импорта данных, экспорта и обработки с помощью spring xd на пряже, все порты которой необходимо открыть для узлов данных внутри кластера. Я вижу порт для redis, rabbit, базы данных, которую мы собираемся...
44 просмотров
schedule 06.01.2023

Исключение при получении статуса выполнения задания в Spring-XD Admin
Я пытаюсь увидеть статус выполнения задания, которое я запускал, но в некоторых случайных точках я получаю следующую ошибку: 2015-10-14T14:41:24-0400 1.2.0.RELEASE ERROR qtp195949131-28 rest.RestControllerAdvice - Caught exception while handling a...
182 просмотров
schedule 10.10.2022

Счетчик значения поля SpringXD не работает после разделения массива объектов Json на отдельные объекты
Допустим, мои исходные данные SpringXD содержат массив объектов json (собак), и я хочу подсчитать значение поля (dogType), которое имеет каждый элемент массива (собака). Для этого сначала я определяю входной поток и использую разделитель для...
66 просмотров
schedule 03.08.2022