Где скачать правильный JAR-файл соединителя Flink ClickHouse для Flink 1.18?JAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Где скачать правильный JAR-файл соединителя Flink ClickHouse для Flink 1.18?

Сообщение Anonymous »

Я использую Flink 1.18 (автономный/Docker) с использованием PyFlink и пытаюсь передать данные из Pulsar в ClickHouse с помощью Table API.
Сначала я попробовал стандартный универсальный соединитель JDBC, но столкнулся с ошибкой NoDialectFactory, поскольку стандартный соединитель JDBC не поддерживает диалект ClickHouse напрямую.
Сейчас я ищу выделенный JAR-файл flink-connector-clickhouse, совместимый с Flink 1.18.
Может ли кто-нибудь предоставить рабочую прямую ссылку для скачивания (Maven Central или иную) для скомпилированного JAR-файла, который я могу просто поместить в папку lib/ Flink, чтобы использовать соединитель = 'clickhouse'?
Моя среда:
  • Версия Flink: 1.18.0
  • Версия Python: 3.10
Цель: СОЗДАТЬ ТАБЛИЦУ ... С ('connector' = 'clickhouse', ...)

Подробнее здесь: https://stackoverflow.com/questions/798 ... flink-1-18
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»