flink1.11连接mysql问题

classic Classic list List threaded Threaded
5 messages Options
Reply | Threaded
Open this post in threaded view
|

flink1.11连接mysql问题

酷酷的浑蛋
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’也不管用

Reply | Threaded
Open this post in threaded view
|

Re: flink1.11连接mysql问题

Danny Chan
这个问题已经有 issue 在追踪了 [1]

[1] https://issues.apache.org/jira/browse/FLINK-12494

Best,
Danny Chan
在 2020年8月28日 +0800 PM3:02,[hidden email],写道:
>
> CommunicationsException
Reply | Threaded
Open this post in threaded view
|

Re: flink1.11连接mysql问题

Leonard Xu
In reply to this post by 酷酷的浑蛋


> 在 2020年8月28日,15:02,酷酷的浑蛋 <[hidden email]> 写道:
>
> 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>

Reply | Threaded
Open this post in threaded view
|

回复: flink1.11连接mysql问题

酷酷的浑蛋


下面是我连接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<[hidden email]> 写道:


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

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>

Reply | Threaded
Open this post in threaded view
|

Re: 回复: flink1.11连接mysql问题

amenhub@163.com
如果是mysql5.x以上的版本,url中autoReconnect参数会无效吧,

可以尝试下修改配置文件wait_timeout/interactive_out参数

best,
amenhub
 
发件人: 酷酷的浑蛋
发送时间: 2020-08-31 20:48
收件人: [hidden email]
主题: 回复: flink1.11连接mysql问题
 
 
下面是我连接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<[hidden email]> 写道:
 
 
在 2020年8月28日,15:02,酷酷的浑蛋 <[hidden email]> 写道:
 
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>