Skip to content

Latest commit

 

History

History
61 lines (37 loc) · 3.49 KB

flink_install.md

File metadata and controls

61 lines (37 loc) · 3.49 KB

Flink SQL Client 配置(推荐1.10.0 scala 版本为2.11)

由于DNS污染目前官网的connector下载链接打不开,提供下面备用下载链接

Connector

Formats

一键下载脚本(不包含kafka和Elasticsearch依赖,请单独下载具体使用的kafka版本,注意不要下载多个kafka版本,目前不支持一个集群使用多版本kafka)

cd /opt/flink-1.10.0/lib
for p in '/flink-hbase_2.11/1.10.0/flink-hbase_2.11-1.10.0.jar' '/flink-jdbc_2.11/1.10.0/flink-jdbc_2.11-1.10.0.jar' '/flink-csv/1.10.0/flink-csv-1.10.0-sql-jar.jar' '/flink-json/1.10.0/flink-json-1.10.0-sql-jar.jar' '/flink-avro/1.10.0/flink-avro-1.10.0-sql-jar.jar'
do
  echo "begin download https://repo1.maven.org/maven2/org/apache/flink$p"
  wget "https://repo1.maven.org/maven2/org/apache/flink$p"
done

Option (JDBC Driver)

  • MySQL mysql mysql-connector-java Download
  • PostgreSQL org.postgresql postgresql Download
  • Derby org.apache.derby derby Download

Hive 支持

请参考下面这个项目

flink-hive-dependence

HiveServer2依赖

CentOS:

sudo yum install cyrus-sasl-devel cyrus-sasl-gssapi cyrus-sasl-md5 cyrus-sasl-plain

Ubuntu:

sudo apt-get install sasl2-bin libsasl2-2 libsasl2-dev libsasl2-modules