search

apache / flink-cdc

Flink CDC is a streaming data integration tool
https://nightlies.apache.org/flink/flink-cdc-docs-stable
Apache License 2.0
5.7k stars 1.94k forks source link

Connect to mariadb: TLS change to TCP #1663

Closed water5-cmd closed 8 months ago

water5-cmd commented 2 years ago

Hi, @GOODBOY008, @leonardBang,

I tried to connect to EdgelessDB (5.5.5-10.5.11-MariaDB) using Flink CDC, and through the error log and tcpdump, I found Flink CDC keeps establishing a connection with EdgelessDB, the first two connections used TLSv1.2, but on the third time, it changed to TCP, and thus error occurs.

Environment :

To Reproduce Steps to reproduce the behavior:

  1. The test code : 
    
Flink SQL> CREATE TABLE user_source3 (
>       `id` int,
>       name STRING,
>       age int,
>       PRIMARY KEY (`id`) NOT ENFORCED
>     ) WITH (
>       'connector' = 'mysql-cdc',
>       'hostname' = '10.0.23.102',
>       'port' = '3307',
>       'username' = 'test',
>       'password' = '123',
>       'database-name' = 'demo',
>       'table-name' = 'student1',
>       'jdbc.properties.enabledTLSProtocols' = 'TLSv1.2',
>       'jdbc.properties.useSSL' = 'true', 
>       'jdbc.properties.trustServerCertificate' = 'true'
>  );
[INFO] Execute statement succeed.

Flink SQL> select * from user_source3; [ERROR] Could not execute SQL statement. Reason: java.sql.SQLException: Access denied for user 'test'@'10.0.23.103' (using password: YES)

3. The error:

Access denied for user 'test'@'10.0.23.103' (using password: YES)


**Additional Description**
First look at the tcpdump log,

1 0.000000 10.0.23.103 10.0.23.102 TCP 66 54090 → 3307 [FIN, ACK] Seq=1 Ack=1 Win=501 Len=0 TSval=2335258667 TSecr=2139160802 2 0.000004 10.0.23.103 10.0.23.102 TCP 66 54086 → 3307 [FIN, ACK] Seq=1 Ack=1 Win=546 Len=0 TSval=2335258667 TSecr=2139160802 3 0.000048 10.0.23.102 10.0.23.103 TCP 54 3307 → 54090 [RST] Seq=1 Win=0 Len=0 4 0.000055 10.0.23.102 10.0.23.103 TCP 54 3307 → 54086 [RST] Seq=1 Win=0 Len=0 5 29.002859 10.0.23.103 10.0.23.102 TCP 74 54202 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=2335287670 TSecr=0 WS=128 6 29.002927 10.0.23.102 10.0.23.103 TCP 74 3307 → 54202 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=2139252837 TSecr=2335287670 WS=128 7 29.003326 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=2335287670 TSecr=2139252837 8 29.004590 10.0.23.102 10.0.23.103 TLSv1.2 169 Ignored Unknown Record 9 29.005045 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=2335287672 TSecr=2139252838 10 29.036110 10.0.23.103 10.0.23.102 TLSv1.2 102 Ignored Unknown Record 11 29.036142 10.0.23.102 10.0.23.103 TCP 66 3307 → 54202 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=2139252870 TSecr=2335287703 12 29.280060 10.0.23.103 10.0.23.102 TLSv1.2 362 Client Hello 13 29.280107 10.0.23.102 10.0.23.103 TCP 66 3307 → 54202 [ACK] Seq=104 Ack=333 Win=65024 Len=0 TSval=2139253114 TSecr=2335287947 14 29.282759 10.0.23.102 10.0.23.103 TLSv1.2 777 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done 15 29.283119 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=333 Ack=815 Win=64128 Len=0 TSval=2335287950 TSecr=2139253116 16 29.294228 10.0.23.103 10.0.23.102 TLSv1.2 78 Certificate 17 29.294260 10.0.23.102 10.0.23.103 TCP 66 3307 → 54202 [ACK] Seq=815 Ack=345 Win=65024 Len=0 TSval=2139253128 TSecr=2335287961 18 29.303425 10.0.23.103 10.0.23.102 TLSv1.2 108 Client Key Exchange 19 29.303457 10.0.23.102 10.0.23.103 TCP 66 3307 → 54202 [ACK] Seq=815 Ack=387 Win=65024 Len=0 TSval=2139253137 TSecr=2335287971 20 29.310372 10.0.23.103 10.0.23.102 TLSv1.2 72 Change Cipher Spec 21 29.310404 10.0.23.102 10.0.23.103 TCP 66 3307 → 54202 [ACK] Seq=815 Ack=393 Win=65024 Len=0 TSval=2139253144 TSecr=2335287977 22 29.317323 10.0.23.103 10.0.23.102 TLSv1.2 111 Encrypted Handshake Message 23 29.317354 10.0.23.102 10.0.23.103 TCP 66 3307 → 54202 [ACK] Seq=815 Ack=438 Win=65024 Len=0 TSval=2139253151 TSecr=2335287984 24 29.317840 10.0.23.102 10.0.23.103 TLSv1.2 117 Change Cipher Spec, Encrypted Handshake Message 25 29.318344 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=438 Ack=866 Win=64128 Len=0 TSval=2335287985 TSecr=2139253151 26 29.322530 10.0.23.103 10.0.23.102 TLSv1.2 302 Application Data 27 29.322563 10.0.23.102 10.0.23.103 TCP 66 3307 → 54202 [ACK] Seq=866 Ack=674 Win=64896 Len=0 TSval=2139253156 TSecr=2335287990 28 29.323313 10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data 29 29.323614 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=674 Ack=906 Win=64128 Len=0 TSval=2335287991 TSecr=2139253157 30 29.326029 10.0.23.103 10.0.23.102 TLSv1.2 1071 Application Data 31 29.328870 10.0.23.102 10.0.23.103 TLSv1.2 1237 Application Data 32 29.329367 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=1679 Ack=2077 Win=64128 Len=0 TSval=2335287996 TSecr=2139253163 33 29.337663 10.0.23.103 10.0.23.102 TLSv1.2 117 Application Data 34 29.338722 10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data 35 29.339108 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=1730 Ack=2117 Win=64128 Len=0 TSval=2335288006 TSecr=2139253172 36 29.339960 10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data 37 29.340740 10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data 38 29.345242 10.0.23.103 10.0.23.102 TLSv1.2 100 Application Data 39 29.345631 10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data 40 29.346864 10.0.23.103 10.0.23.102 TLSv1.2 129 Application Data 41 29.347758 10.0.23.102 10.0.23.103 TLSv1.2 179 Application Data 42 29.364559 10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data 43 29.365506 10.0.23.102 10.0.23.103 TLSv1.2 176 Application Data 44 29.372858 10.0.23.103 10.0.23.102 TLSv1.2 142 Application Data 45 29.380187 10.0.23.102 10.0.23.103 TLSv1.2 334 Application Data 46 29.381436 10.0.23.103 10.0.23.102 TLSv1.2 145 Application Data 47 29.387865 10.0.23.102 10.0.23.103 TLSv1.2 338 Application Data 48 29.396371 10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data 49 29.400231 10.0.23.102 10.0.23.103 TLSv1.2 246 Application Data 50 29.403007 10.0.23.103 10.0.23.102 TLSv1.2 163 Application Data 51 29.406474 10.0.23.102 10.0.23.103 TLSv1.2 314 Application Data 52 29.408292 10.0.23.103 10.0.23.102 TLSv1.2 158 Application Data 53 29.411333 10.0.23.102 10.0.23.103 TLSv1.2 335 Application Data 54 29.413409 10.0.23.103 10.0.23.102 TLSv1.2 172 Application Data 55 29.415973 10.0.23.102 10.0.23.103 TLSv1.2 301 Application Data 56 29.417230 10.0.23.103 10.0.23.102 TLSv1.2 159 Application Data 57 29.422200 10.0.23.102 10.0.23.103 TLSv1.2 1021 Application Data 58 29.429676 10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data 59 29.449968 10.0.23.102 10.0.23.103 TCP 7306 3307 → 54202 [PSH, ACK] Seq=4847 Ack=2566 Win=64128 Len=7240 TSval=2139253284 TSecr=2335288097 [TCP segment of a reassembled PDU] 60 29.449979 10.0.23.102 10.0.23.103 TCP 7306 3307 → 54202 [PSH, ACK] Seq=12087 Ack=2566 Win=64128 Len=7240 TSval=2139253284 TSecr=2335288097 [TCP segment of a reassembled PDU] 61 29.450606 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=2566 Ack=7743 Win=63488 Len=0 TSval=2335288118 TSecr=2139253284 62 29.450650 10.0.23.102 10.0.23.103 TLSv1.2 1999 Application Data 63 29.450881 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=2566 Ack=12087 Win=64128 Len=0 TSval=2335288118 TSecr=2139253284 64 29.451355 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=2566 Ack=16431 Win=64128 Len=0 TSval=2335288118 TSecr=2139253284 65 29.451616 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=2566 Ack=20775 Win=64128 Len=0 TSval=2335288119 TSecr=2139253284 66 29.451912 10.0.23.102 10.0.23.103 TLSv1.2 6536 Application Data 67 29.455941 10.0.23.103 10.0.23.102 TCP 74 54206 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=2335288123 TSecr=0 WS=128 68 29.455999 10.0.23.102 10.0.23.103 TCP 74 3307 → 54206 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=2139253290 TSecr=2335288123 WS=128 69 29.456239 10.0.23.103 10.0.23.102 TCP 66 54206 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=2335288123 TSecr=2139253290 70 29.458043 10.0.23.102 10.0.23.103 TLSv1.2 169 Ignored Unknown Record 71 29.458530 10.0.23.103 10.0.23.102 TCP 66 54206 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=2335288126 TSecr=2139253292 72 29.458975 10.0.23.103 10.0.23.102 TLSv1.2 102 Ignored Unknown Record 73 29.459007 10.0.23.102 10.0.23.103 TCP 66 3307 → 54206 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=2139253293 TSecr=2335288126 74 29.470102 10.0.23.102 10.0.23.103 TCP 744 [TCP Retransmission] 3307 → 54202 [PSH, ACK] Seq=27052 Ack=2566 Win=64128 Len=678 TSval=2139253304 TSecr=2335288119 75 29.470515 10.0.23.103 10.0.23.102 TCP 78 54202 → 3307 [ACK] Seq=2566 Ack=27730 Win=60672 Len=0 TSval=2335288138 TSecr=2139253284 SLE=27052 SRE=27730 76 29.477007 10.0.23.103 10.0.23.102 TLSv1.2 362 Client Hello 77 29.477039 10.0.23.102 10.0.23.103 TCP 66 3307 → 54206 [ACK] Seq=104 Ack=333 Win=65024 Len=0 TSval=2139253311 TSecr=2335288144 78 29.477892 10.0.23.102 10.0.23.103 TLSv1.2 776 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done 79 29.478257 10.0.23.103 10.0.23.102 TCP 66 54206 → 3307 [ACK] Seq=333 Ack=814 Win=64128 Len=0 TSval=2335288145 TSecr=2139253312 80 29.488823 10.0.23.103 10.0.23.102 TLSv1.2 78 Certificate 81 29.488855 10.0.23.102 10.0.23.103 TCP 66 3307 → 54206 [ACK] Seq=814 Ack=345 Win=65024 Len=0 TSval=2139253323 TSecr=2335288156 82 29.490779 10.0.23.103 10.0.23.102 TLSv1.2 108 Client Key Exchange 83 29.490811 10.0.23.102 10.0.23.103 TCP 66 3307 → 54206 [ACK] Seq=814 Ack=387 Win=65024 Len=0 TSval=2139253324 TSecr=2335288158 84 29.497888 10.0.23.103 10.0.23.102 TLSv1.2 72 Change Cipher Spec 85 29.497920 10.0.23.102 10.0.23.103 TCP 66 3307 → 54206 [ACK] Seq=814 Ack=393 Win=65024 Len=0 TSval=2139253332 TSecr=2335288165 86 29.499302 10.0.23.103 10.0.23.102 TLSv1.2 111 Encrypted Handshake Message 87 29.499334 10.0.23.102 10.0.23.103 TCP 66 3307 → 54206 [ACK] Seq=814 Ack=438 Win=65024 Len=0 TSval=2139253333 TSecr=2335288166 88 29.499798 10.0.23.102 10.0.23.103 TLSv1.2 117 Change Cipher Spec, Encrypted Handshake Message 89 29.500236 10.0.23.103 10.0.23.102 TCP 66 54206 → 3307 [ACK] Seq=438 Ack=865 Win=64128 Len=0 TSval=2335288167 TSecr=2139253333 90 29.503136 10.0.23.103 10.0.23.102 TLSv1.2 302 Application Data 91 29.503169 10.0.23.102 10.0.23.103 TCP 66 3307 → 54206 [ACK] Seq=865 Ack=674 Win=64896 Len=0 TSval=2139253337 TSecr=2335288170 92 29.503784 10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data 93 29.504232 10.0.23.103 10.0.23.102 TCP 66 54206 → 3307 [ACK] Seq=674 Ack=905 Win=64128 Len=0 TSval=2335288171 TSecr=2139253337 94 29.505218 10.0.23.103 10.0.23.102 TLSv1.2 1071 Application Data 95 29.507490 10.0.23.102 10.0.23.103 TLSv1.2 1237 Application Data 96 29.507989 10.0.23.103 10.0.23.102 TCP 66 54206 → 3307 [ACK] Seq=1679 Ack=2076 Win=64128 Len=0 TSval=2335288175 TSecr=2139253341 97 29.509337 10.0.23.103 10.0.23.102 TLSv1.2 117 Application Data 98 29.510147 10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data 99 29.511251 10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data 100 29.511947 10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data 101 29.553730 10.0.23.103 10.0.23.102 TCP 66 54206 → 3307 [ACK] Seq=1780 Ack=2156 Win=64128 Len=0 TSval=2335288221 TSecr=2139253346 102 29.593459 10.0.23.103 10.0.23.102 TLSv1.2 135 Application Data 103 29.595828 10.0.23.102 10.0.23.103 TLSv1.2 371 Application Data 104 29.596175 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=2635 Ack=28035 Win=67072 Len=0 TSval=2335288263 TSecr=2139253429 105 29.922548 10.0.23.103 10.0.23.102 TLSv1.2 150 Application Data 106 29.926628 10.0.23.102 10.0.23.103 TLSv1.2 197 Application Data 107 29.926993 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=2719 Ack=28166 Win=69888 Len=0 TSval=2335288594 TSecr=2139253760 108 29.940711 10.0.23.103 10.0.23.102 TLSv1.2 111 Application Data 109 29.941577 10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data 110 29.941987 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=2764 Ack=28206 Win=69888 Len=0 TSval=2335288609 TSecr=2139253775 111 29.942942 10.0.23.103 10.0.23.102 TLSv1.2 134 Application Data 112 29.946105 10.0.23.102 10.0.23.103 TLSv1.2 1730 Application Data 113 29.946747 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=2832 Ack=29870 Win=69632 Len=0 TSval=2335288614 TSecr=2139253780 114 29.959465 10.0.23.103 10.0.23.102 TLSv1.2 212 Application Data 115 29.964067 10.0.23.102 10.0.23.103 TLSv1.2 156 Application Data 116 30.005720 10.0.23.103 10.0.23.102 TCP 66 54202 → 3307 [ACK] Seq=2978 Ack=29960 Win=69888 Len=0 TSval=2335288673 TSecr=2139253798 117 30.598072 10.0.23.103 10.0.23.102 TCP 74 54216 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=2335289265 TSecr=0 WS=128 118 30.598129 10.0.23.102 10.0.23.103 TCP 74 3307 → 54216 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=2139254432 TSecr=2335289265 WS=128 119 30.598556 10.0.23.103 10.0.23.102 TCP 66 54216 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=2335289266 TSecr=2139254432 120 30.600348 10.0.23.102 10.0.23.103 TCP 169 3307 → 54216 [PSH, ACK] Seq=1 Ack=1 Win=65280 Len=103 TSval=2139254434 TSecr=2335289266 121 30.600781 10.0.23.103 10.0.23.102 TCP 66 54216 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=2335289268 TSecr=2139254434 122 30.630637 10.0.23.103 10.0.23.102 TCP 273 54216 → 3307 [PSH, ACK] Seq=1 Ack=104 Win=64256 Len=207 TSval=2335289298 TSecr=2139254434 123 30.630670 10.0.23.102 10.0.23.103 TCP 66 3307 → 54216 [ACK] Seq=104 Ack=208 Win=65152 Len=0 TSval=2139254464 TSecr=2335289298 124 30.631651 10.0.23.102 10.0.23.103 TCP 144 3307 → 54216 [PSH, ACK] Seq=104 Ack=208 Win=65152 Len=78 TSval=2139254465 TSecr=2335289298 125 30.631918 10.0.23.102 10.0.23.103 TCP 66 3307 → 54216 [FIN, ACK] Seq=182 Ack=208 Win=65152 Len=0 TSval=2139254466 TSecr=2335289298 126 30.631978 10.0.23.103 10.0.23.102 TCP 66 54216 → 3307 [ACK] Seq=208 Ack=182 Win=64256 Len=0 TSval=2335289299 TSecr=2139254465 127 30.654418 10.0.23.103 10.0.23.102 TCP 66 54216 → 3307 [FIN, ACK] Seq=208 Ack=183 Win=64256 Len=0 TSval=2335289322 TSecr=2139254466 128 30.654468 10.0.23.102 10.0.23.103 TCP 66 3307 → 54216 [ACK] Seq=183 Ack=209 Win=65152 Len=0 TSval=2139254488 TSecr=2335289322

