[IOTDB-1038] [Flink] setStorageGroup() should not be called every time in IoTDBSink

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.11.1
• Component/s: Connectors/Flink
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Xiangdong Huang
• Created: 02/Dec/20 09:49
• Updated: 25/Aug/21 08:20
• Resolved: 02/Dec/20 12:42

Description

in IoTDBSink, the codes are:

  void initSession() throws Exception {
    pool = new SessionPool(options.getHost(), options.getPort(), options.getUser(),
        options.getPassword(), sessionPoolSize);

    pool.setStorageGroup(options.getStorageGroup());
    for (IoTDBOptions.TimeseriesOption option : options.getTimeseriesOptionList()) {
      if (!pool.checkTimeseriesExists(option.getPath())) {
        pool.createTimeseries(option.getPath(), option.getDataType(), option.getEncoding(),
            option.getCompressor());
      }
    }
  }

When we re-run the Flink task , IoTDBSink will try to create the storage group again and fails and then stop the program.... It is incorrect.

solution:
1. use try-catch to wrap the setStorageGroup()
or,
2. check whether the sg exist, and only create it if not exist.

Issue Links

• links to: GitHub Pull Request #2165