Wed Sep  :: GMT+:  WARN: Establishing SSL connection without server's identity verification is not recommended. According to MySQL 5.5.45+, 5.6.26+ and 5.7.6+ requirements SSL connection must be established by default if explicit option isn't set. For compliance with existing applications not using SSL the verifyServerCertificate property is set to 'false'. You need either to explicitly disable SSL by setting useSSL=false, or set useSSL=true and provide truststore for server certificate verification.

Wed Sep  :: GMT+:  WARN: Establishing SSL connection without server's identity verification is not recommended. According to MySQL 5.5.45+, 5.6.26+ and 5.7.6+ requirements SSL connection must be established by default if explicit option isn't set. For compliance with existing applications not using SSL the verifyServerCertificate property is set to 'false'. You need either to explicitly disable SSL by setting useSSL=false, or set useSSL=true and provide truststore for server certificate verification.

-- ::00.722 [pool--thread-] ERROR com.alibaba.druid.pool.DruidDataSource - discard connection

com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: The last packet successfully received from the server was  milliseconds ago.  The last packet sent successfully to the server was ,, milliseconds ago. is longer than the server configured value of 'wait_timeout'. You should consider either expiring and/or testing connection validity before use in your application, increasing the server configured values for client timeouts, or using the Connector/J connection property 'autoReconnect=true' to avoid this problem.

    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)

    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:)

    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:)

    at java.lang.reflect.Constructor.newInstance(Constructor.java:)

    at com.mysql.jdbc.Util.handleNewInstance(Util.java:)

    at com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:)

    at com.mysql.jdbc.MysqlIO.send(MysqlIO.java:)

    at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:)

    at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:)

    at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:)

    at com.mysql.jdbc.StatementImpl.executeSimpleNonQuery(StatementImpl.java:)

    at com.mysql.jdbc.RowDataDynamic.close(RowDataDynamic.java:)

    at com.mysql.jdbc.ResultSetImpl.realClose(ResultSetImpl.java:)

    at com.mysql.jdbc.ResultSetImpl.close(ResultSetImpl.java:)

    at com.alibaba.druid.pool.DruidPooledResultSet.close(DruidPooledResultSet.java:)

    at com.alibaba.otter.canal.client.adapter.support.Util.sqlRS(Util.java:)

    at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.subTableSimpleFieldOperation(ESSyncService.java:)

    at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.update(ESSyncService.java:)

    at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.sync(ESSyncService.java:)

    at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.sync(ESSyncService.java:)

    at com.alibaba.otter.canal.client.adapter.es.ESAdapter.sync(ESAdapter.java:)

    at com.alibaba.otter.canal.client.adapter.es.ESAdapter.sync(ESAdapter.java:)

    at com.alibaba.otter.canal.adapter.launcher.loader.AbstractCanalAdapterWorker.batchSync(AbstractCanalAdapterWorker.java:)

    at com.alibaba.otter.canal.adapter.launcher.loader.AbstractCanalAdapterWorker.lambda$null$(AbstractCanalAdapterWorker.java:)

    at java.util.ArrayList.forEach(ArrayList.java:)

    at com.alibaba.otter.canal.adapter.launcher.loader.AbstractCanalAdapterWorker.lambda$null$(AbstractCanalAdapterWorker.java:)

    at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:)

    at java.util.concurrent.FutureTask.run(FutureTask.java)

    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:)

    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:)

    at java.lang.Thread.run(Thread.java:)

Caused by: java.net.SocketException: Software caused connection abort: socket write error

    at java.net.SocketOutputStream.socketWrite0(Native Method)

    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:)

    at java.net.SocketOutputStream.write(SocketOutputStream.java:)

    at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:)

    at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:)

    at com.mysql.jdbc.MysqlIO.send(MysqlIO.java:)

    ...  common frames omitted

-- ::00.867 [pool--thread-] ERROR com.alibaba.otter.canal.client.adapter.support.Util - sqlRs has error, sql: SELECT * FROM (SELECT user_id, group_concat(label ORDER BY id DESC SEPARATOR ';') AS labels

FROM label

GROUP BY user_id) c WHERE c.user_id=

-- ::00.867 [pool--thread-] ERROR c.a.otter.canal.client.adapter.es.service.ESSyncService - sync error, es index: erdp-join, DML : Dml{destination='example', database='elppmdb', table='label', type='UPDATE', es=, ts=, sql='', data=[{id=, user_id=, name=ttt, label=lab-rst, c_time=-- ::19.0}], old=[{label=lab-rs, c_time=-- ::04.0}]}

-- ::00.923 [pool--thread-] ERROR c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - java.lang.RuntimeException: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: The last packet successfully received from the server was  milliseconds ago.  The last packet sent successfully to the server was ,, milliseconds ago. is longer than the server configured value of 'wait_timeout'. You should consider either expiring and/or testing connection validity before use in your application, increasing the server configured values for client timeouts, or using the Connector/J connection property 'autoReconnect=true' to avoid this problem.