From the above, we can see that flink CDC keeps establishing connection with EdgelessDB, the first two connections are TLSv1.2 connections, but on the third time, it changed to TCP connection, so EdgelessDB returned `Access denied for user 'test'@'10.0.23.103' (using password: YES)` error.

Let's look at the logs of EdgelessDB.

cat edblogs/mariadb.log edb, Version: 10.5.11-MariaDB-debug-log (Source distribution). started with: Tcp port: 3307 Unix socket: (null) Time Id Command Argument 221027 2:23:47 2 Connect root@255.0.0.1 on using TCP/IP 2 Query SELECT from $edgeless.config 2 Quit 221027 2:25:02 6 Connect test@10.0.23.103 on using SSL/TLS 6 Query / mysql-connector-java-8.0.21 (Revision: 33f65445a1bcc544eb0120491926484da168f199) /SELECT @@session.auto_increment_increment AS auto_increment_increment, @@character_set_client AS character_set_client, @@character_set_connection AS character_set_connection, @@character_set_results AS character_set_results, @@character_set_server AS character_set_server, @@collation_server AS collation_server, @@collation_connection AS collation_connection, @@init_connect AS init_connect, @@interactive_timeout AS interactive_timeout, @@license AS license, @@lower_case_table_names AS lower_case_table_names, @@max_allowed_packet AS max_allowed_packet, @@net_write_timeout AS net_write_timeout, @@performance_schema AS performance_schema, @@query_cache_size AS query_cache_size, @@query_cache_type AS query_cache_type, @@sql_mode AS sql_mode, @@system_time_zone AS system_time_zone, @@time_zone AS time_zone, @@tx_isolation AS transaction_isolation, @@wait_timeout AS wait_timeout 6 Query SET NAMES utf8mb4 6 Query SET autocommit=1 6 Query SELECT @@session.tx_isolation 6 Query SELECT VERSION() 6 Query SHOW GLOBAL VARIABLES LIKE 'binlog_format' 6 Query SHOW GLOBAL VARIABLES LIKE 'binlog_row_image' 6 Query SHOW DATABASES 6 Query SHOW FULL TABLES IN $edgeless where Table_Type = 'BASE TABLE' 6 Query SHOW FULL TABLES IN demo where Table_Type = 'BASE TABLE' 6 Query SHOW FULL TABLES IN information_schema where Table_Type = 'BASE TABLE' 6 Query SHOW FULL TABLES IN mysql where Table_Type = 'BASE TABLE' 6 Query SHOW VARIABLES 7 Connect test@10.0.23.103 on using SSL/TLS 7 Query / mysql-connector-java-8.0.21 (Revision: 33f65445a1bcc544eb0120491926484da168f199) */SELECT @@session.auto_increment_increment AS auto_increment_increment, @@character_set_client AS character_set_client, @@character_set_connection AS character_set_connection, @@character_set_results AS character_set_results, @@character_set_server AS character_set_server, @@collation_server AS collation_server, @@collation_connection AS collation_connection, @@init_connect AS init_connect, @@interactive_timeout AS interactive_timeout, @@license AS license, @@lower_case_table_names AS lower_case_table_names, @@max_allowed_packet AS max_allowed_packet, @@net_write_timeout AS net_write_timeout, @@performance_schema AS performance_schema, @@query_cache_size AS query_cache_size, @@query_cache_type AS query_cache_type, @@sql_mode AS sql_mode, @@system_time_zone AS system_time_zone, @@time_zone AS time_zone, @@tx_isolation AS transaction_isolation, @@wait_timeout AS wait_timeout 7 Query SET NAMES utf8mb4 7 Query SET autocommit=1 6 Query SHOW CREATE TABLE demo.student1 6 Query SELECT MIN(id), MAX(id) FROM demo.student1 6 Query USE demo 6 Query SHOW TABLE STATUS LIKE 'student1' 6 Query SELECT MAX(id) FROM (SELECT id FROM demo.student1 WHERE id >= 10001 ORDER BY id ASC LIMIT 8096) AS T 221027 2:25:03 8 Connect test@10.0.23.103 on using TCP/IP 8 Connect Access denied for user 'test'@'10.0.23.103' (using password: YES)


As you can see from the mariadb.log, the first two TLS connections (6 and 7) are normal, and the third connection (8) is a TCP connection, which also matches the tcpdump result.

Can you give me some advice on why the TLS protocol changes to TCP during the connection?
GOODBOY008 commented 2 years ago

@lijun0314 Thanks for your report , I will reproduce this sceno by following your steps.

water5-cmd commented 2 years ago

Hi, @GOODBOY008，

As I debugged more, I realized that I didn't know enough about jdbc.properties.* and debezium.*. When I set the connection parameters as follows, the TLS version falls back from 1.2 to 1.1, which is the default version of debezium.

The details are as follows.

Flink SQL> CREATE TABLE user_source10 (
       `id` int,
       name STRING,
       age int,
       PRIMARY KEY (`id`) NOT ENFORCED
     ) WITH (
       'connector' = 'mysql-cdc',
       'hostname' = '10.0.23.102',
       'port' = '3307',
       'username' = 'test',
       'password' = '123',
       'database-name' = 'demo',
       'table-name' = 'student1', 'jdbc.properties.enabledTLSProtocols' = 'TLSv1.2', 'debezium.database.ssl.mode'='required',
       'jdbc.properties.verifyServerCertificate' = 'false'
 );
[INFO] Execute statement succeed.

Flink SQL> select * from user_source10;
[ERROR] Could not execute SQL statement. Reason:
javax.net.ssl.SSLHandshakeException: Received fatal alert: protocol_version

the tcpdump log:

