yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-07-25 18:30:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Wait for Indexing Job to complete (#14986)

Browse Source
This commit is contained in:
Mohit Yadav 2024-02-01 17:04:21 +05:30 committed by GitHub
parent 306adfcca0
commit 8f94e54395
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
openmetadata-service/src/main/java/org/openmetadata/service/apps/bundles/searchIndex/SearchIndexApp.java
View File

@ -250,9 +250,11 @@ public class SearchIndexApp extends AbstractNativeApplication {
private void sendUpdates() { private void sendUpdates() {
try { try {
WebSocketManager.getInstance() if (WebSocketManager.getInstance() != null) {
.broadCastMessageToAll( WebSocketManager.getInstance()
WebSocketManager.JOB_STATUS_BROADCAST_CHANNEL, JsonUtils.pojoToJson(jobData)); .broadCastMessageToAll(
WebSocketManager.JOB_STATUS_BROADCAST_CHANNEL, JsonUtils.pojoToJson(jobData));
}
} catch (Exception ex) { } catch (Exception ex) {
LOG.error("Failed to send updated stats with WebSocket", ex); LOG.error("Failed to send updated stats with WebSocket", ex);
} }

3
openmetadata-service/src/main/java/org/openmetadata/service/apps/scheduler/AppScheduler.java
View File

@ -6,6 +6,7 @@ import static org.quartz.impl.matchers.GroupMatcher.jobGroupEquals;
import java.util.UUID; import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ConcurrentMap;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.openmetadata.common.utils.CommonUtil; import org.openmetadata.common.utils.CommonUtil;
import org.openmetadata.schema.AppRuntime; import org.openmetadata.schema.AppRuntime;
@ -37,7 +38,7 @@ public class AppScheduler {
public static final String SEARCH_CLIENT_KEY = "searchClientKey"; public static final String SEARCH_CLIENT_KEY = "searchClientKey";
private static AppScheduler instance; private static AppScheduler instance;
private static volatile boolean initialized = false; private static volatile boolean initialized = false;
private final Scheduler scheduler; @Getter private final Scheduler scheduler;
private static final ConcurrentHashMap<UUID, JobDetail> appJobsKeyMap = new ConcurrentHashMap<>(); private static final ConcurrentHashMap<UUID, JobDetail> appJobsKeyMap = new ConcurrentHashMap<>();
private final CollectionDAO collectionDAO; private final CollectionDAO collectionDAO;
private final SearchRepository searchClient; private final SearchRepository searchClient;

1
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/TeamRepository.java
View File

@ -100,6 +100,7 @@ public class TeamRepository extends EntityRepository<Team> {
TEAM_UPDATE_FIELDS); TEAM_UPDATE_FIELDS);
this.quoteFqn = true; this.quoteFqn = true;
supportsSearch = true; supportsSearch = true;
initOrganization();
} }
@Override @Override

3
openmetadata-service/src/main/java/org/openmetadata/service/util/OpenMetadataOperations.java
View File

@ -252,6 +252,9 @@ public class OpenMetadataOperations implements Callable<Integer> {
config.getElasticSearchConfiguration().getSearchIndexMappingLanguage())) config.getElasticSearchConfiguration().getSearchIndexMappingLanguage()))
.withRuntime(new ScheduledExecutionContext().withEnabled(true)); .withRuntime(new ScheduledExecutionContext().withEnabled(true));
AppScheduler.getInstance().triggerOnDemandApplication(searchIndexApp); AppScheduler.getInstance().triggerOnDemandApplication(searchIndexApp);
do {
Thread.sleep(3000l);
} while (!AppScheduler.getInstance().getScheduler().getCurrentlyExecutingJobs().isEmpty());
return 0; return 0;
} catch (Exception e) { } catch (Exception e) {
LOG.error("Failed to reindex due to ", e); LOG.error("Failed to reindex due to ", e);