Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 93f6b7d

Browse files
committedMar 2, 2020
Merge branch 'hotfix_1.8_3.9.x_21763' into '1.8_release_3.9.x'
多维表join See merge request !256
2 parents 08ecc68 + 0beef49 commit 93f6b7d

File tree

115 files changed

+4417
-3433
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

115 files changed

+4417
-3433
lines changed
 

‎README.md

Lines changed: 20 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,18 @@
4848
* Java: JDK8及以上
4949
* Flink集群: 1.4,1.5,1.8(单机模式不需要安装Flink集群)
5050
* 操作系统:理论上不限
51+
* kerberos环境需要在flink-conf.yaml配置security.kerberos.login.keytab以及security.kerberos.login.principal参数,配置案例:
52+
```
53+
## hadoop配置文件路径
54+
fs.hdfs.hadoopconf: /Users/maqi/tmp/hadoopconf/hadoop_250
55+
security.kerberos.login.use-ticket-cache: true
56+
security.kerberos.login.keytab: /Users/maqi/tmp/hadoopconf/hadoop_250/maqi.keytab
57+
security.kerberos.login.principal: maqi@DTSTACK.COM
58+
security.kerberos.login.contexts: Client,KafkaClient
59+
zookeeper.sasl.service-name: zookeeper
60+
zookeeper.sasl.login-context-name: Client
61+
62+
```
5163

5264
### 1.3 打包
5365

@@ -56,9 +68,16 @@
5668
```
5769
mvn clean package -Dmaven.test.skip
5870
59-
打包结束后,项目根目录下会产生plugins目录,plugins目录下存放编译好的数据同步插件包,在lib目下存放job提交的包
6071
```
6172

73+
打包完成后的包结构:
74+
75+
> * dt-center-flinkStreamSQL
76+
> > * bin: 任务启动脚本
77+
> > * lib: launcher包存储路径,是任务提交的入口
78+
> > * plugins: 插件包存储路径
79+
> > * ........ : core及插件代码
80+
6281
### 1.4 启动
6382

6483
#### 1.4.1 启动命令

‎cassandra/cassandra-side/cassandra-all-side/pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@
3636
<goal>shade</goal>
3737
</goals>
3838
<configuration>
39+
<createDependencyReducedPom>false</createDependencyReducedPom>
3940
<artifactSet>
4041
<excludes>
4142
<exclude>org.slf4j</exclude>

0 commit comments

Comments
 (0)
Please sign in to comment.