Flink Connector
flink-connector-jdbc_2.11sink が StarRocks で 8 時間遅れている
問題の説明:
localtimestap 関数によって生成された時間は Flink では正常です。しかし、StarRocks に送信されたときに 8 時間遅れました。Flink サーバーと StarRocks サーバーは同じタイムゾーン、つまり Asia/Shanghai UTC/GMT+08:00 にあります。Flink のバージョンは 1.12 です。ドライバー: flink-connector-jdbc_2.11。この問題を解決する方法を教えてください。
解決策:
Flink のシンクテーブルで時間パラメータ 'server-time-zone' = 'Asia/Shanghai' を設定してみてください。また、jdbc URL に &serverTimezone=Asia/Shanghai を追加することもできます。以下に例を示します:
CREATE TABLE sk (
sid int,
local_dtm TIMESTAMP,
curr_dtm TIMESTAMP
)
WITH (
'connector' = 'jdbc',
'url' = 'jdbc:mysql://192.168.110.66:9030/sys_device?characterEncoding=utf-8&serverTimezone=Asia/Shanghai',
'table-name' = 'sink',
'driver' = 'com.mysql.jdbc.Driver',
'username' = 'sr',
'password' = 'sr123',
'server-time-zone' = 'Asia/Shanghai'
);
Flink インポートでは、StarRocks クラスターにデプロイされた kafka クラスターのみをインポートできる
問題の説明:
failed to query wartermark offset, err: Local: Bad message format
解決策:
Kafka の通信にはホスト名が必要です。ユーザーは StarRocks クラスターのノードでホスト名解決 /etc/hosts を設定する必要があります。
StarRocks は 'create table statements' をバッチでエクスポートできますか？
解決策:
StarRocks Tools を使用してステートメントをエクスポートできます。
BE によって要求されたメモリがオペレーションシステムに戻されない
これは通常の現象です。オペレーティングシステムからデータベースに割り当てられた大きなメモリブロックは、メモリを再利用し、メモリ割り当てをより便利にするために、割り当て時に予約され、解放時に遅延されます。ユーザーは、長期間にわたってメモリ使用量を監視することで、メモリが解放されるかどうかを確認するためにテスト環境を検証することをお勧めします。
ダウンロード後に Flink コネクタが機能しない
問題の説明:
このパッケージは、Aliyun ミラーアドレスを通じて取得する必要があります。
解決策:
/etc/maven/settings.xml のミラー部分がすべて Aliyun ミラーアドレスを通じて取得されるように設定されていることを確認してください。
もしそうであれば、次のように変更してください:
Flink-connector-StarRocks のパラメータ sink.buffer-flush.interval-ms の意味
問題の説明:
+----------------------+--------------------------------------------------------------+
| Option | Required | Default | Type | Description |
+-------------------------------------------------------------------------------------+
| sink.buffer-flush. | NO | 300000 | String | the flushing time interval, |
| interval-ms | | | | range: [1000ms, 3600000ms] |
+----------------------+--------------------------------------------------------------+
このパラメータが 15 秒に設定され、チェックポイント間隔が 5 分に等しい場合、この値はまだ有効ですか？
解決策:
3 つのしきい値のうち、どれかが最初に達成されると、そのしきい値が最初に有効になります。これは、チェックポイント間隔の値には影響されません。チェックポイント間隔の値は、exactly once にのみ機能します。interval-ms は at_least_once によって使用されます。
Flink Connector を使用した部分更新が "NULL value in non-nullable column" で失敗するのはなぜですか？
次のプロパティを設定します。
sink.properties.partial_update=true
sink.properties.columns=<primary_key,columns_to_update>
JSON データを使用した Flink インポートエラー "The size of this batch exceed the max size [104857600]" をどのように処理しますか？
バッチ頻度を減らすか、sink.properties.ignore_json_size を true に設定します（これによりメモリ使用量が増加する可能性があります）。
Flink CDC で bigint unsigned フィールドが文字列に変換され、その値が変更された場合はどうすればよいですか？
次の設定を追加します。
'debezium.bigint.unsigned.handling.mode' = 'precise'
Flink コネクタを使用してデータをインポートする際に "None of hosts in load_url could be connected" と表示されるのはなぜですか？
load_url が到達不能またはタイムアウトしています。プロパティ sink.connect.timeout-ms の値を増やします（範囲：[100, 60000]）。
Kafka を消費する際に Routine Load が "Bad message format" を報告するのはなぜですか？
Kafka は通信にホスト名を使用します。StarRocks ノードをホストするすべてのサーバーの /etc/hosts に Kafka ノードのホスト名解決を追加します。