1   0.000000    10.0.23.103 10.0.23.102 TCP 74  33380 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=3300509026 TSecr=0 WS=128
2   0.000076    10.0.23.102 10.0.23.103 TCP 74  3307 → 33380 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=3104474198 TSecr=3300509026 WS=128
3   0.000561    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=3300509027 TSecr=3104474198
4   0.001814    10.0.23.102 10.0.23.103 MySQL   169 Server Greeting  proto=10 version=10.5.11-MariaDB-debug-log 
5   0.002195    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=3300509028 TSecr=3104474199
6   0.036506    10.0.23.103 10.0.23.102 MySQL   102 Login Request user= 
7   0.036537    10.0.23.102 10.0.23.103 TCP 66  3307 → 33380 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=3104474234 TSecr=3300509062
8   0.309851    10.0.23.103 10.0.23.102 TLSv1.2 362 Client Hello
9   0.309895    10.0.23.102 10.0.23.103 TCP 66  3307 → 33380 [ACK] Seq=104 Ack=333 Win=65024 Len=0 TSval=3104474507 TSecr=3300509336
10  0.310818    10.0.23.102 10.0.23.103 TLSv1.2 775 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done
11  0.311294    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=333 Ack=813 Win=64128 Len=0 TSval=3300509337 TSecr=3104474508
12  0.323028    10.0.23.103 10.0.23.102 TLSv1.2 78  Certificate
13  0.323059    10.0.23.102 10.0.23.103 TCP 66  3307 → 33380 [ACK] Seq=813 Ack=345 Win=65024 Len=0 TSval=3104474521 TSecr=3300509349
14  0.332939    10.0.23.103 10.0.23.102 TLSv1.2 108 Client Key Exchange
15  0.332971    10.0.23.102 10.0.23.103 TCP 66  3307 → 33380 [ACK] Seq=813 Ack=387 Win=65024 Len=0 TSval=3104474530 TSecr=3300509359
16  0.340185    10.0.23.103 10.0.23.102 TLSv1.2 72  Change Cipher Spec
17  0.340216    10.0.23.102 10.0.23.103 TCP 66  3307 → 33380 [ACK] Seq=813 Ack=393 Win=65024 Len=0 TSval=3104474538 TSecr=3300509366
18  0.347447    10.0.23.103 10.0.23.102 TLSv1.2 111 Encrypted Handshake Message
19  0.347478    10.0.23.102 10.0.23.103 TCP 66  3307 → 33380 [ACK] Seq=813 Ack=438 Win=65024 Len=0 TSval=3104474545 TSecr=3300509373
20  0.347990    10.0.23.102 10.0.23.103 TLSv1.2 117 Change Cipher Spec, Encrypted Handshake Message
21  0.348280    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=438 Ack=864 Win=64128 Len=0 TSval=3300509374 TSecr=3104474545
22  0.352366    10.0.23.103 10.0.23.102 TLSv1.2 302 Application Data
23  0.352398    10.0.23.102 10.0.23.103 TCP 66  3307 → 33380 [ACK] Seq=864 Ack=674 Win=64896 Len=0 TSval=3104474550 TSecr=3300509378
24  0.353031    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
25  0.353506    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=674 Ack=904 Win=64128 Len=0 TSval=3300509379 TSecr=3104474550
26  0.355723    10.0.23.103 10.0.23.102 TLSv1.2 1071    Application Data
27  0.358055    10.0.23.102 10.0.23.103 TLSv1.2 1237    Application Data
28  0.358511    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=1679 Ack=2075 Win=64128 Len=0 TSval=3300509384 TSecr=3104474555
29  0.366848    10.0.23.103 10.0.23.102 TLSv1.2 117 Application Data
30  0.367659    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
31  0.368004    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=1730 Ack=2115 Win=64128 Len=0 TSval=3300509394 TSecr=3104474565
32  0.368709    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
33  0.369420    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
34  0.369735    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=1780 Ack=2155 Win=64128 Len=0 TSval=3300509396 TSecr=3104474567
35  0.374094    10.0.23.103 10.0.23.102 TLSv1.2 100 Application Data
36  0.374531    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
37  0.374998    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=1814 Ack=2195 Win=64128 Len=0 TSval=3300509401 TSecr=3104474572
38  0.375347    10.0.23.103 10.0.23.102 TLSv1.2 129 Application Data
39  0.376274    10.0.23.102 10.0.23.103 TLSv1.2 179 Application Data
40  0.376848    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=1877 Ack=2308 Win=64128 Len=0 TSval=3300509403 TSecr=3104474574
41  0.393695    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
42  0.394622    10.0.23.102 10.0.23.103 TLSv1.2 176 Application Data
43  0.395145    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=1927 Ack=2418 Win=64128 Len=0 TSval=3300509421 TSecr=3104474592
44  0.402919    10.0.23.103 10.0.23.102 TLSv1.2 142 Application Data
45  0.409438    10.0.23.102 10.0.23.103 TLSv1.2 334 Application Data
46  0.411266    10.0.23.103 10.0.23.102 TLSv1.2 145 Application Data
47  0.417738    10.0.23.102 10.0.23.103 TLSv1.2 338 Application Data
48  0.426803    10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data
49  0.428658    10.0.23.102 10.0.23.103 TLSv1.2 246 Application Data
50  0.431929    10.0.23.103 10.0.23.102 TLSv1.2 163 Application Data
51  0.434456    10.0.23.102 10.0.23.103 TLSv1.2 314 Application Data
52  0.436912    10.0.23.103 10.0.23.102 TLSv1.2 158 Application Data
53  0.439444    10.0.23.102 10.0.23.103 TLSv1.2 335 Application Data
54  0.441681    10.0.23.103 10.0.23.102 TLSv1.2 172 Application Data
55  0.444299    10.0.23.102 10.0.23.103 TLSv1.2 301 Application Data
56  0.445871    10.0.23.103 10.0.23.102 TLSv1.2 159 Application Data
57  0.451236    10.0.23.102 10.0.23.103 TLSv1.2 1021    Application Data
58  0.463540    10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data
59  0.483478    10.0.23.102 10.0.23.103 TCP 7306    3307 → 33380 [PSH, ACK] Seq=4845 Ack=2566 Win=64128 Len=7240 TSval=3104474681 TSecr=3300509490 [TCP segment of a reassembled PDU]
60  0.483492    10.0.23.102 10.0.23.103 TCP 7306    3307 → 33380 [PSH, ACK] Seq=12085 Ack=2566 Win=64128 Len=7240 TSval=3104474681 TSecr=3300509490 [TCP segment of a reassembled PDU]
61  0.484251    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=2566 Ack=10637 Win=64128 Len=0 TSval=3300509510 TSecr=3104474681
62  0.484279    10.0.23.103 10.0.23.102 TCP 74  33384 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=3300509510 TSecr=0 WS=128
63  0.484291    10.0.23.102 10.0.23.103 TLSv1.2 1999    Application Data
64  0.484338    10.0.23.102 10.0.23.103 TCP 74  3307 → 33384 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=3104474682 TSecr=3300509510 WS=128
65  0.484491    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=2566 Ack=13533 Win=64128 Len=0 TSval=3300509511 TSecr=3104474681
66  0.484746    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=2566 Ack=16429 Win=64128 Len=0 TSval=3300509511 TSecr=3104474681
67  0.485004    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=2566 Ack=19325 Win=64128 Len=0 TSval=3300509511 TSecr=3104474681
68  0.485194    10.0.23.103 10.0.23.102 TCP 66  33384 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=3300509511 TSecr=3104474682
69  0.485259    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=2566 Ack=21258 Win=64128 Len=0 TSval=3300509511 TSecr=3104474682
70  0.485381    10.0.23.102 10.0.23.103 TLSv1.2 6547    Application Data
71  0.486432    10.0.23.102 10.0.23.103 MySQL   169 Server Greeting  proto=10 version=10.5.11-MariaDB-debug-log 
72  0.486961    10.0.23.103 10.0.23.102 TCP 66  33384 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=3300509513 TSecr=3104474684
73  0.487383    10.0.23.103 10.0.23.102 MySQL   102 Login Request user= 
74  0.487415    10.0.23.102 10.0.23.103 TCP 66  3307 → 33384 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=3104474685 TSecr=3300509513
75  0.502302    10.0.23.102 10.0.23.103 TCP 755 [TCP Retransmission] 3307 → 33380 [PSH, ACK] Seq=27050 Ack=2566 Win=64128 Len=689 TSval=3104474700 TSecr=3300509511
76  0.502660    10.0.23.103 10.0.23.102 TCP 78  33380 → 3307 [ACK] Seq=2566 Ack=27739 Win=60672 Len=0 TSval=3300509529 TSecr=3104474683 SLE=27050 SRE=27739
77  0.504613    10.0.23.103 10.0.23.102 TLSv1.2 362 Client Hello
78  0.504646    10.0.23.102 10.0.23.103 TCP 66  3307 → 33384 [ACK] Seq=104 Ack=333 Win=65024 Len=0 TSval=3104474702 TSecr=3300509531
79  0.505488    10.0.23.102 10.0.23.103 TLSv1.2 774 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done
80  0.505913    10.0.23.103 10.0.23.102 TCP 66  33384 → 3307 [ACK] Seq=333 Ack=812 Win=64128 Len=0 TSval=3300509532 TSecr=3104474703
81  0.533573    10.0.23.103 10.0.23.102 TLSv1.2 78  Certificate
82  0.533605    10.0.23.102 10.0.23.103 TCP 66  3307 → 33384 [ACK] Seq=812 Ack=345 Win=65024 Len=0 TSval=3104474731 TSecr=3300509560
83  0.535913    10.0.23.103 10.0.23.102 TLSv1.2 108 Client Key Exchange
84  0.535945    10.0.23.102 10.0.23.103 TCP 66  3307 → 33384 [ACK] Seq=812 Ack=387 Win=65024 Len=0 TSval=3104474733 TSecr=3300509562
85  0.543152    10.0.23.103 10.0.23.102 TLSv1.2 72  Change Cipher Spec
86  0.543183    10.0.23.102 10.0.23.103 TCP 66  3307 → 33384 [ACK] Seq=812 Ack=393 Win=65024 Len=0 TSval=3104474741 TSecr=3300509569
87  0.543756    10.0.23.103 10.0.23.102 TLSv1.2 111 Encrypted Handshake Message
88  0.543787    10.0.23.102 10.0.23.103 TCP 66  3307 → 33384 [ACK] Seq=812 Ack=438 Win=65024 Len=0 TSval=3104474741 TSecr=3300509570
89  0.544282    10.0.23.102 10.0.23.103 TLSv1.2 117 Change Cipher Spec, Encrypted Handshake Message
90  0.544614    10.0.23.103 10.0.23.102 TCP 66  33384 → 3307 [ACK] Seq=438 Ack=863 Win=64128 Len=0 TSval=3300509571 TSecr=3104474742
91  0.546099    10.0.23.103 10.0.23.102 TLSv1.2 302 Application Data
92  0.546132    10.0.23.102 10.0.23.103 TCP 66  3307 → 33384 [ACK] Seq=863 Ack=674 Win=64896 Len=0 TSval=3104474744 TSecr=3300509572
93  0.546747    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
94  0.547147    10.0.23.103 10.0.23.102 TCP 66  33384 → 3307 [ACK] Seq=674 Ack=903 Win=64128 Len=0 TSval=3300509573 TSecr=3104474744
95  0.548019    10.0.23.103 10.0.23.102 TLSv1.2 1071    Application Data
96  0.548052    10.0.23.102 10.0.23.103 TCP 66  3307 → 33384 [ACK] Seq=903 Ack=1679 Win=64128 Len=0 TSval=3104474745 TSecr=3300509574
97  0.550332    10.0.23.102 10.0.23.103 TLSv1.2 1237    Application Data
98  0.550890    10.0.23.103 10.0.23.102 TCP 66  33384 → 3307 [ACK] Seq=1679 Ack=2074 Win=64128 Len=0 TSval=3300509577 TSecr=3104474748
99  0.552197    10.0.23.103 10.0.23.102 TLSv1.2 117 Application Data
100 0.552229    10.0.23.102 10.0.23.103 TCP 66  3307 → 33384 [ACK] Seq=2074 Ack=1730 Win=64128 Len=0 TSval=3104474750 TSecr=3300509578
101 0.552989    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
102 0.553941    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
103 0.553979    10.0.23.102 10.0.23.103 TCP 66  3307 → 33384 [ACK] Seq=2114 Ack=1780 Win=64128 Len=0 TSval=3104474751 TSecr=3300509580
104 0.554698    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
105 0.598836    10.0.23.103 10.0.23.102 TCP 66  33384 → 3307 [ACK] Seq=1780 Ack=2154 Win=64128 Len=0 TSval=3300509625 TSecr=3104474752
106 0.658732    10.0.23.103 10.0.23.102 TLSv1.2 135 Application Data
107 0.659671    10.0.23.102 10.0.23.103 TLSv1.2 371 Application Data
108 0.660085    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=2635 Ack=28044 Win=67072 Len=0 TSval=3300509686 TSecr=3104474857
109 0.999188    10.0.23.103 10.0.23.102 TLSv1.2 150 Application Data
110 1.001233    10.0.23.102 10.0.23.103 TLSv1.2 197 Application Data
111 1.001617    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=2719 Ack=28175 Win=69888 Len=0 TSval=3300510028 TSecr=3104475199
112 1.013832    10.0.23.103 10.0.23.102 TLSv1.2 111 Application Data
113 1.014647    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
114 1.015132    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=2764 Ack=28215 Win=69888 Len=0 TSval=3300510041 TSecr=3104475212
115 1.015877    10.0.23.103 10.0.23.102 TLSv1.2 134 Application Data
116 1.019059    10.0.23.102 10.0.23.103 TLSv1.2 1752    Application Data
117 1.019639    10.0.23.103 10.0.23.102 TCP 66  33380 → 3307 [ACK] Seq=2832 Ack=29901 Win=69632 Len=0 TSval=3300510046 TSecr=3104475216
118 1.755338    10.0.23.103 10.0.23.102 TCP 74  33394 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=3300510781 TSecr=0 WS=128
119 1.755395    10.0.23.102 10.0.23.103 TCP 74  3307 → 33394 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=3104475953 TSecr=3300510781 WS=128
120 1.755695    10.0.23.103 10.0.23.102 TCP 66  33394 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=3300510782 TSecr=3104475953
121 1.756896    10.0.23.102 10.0.23.103 MySQL   169 Server Greeting  proto=10 version=10.5.11-MariaDB-debug-log 
122 1.757413    10.0.23.103 10.0.23.102 TCP 66  33394 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=3300510783 TSecr=3104475954
123 1.791525    10.0.23.103 10.0.23.102 MySQL   102 Login Request user= 
124 1.791557    10.0.23.102 10.0.23.103 TCP 66  3307 → 33394 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=3104475989 TSecr=3300510818
125 1.949097    10.0.23.103 10.0.23.102 TLSv1.1 216 Client Hello
126 1.949129    10.0.23.102 10.0.23.103 TCP 66  3307 → 33394 [ACK] Seq=104 Ack=187 Win=65152 Len=0 TSval=3104476147 TSecr=3300510975
127 1.949454    10.0.23.102 10.0.23.103 TLSv1.1 73  Alert (Level: Fatal, Description: Protocol Version)
128 1.949678    10.0.23.102 10.0.23.103 TCP 92  3307 → 33394 [PSH, ACK] Seq=111 Ack=187 Win=65152 Len=26 TSval=3104476147 TSecr=3300510975 [TCP segment of a reassembled PDU]
129 1.949783    10.0.23.103 10.0.23.102 TCP 66  33394 → 3307 [ACK] Seq=187 Ack=111 Win=64256 Len=0 TSval=3300510976 TSecr=3104476147
130 1.949989    10.0.23.102 10.0.23.103 TCP 66  3307 → 33394 [FIN, ACK] Seq=137 Ack=187 Win=65152 Len=0 TSval=3104476147 TSecr=3300510976
131 1.950037    10.0.23.103 10.0.23.102 TCP 66  33394 → 3307 [ACK] Seq=187 Ack=137 Win=64256 Len=0 TSval=3300510976 TSecr=3104476147
132 1.950737    10.0.23.103 10.0.23.102 TCP 66  33394 → 3307 [FIN, ACK] Seq=187 Ack=138 Win=64256 Len=0 TSval=3300510977 TSecr=3104476147
133 1.950785    10.0.23.102 10.0.23.103 TCP 66  3307 → 33394 [ACK] Seq=138 Ack=188 Win=65152 Len=0 TSval=3104476148 TSecr=3300510977

