メインコンテンツまでスキップ

Flink connector

Flink Connector

問題の説明:

Flinkで生成された時間は正常ですが、StarRocksにsinkすると8時間遅れて表示されます。FlinkサーバーとStarRocksサーバーは同じタイムゾーン（Asia/Shanghai UTC/GMT+08:00）にあります。 Flinkのバージョンは1.12で、ドライバは flink-connector-jdbc_2.11です。この問題を解決する方法を教えていただけますか？

解決策:

Flinkのsinkテーブルで、パラメータ '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はテーブル作成文を一括でエクスポートできますか？​

解決策:

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

BEに要求されたメモリがオペレーティングシステムに返されません​

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

問題の説明:

このパッケージはAliyunミラーアドレスから取得する必要があります。

解決策:

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

設定されている場合は、以下の設定に変更してください:aliyunmaven central aliyun public repo https: //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つのしきい値のうち、最初に達したものが最初に適用されます。これはチェックポイント間隔の値には影響を受けず、精確に一度だけ動作します。interval-msは at_least_once によって使用されます。