apache-flink

1зной

1ответ

Флинк: не удается отменить текущую работу (потоковая передача)

Я хочу запустить потоковое задание. Когда я пытаюсь запустить его локально, используя start-clusted.sh и интерфейс Flink Web, у меня нет проблем. Однако, я в настоящее время пытаюсь запустить свою раб

apache-flink flink-streaming 2016-10-19

---

1зной

1ответ

NoSuchMethodError при отправке Flink job

Я пытаюсь подключить Flink с Cassandra. Я бегу пример программы из Github, но я получаю следующее сообщение об ошибке: Exception in thread "main" java.lang.NoSuchMethodError: org.apache.flink.streamin

java apache-flink 2016-10-20

---

0зной

1ответ

Слишком много ошибок при открытии файлов при чтении из каталога

Я использую readTextFile (/ path/to/dir), чтобы читать партии файлов, делать некоторые манипуляции на линиях и сохранять их в cassandra. Все, казалось, работало нормально, пока я не достиг более 170 ф

apache-flink 2016-10-20

---

4зной

1ответ

Как получить Partitioner в Apache Flink?

Мы пытаемся создать расширение для Apache Flink, которое использует настраиваемое разделение. Для некоторых операторов мы хотим проверить/извлечь использованный разделитель. К сожалению, я не мог найт

scala partitioning apache-flink 2016-10-24

---