sql client log:

2022-11-07 14:54:11,181 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.address, localhost
2022-11-07 14:54:11,183 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.rpc.port, 6123
2022-11-07 14:54:11,183 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.memory.process.size, 2048m
2022-11-07 14:54:11,183 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.memory.process.size, 4096m
2022-11-07 14:54:11,183 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2022-11-07 14:54:11,184 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: parallelism.default, 1
2022-11-07 14:54:11,184 INFO  org.apache.flink.configuration.GlobalConfiguration           [] - Loading configuration property: jobmanager.execution.failover-strategy, region
2022-11-07 14:54:11,198 INFO  org.apache.flink.client.cli.CliFrontend                      [] - Loading FallbackYarnSessionCli
2022-11-07 14:54:11,227 INFO  org.apache.flink.core.fs.FileSystem                          [] - Hadoop is not in the classpath/dependencies. The extended set of supported File Systems via Hadoop is not available.
2022-11-07 14:54:11,263 INFO  org.apache.flink.table.client.gateway.context.DefaultContext [] - Executor config: {execution.savepoint.ignore-unclaimed-state=false, execution.attached=true, execution.shutdown-on-attached-exit=false, pipeline.jars=[file:/home/adminroot/flink-test/flink-1.14.4/opt/flink-sql-client_2.12-1.14.4.jar, file:/home/adminroot/flink-test/flink-1.14.4/opt/flink-python_2.12-1.14.4.jar], pipeline.classpaths=[], execution.target=remote}
2022-11-07 14:54:12,271 INFO  org.apache.flink.table.client.cli.CliClient                  [] - Command history file path: /root/.flink-sql-history
2022-11-07 14:54:20,673 INFO  org.apache.flink.configuration.Configuration                 [] - Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'
2022-11-07 14:54:20,714 INFO  org.apache.flink.client.program.rest.RestClusterClient       [] - Submitting job 'collect' (22259bba190157b63251c0ccbc95748f).
2022-11-07 14:54:21,845 INFO  org.apache.flink.client.program.rest.RestClusterClient       [] - Successfully submitted job 'collect' (22259bba190157b63251c0ccbc95748f) to 'http://localhost:8081'.
2022-11-07 14:54:25,567 INFO  org.apache.flink.configuration.Configuration                 [] - Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'
2022-11-07 14:54:25,631 INFO  org.apache.flink.configuration.Configuration                 [] - Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'
2022-11-07 14:54:25,735 INFO  org.apache.flink.configuration.Configuration                 [] - Config uses fallback configuration key 'jobmanager.rpc.address' instead of key 'rest.address'
2022-11-07 14:54:26,709 INFO  org.apache.flink.table.client.gateway.local.LocalExecutor    [] - Cancelling job 22259bba190157b63251c0ccbc95748f and result retrieval.
2022-11-07 14:54:26,725 WARN  org.apache.flink.table.client.cli.CliClient                  [] - Could not execute SQL statement.
org.apache.flink.table.client.gateway.SqlExecutionException: Error while retrieving result.
    at org.apache.flink.table.client.gateway.local.result.CollectResultBase$ResultRetrievalThread.run(CollectResultBase.java:78) ~[flink-sql-client_2.12-1.14.4.jar:1.14.4]
Caused by: java.lang.RuntimeException: Failed to fetch next result
    at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.hasNext(TableResultImpl.java:370) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.table.client.gateway.local.result.CollectResultBase$ResultRetrievalThread.run(CollectResultBase.java:74) ~[flink-sql-client_2.12-1.14.4.jar:1.14.4]
Caused by: java.io.IOException: Failed to fetch job execution result
    at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:177) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:120) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.hasNext(TableResultImpl.java:370) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.table.client.gateway.local.result.CollectResultBase$ResultRetrievalThread.run(CollectResultBase.java:74) ~[flink-sql-client_2.12-1.14.4.jar:1.14.4]
Caused by: java.util.concurrent.ExecutionException: org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: 22259bba190157b63251c0ccbc95748f)
    at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395) ~[?:?]
    at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2022) ~[?:?]
    at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:175) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:120) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.hasNext(TableResultImpl.java:370) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.table.client.gateway.local.result.CollectResultBase$ResultRetrievalThread.run(CollectResultBase.java:74) ~[flink-sql-client_2.12-1.14.4.jar:1.14.4]
Caused by: org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: 22259bba190157b63251c0ccbc95748f)
    at org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:125) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) ~[?:?]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) ~[?:?]
    at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:403) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) ~[?:?]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) ~[?:?]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) ~[?:?]
    at org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$26(RestClusterClient.java:698) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) ~[?:?]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) ~[?:?]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) ~[?:?]
    at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:403) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) ~[?:?]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) ~[?:?]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
    at java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:610) ~[?:?]
    at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1085) ~[?:?]
    at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
    at java.lang.Thread.run(Thread.java:829) ~[?:?]
Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
    at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:123) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) ~[?:?]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) ~[?:?]
    at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:403) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) ~[?:?]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) ~[?:?]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) ~[?:?]
    at org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$26(RestClusterClient.java:698) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) ~[?:?]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) ~[?:?]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
    at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) ~[?:?]
    at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:403) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) ~[?:?]
    at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) ~[?:?]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) ~[?:?]
    at java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:610) ~[?:?]
    at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1085) ~[?:?]
    at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
    at java.lang.Thread.run(Thread.java:829) ~[?:?]
Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
    at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
    at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
    at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
    at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) ~[?:?]
    at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) ~[?:?]
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) ~[?:?]
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) ~[?:?]
    at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) ~[?:?]
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) ~[?:?]
    at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) ~[?:?]
    at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) ~[?:?]
    at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) ~[?:?]
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at akka.actor.Actor.aroundReceive(Actor.scala:537) ~[?:?]
    at akka.actor.Actor.aroundReceive$(Actor.scala:535) ~[?:?]
    at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) ~[?:?]
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) ~[?:?]
    at akka.actor.ActorCell.invoke(ActorCell.scala:548) ~[?:?]
    at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) ~[?:?]
    at akka.dispatch.Mailbox.run(Mailbox.scala:231) ~[?:?]
    at akka.dispatch.Mailbox.exec(Mailbox.scala:243) ~[?:?]
    at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) ~[?:?]
    at java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) ~[?:?]
    at java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) ~[?:?]
    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) ~[?:?]
    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183) ~[?:?]
Caused by: java.lang.RuntimeException: One or more fetchers have encountered exception
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:225) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:169) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:130) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:351) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:496) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist_2.12-1.14.4.jar:1.14.4]
    at java.lang.Thread.run(Thread.java:829) ~[?:?]
Caused by: java.lang.RuntimeException: SplitFetcher thread 0 received unexpected exception while polling the records
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:150) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
    at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
    at java.lang.Thread.run(Thread.java:829) ~[?:?]
Caused by: io.debezium.DebeziumException: Error reading MySQL variables: Communications link failure

The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.
    at io.debezium.connector.mysql.MySqlConnection.querySystemVariables(MySqlConnection.java:139) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.readMySqlSystemVariables(MySqlConnection.java:119) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.isTableIdCaseSensitive(MySqlConnection.java:429) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.configure(StatefulTaskContext.java:103) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.submitSplit(SnapshotSplitReader.java:93) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.submitSplit(SnapshotSplitReader.java:64) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader.checkSplitOrStartNext(MySqlSplitReader.java:163) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader.fetch(MySqlSplitReader.java:73) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
    at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
    at java.lang.Thread.run(Thread.java:829) ~[?:?]
Caused by: com.mysql.cj.jdbc.exceptions.CommunicationsException: Communications link failure

The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.
    at com.mysql.cj.jdbc.exceptions.SQLError.createCommunicationsException(SQLError.java:174) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:64) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:836) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:456) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:246) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:197) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:231) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:872) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.connection(MySqlConnection.java:79) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:867) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:550) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:498) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.querySystemVariables(MySqlConnection.java:125) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.readMySqlSystemVariables(MySqlConnection.java:119) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.isTableIdCaseSensitive(MySqlConnection.java:429) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.configure(StatefulTaskContext.java:103) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.submitSplit(SnapshotSplitReader.java:93) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.submitSplit(SnapshotSplitReader.java:64) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader.checkSplitOrStartNext(MySqlSplitReader.java:163) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader.fetch(MySqlSplitReader.java:73) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
    at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
    at java.lang.Thread.run(Thread.java:829) ~[?:?]
Caused by: com.mysql.cj.exceptions.CJCommunicationsException: Communications link failure

