Ich verwende Flink 1.18 (Standalone/Docker) mit PyFlink und versuche, Daten mithilfe der Tabellen-API von Pulsar zu ClickHouse zu übertragen.
Ich habe zunächst den generischen Standard-JDBC-Connector ausprobiert, bin aber auf den NoDialectFactory-Fehler gestoßen, weil der Standard-JDBC-Connector den ClickHouse-Dialekt nicht direkt unterstützt.
Ich suche jetzt nach dem dedizierten flink-connector-clickhouse JAR, das mit Flink 1.18 kompatibel ist.
Könnte mir bitte jemand einen funktionierenden direkten Download-Link (Maven Central oder anders) für das kompilierte JAR bereitstellen, den ich einfach in meinen Flink lib/-Ordner legen kann, um Connector = 'clickhouse' zu verwenden?
Meine Umgebung:
Flink-Version: 1.18.0
Python-Version: 3.10
Ziel: TABELLE ERSTELLEN ... MIT ('connector' = 'clickhouse', ...)
Vielen Dank im Voraus!
Wo kann man die richtige Flink ClickHouse Connector JAR für Flink 1.18 herunterladen? ⇐ Java
-
- Similar Topics
- Replies
- Views
- Last post
Mobile version