メインコンテンツまでスキップ
バージョン: 3.1

Flink Connector

問題の説明:

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'
);

問題の説明:

failed to query wartermark offset, err: Local: Bad message format

解決策:

Kafka の通信にはホスト名が必要です。ユーザーは StarRocks クラスターのノードで /etc/hosts のホスト名解決を設定する必要があります。

StarRocks は 'create table statements' をバッチでエクスポートできますか？​

解決策:

StarRocks Tools を使用してステートメントをエクスポートできます。

BE によって要求されたメモリがオペレーションシステムに戻されない​

これは通常の現象です。オペレーティングシステムからデータベースに割り当てられた大きなメモリブロックは、メモリを再利用し、メモリ割り当てをより便利にするために、割り当て時に予約され、解放時に遅延されます。ユーザーは、長期間にわたってメモリ使用量を監視することで、メモリが解放されるかどうかを確認するために、テスト環境を検証することをお勧めします。

問題の説明:

このパッケージは、Aliyun ミラーアドレスを通じて取得する必要があります。

解決策:

/etc/maven/settings.xml のミラー部分がすべて Aliyun ミラーアドレスを通じて取得されるように設定されていることを確認してください。

もしそうであれば、次のように変更してください:

aliyunmaven centralaliyun public repohttps: //maven.aliyun.com/repository/public

問題の説明:

+----------------------+--------------------------------------------------------------+
|         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 に使用されます。