回复： flink1.11连接mysql问题

Mon, 31 Aug 2020 05:49:38 -0700 


下面是我连接mysql的配置，用的flink-1.11.1，还是报那个错误
CREATE TABLE xx(
  `xx` varchar,
  `xx` varchar
) WITH (
    'connector' = 'jdbc',
    'url' = 'jdbc:mysql://xx/xx?autoReconnect=true&failOverReadOnly=false',
    'table-name' = ‘xx',
    'driver' = 'com.mysql.jdbc.Driver',
    'username' = ‘xx',
    'password' = ‘xx',
    'scan.partition.column' = 'id',
    'scan.partition.num' = '50',
    'scan.partition.lower-bound' = '500',
    'scan.partition.upper-bound' = '1000',
    'scan.fetch-size' = '100',
    'lookup.cache.max-rows' = '5000',
    'lookup.cache.ttl' = '10s'
);
在2020年08月31日 17:33，Leonard Xu<[email protected]> 写道：


在 2020年8月28日，15:02，酷酷的浑蛋 <[email protected]> 写道：

com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: The last packet 
successfully received from the server was 52,445,041 milliseconds ago. The last 
packet sent successfully to the server was 52,445,045 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, 
orusing the Connector/J connection property 'autoReconnect=true' to avoid this 
problem.




flink连接mysql，在过了一定时间后，就断开连接了，设置'autoReconnect=true’也不管用



Hi

超时断开问题在1.11应该已经修复[1]，你是怎么使用的？可以提供更多的信息吗

Best
Leonard
[1]https://issues.apache.org/jira/browse/FLINK-16681 
<https://issues.apache.org/jira/browse/FLINK-16681>

回复