apache-flink

1зной

1ответ

Что такое замена EventTimeSourceFunction (Flink 0.10.x) в Flink 1.x?

Я пытаюсь перенести пример SlidingArrivalCount.scala, основанный на Flink 0.10.1 на Flink 1.1.1. Источник данных источника данных TaxiRideSource, используемый в примере, реализует интерфейс org.apache

4зной

1ответ

Флинк не запускает мое приложение из-за ошибки invalidtypes при использовании java8 lambdas

Я использую Flink и Java8. При использовании лямбда-функций с кортежами и родовых типов, мой компилятор заканчивается исключением /Library/Java/JavaVirtualMachines/jdk1.8.0_102.jdk/Contents/Home/bin/j

2зной

1ответ

Scala WindowFunction не компилируется

Я пишу прототип приложения, используя Apache Flink. В этом процессе я решил использовать org.apache.flink.streaming.api.functions.windowing.WindowFunction для конкретного примера использования. Однако

7зной

1ответ

Зачем кому-то запускать Spark/Flink на Tez? .

В Tez paper из Саа и др следующим модульная архитектура Hadoop 2 с Tez показано: Почему бы кто-то запустить Спарк/Flink на Tez? В чем преимущества? Лучше использовать YARN?

1зной

2ответ

Ошибка Flink конвертировать в паркет

Я пытаюсь использовать flink, чтобы написать файл csv как паркет. Я использую следующий код и получаю сообщение об ошибке. val parquetFormat = new HadoopOutputFormat[Void, String](new AvroParquetOutpu

1зной

1ответ

AWS EMR - веб-клиент Apache Flink

Есть ли способ запустить веб-клиент Flink, чтобы разрешить отправку материалов при работе с использованием AWS EMR? Я загрузил FLink 1.1.2 и в старые документы < 1.0 Я вижу ссылки на ./bin/start-webcl