Я использую 64 ГБ ОЗУ и 24-ядерный компьютер и выделил 32 ГБ для JVM. Я хотел запустить следующие...

Я использую Spark Structured Streaming для обработки входящих и исходящих потоков данных от и до...

Я создал следующее приложение, которое печатает определенные сообщения в течение 20 секунд: public...

Я запускаю код производителя и потребителя kafka для тестирования в CDH 5.12.Пока я пытаюсь это...

Безопасно ли использовать Kafka и Spark Structured Streaming (SSS) (> = v2.2) с контрольными...

У нас есть некоторые исторические данные, поставленные в очередь по нашим темам, мы не хотим...

Мне нужно написать тест, который должен выполнить запрос на зажигание в локальном режиме в...

Ищите предложения по потоковой передаче искры.Я передаю данные с помощью kafka и сохраняю результат...

использую искру 2.3.И у меня есть почти 30 конфигураций потоковых запросов, которые будут...

У меня есть задание потоковой передачи, которое запускается на EMR, читает сообщения от Kafka и...

При использовании Spark Streaming для использования темы Apache Kafka с прямым потоком ключ данных...

Amazon EMR, Apache Spark 2.3, Apache Kafka, ~ 10 млн. Записей в день. Apache Spark используется для...

У меня есть приложение Scala Spark, в котором мне нужно переключаться между потоковой передачей от...

В одном из моих приложений я включил динамическое распределение с искровым потоком.Это работает...

У меня есть стриминговая работа по чтению сообщений в формате Json из темы кафки.Сценарий: чтение...

Привет, я столкнулся с проблемой при чтении файла журнала приложения из Windows через Apache Flume

Я использую структурную потоковую интеграцию kafka для потоковой передачи данных из концентратора...

Я работаю над небольшим проектом, где я делаю анализ настроений в твиттере.Я довольно новичок в...

Я пишу программу для приема данных.Для чтения из Kafka в DStream разделите Dstrem на 3 потока и...

У нас есть случай использования, когда у нас есть устаревшая система, данные которой находятся в MS...

sparkStreaming получает данные от kafka, затем возвращается к kafka после фильтрации.Я получаю три...

Пока я читаю таблицу из redis, получаю следующее сообщение об ошибке. Код ниже работает нормально....

У меня есть приложение Spark Streaming (Scala), работающее на CDH 5.13, использующее сообщения от...

Структура потоковой передачи Sparks записывает данные в Kafka, выдавая исключение: Невозможно...

У меня в кластере Hortonworks запущено задание потоковой передачи.Я запускаю его в режиме кластера...