The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server.
    at jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[?:?]
    at jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) ~[?:?]
    at jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[?:?]
    at java.lang.reflect.Constructor.newInstance(Constructor.java:490) ~[?:?]
    at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:61) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:105) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.exceptions.ExceptionFactory.createException(ExceptionFactory.java:151) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.exceptions.ExceptionFactory.createCommunicationsException(ExceptionFactory.java:167) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.protocol.a.NativeProtocol.negotiateSSLConnection(NativeProtocol.java:334) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.protocol.a.NativeAuthenticationProvider.connect(NativeAuthenticationProvider.java:164) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.protocol.a.NativeProtocol.connect(NativeProtocol.java:1342) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.NativeSession.connect(NativeSession.java:157) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:956) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:826) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:456) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:246) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:197) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:231) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:872) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.connection(MySqlConnection.java:79) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:867) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:550) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:498) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.querySystemVariables(MySqlConnection.java:125) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.readMySqlSystemVariables(MySqlConnection.java:119) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.isTableIdCaseSensitive(MySqlConnection.java:429) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.configure(StatefulTaskContext.java:103) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.submitSplit(SnapshotSplitReader.java:93) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.submitSplit(SnapshotSplitReader.java:64) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader.checkSplitOrStartNext(MySqlSplitReader.java:163) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader.fetch(MySqlSplitReader.java:73) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
    at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
    at java.lang.Thread.run(Thread.java:829) ~[?:?]
Caused by: javax.net.ssl.SSLHandshakeException: Received fatal alert: protocol_version
    at sun.security.ssl.Alert.createSSLException(Alert.java:131) ~[?:?]
    at sun.security.ssl.Alert.createSSLException(Alert.java:117) ~[?:?]
    at sun.security.ssl.TransportContext.fatal(TransportContext.java:340) ~[?:?]
    at sun.security.ssl.Alert$AlertConsumer.consume(Alert.java:293) ~[?:?]
    at sun.security.ssl.TransportContext.dispatch(TransportContext.java:186) ~[?:?]
    at sun.security.ssl.SSLTransport.decode(SSLTransport.java:172) ~[?:?]
    at sun.security.ssl.SSLSocketImpl.decode(SSLSocketImpl.java:1506) ~[?:?]
    at sun.security.ssl.SSLSocketImpl.readHandshakeRecord(SSLSocketImpl.java:1416) ~[?:?]
    at sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:456) ~[?:?]
    at sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:427) ~[?:?]
    at com.mysql.cj.protocol.ExportControlled.performTlsHandshake(ExportControlled.java:336) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.protocol.StandardSocketFactory.performTlsHandshake(StandardSocketFactory.java:188) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.protocol.a.NativeSocketConnection.performTlsHandshake(NativeSocketConnection.java:99) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.protocol.a.NativeProtocol.negotiateSSLConnection(NativeProtocol.java:325) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.protocol.a.NativeAuthenticationProvider.connect(NativeAuthenticationProvider.java:164) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.protocol.a.NativeProtocol.connect(NativeProtocol.java:1342) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.NativeSession.connect(NativeSession.java:157) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:956) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:826) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:456) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:246) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.mysql.cj.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:197) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:231) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:872) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.connection(MySqlConnection.java:79) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:867) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:550) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:498) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.querySystemVariables(MySqlConnection.java:125) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.readMySqlSystemVariables(MySqlConnection.java:119) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at io.debezium.connector.mysql.MySqlConnection.isTableIdCaseSensitive(MySqlConnection.java:429) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.configure(StatefulTaskContext.java:103) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.submitSplit(SnapshotSplitReader.java:93) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.submitSplit(SnapshotSplitReader.java:64) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader.checkSplitOrStartNext(MySqlSplitReader.java:163) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at com.ververica.cdc.connectors.mysql.source.reader.MySqlSplitReader.fetch(MySqlSplitReader.java:73) ~[flink-sql-connector-mysql-cdc-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
    at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105) ~[flink-table_2.12-1.14.4.jar:1.14.4]
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
    at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
    at java.lang.Thread.run(Thread.java:829) ~[?:?]

I can see from this issue that debezium supports TLSv1.2 and that TLSv1.1 can be overridden by passing in the TLS version parameter, but my test results show that this is not the case. Are the TLS-related parameters I set when establishing the connection correct?

Also, I found some custom TLS code in the source code for binlog connections, is this the reason for this problem?

water5-cmd commented 2 years ago

Hi, @GOODBOY008,

I modified the source code of Debezium in order to change the default TLS version of Debezium to TLSv1.2; The modified code is as follows:

...
168             props.setProperty("database.server.name", DATABASE_SERVER_NAME);
169             props.setProperty("database.hostname", checkNotNull(hostname));
170             props.setProperty("database.user", checkNotNull(username));
171             props.setProperty("database.password", checkNotNull(password));
172             props.setProperty("database.port", String.valueOf(port));
173             props.setProperty("database.history.skip.unparseable.ddl", String.valueOf(true));
174             props.setProperty("database.enabledTLSProtocols", "TLSv1.2");     // add this
...
Note: The source code is from branch release-2.3.

flink SQL client:

Flink SQL> SET 'execution.checkpointing.interval' = '3s';
[INFO] Session property has been set.

Flink SQL> CREATE TABLE user_source3 (
>       `id` int,
>       name STRING,
>       age int,
>       PRIMARY KEY (`id`) NOT ENFORCED
>     ) WITH (
>       'connector' = 'mysql-cdc',
>       'hostname' = '10.0.23.102',
>       'port' = '3307',
>       'username' = 'test',
>       'password' = '123',
>       'database-name' = 'demo',
>       'table-name' = 'student1', 'jdbc.properties.enabledTLSProtocols' = 'TLSv1.2', 'debezium.database.ssl.mode'='required'
>  );
[INFO] Execute statement succeed.

Flink SQL> select * from user_source3;

Then you can see the data obtained from the database.

Here is the tcpdump log:

