0
Flink에서 데이터를 쓰거나 읽으려고 할 때 Flink 데이터베이스 연결 문제가 발생했습니다 .은 MySQL에 데이터 크기가 작습니다. 그러나 동시에 많은 수의 sinkFuction이 호출 될 수 있습니다. 저비용으로이 문제를 해결할 더 좋은 방법이 있는지 알고 싶습니다.Flink 데이터베이스 연결
A
답변
0
RichSinkFunction을 사용하고 open 및 close 메서드를 재정 의하여 MySQL 연결을 만들고 삭제할 수 있습니다. 또는 테이블 싱크가있는 테이블 API를 사용하는 것이 더 좋습니다 (https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/table/sourceSinks.html#define-a-tablesink).