Shawn Huang

Document about running the code

2

Hi, Thanks for your great work! I try to run this code by `python supervised_train.py` but the problem is: ``` Traceback (most recent call last): File "/home/huangxiao/gitProjects/DREAM/graphsage/supervised_train.py", line 240, in...

In JDK 8 and earlier version, if multiple threads invoke `Class.forName("com.xx.Driver")` simultaneously, it may cause jdbc driver deadlock. [FLINK-19435](https://issues.apache.org/jira/browse/FLINK-19435)  analyzes this problem.

Improve MySqlStreamingChangeEventSource to skip null events in event deserializer.

The value of option `connector.timeout` needs to be checked at compile time.

Improve jdbc connection pool initialization failure message.

Since MySQL does not support the ability to quickly locate an binlog offset through a timestamp, the current logic for starting from a timestamp is to begin from the earliest...

[FLINK-35409][cdc][mysql] Request more splits if all splits are filtered from addSplits method

1

The issue is described in [FLINK-35409](https://issues.apache.org/jira/browse/FLINK-35409).

Now, MySQL CDC connector will retrieve the offset seconds between the configured timezone and UTC by executing the SQL statement below, and then compare it with the configured timezone. ```SQL...

FlinkCDC uses debezium for capturing and parsing incremental data, but during the snapshot phase, FlinkCDC uses its own designed read implementation, so for FlinkCDC, some debezium options do not take...