trace-etl/trace-etl-metadata/src/main/java/org/apache/ozhera/trace/etl/metadata/mq/RocketMQHeraMetaDataConsumer.java [196:219]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private boolean waitSyncData() {
        long startTime = System.currentTimeMillis();
        String isSync = redisService.get(Const.SYNC_DATA_LOCK_REDIS_KEY);
        // default return true
        if (isSync == null) {
            return true;
        }
        while (true) {
            if (!"true".equals(isSync)) {
                try {
                    TimeUnit.SECONDS.sleep(1);
                } catch (Exception e) {
                    log.error("Hera meta data Consumer waitSyncData error : ", e);
                }
                if (System.currentTimeMillis() - startTime > Const.SYNC_REDIS_WAIT_DURATION) {
                    log.warn("Hera meta data Consumer waitSyncData timeout!");
                    return true;
                }
                isSync = redisService.get(Const.SYNC_DATA_LOCK_REDIS_KEY);
            } else {
                return true;
            }
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



trace-etl/trace-etl-metadata/src/main/java/org/apache/ozhera/trace/etl/metadata/mq/KafkaHeraMetaDataConsumer.java [197:220]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private boolean waitSyncData() {
        long startTime = System.currentTimeMillis();
        String isSync = redisService.get(Const.SYNC_DATA_LOCK_REDIS_KEY);
        // default return true
        if (isSync == null) {
            return true;
        }
        while (true) {
            if (!"true".equals(isSync)) {
                try {
                    TimeUnit.SECONDS.sleep(1);
                } catch (Exception e) {
                    log.error("Hera meta data Consumer waitSyncData error : ", e);
                }
                if (System.currentTimeMillis() - startTime > Const.SYNC_REDIS_WAIT_DURATION) {
                    log.warn("Hera meta data Consumer waitSyncData timeout!");
                    return true;
                }
                isSync = redisService.get(Const.SYNC_DATA_LOCK_REDIS_KEY);
            } else {
                return true;
            }
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -