@@ -0,0 +1,2070 @@
+package com.orientechnologies.orient.server.distributed;%0A%0Aimport com.orientechnologies.orient.core.db.ODatabaseSession;%0Aimport com.orientechnologies.orient.core.db.OrientDB;%0Aimport com.orientechnologies.orient.core.db.OrientDBConfig;%0Aimport com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx;%0Aimport com.orientechnologies.orient.core.sql.executor.OResultSet;%0Aimport com.orientechnologies.orient.setup.TestSetup;%0Aimport com.orientechnologies.orient.setup.TestSetupUtil;%0Aimport com.orientechnologies.orient.setup.configs.SimpleDServerConfig;%0Aimport org.junit.After;%0Aimport org.junit.Before;%0Aimport org.junit.Test;%0A%0Apublic class SimpleDDLRestartDistributedIT %7B%0A%0A  private OrientDB remote;%0A  private ODatabaseSession session;%0A  private TestSetup setup;%0A%0A  @Before%0A  public void before() throws Exception %7B%0A    SimpleDServerConfig config = new SimpleDServerConfig();%0A    setup = TestSetupUtil.create(config);%0A    setup.setup();%0A%0A    remote =%0A        setup.createRemote(%0A            SimpleDServerConfig.SERVER0, %22root%22, %22test%22, OrientDBConfig.defaultConfig());%0A    remote.execute(%0A        %22create database ? plocal users(admin identified by 'admin' role admin)%22, %22test%22);%0A    session = remote.open(%22test%22, %22admin%22, %22admin%22);%0A  %7D%0A%0A  @Test%0A  public void test() throws Exception %7B%0A    session.command(%22create class one%22);%0A    setup.shutdownServer(SimpleDServerConfig.SERVER2);%0A    session.command(%22create class testClass%22);%0A    session.close();%0A    setup.startServer(SimpleDServerConfig.SERVER2);%0A    try (OrientDB remoteServer2 =%0A        setup.createRemote(SimpleDServerConfig.SERVER2, OrientDBConfig.defaultConfig())) %7B%0A      try (ODatabaseSession server2Session = remoteServer2.open(%22test%22, %22admin%22, %22admin%22)) %7B%0A        try (OResultSet result = server2Session.query(%22select from one%22)) %7B%7D%0A        try (OResultSet result = server2Session.query(%22select from testClass%22)) %7B%7D%0A      %7D%0A    %7D%0A  %7D%0A%0A  @After%0A  public void after() throws InterruptedException %7B%0A    remote.drop(%22test%22);%0A    remote.close();%0A    setup.teardown();%0A    ODatabaseDocumentTx.closeAll();%0A  %7D%0A%7D%0A

add test case to verify correct sync after ddl