Вопросы с тегом искровой-потоковый

1 голос

0 ответов

Возможно ли иметь больше активных задач, чем количество ядер на исполнителе в Spark-Streaming?

S Mishra / 04 мая 2020

0 голосов

1 ответ

как инициализировать оболочку spark с указанным пользователем c для сохранения данных в hdfs с помощью apache spark

amine djeddi / 04 мая 2020

1 голос

1 ответ

ошибка при попытке сохранить искру датафрейма в файл hdfs

amine djeddi / 03 мая 2020

0 голосов

1 ответ

При принудительном удалении драйвера свечи зажигания драйвер не перезапускается

JDev / 02 мая 2020

0 голосов

1 ответ

Получение ошибки: Исключение в потоке "main" java .lang.NoClassDefFoundError: org / apache / spark / SparkConf

Harsh Somani / 01 мая 2020

0 голосов

0 ответов

Spark Streaming / Запись в CSV или TEXT

Francisco Vigo / 01 мая 2020

1 голос

1 ответ

Пример запуска Spark: ClassNotFoundException: org. apache .kafka.common.serialization.StringDeserializer

Daniel Germain / 30 апреля 2020

0 голосов

1 ответ

Чтение метки времени с использованием DStream API в Spark Straming от Kafka

Boni García / 30 апреля 2020

0 голосов

0 ответов

Как выбрать тип транспортного средства из входящего потока?

Kush Singh / 30 апреля 2020

0 голосов

1 ответ

Spark Streaming handle Перекошенные перегородки Kafka

dunlu_98k / 30 апреля 2020

0 голосов

0 ответов

Как можно применить внешнюю функцию для искры потоковой передачи данных

Hager Saleh / 28 апреля 2020

0 голосов

1 ответ

Почему в формате df write console ничего не отображается?

pinku / 26 апреля 2020

0 голосов

1 ответ

потоковое воспроизведение: выполните ежедневную агрегацию

romborimba / 23 апреля 2020

1 голос

1 ответ

Как мне прочитать одно и то же начальное смещение в каждой микропакете в задании потоковой передачи с искрой

conetfun / 23 апреля 2020

0 голосов

1 ответ

При потоковой передаче Spark создается исключение java .util.ConcurrentModificationException при добавлении JsonArray.

boy / 23 апреля 2020

0 голосов

0 ответов

pyspark Потоковая агрегация на основе меньших

romborimba / 22 апреля 2020

1 голос

0 ответов

Как оптимизировать задержку в работе Spark Streaming при чтении данных из Kafka?

Alex / 22 апреля 2020

0 голосов

1 ответ

Удалять дубликаты с течением времени в pyspark

romborimba / 21 апреля 2020

1 голос

2 ответов

Кафка-сообщение в реальном времени для ElasticSearch с использованием Apache Spark Streaming

AIZ / 21 апреля 2020

0 голосов

0 ответов

NoFileException при записи данных из структурированного потока в контрольную точку S3

Alchemist / 20 апреля 2020

0 голосов

0 ответов

Где поставить awaitTermination () при использовании foreachBatch - потоковая передача pyspark

ChrisAdkin / 20 апреля 2020

0 голосов

0 ответов

Функция CTE с искрой sql

santoXme / 19 апреля 2020

0 голосов

1 ответ

Подсчет записей Spark RDD и Incoordination веб-интерфейса Spark Streaming

sem / 16 апреля 2020

3 голосов

0 ответов

Получение центров кластера в режиме реального времени с использованием искры StreamingKMeans

lior itzhak / 15 апреля 2020

0 голосов

0 ответов

Почему в искровой структурированной потоковой передаче он не фиксируется, пока не будет готова новая партия?

Rob / 15 апреля 2020