@Override
  public void waitInitializationCompleted() {
    LOG.info("Waiting for Record State initialization");
    recordState.waitWriteRocksDBDone();
    LOG.info("The concurrent threads have finished writing data into the Record State.");
    recordState.initializationCompleted();
  }
Use a unique index to lookup. Working for the situation where the join keys include the
mixed-format table's primary keys.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/UniqueIndexTable.java