Перейти к основному содержимому

Flink Connector

Описание проблемы:

Время, генерируемое функцией localtimestap, нормальное в Flink. Но оно стало отставать на 8 часов при записи в Selena. Сервер Flink и сервер Selena находятся в одном часовом поясе, а именно Asia/Shanghai UTC/GMT+08:00. Версия Flink 1.12. Драйвер: flink-connector-jdbc_2.11. Можно ли узнать, как решить эту проблему?

Решение:

Пожалуйста, попробуйте настроить параметр времени 'server-time-zone' = 'Asia/Shanghai' в таблице sink Flink. Вы также можете добавить &serverTimezone=Asia/Shanghai в jdbc url. Пример показан ниже:

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 требуется имя хоста. Пользователям необходимо настроить разрешение имен хостов /etc/hosts в узлах кластера Selena.

Может ли Selena экспортировать 'операторы создания таблиц' пакетно?​

Решение:

Вы можете использовать Selena 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]  |
+----------------------+--------------------------------------------------------------+

Если этот параметр установлен как 15s с интервалом checkpoint равным 5 минутам, действует ли это значение по-прежнему?

Решение:

Какой из трех порогов будет достигнут первым, тот и сработает первым. На это не влияет значение интервала checkpoint, которое работает только для exactly once. Interval-ms используется at_least_once.