java.lang.RuntimeException: java.lang.RuntimeException: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: The last packet successfully received from the server was  milliseconds ago.  The last packet sent successfully to the server was ,, milliseconds ago. is longer than the server configured value of 'wait_timeout'. You should consider either expiring and/or testing connection validity before use in your application, increasing the server configured values for client timeouts, or using the Connector/J connection property 'autoReconnect=true' to avoid this problem.

    at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.sync(ESSyncService.java:)

    at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.sync(ESSyncService.java:)

    at com.alibaba.otter.canal.client.adapter.es.ESAdapter.sync(ESAdapter.java:)

    at com.alibaba.otter.canal.client.adapter.es.ESAdapter.sync(ESAdapter.java:)

    at com.alibaba.otter.canal.adapter.launcher.loader.AbstractCanalAdapterWorker.batchSync(AbstractCanalAdapterWorker.java:)

    at com.alibaba.otter.canal.adapter.launcher.loader.AbstractCanalAdapterWorker.lambda$null$(AbstractCanalAdapterWorker.java:)

    at java.util.ArrayList.forEach(ArrayList.java:)

    at com.alibaba.otter.canal.adapter.launcher.loader.AbstractCanalAdapterWorker.lambda$null$(AbstractCanalAdapterWorker.java:)

    at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:)

    at java.util.concurrent.FutureTask.run(FutureTask.java)

    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:)

    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:)

    at java.lang.Thread.run(Thread.java:)

Caused by: java.lang.RuntimeException: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: The last packet successfully received from the server was  milliseconds ago.  The last packet sent successfully to the server was ,, milliseconds ago. is longer than the server configured value of 'wait_timeout'. You should consider either expiring and/or testing connection validity before use in your application, increasing the server configured values for client timeouts, or using the Connector/J connection property 'autoReconnect=true' to avoid this problem.

    at com.alibaba.otter.canal.client.adapter.support.Util.sqlRS(Util.java:)

    at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.subTableSimpleFieldOperation(ESSyncService.java:)

    at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.update(ESSyncService.java:)

    at com.alibaba.otter.canal.client.adapter.es.service.ESSyncService.sync(ESSyncService.java:)

    ...  common frames omitted

Caused by: com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: The last packet successfully received from the server was  milliseconds ago.  The last packet sent successfully to the server was ,, milliseconds ago. is longer than the server configured value of 'wait_timeout'. You should consider either expiring and/or testing connection validity before use in your application, increasing the server configured values for client timeouts, or using the Connector/J connection property 'autoReconnect=true' to avoid this problem.

    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)

    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:)

    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:)

    at java.lang.reflect.Constructor.newInstance(Constructor.java:)

    at com.mysql.jdbc.Util.handleNewInstance(Util.java:)

    at com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:)

    at com.mysql.jdbc.MysqlIO.send(MysqlIO.java:)

    at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:)

    at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:)

    at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:)

    at com.mysql.jdbc.StatementImpl.executeSimpleNonQuery(StatementImpl.java:)

    at com.mysql.jdbc.RowDataDynamic.close(RowDataDynamic.java:)

    at com.mysql.jdbc.ResultSetImpl.realClose(ResultSetImpl.java:)

    at com.mysql.jdbc.ResultSetImpl.close(ResultSetImpl.java:)

    at com.alibaba.druid.pool.DruidPooledResultSet.close(DruidPooledResultSet.java:)

    at com.alibaba.otter.canal.client.adapter.support.Util.sqlRS(Util.java:)

    ...  common frames omitted

Caused by: java.net.SocketException: Software caused connection abort: socket write error

    at java.net.SocketOutputStream.socketWrite0(Native Method)

    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:)

    at java.net.SocketOutputStream.write(SocketOutputStream.java:)

    at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:)

    at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:)

    at com.mysql.jdbc.MysqlIO.send(MysqlIO.java:)

    ...  common frames omitted

-- ::01.447 [Thread-] ERROR c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - process error!

com.alibaba.otter.canal.protocol.exception.CanalClientException: java.io.IOException: 你的主机中的软件中止了一个已建立的连接。

    at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.ack(SimpleCanalConnector.java:)

    at com.alibaba.otter.canal.adapter.launcher.loader.CanalAdapterWorker.process(CanalAdapterWorker.java:)

    at java.lang.Thread.run(Thread.java:)

Caused by: java.io.IOException: 你的主机中的软件中止了一个已建立的连接。

    at sun.nio.ch.SocketDispatcher.write0(Native Method)

    at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:)

    at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:)

    at sun.nio.ch.IOUtil.write(IOUtil.java:)

    at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:)

    at java.nio.channels.Channels.writeFullyImpl(Channels.java:)

    at java.nio.channels.Channels.writeFully(Channels.java:)

    at java.nio.channels.Channels.access$(Channels.java:)

    at java.nio.channels.Channels$.write(Channels.java:)

    at java.nio.channels.Channels$WritableByteChannelImpl.write(Channels.java:)

    at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.writeWithHeader(SimpleCanalConnector.java:)

    at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.writeWithHeader(SimpleCanalConnector.java:)

    at com.alibaba.otter.canal.client.impl.SimpleCanalConnector.ack(SimpleCanalConnector.java:)

    ...  common frames omitted

-- ::01.449 [Thread-] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - =============> Disconnect destination: example <=============

-- ::02.450 [Thread-] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - =============> Start to connect destination: example <=============

-- ::02.454 [Thread-] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - =============> Start to subscribe destination: example <=============

-- ::02.455 [Thread-] INFO  c.a.o.canal.adapter.launcher.loader.CanalAdapterWorker - =============> Subscribe destination: example succeed <=============

-- ::02.476 [pool--thread-] INFO  c.a.o.canal.client.adapter.logger.LoggerAdapterExample - DML: {"data":[{"id":,"user_id":,"name":"ttt","label":"lab-rst","c_time":}],"database":"elppmdb","destination":"example","es":,"groupId":null,"isDdl":false,"old":[{"label":"lab-rs","c_time":}],"pkNames":["id"],"sql":"","table":"label","ts":,"type":"UPDATE"}