Dear all:
I have a problem when I want to sink data to Hana database.
Process is suspended when get Hana connection in the open method of sink
function as below.
My flink version is 1.10.
public class HrrmPayValueSumToHana extends
RichSinkFunction<HrmsPayValueAccumulator> {
@Override
public void open(Configuration parameters) throws Exception {
super.open(parameters);
connection = HrrmUtils.getHanaConnection(); // process is suspended here
}
@Override
public void invoke() {
.......
}
@Override
public void close() throws Exception {
..........
}
}
public static Connection getHanaConnection() {
Connection con = null;
try {
Class.forName(HrrmConstants.HANA_DRIVER_CLASS);
con = DriverManager.getConnection(HrrmConstants.HANA_SOURCE_DRIVER_URL,
HrrmConstants.HANA_SOURCE_USER, HrrmConstants.HANA_SOURCE_PASSWORD);
} catch (Exception e) {
LOG.error("-----------hana get connection has exception , msg = ", e);
}
return con;
}
Hana driver dependency as below:
<dependency>
<groupId>com.sap.cloud.db.jdbc</groupId>
<artifactId>ngdbc</artifactId>
<version>2.3.62</version>
</dependency>
