Обработчик данных выборки MySQL зависает при втором запуске - PullRequest
Новая
       77

Обработчик данных выборки MySQL зависает при втором запуске

0 голосов
/ 25 сентября 2018

У меня простой процессор mysql GenerateTableFetch, который бесконечно зависает при втором запуске.Когда я запускаю поток - работает как чудо, и на следующем запланированном запуске он застрял.

Поток: взять данные с удаленного сервера MySQL из одной таблицы, выполнить преобразования и поместить их на сервер SQL.

Flow

Processor

Connection pool

Расположение драйвера Mysql: файл: /// home / user / jdbc / mysql /mysql-connector-java-8.0.12.jar

Nifi версии 1.7.1.

Что я пробовал:

разные коннекторы mysql (5.1.47 и 8.0.12), разные процессоры (QueryDatabaseTable, ExecuteSQL) - все застряли одинаково.

Идентичный поток с сервера sql на сервер sql работает идеально.

Из журнала дампа выглядит как поток, застрявший при попытке закрытьпредыдущее соединение mysql: 

"Abandoned connection cleanup thread" Id=3080 TIMED_WAITING  on java.lang.ref.ReferenceQueue$Lock@607800ac
    at java.lang.Object.wait(Native Method)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144)
    at com.mysql.cj.jdbc.AbandonedConnectionCleanupThread.run(AbandonedConnectionCleanupThread.java:70)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
    Number of Locked Synchronizers: 1
    - java.util.concurrent.ThreadPoolExecutor$Worker@1f01ec47

В чем может быть проблема?Или что я могу проверить дальше?

Спасибо!

...