Flink+ClickHouse构建亿级电商用户画像平台（PC、移动、小程序）

 // 清空records集合

    records.clear();

    // 构建消息，表示数据已写入

    final WriteMetadataEvent event = WriteMetadataEvent.builder()

        .taskID(taskID)

        .instantTime(instant) // the write instant may shift but the event still use the currentInstant.

        .writeStatus(writeStatus)

        .lastBatch(false)

        .endInput(false)

        .build();

    // 发送消息给coordinator

    this.eventGateway.sendEventToCoordinator(event);

    writeStatuses.addAll(writeStatus);

    return true;