1   0.000000    10.0.23.103 10.0.23.102 TCP 74  41928 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=3484186327 TSecr=0 WS=128
2   0.000061    10.0.23.102 10.0.23.103 TCP 74  3307 → 41928 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=3288151495 TSecr=3484186327 WS=128
3   0.000478    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=3484186327 TSecr=3288151495
4   0.001741    10.0.23.102 10.0.23.103 MySQL   169 Server Greeting  proto=10 version=10.5.11-MariaDB-debug-log 
5   0.002155    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=3484186329 TSecr=3288151496
6   0.038817    10.0.23.103 10.0.23.102 MySQL   102 Login Request user= 
7   0.038848    10.0.23.102 10.0.23.103 TCP 66  3307 → 41928 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=3288151533 TSecr=3484186366
8   0.187257    10.0.23.103 10.0.23.102 TLSv1.2 362 Client Hello
9   0.187289    10.0.23.102 10.0.23.103 TCP 66  3307 → 41928 [ACK] Seq=104 Ack=333 Win=65024 Len=0 TSval=3288151682 TSecr=3484186514
10  0.188088    10.0.23.102 10.0.23.103 TLSv1.2 776 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done
11  0.188595    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=333 Ack=814 Win=64128 Len=0 TSval=3484186515 TSecr=3288151683
12  0.207356    10.0.23.103 10.0.23.102 TLSv1.2 78  Certificate
13  0.207387    10.0.23.102 10.0.23.103 TCP 66  3307 → 41928 [ACK] Seq=814 Ack=345 Win=65024 Len=0 TSval=3288151702 TSecr=3484186534
14  0.217204    10.0.23.103 10.0.23.102 TLSv1.2 108 Client Key Exchange
15  0.217235    10.0.23.102 10.0.23.103 TCP 66  3307 → 41928 [ACK] Seq=814 Ack=387 Win=65024 Len=0 TSval=3288151712 TSecr=3484186544
16  0.224354    10.0.23.103 10.0.23.102 TLSv1.2 72  Change Cipher Spec
17  0.224386    10.0.23.102 10.0.23.103 TCP 66  3307 → 41928 [ACK] Seq=814 Ack=393 Win=65024 Len=0 TSval=3288151719 TSecr=3484186551
18  0.230976    10.0.23.103 10.0.23.102 TLSv1.2 111 Encrypted Handshake Message
19  0.231008    10.0.23.102 10.0.23.103 TCP 66  3307 → 41928 [ACK] Seq=814 Ack=438 Win=65024 Len=0 TSval=3288151726 TSecr=3484186558
20  0.231403    10.0.23.102 10.0.23.103 TLSv1.2 117 Change Cipher Spec, Encrypted Handshake Message
21  0.231785    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=438 Ack=865 Win=64128 Len=0 TSval=3484186559 TSecr=3288151726
22  0.237912    10.0.23.103 10.0.23.102 TLSv1.2 302 Application Data
23  0.237944    10.0.23.102 10.0.23.103 TCP 66  3307 → 41928 [ACK] Seq=865 Ack=674 Win=64896 Len=0 TSval=3288151733 TSecr=3484186565
24  0.238390    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
25  0.238807    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=674 Ack=905 Win=64128 Len=0 TSval=3484186566 TSecr=3288151733
26  0.241406    10.0.23.103 10.0.23.102 TLSv1.2 1071    Application Data
27  0.243553    10.0.23.102 10.0.23.103 TLSv1.2 1249    Application Data
28  0.244061    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=1679 Ack=2088 Win=64128 Len=0 TSval=3484186571 TSecr=3288151738
29  0.253392    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
30  0.254054    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
31  0.258239    10.0.23.103 10.0.23.102 TLSv1.2 100 Application Data
32  0.258571    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
33  0.259469    10.0.23.103 10.0.23.102 TLSv1.2 129 Application Data
34  0.260232    10.0.23.102 10.0.23.103 TLSv1.2 179 Application Data
35  0.277788    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
36  0.278513    10.0.23.102 10.0.23.103 TLSv1.2 176 Application Data
37  0.286757    10.0.23.103 10.0.23.102 TLSv1.2 142 Application Data
38  0.293134    10.0.23.102 10.0.23.103 TLSv1.2 334 Application Data
39  0.294452    10.0.23.103 10.0.23.102 TLSv1.2 145 Application Data
40  0.300361    10.0.23.102 10.0.23.103 TLSv1.2 338 Application Data
41  0.302393    10.0.23.103 10.0.23.102 TLSv1.2 152 Application Data
42  0.303201    10.0.23.102 10.0.23.103 TLSv1.2 192 Application Data
43  0.310984    10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data
44  0.329347    10.0.23.102 10.0.23.103 TCP 7306    3307 → 41928 [PSH, ACK] Seq=3057 Ack=2165 Win=64128 Len=7240 TSval=3288151824 TSecr=3484186638 [TCP segment of a reassembled PDU]
45  0.329358    10.0.23.102 10.0.23.103 TCP 7306    3307 → 41928 [PSH, ACK] Seq=10297 Ack=2165 Win=64128 Len=7240 TSval=3288151824 TSecr=3484186638 [TCP segment of a reassembled PDU]
46  0.330051    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=2165 Ack=7401 Win=64128 Len=0 TSval=3484186657 TSecr=3288151824
47  0.330065    10.0.23.102 10.0.23.103 TLSv1.2 1999    Application Data
48  0.330296    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=2165 Ack=10297 Win=64128 Len=0 TSval=3484186657 TSecr=3288151824
49  0.330529    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=2165 Ack=13193 Win=64128 Len=0 TSval=3484186657 TSecr=3288151824
50  0.330782    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=2165 Ack=16089 Win=64128 Len=0 TSval=3484186658 TSecr=3288151824
51  0.331024    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=2165 Ack=19470 Win=64128 Len=0 TSval=3484186658 TSecr=3288151824
52  0.331637    10.0.23.102 10.0.23.103 TLSv1.2 6509    Application Data
53  0.347933    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=2165 Ack=25913 Win=64128 Len=0 TSval=3484186675 TSecr=3288151826
54  0.367863    10.0.23.103 10.0.23.102 TCP 74  41932 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=3484186695 TSecr=0 WS=128
55  0.367919    10.0.23.102 10.0.23.103 TCP 74  3307 → 41932 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=3288151863 TSecr=3484186695 WS=128
56  0.368263    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=3484186695 TSecr=3288151863
57  0.369496    10.0.23.102 10.0.23.103 MySQL   169 Server Greeting  proto=10 version=10.5.11-MariaDB-debug-log 
58  0.369984    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=3484186697 TSecr=3288151864
59  0.370497    10.0.23.103 10.0.23.102 MySQL   102 Login Request user= 
60  0.370528    10.0.23.102 10.0.23.103 TCP 66  3307 → 41932 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=3288151865 TSecr=3484186697
61  0.382454    10.0.23.103 10.0.23.102 TLSv1.2 362 Client Hello
62  0.382486    10.0.23.102 10.0.23.103 TCP 66  3307 → 41932 [ACK] Seq=104 Ack=333 Win=65024 Len=0 TSval=3288151877 TSecr=3484186709
63  0.383319    10.0.23.102 10.0.23.103 TLSv1.2 775 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done
64  0.383715    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=333 Ack=813 Win=64128 Len=0 TSval=3484186710 TSecr=3288151878
65  0.393497    10.0.23.103 10.0.23.102 TLSv1.2 78  Certificate
66  0.393528    10.0.23.102 10.0.23.103 TCP 66  3307 → 41932 [ACK] Seq=813 Ack=345 Win=65024 Len=0 TSval=3288151888 TSecr=3484186720
67  0.396089    10.0.23.103 10.0.23.102 TLSv1.2 108 Client Key Exchange
68  0.396120    10.0.23.102 10.0.23.103 TCP 66  3307 → 41932 [ACK] Seq=813 Ack=387 Win=65024 Len=0 TSval=3288151891 TSecr=3484186723
69  0.402752    10.0.23.103 10.0.23.102 TLSv1.2 72  Change Cipher Spec
70  0.402783    10.0.23.102 10.0.23.103 TCP 66  3307 → 41932 [ACK] Seq=813 Ack=393 Win=65024 Len=0 TSval=3288151897 TSecr=3484186729
71  0.403057    10.0.23.103 10.0.23.102 TLSv1.2 111 Encrypted Handshake Message
72  0.403088    10.0.23.102 10.0.23.103 TCP 66  3307 → 41932 [ACK] Seq=813 Ack=438 Win=65024 Len=0 TSval=3288151898 TSecr=3484186730
73  0.403439    10.0.23.102 10.0.23.103 TLSv1.2 117 Change Cipher Spec, Encrypted Handshake Message
74  0.403706    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=438 Ack=864 Win=64128 Len=0 TSval=3484186730 TSecr=3288151898
75  0.410488    10.0.23.103 10.0.23.102 TLSv1.2 302 Application Data
76  0.410520    10.0.23.102 10.0.23.103 TCP 66  3307 → 41932 [ACK] Seq=864 Ack=674 Win=64896 Len=0 TSval=3288151905 TSecr=3484186737
77  0.411017    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
78  0.411468    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=674 Ack=904 Win=64128 Len=0 TSval=3484186738 TSecr=3288151906
79  0.413257    10.0.23.103 10.0.23.102 TLSv1.2 1071    Application Data
80  0.415438    10.0.23.102 10.0.23.103 TLSv1.2 1249    Application Data
81  0.415967    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=1679 Ack=2087 Win=64128 Len=0 TSval=3484186743 TSecr=3288151910
82  0.417323    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
83  0.418046    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
84  0.418447    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=1729 Ack=2127 Win=64128 Len=0 TSval=3484186745 TSecr=3288151913
85  0.449448    10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data
86  0.451177    10.0.23.102 10.0.23.103 TLSv1.2 246 Application Data
87  0.451869    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=1777 Ack=2307 Win=64128 Len=0 TSval=3484186779 TSecr=3288151946
88  0.456492    10.0.23.103 10.0.23.102 TLSv1.2 163 Application Data
89  0.458896    10.0.23.102 10.0.23.103 TLSv1.2 314 Application Data
90  0.462083    10.0.23.103 10.0.23.102 TLSv1.2 158 Application Data
91  0.464445    10.0.23.102 10.0.23.103 TLSv1.2 335 Application Data
92  0.467335    10.0.23.103 10.0.23.102 TLSv1.2 172 Application Data
93  0.469865    10.0.23.102 10.0.23.103 TLSv1.2 301 Application Data
94  0.471583    10.0.23.103 10.0.23.102 TLSv1.2 159 Application Data
95  0.476928    10.0.23.102 10.0.23.103 TLSv1.2 1021    Application Data
96  0.485045    10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data
97  0.502614    10.0.23.102 10.0.23.103 TCP 7306    3307 → 41932 [PSH, ACK] Seq=4014 Ack=2213 Win=64128 Len=7240 TSval=3288151997 TSecr=3484186812 [TCP segment of a reassembled PDU]
98  0.502627    10.0.23.102 10.0.23.103 TCP 7306    3307 → 41932 [PSH, ACK] Seq=11254 Ack=2213 Win=64128 Len=7240 TSval=3288151997 TSecr=3484186812 [TCP segment of a reassembled PDU]
99  0.503251    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=2213 Ack=6910 Win=63488 Len=0 TSval=3484186830 TSecr=3288151997
100 0.503294    10.0.23.102 10.0.23.103 TLSv1.2 1999    Application Data
101 0.503345    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=2213 Ack=9806 Win=63488 Len=0 TSval=3484186830 TSecr=3288151997
102 0.503647    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=2213 Ack=12702 Win=63488 Len=0 TSval=3484186830 TSecr=3288151997
103 0.503882    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=2213 Ack=15598 Win=63488 Len=0 TSval=3484186831 TSecr=3288151997
104 0.504136    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=2213 Ack=18494 Win=63488 Len=0 TSval=3484186831 TSecr=3288151997
105 0.504382    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=2213 Ack=20427 Win=63488 Len=0 TSval=3484186831 TSecr=3288151998
106 0.504894    10.0.23.102 10.0.23.103 TLSv1.2 6509    Application Data
107 0.505404    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=2213 Ack=23323 Win=63488 Len=0 TSval=3484186832 TSecr=3288152000
108 0.510793    10.0.23.103 10.0.23.102 TCP 66  41932 → 3307 [ACK] Seq=2213 Ack=26870 Win=64128 Len=0 TSval=3484186838 TSecr=3288152000
109 0.530983    10.0.23.103 10.0.23.102 TLSv1.2 135 Application Data
110 0.531768    10.0.23.102 10.0.23.103 TLSv1.2 371 Application Data
111 0.578156    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=2234 Ack=26218 Win=67072 Len=0 TSval=3484186905 TSecr=3288152026
112 0.902238    10.0.23.103 10.0.23.102 TLSv1.2 150 Application Data
113 0.904093    10.0.23.102 10.0.23.103 TLSv1.2 197 Application Data
114 0.904346    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=2318 Ack=26349 Win=69888 Len=0 TSval=3484187231 TSecr=3288152399
115 0.908639    10.0.23.103 10.0.23.102 TLSv1.2 111 Application Data
116 0.909302    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
117 0.909663    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=2363 Ack=26389 Win=69888 Len=0 TSval=3484187236 TSecr=3288152404
118 0.910369    10.0.23.103 10.0.23.102 TLSv1.2 134 Application Data
119 0.913360    10.0.23.102 10.0.23.103 TLSv1.2 1752    Application Data
120 0.913935    10.0.23.103 10.0.23.102 TCP 66  41928 → 3307 [ACK] Seq=2431 Ack=28075 Win=69632 Len=0 TSval=3484187241 TSecr=3288152408
121 1.633268    10.0.23.103 10.0.23.102 TCP 74  41942 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=3484187960 TSecr=0 WS=128
122 1.633326    10.0.23.102 10.0.23.103 TCP 74  3307 → 41942 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=3288153128 TSecr=3484187960 WS=128
123 1.633787    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=3484187960 TSecr=3288153128
124 1.634984    10.0.23.102 10.0.23.103 MySQL   169 Server Greeting  proto=10 version=10.5.11-MariaDB-debug-log 
125 1.635505    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=3484187962 TSecr=3288153130
126 1.668991    10.0.23.103 10.0.23.102 MySQL   102 Login Request user= 
127 1.669022    10.0.23.102 10.0.23.103 TCP 66  3307 → 41942 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=3288153164 TSecr=3484187996
128 1.768603    10.0.23.103 10.0.23.102 TLSv1.2 362 Client Hello
129 1.768636    10.0.23.102 10.0.23.103 TCP 66  3307 → 41942 [ACK] Seq=104 Ack=333 Win=65024 Len=0 TSval=3288153263 TSecr=3484188095
130 1.769516    10.0.23.102 10.0.23.103 TLSv1.2 776 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done
131 1.769927    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=333 Ack=814 Win=64128 Len=0 TSval=3484188097 TSecr=3288153264
132 1.786823    10.0.23.103 10.0.23.102 TLSv1.2 78  Certificate
133 1.786855    10.0.23.102 10.0.23.103 TCP 66  3307 → 41942 [ACK] Seq=814 Ack=345 Win=65024 Len=0 TSval=3288153281 TSecr=3484188114
134 1.795901    10.0.23.103 10.0.23.102 TLSv1.2 108 Client Key Exchange
135 1.795933    10.0.23.102 10.0.23.103 TCP 66  3307 → 41942 [ACK] Seq=814 Ack=387 Win=65024 Len=0 TSval=3288153291 TSecr=3484188123
136 1.803141    10.0.23.103 10.0.23.102 TLSv1.2 72  Change Cipher Spec
137 1.803172    10.0.23.102 10.0.23.103 TCP 66  3307 → 41942 [ACK] Seq=814 Ack=393 Win=65024 Len=0 TSval=3288153298 TSecr=3484188130
138 1.810185    10.0.23.103 10.0.23.102 TLSv1.2 111 Encrypted Handshake Message
139 1.810216    10.0.23.102 10.0.23.103 TCP 66  3307 → 41942 [ACK] Seq=814 Ack=438 Win=65024 Len=0 TSval=3288153305 TSecr=3484188137
140 1.810685    10.0.23.102 10.0.23.103 TLSv1.2 117 Change Cipher Spec, Encrypted Handshake Message
141 1.811150    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=438 Ack=865 Win=64128 Len=0 TSval=3484188138 TSecr=3288153305
142 1.817851    10.0.23.103 10.0.23.102 TLSv1.2 302 Application Data
143 1.817884    10.0.23.102 10.0.23.103 TCP 66  3307 → 41942 [ACK] Seq=865 Ack=674 Win=64896 Len=0 TSval=3288153313 TSecr=3484188145
144 1.818395    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
145 1.818882    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=674 Ack=905 Win=64128 Len=0 TSval=3484188146 TSecr=3288153313
146 1.821765    10.0.23.103 10.0.23.102 TLSv1.2 1071    Application Data
147 1.823938    10.0.23.102 10.0.23.103 TLSv1.2 1249    Application Data
148 1.824407    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1679 Ack=2088 Win=64128 Len=0 TSval=3484188151 TSecr=3288153319
149 1.832188    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
150 1.832917    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
151 1.841406    10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data
152 1.859086    10.0.23.102 10.0.23.103 TCP 7306    3307 → 41942 [PSH, ACK] Seq=2128 Ack=1777 Win=64128 Len=7240 TSval=3288153354 TSecr=3484188168 [TCP segment of a reassembled PDU]
153 1.859098    10.0.23.102 10.0.23.103 TCP 7306    3307 → 41942 [PSH, ACK] Seq=9368 Ack=1777 Win=64128 Len=7240 TSval=3288153354 TSecr=3484188168 [TCP segment of a reassembled PDU]
154 1.859676    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1777 Ack=5024 Win=63488 Len=0 TSval=3484188186 TSecr=3288153354
155 1.859717    10.0.23.102 10.0.23.103 TLSv1.2 1999    Application Data
156 1.859859    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1777 Ack=7920 Win=63488 Len=0 TSval=3484188187 TSecr=3288153354
157 1.860116    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1777 Ack=10816 Win=63488 Len=0 TSval=3484188187 TSecr=3288153354
158 1.860373    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1777 Ack=13712 Win=63488 Len=0 TSval=3484188187 TSecr=3288153354
159 1.860601    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1777 Ack=16608 Win=63488 Len=0 TSval=3484188187 TSecr=3288153354
160 1.860852    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1777 Ack=18541 Win=63488 Len=0 TSval=3484188188 TSecr=3288153354
161 1.861410    10.0.23.102 10.0.23.103 TLSv1.2 6509    Application Data
162 1.861867    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1777 Ack=21437 Win=63488 Len=0 TSval=3484188189 TSecr=3288153356
163 1.868589    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1777 Ack=24984 Win=64128 Len=0 TSval=3484188195 TSecr=3288153356
164 1.969700    10.0.23.103 10.0.23.102 TLSv1.2 118 Application Data
165 1.970333    10.0.23.102 10.0.23.103 TLSv1.2 283 Application Data
166 1.982673    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
167 1.983296    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
168 2.000666    10.0.23.103 10.0.23.102 TLSv1.2 131 Application Data
169 2.002641    10.0.23.102 10.0.23.103 TLSv1.2 457 Application Data
170 2.019966    10.0.23.103 10.0.23.102 TLSv1.2 118 Application Data
171 2.020602    10.0.23.102 10.0.23.103 TLSv1.2 283 Application Data
172 2.062128    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=1996 Ack=25849 Win=70528 Len=0 TSval=3484188389 TSecr=3288153515
173 2.479559    10.0.23.103 10.0.23.102 TLSv1.2 108 Application Data
174 2.480172    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
175 2.480485    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [ACK] Seq=2038 Ack=25889 Win=70528 Len=0 TSval=3484188807 TSecr=3288153975
176 2.481391    10.0.23.103 10.0.23.102 TLSv1.2 100 Application Data
177 2.482074    10.0.23.102 10.0.23.103 TCP 66  3307 → 41942 [FIN, ACK] Seq=25889 Ack=2072 Win=64128 Len=0 TSval=3288153977 TSecr=3484188808
178 2.482988    10.0.23.103 10.0.23.102 TLSv1.2 97  Encrypted Alert
179 2.483038    10.0.23.102 10.0.23.103 TCP 54  3307 → 41942 [RST] Seq=25890 Win=0 Len=0
180 2.483072    10.0.23.103 10.0.23.102 TCP 66  41942 → 3307 [FIN, ACK] Seq=2103 Ack=25890 Win=70528 Len=0 TSval=3484188810 TSecr=3288153977
181 2.483085    10.0.23.102 10.0.23.103 TCP 54  3307 → 41942 [RST] Seq=25890 Win=0 Len=0
182 2.720130    10.0.23.103 10.0.23.102 TCP 74  41944 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=3484189047 TSecr=0 WS=128
183 2.720185    10.0.23.102 10.0.23.103 TCP 74  3307 → 41944 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=3288154215 TSecr=3484189047 WS=128
184 2.720404    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=3484189047 TSecr=3288154215
185 2.721594    10.0.23.102 10.0.23.103 MySQL   169 Server Greeting  proto=10 version=10.5.11-MariaDB-debug-log 
186 2.722135    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=3484189049 TSecr=3288154216
187 2.722421    10.0.23.103 10.0.23.102 MySQL   102 Login Request user= 
188 2.722451    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=3288154217 TSecr=3484189049
189 2.728733    10.0.23.103 10.0.23.102 TLSv1.2 362 Client Hello
190 2.728764    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [ACK] Seq=104 Ack=333 Win=65024 Len=0 TSval=3288154223 TSecr=3484189055
191 2.729634    10.0.23.102 10.0.23.103 TLSv1.2 775 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done
192 2.730102    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=333 Ack=813 Win=64128 Len=0 TSval=3484189057 TSecr=3288154224
193 2.734232    10.0.23.103 10.0.23.102 TLSv1.2 78  Certificate
194 2.734263    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [ACK] Seq=813 Ack=345 Win=65024 Len=0 TSval=3288154229 TSecr=3484189061
195 2.735008    10.0.23.103 10.0.23.102 TLSv1.2 108 Client Key Exchange
196 2.735038    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [ACK] Seq=813 Ack=387 Win=65024 Len=0 TSval=3288154230 TSecr=3484189062
197 2.737376    10.0.23.103 10.0.23.102 TLSv1.2 72  Change Cipher Spec
198 2.737406    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [ACK] Seq=813 Ack=393 Win=65024 Len=0 TSval=3288154232 TSecr=3484189064
199 2.737546    10.0.23.103 10.0.23.102 TLSv1.2 111 Encrypted Handshake Message
200 2.737577    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [ACK] Seq=813 Ack=438 Win=65024 Len=0 TSval=3288154232 TSecr=3484189064
201 2.738072    10.0.23.102 10.0.23.103 TLSv1.2 117 Change Cipher Spec, Encrypted Handshake Message
202 2.738338    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=438 Ack=864 Win=64128 Len=0 TSval=3484189065 TSecr=3288154233
203 2.739203    10.0.23.103 10.0.23.102 TLSv1.2 302 Application Data
204 2.739234    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [ACK] Seq=864 Ack=674 Win=64896 Len=0 TSval=3288154234 TSecr=3484189066
205 2.739746    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
206 2.740635    10.0.23.103 10.0.23.102 TLSv1.2 1071    Application Data
207 2.740672    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [ACK] Seq=904 Ack=1679 Win=64128 Len=0 TSval=3288154235 TSecr=3484189067
208 2.742862    10.0.23.102 10.0.23.103 TLSv1.2 1249    Application Data
209 2.744141    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
210 2.744177    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [ACK] Seq=2087 Ack=1729 Win=64128 Len=0 TSval=3288154239 TSecr=3484189071
211 2.744877    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
212 2.745829    10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data
213 2.745865    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [ACK] Seq=2127 Ack=1777 Win=64128 Len=0 TSval=3288154240 TSecr=3484189073
214 2.747547    10.0.23.102 10.0.23.103 TLSv1.2 246 Application Data
215 2.749093    10.0.23.103 10.0.23.102 TLSv1.2 163 Application Data
216 2.751423    10.0.23.102 10.0.23.103 TLSv1.2 314 Application Data
217 2.752705    10.0.23.103 10.0.23.102 TLSv1.2 158 Application Data
218 2.755103    10.0.23.102 10.0.23.103 TLSv1.2 335 Application Data
219 2.756569    10.0.23.103 10.0.23.102 TLSv1.2 172 Application Data
220 2.759083    10.0.23.102 10.0.23.103 TLSv1.2 301 Application Data
221 2.760342    10.0.23.103 10.0.23.102 TLSv1.2 159 Application Data
222 2.765542    10.0.23.102 10.0.23.103 TLSv1.2 1021    Application Data
223 2.770893    10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data
224 2.787989    10.0.23.102 10.0.23.103 TCP 7306    3307 → 41944 [PSH, ACK] Seq=4014 Ack=2213 Win=64128 Len=7240 TSval=3288154283 TSecr=3484189098 [TCP segment of a reassembled PDU]
225 2.788002    10.0.23.102 10.0.23.103 TCP 7306    3307 → 41944 [PSH, ACK] Seq=11254 Ack=2213 Win=64128 Len=7240 TSval=3288154283 TSecr=3484189098 [TCP segment of a reassembled PDU]
226 2.788695    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=2213 Ack=8358 Win=62592 Len=0 TSval=3484189115 TSecr=3288154283
227 2.788734    10.0.23.102 10.0.23.103 TLSv1.2 1999    Application Data
228 2.788752    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=2213 Ack=11254 Win=63488 Len=0 TSval=3484189116 TSecr=3288154283
229 2.789081    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=2213 Ack=14150 Win=63488 Len=0 TSval=3484189116 TSecr=3288154283
230 2.789312    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=2213 Ack=17046 Win=63488 Len=0 TSval=3484189116 TSecr=3288154283
231 2.789571    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=2213 Ack=19942 Win=63488 Len=0 TSval=3484189116 TSecr=3288154283
232 2.790152    10.0.23.102 10.0.23.103 TLSv1.2 6509    Application Data
233 2.790586    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=2213 Ack=21875 Win=64128 Len=0 TSval=3484189117 TSecr=3288154283
234 2.796585    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=2213 Ack=26870 Win=60672 Len=0 TSval=3484189123 TSecr=3288154285
235 2.807532    10.0.23.103 10.0.23.102 TLSv1.2 135 Application Data
236 2.808288    10.0.23.102 10.0.23.103 TLSv1.2 371 Application Data
237 2.850120    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [ACK] Seq=2282 Ack=27175 Win=64128 Len=0 TSval=3484189177 TSecr=3288154303
238 3.110765    10.0.23.103 10.0.23.102 TLSv1.2 100 Application Data
239 3.110967    10.0.23.103 10.0.23.102 TLSv1.2 97  Encrypted Alert
240 3.110996    10.0.23.103 10.0.23.102 TCP 66  41944 → 3307 [FIN, ACK] Seq=2347 Ack=27175 Win=64128 Len=0 TSval=3484189438 TSecr=3288154303
241 3.111438    10.0.23.102 10.0.23.103 TCP 66  3307 → 41944 [RST, ACK] Seq=27175 Ack=2348 Win=64128 Len=0 TSval=3288154606 TSecr=3484189437
242 3.125219    10.0.23.103 10.0.23.102 TCP 74  41952 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=3484189452 TSecr=0 WS=128
243 3.125274    10.0.23.102 10.0.23.103 TCP 74  3307 → 41952 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=3288154620 TSecr=3484189452 WS=128
244 3.125582    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=3484189452 TSecr=3288154620
245 3.126707    10.0.23.102 10.0.23.103 MySQL   169 Server Greeting  proto=10 version=10.5.11-MariaDB-debug-log 
246 3.127043    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=3484189454 TSecr=3288154621
247 3.127496    10.0.23.103 10.0.23.102 MySQL   102 Login Request user= 
248 3.127527    10.0.23.102 10.0.23.103 TCP 66  3307 → 41952 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=3288154622 TSecr=3484189454
249 3.135461    10.0.23.103 10.0.23.102 TLSv1.2 362 Client Hello
250 3.135492    10.0.23.102 10.0.23.103 TCP 66  3307 → 41952 [ACK] Seq=104 Ack=333 Win=65024 Len=0 TSval=3288154630 TSecr=3484189462
251 3.136319    10.0.23.102 10.0.23.103 TLSv1.2 777 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done
252 3.136787    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=333 Ack=815 Win=64128 Len=0 TSval=3484189463 TSecr=3288154631
253 3.142238    10.0.23.103 10.0.23.102 TLSv1.2 78  Certificate
254 3.142269    10.0.23.102 10.0.23.103 TCP 66  3307 → 41952 [ACK] Seq=815 Ack=345 Win=65024 Len=0 TSval=3288154637 TSecr=3484189469
255 3.143767    10.0.23.103 10.0.23.102 TLSv1.2 108 Client Key Exchange
256 3.143797    10.0.23.102 10.0.23.103 TCP 66  3307 → 41952 [ACK] Seq=815 Ack=387 Win=65024 Len=0 TSval=3288154638 TSecr=3484189470
257 3.146476    10.0.23.103 10.0.23.102 TLSv1.2 72  Change Cipher Spec
258 3.146506    10.0.23.102 10.0.23.103 TCP 66  3307 → 41952 [ACK] Seq=815 Ack=393 Win=65024 Len=0 TSval=3288154641 TSecr=3484189473
259 3.146773    10.0.23.103 10.0.23.102 TLSv1.2 111 Encrypted Handshake Message
260 3.146803    10.0.23.102 10.0.23.103 TCP 66  3307 → 41952 [ACK] Seq=815 Ack=438 Win=65024 Len=0 TSval=3288154641 TSecr=3484189474
261 3.147170    10.0.23.102 10.0.23.103 TLSv1.2 117 Change Cipher Spec, Encrypted Handshake Message
262 3.147504    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=438 Ack=866 Win=64128 Len=0 TSval=3484189474 TSecr=3288154642
263 3.148828    10.0.23.103 10.0.23.102 TLSv1.2 302 Application Data
264 3.148859    10.0.23.102 10.0.23.103 TCP 66  3307 → 41952 [ACK] Seq=866 Ack=674 Win=64896 Len=0 TSval=3288154643 TSecr=3484189476
265 3.149377    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
266 3.149780    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=674 Ack=906 Win=64128 Len=0 TSval=3484189476 TSecr=3288154644
267 3.150494    10.0.23.103 10.0.23.102 TLSv1.2 1071    Application Data
268 3.150525    10.0.23.102 10.0.23.103 TCP 66  3307 → 41952 [ACK] Seq=906 Ack=1679 Win=64128 Len=0 TSval=3288154645 TSecr=3484189477
269 3.152665    10.0.23.102 10.0.23.103 TLSv1.2 1249    Application Data
270 3.153003    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1679 Ack=2089 Win=64128 Len=0 TSval=3484189480 TSecr=3288154647
271 3.154216    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
272 3.154247    10.0.23.102 10.0.23.103 TCP 66  3307 → 41952 [ACK] Seq=2089 Ack=1729 Win=64128 Len=0 TSval=3288154649 TSecr=3484189481
273 3.154947    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
274 3.155257    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1729 Ack=2129 Win=64128 Len=0 TSval=3484189482 TSecr=3288154650
275 3.156056    10.0.23.103 10.0.23.102 TLSv1.2 114 Application Data
276 3.173733    10.0.23.102 10.0.23.103 TCP 7306    3307 → 41952 [PSH, ACK] Seq=2129 Ack=1777 Win=64128 Len=7240 TSval=3288154668 TSecr=3484189483 [TCP segment of a reassembled PDU]
277 3.173745    10.0.23.102 10.0.23.103 TCP 7306    3307 → 41952 [PSH, ACK] Seq=9369 Ack=1777 Win=64128 Len=7240 TSval=3288154668 TSecr=3484189483 [TCP segment of a reassembled PDU]
278 3.174284    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1777 Ack=5025 Win=63488 Len=0 TSval=3484189501 TSecr=3288154668
279 3.174323    10.0.23.102 10.0.23.103 TLSv1.2 1999    Application Data
280 3.174505    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1777 Ack=7921 Win=63488 Len=0 TSval=3484189501 TSecr=3288154668
281 3.174740    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1777 Ack=10817 Win=63488 Len=0 TSval=3484189501 TSecr=3288154668
282 3.174981    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1777 Ack=13713 Win=63488 Len=0 TSval=3484189502 TSecr=3288154668
283 3.175231    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1777 Ack=16609 Win=63488 Len=0 TSval=3484189502 TSecr=3288154668
284 3.175480    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1777 Ack=18542 Win=63488 Len=0 TSval=3484189502 TSecr=3288154669
285 3.175714    10.0.23.102 10.0.23.103 TLSv1.2 6510    Application Data
286 3.176261    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1777 Ack=21438 Win=63488 Len=0 TSval=3484189503 TSecr=3288154670
287 3.179320    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1777 Ack=24986 Win=60672 Len=0 TSval=3484189506 TSecr=3288154670
288 3.187971    10.0.23.103 10.0.23.102 TLSv1.2 116 Application Data
289 3.188614    10.0.23.102 10.0.23.103 TLSv1.2 206 Application Data
290 3.189054    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1827 Ack=25126 Win=64128 Len=0 TSval=3484189516 TSecr=3288154683
291 3.202300    10.0.23.103 10.0.23.102 TLSv1.2 138 Application Data
292 3.211740    10.0.23.102 10.0.23.103 TLSv1.2 324 Application Data
293 3.211998    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=1899 Ack=25384 Win=67072 Len=0 TSval=3484189539 TSecr=3288154706
294 3.229530    10.0.23.103 10.0.23.102 TLSv1.2 138 Application Data
295 3.235804    10.0.23.102 10.0.23.103 TLSv1.2 312 Application Data
296 3.238068    10.0.23.103 10.0.23.102 TLSv1.2 118 Application Data
297 3.238703    10.0.23.102 10.0.23.103 TLSv1.2 283 Application Data
298 3.243792    10.0.23.103 10.0.23.102 TCP 74  41958 → 3307 [SYN] Seq=0 Win=64240 Len=0 MSS=1460 SACK_PERM TSval=3484189570 TSecr=0 WS=128
299 3.243847    10.0.23.102 10.0.23.103 TCP 74  3307 → 41958 [SYN, ACK] Seq=0 Ack=1 Win=65160 Len=0 MSS=1460 SACK_PERM TSval=3288154738 TSecr=3484189570 WS=128
300 3.244249    10.0.23.103 10.0.23.102 TCP 66  41958 → 3307 [ACK] Seq=1 Ack=1 Win=64256 Len=0 TSval=3484189571 TSecr=3288154738
301 3.246018    10.0.23.102 10.0.23.103 MySQL   169 Server Greeting  proto=10 version=10.5.11-MariaDB-debug-log 
302 3.246204    10.0.23.103 10.0.23.102 TCP 66  41958 → 3307 [ACK] Seq=1 Ack=104 Win=64256 Len=0 TSval=3484189573 TSecr=3288154741
303 3.251694    10.0.23.103 10.0.23.102 MySQL   102 Login Request user= 
304 3.251724    10.0.23.102 10.0.23.103 TCP 66  3307 → 41958 [ACK] Seq=104 Ack=37 Win=65280 Len=0 TSval=3288154746 TSecr=3484189578
305 3.286097    10.0.23.103 10.0.23.102 TCP 66  41952 → 3307 [ACK] Seq=2023 Ack=25847 Win=72832 Len=0 TSval=3484189613 TSecr=3288154733
306 3.300820    10.0.23.103 10.0.23.102 TLSv1.2 367 Client Hello
307 3.300852    10.0.23.102 10.0.23.103 TCP 66  3307 → 41958 [ACK] Seq=104 Ack=338 Win=65024 Len=0 TSval=3288154795 TSecr=3484189627
308 3.301707    10.0.23.102 10.0.23.103 TLSv1.2 777 Server Hello, Certificate, Server Key Exchange, Certificate Request, Server Hello Done
309 3.302193    10.0.23.103 10.0.23.102 TCP 66  41958 → 3307 [ACK] Seq=338 Ack=815 Win=64128 Len=0 TSval=3484189629 TSecr=3288154796
310 3.312157    10.0.23.103 10.0.23.102 TLSv1.2 78  Certificate
311 3.312187    10.0.23.102 10.0.23.103 TCP 66  3307 → 41958 [ACK] Seq=815 Ack=350 Win=65024 Len=0 TSval=3288154807 TSecr=3484189639
312 3.314142    10.0.23.103 10.0.23.102 TLSv1.2 108 Client Key Exchange
313 3.314173    10.0.23.102 10.0.23.103 TCP 66  3307 → 41958 [ACK] Seq=815 Ack=392 Win=65024 Len=0 TSval=3288154809 TSecr=3484189641
314 3.317809    10.0.23.103 10.0.23.102 TLSv1.2 72  Change Cipher Spec
315 3.317839    10.0.23.102 10.0.23.103 TCP 66  3307 → 41958 [ACK] Seq=815 Ack=398 Win=65024 Len=0 TSval=3288154812 TSecr=3484189645
316 3.318263    10.0.23.103 10.0.23.102 TLSv1.2 111 Encrypted Handshake Message
317 3.318293    10.0.23.102 10.0.23.103 TCP 66  3307 → 41958 [ACK] Seq=815 Ack=443 Win=65024 Len=0 TSval=3288154813 TSecr=3484189645
318 3.318599    10.0.23.102 10.0.23.103 TLSv1.2 117 Change Cipher Spec, Encrypted Handshake Message
319 3.318903    10.0.23.103 10.0.23.102 TCP 66  41958 → 3307 [ACK] Seq=443 Ack=866 Win=64128 Len=0 TSval=3484189646 TSecr=3288154813
320 3.330340    10.0.23.103 10.0.23.102 TLSv1.2 179 Application Data
321 3.330371    10.0.23.102 10.0.23.103 TCP 66  3307 → 41958 [ACK] Seq=866 Ack=556 Win=65024 Len=0 TSval=3288154825 TSecr=3484189657
322 3.330948    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
323 3.331237    10.0.23.103 10.0.23.102 TCP 66  41958 → 3307 [ACK] Seq=556 Ack=906 Win=64128 Len=0 TSval=3484189658 TSecr=3288154826
324 3.332656    10.0.23.103 10.0.23.102 TLSv1.2 144 Application Data
325 3.339048    10.0.23.102 10.0.23.103 TLSv1.2 345 Application Data
326 3.339491    10.0.23.103 10.0.23.102 TCP 66  41958 → 3307 [ACK] Seq=634 Ack=1185 Win=64128 Len=0 TSval=3484189666 TSecr=3288154834
327 3.341000    10.0.23.103 10.0.23.102 TLSv1.2 153 Application Data
328 3.341725    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
329 3.342424    10.0.23.103 10.0.23.102 TLSv1.2 118 Application Data
330 3.343217    10.0.23.102 10.0.23.103 TLSv1.2 161 Application Data
331 3.344061    10.0.23.103 10.0.23.102 TLSv1.2 140 Application Data
332 3.344697    10.0.23.102 10.0.23.103 TLSv1.2 106 Application Data
333 3.345952    10.0.23.103 10.0.23.102 TLSv1.2 126 Application Data
334 3.347283    10.0.23.102 10.0.23.103 TLSv1.2 404 Application Data
335 3.390125    10.0.23.103 10.0.23.102 TCP 66  41958 → 3307 [ACK] Seq=907 Ack=1698 Win=64128 Len=0 TSval=3484189717 TSecr=3288154842
336 19.127493   10.0.23.102 10.0.23.103 TLSv1.2 376 Application Data
337 19.127809   10.0.23.103 10.0.23.102 TCP 66  41958 → 3307 [ACK] Seq=907 Ack=2008 Win=64128 Len=0 TSval=3484205455 TSecr=3288170622

