flink開發遇到的問題總結

2021-10-13 21:06:30 字數 2435 閱讀 7854

flink開發遇到的問題總結

問題1:

exception

inthread

"main"

org.

apache

.flink

.table

.api

.nomatchingtablefactoryexception:

could

notfind

asuitable

table

factory

for'org.apache.flink.table.factories.tablesinkfactory'

inthe

classpath

.

org.apache.flink.table.factories.tablesinkfactory 在如下依賴裡面可以找到:

<

dependency

>

<

groupid

>

org.

apache

.flink

<

/groupid

>

<

artifactid

>

flink-table-common

<

/artifactid

>

<

version

>

1.10

.0<

/version

>

<

scope

>

provided

<

/scope

>

<

/dependency

>

參考:

或者:(2)匯入如下依賴:

<

dependency

>

<

groupid

>

org.

apache

.flink

<

/groupid

>

<

artifactid

>

flink-jdbc_2.11

<

/artifactid

>

<

version

>

1.10

.0<

/version

>

<

/dependency

>

問題2:

sun

nov2901:

07:23cst

2020

warn:

establishing

sslconnection

without

server's

identity

verification

isnot

recommended

.according

tomysql

5.5.45+,

5.6.26

+and

5.7.6

+requirements

sslconnection

must

beestablished

bydefault

ifexplicit

option

isn'

tset

.for

compliance

with

existing

notusing

sslthe

verifyservercertificate

property

isset

to'false'

.you

need

either

toexplicitly

disable

sslby

setting

usessl

=false,or

setusessl

=true

andprovide

truststore

forserver

certificate

verification

.

解決:

connector

.url

' = '

jdbc:mysql://

localhost:

3307

/test?characterencoding=utf-8&

usessl

=false

'

flink 運維中遇到的問題

不要去設定什麼環境變數 網上的答案大多數都是對官方文件的誤解 只需要執行 export hadoop classpath hadoop classpath 即可其實hadoop classpath 命令就是把有關於hadoop的環境全部載入出來 連不上8032埠 flink on yarn 只能在 ...

6 5 開發中遇到的問題總結

今天在測試時發現,當多個執行緒同時往networkstream裡寫入不同的命令時,出現問題,描述如下 1。假設執行緒1要發命令 a 然後伺服器收到a之後返回相應的操作,執行緒2傳送命令b,伺服器收到命令b後返回相應的操作 2.由於在傳送b命令之前沒有考慮,已經寫進networkstream中的命令a...

Access開發遇到的問題與總結

問題 1.欄位限制。當字元數超過65000時,報錯。查詢過於複雜。解決辦法 可以通過使用preparedstatement 的引數查詢功能解決。示例 string sql insert into table title,legislationnumber,assentdate,href,texts ...