apache-flink

2зной

1ответ

SBT сборки плагин включает в себя «при условии» библиотеки, и это родословная

Вот мой build.sbt resolvers ++= Seq("Apache Development Snapshot Repository" at "https://repository.apache.org/content/repositories/snapshots/", Resolver.mavenLocal) name := "flink-wiki-edits"

2зной

1ответ

Что такое непринужденный способ дать подсказкам типа для вывода потоков вывода?

Я работал в InvalidTypesException s в Flink, как правило, при настройке общего SourceFunction<OUT>. Вот пример, который при добавлении к моему StreamExecutionEnvironment, броски эти исключения во врем

3зной

1ответ

Watermarks в Apache Flink

Будет полезно, если кто-то дать USECASE пример, чтобы объяснить разницу между каждым из водяного знака API с Apache FLiNK приведены ниже Периодические водяные знаки - AssignerWithPeriodicWatermarks [T

1зной

2ответ

Flink: Ошибка выполнения кластера потери Taskmanager

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

1зной

1ответ

Как Флинк (источник Кафки) управляет смещениями?

Я использую Flink's FlinkKafkaConsumer09, и я задаюсь вопросом, где хранятся запасные части потребителя kafka? Я не могу найти их в Zookeeper или в теме смещения Кафки. Также инструмент kafka-consumer

3зной

3ответ

Flink Streaming - примените функцию в окнах

Я новичок в флинках и потоках. Я хочу применить определенную функцию для каждого раздела к каждому окну потока (используется время события). То, что я сделал до сих пор это: val env = StreamExecutionE

0зной

1ответ

Usecases для GroupCombine in flink

Может ли кто-нибудь предоставить некоторый свет на практические применения GroupCombine Grouped Dataset в Apache flink. Ref: https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/batch/datas