apache-flink

0зной

1ответ

При упаковке задания на флинк, в котором используются, например, некоторые флинковые соединители и некоторые сторонние библиотеки (для обработки), какие зависимости должны заканчиваться в банке задани

0зной

1ответ

Flink InvocationTargetException. Недостаточное количество сетевых буферов

Это часть исходного кода WordCount.java. public static void main(String[] args) throws Exception { // set up the execution environment final ExecutionEnvironment env = ExecutionEnvironment.

7зной

3ответ

не удалось найти неявное значение параметра доказательства типа org.apache.flink.api.common.typeinfo.TypeInformation [...]

Я пытаюсь написать некоторые варианты использования Apache Flink. Одна ошибка я бегу в довольно часто could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.

0зной

1ответ

Flink Streaming при расчете суммы метания исключения

Я использую пример Flink Streaming, где стеллажи доступны & Я хочу, чтобы вычислить сумму температуры группы по стойке IDs..following мой код: static Properties properties=new Properties(); publi

4зной

1ответ

Вычислить среднее значение с помощью Flink DataStream для продолжительности окна

Я использую API Flink DataStream, где есть места, где имеются стойки & Я хочу рассчитать «среднюю» группу температур по идентификаторам стойки. Мое время окна составляет 40 секунд. & мое окно раздвига

0зной

1ответ

Flink пример пользовательского разметки

Прецедент, что я пытаюсь решить следующим образом: У нас есть поток данных, поступающих из Кафки Мы хотели бы, чтобы гарантировать, что сообщение/записи, содержащие тот же значение для конкретного объ

0зной

1ответ

flink.api.table.TableException: Тип не поддерживается

Я пытаюсь использовать API Flink Table в scala. Нет ошибок при составлении времени, но qhen i'm выполнения задания в моем FLiNK кластера: flink.api.table.TableException: Type is not supported:<Generic