My question is will my modification affect other code of flink cdc?

water5-cmd commented 2 years ago

I just tested the release version of flink-sql-connector-mysql-cdc-2.3.0.jar and found that the above problem still exists, but it is a little different;

flink sql client:

Flink SQL> CREATE TABLE user_source10 (
>       `id` int,
>       name STRING,
>       age int,
>       PRIMARY KEY (`id`) NOT ENFORCED
>     ) WITH (
>       'connector' = 'mysql-cdc',
>       'hostname' = '10.0.23.102',
>       'port' = '3307',
>       'username' = 'test',
>       'password' = '123',
>       'database-name' = 'demo',
>       'table-name' = 'student1', 'jdbc.properties.enabledTLSProtocols' = 'TLSv1.2','jdbc.properties.u
seSSL' = 'true', 'jdbc.properties.requireSSL'= 'true', 'jdbc.properties.verifyServerCertificate' = 'false' );

This connection configuration will still use the TCP connection for the third time;

Flink SQL> CREATE TABLE user_source9 (
>       `id` int,
>       name STRING,
>       age int,
>       PRIMARY KEY (`id`) NOT ENFORCED
>     ) WITH (
>       'connector' = 'mysql-cdc',
>       'hostname' = '10.0.23.102',
>       'port' = '3307',
>       'username' = 'test',
>       'password' = '123',
>       'database-name' = 'demo',
>       'table-name' = 'student1', 'jdbc.properties.enabledTLSProtocols' = 'TLSv1.2', 'debezium.database.ssl.mode'='required', 'jdbc.properties.verifyServerCertificate' = 'false' );
[INFO] Execute statement succeed.
Flink SQL> select * from user_source9;
[ERROR] Could not execute SQL statement. Reason:
java.net.SocketException: Connection reset by peer (Write failed)

This connection configuration is different from flink-sql-connector-mysql-cdc-2.2.1, it will always maintain the TLSv1.2 connection, although there are still errors;

leonardBang commented 2 years ago

@lijun0314 Have you tried MySQL? Given the fact that the community never tested EdgelessDB, thus I can not offer valuable inputs.

PatrickRen commented 8 months ago

Closing this issue because it was created before version 2.3.0 (2022-11-10). Please try the latest version of Flink CDC to see if the issue has been resolved. If the issue is still valid, kindly report it on Apache Jira under project Flink with component tag Flink CDC. Thank you!