backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/in/source/InCompressDataSource.java [106:128]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            .transform(doNext())
            .sequential()
            .doFinally(
                signalType -> {
                  for (String key : COMPRESS_MAP.keySet()) {
                    COMPRESS_MAP
                        .get(key)
                        .forEach(
                            inputStream -> {
                              if (inputStream != null) {
                                try {
                                  inputStream.close();
                                } catch (IOException e) {
                                }
                              }
                            });
                  }
                  scheduler.dispose();
                })
            .contextWrite(
                context -> {
                  return context.put("totalSize", totalSize);
                });
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/in/source/InSqlDataSource.java [96:118]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
          .transform(doNext())
          .sequential()
          .doFinally(
              signalType -> {
                for (String key : COMPRESS_MAP.keySet()) {
                  COMPRESS_MAP
                      .get(key)
                      .forEach(
                          inputStream -> {
                            if (inputStream != null) {
                              try {
                                inputStream.close();
                              } catch (IOException e) {
                              }
                            }
                          });
                }
                scheduler.dispose();
              })
          .contextWrite(
              context -> {
                return context.put("totalSize", totalSize);
              });
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -