[ASTERIXDB-1723] Delete managix - user model changes: yes - storage format changes: no - interface changes: yes
Details: - Delete managix installer method and all dependencies - Remove xml-based configuration Change-Id: I5c710b6ec870bedd49dd46b74ed96a3665670e9b Reviewed-on: https://asterix-gerrit.ics.uci.edu/2155 Integration-Tests: Jenkins <[email protected]> Sonar-Qube: Jenkins <[email protected]> Reviewed-by: Michael Blow <[email protected]> Tested-by: Jenkins <[email protected]> Contrib: Jenkins <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/5dcf139e Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/5dcf139e Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/5dcf139e Branch: refs/heads/master Commit: 5dcf139e532ecf2fa1fa256467c6c7015f590ca5 Parents: cc7d2f0 Author: Ian Maxon <[email protected]> Authored: Thu Dec 14 12:27:45 2017 -0800 Committer: Ian Maxon <[email protected]> Committed: Thu Dec 14 14:22:52 2017 -0800 ---------------------------------------------------------------------- asterixdb/asterix-app/pom.xml | 16 +- .../common/AsterixHyracksIntegrationUtil.java | 121 +- .../app/external/ExternalUDFLibrarian.java | 48 +- .../asterix/app/nc/NCAppRuntimeContext.java | 66 +- .../apache/asterix/app/nc/RecoveryManager.java | 32 +- .../asterix/app/nc/TransactionSubsystem.java | 11 +- .../replication/AutoFaultToleranceStrategy.java | 53 +- .../FaultToleranceStrategyFactory.java | 42 +- .../MetadataNodeFaultToleranceStrategy.java | 3 + .../asterix/app/translator/QueryTranslator.java | 125 +- .../org/apache/asterix/drivers/AsterixCLI.java | 98 -- .../hyracks/bootstrap/CCApplication.java | 33 +- .../bootstrap/ClusterLifecycleListener.java | 51 +- .../hyracks/bootstrap/ClusterWorkExecutor.java | 33 +- .../hyracks/bootstrap/NCApplication.java | 61 +- .../apache/asterix/util/FaultToleranceUtil.java | 15 +- .../asterix-app/src/main/resources/cc-rep.conf | 52 + .../asterix-app/src/main/resources/cc.conf | 56 + .../asterix-app/src/main/resources/cc2.conf | 56 + .../asterix-app/src/main/resources/cc3.conf | 56 + .../asterix-app/src/main/resources/cc4.conf | 53 + .../app/bootstrap/TestNodeController.java | 166 +-- .../aql/translator/QueryTranslatorTest.java | 19 +- .../runtime/ClusterStateManagerTest.java | 1 - .../asterix/test/active/ActiveStatsTest.java | 31 +- .../asterix/test/common/TestExecutor.java | 130 +- .../apache/asterix/test/common/TestHelper.java | 56 +- .../test/dataflow/ComponentRollbackTest.java | 19 +- .../asterix/test/dataflow/LogMarkerTest.java | 12 +- .../dataflow/MultiPartitionLSMIndexTest.java | 39 +- .../org/apache/asterix/test/dml/DmlTest.java | 10 +- .../test/jsonplan/JsonLogicalPlanTest.java | 2 +- .../asterix/test/logging/CheckpointingTest.java | 38 +- .../asterix/test/metadata/MetadataTest.java | 5 +- .../asterix/test/metadata/MetadataTxnTest.java | 20 +- .../asterix/test/optimizer/OptimizerTest.java | 33 +- .../asterix/test/runtime/APIExecutionTest.java | 2 +- .../runtime/AqlExecutionFullParallelismIT.java | 2 +- .../runtime/AqlExecutionLessParallelismIT.java | 2 +- .../asterix/test/runtime/AqlExecutionTest.java | 2 +- .../test/runtime/AqlExecutionTestIT.java | 2 +- .../ClusterStateDefaultParameterTest.java | 2 +- ...lusterStateExecutionFullParallelismTest.java | 2 +- ...lusterStateExecutionLessParallelismTest.java | 2 +- .../asterix/test/runtime/ExecutionTestUtil.java | 19 +- .../asterix/test/runtime/LangExecutionUtil.java | 13 +- .../test/runtime/MetricsExecutionTest.java | 2 +- .../asterix/test/runtime/RebalanceTest.java | 2 +- .../runtime/RebalanceWithCancellationIT.java | 2 +- .../test/runtime/ReplicationExecutionTest.java | 7 +- .../SqlppExecutionFullParallelismIT.java | 2 +- .../asterix/test/runtime/SqlppExecutionIT.java | 2 +- .../SqlppExecutionLessParallelismIT.java | 2 +- .../test/runtime/SqlppExecutionTest.java | 2 +- .../SqlppExecutionWithCancellationTest.java | 2 +- .../asterix/test/storage/DiskIsFullTest.java | 8 +- .../IndexDropOperatorNodePushableTest.java | 26 +- .../MigrateStorageResourcesTaskTest.java | 23 +- .../asterix/test/txn/RecoveryManagerTest.java | 32 +- .../src/test/resources/cc-multipart.conf | 56 + .../asterix-app/src/test/resources/cc.conf | 56 + .../multi-partition-test-configuration.xml | 112 -- .../resources/runtimets/data/big_object_20M.adm | 4 + .../cluster_state_1/cluster_state_1.1.regexadm | 6 +- .../cluster_state_1_full.1.regexadm | 6 +- .../cluster_state_1_less.1.regexadm | 6 +- .../replication/add_replica/add_replica.2.adm | 4 +- .../metadata_failover/metadata_failover.2.adm | 2 +- .../common/cluster/IClusterStateManager.java | 8 +- .../common/config/ClusterProperties.java | 100 -- .../asterix/common/config/NodeProperties.java | 8 + .../common/config/PropertiesAccessor.java | 158 +-- .../common/config/ReplicationProperties.java | 107 +- .../ChainedDeclusteringReplicationStrategy.java | 47 +- .../common/replication/IReplicationManager.java | 6 +- .../replication/IReplicationStrategy.java | 9 +- .../MetadataOnlyReplicationStrategy.java | 70 +- .../replication/NoReplicationStrategy.java | 11 +- .../asterix/common/replication/Replica.java | 77 +- .../replication/ReplicationStrategyFactory.java | 27 +- .../apache/asterix/common/utils/ConfigUtil.java | 41 - .../src/main/resources/schema/asterix-conf.xsd | 157 --- .../src/main/resources/schema/cluster.xsd | 197 --- .../src/main/resources/schema/jaxb-bindings.xjb | 28 - .../src/main/resources/schema/yarn_cluster.xsd | 211 --- asterixdb/asterix-events/pom.xml | 171 --- .../asterix/event/driver/EventConfig.java | 40 - .../asterix/event/driver/EventDriver.java | 120 -- .../asterix/event/error/EventException.java | 29 - .../asterix/event/error/OutputHandler.java | 87 -- .../asterix/event/error/VerificationUtil.java | 128 -- .../management/AsterixEventServiceClient.java | 232 --- .../asterix/event/management/EventExecutor.java | 120 -- .../asterix/event/management/EventTask.java | 154 -- .../event/management/EventTaskReport.java | 54 - .../asterix/event/management/EventUtil.java | 234 --- .../event/management/IOutputHandler.java | 26 - .../event/management/IPatternListener.java | 28 - .../event/management/OutputAnalysis.java | 38 - .../asterix/event/management/Randomizer.java | 69 - .../asterix/event/management/ValueType.java | 99 -- .../asterix/event/model/AsterixInstance.java | 202 --- .../event/model/AsterixRuntimeState.java | 58 - .../apache/asterix/event/model/BackupInfo.java | 72 - .../apache/asterix/event/model/EventList.java | 38 - .../apache/asterix/event/model/ProcessInfo.java | 50 - .../event/service/AsterixEventService.java | 92 -- .../event/service/AsterixEventServiceUtil.java | 514 ------- .../event/service/ClusterStateWatcher.java | 106 -- .../asterix/event/service/ILookupService.java | 50 - .../asterix/event/service/ServiceProvider.java | 33 - .../asterix/event/service/ZooKeeperService.java | 329 ----- .../asterix/event/util/PatternCreator.java | 585 -------- .../src/main/resources/events/backup/backup.sh | 90 -- .../resources/events/cc_failure/cc_failure.sh | 22 - .../main/resources/events/cc_start/cc_start.sh | 75 - .../src/main/resources/events/events.xml | 138 -- .../src/main/resources/events/execute.sh | 45 - .../main/resources/events/file/create_file.sh | 21 - .../src/main/resources/events/file/delete.sh | 22 - .../src/main/resources/events/file/dir_copy.sh | 26 - .../main/resources/events/file/dir_transfer.sh | 26 - .../src/main/resources/events/file/transfer.sh | 44 - .../src/main/resources/events/hdfs/delete.sh | 26 - .../resources/events/node_failure/nc_failure.sh | 38 - .../resources/events/node_info/node_info.sh | 22 - .../main/resources/events/node_join/nc_join.sh | 38 - .../resources/events/node_restart/nc_restart.sh | 40 - .../src/main/resources/events/prepare.sh | 17 - .../main/resources/events/restore/restore.sh | 95 -- .../src/main/resources/schema/event.xsd | 53 - .../main/resources/schema/installer-conf.xsd | 86 -- .../src/main/resources/schema/jaxb-bindings.xjb | 28 - .../src/main/resources/schema/pattern.xsd | 134 -- .../src/main/resources/scripts/execute.sh | 45 - .../src/main/resources/scripts/prepare.sh | 18 - .../provider/StreamRecordReaderProvider.java | 1 - .../apache/asterix/external/util/FeedUtils.java | 1 + asterixdb/asterix-installer/pom.xml | 510 ------- .../src/main/assembly/binary-assembly.xml | 147 -- .../installer/command/AbstractCommand.java | 46 - .../asterix/installer/command/AlterCommand.java | 76 - .../installer/command/BackupCommand.java | 78 - .../installer/command/CommandConfig.java | 23 - .../installer/command/CommandHandler.java | 88 -- .../installer/command/ConfigureCommand.java | 134 -- .../installer/command/CreateCommand.java | 127 -- .../installer/command/DeleteCommand.java | 66 - .../installer/command/DescribeCommand.java | 95 -- .../asterix/installer/command/HelpCommand.java | 110 -- .../asterix/installer/command/ICommand.java | 45 - .../installer/command/InstallCommand.java | 76 - .../asterix/installer/command/LogCommand.java | 109 -- .../installer/command/RestoreCommand.java | 76 - .../installer/command/ShutdownCommand.java | 49 - .../asterix/installer/command/StartCommand.java | 90 -- .../installer/command/StartNodeCommand.java | 105 -- .../asterix/installer/command/StopCommand.java | 100 -- .../installer/command/StopNodeCommand.java | 112 -- .../installer/command/UninstallCommand.java | 78 - .../installer/command/ValidateCommand.java | 311 ---- .../installer/command/VersionCommand.java | 52 - .../installer/driver/InstallerDriver.java | 133 -- .../asterix/installer/driver/InstallerUtil.java | 77 - .../installer/error/InstallerException.java | 29 - .../src/main/resources/clusters/demo/demo.xml | 57 - .../src/main/resources/clusters/local/local.xml | 63 - .../local/local_chained_declustering_rep.xml | 81 -- .../clusters/local/local_metadata_only_rep.xml | 85 -- .../resources/conf/asterix-configuration.xml | 268 ---- .../src/main/resources/conf/log4j.properties | 26 - .../src/main/resources/conf/managix-conf.xml | 35 - .../resources/examples/mugshot/aql/create.aql | 69 - .../resources/examples/mugshot/aql/delete.aql | 22 - .../examples/mugshot/aql/equi-join.aql | 29 - .../mugshot/aql/function-definition.aql | 31 - .../examples/mugshot/aql/function-use.aql | 23 - .../examples/mugshot/aql/group-sort-limit.aql | 31 - .../resources/examples/mugshot/aql/insert.aql | 41 - .../examples/mugshot/aql/join-group.aql | 32 - .../mugshot/aql/left-outer-fuzzy-join.aql | 37 - .../mugshot/aql/left-outer-join-aggr.aql | 32 - .../examples/mugshot/aql/left-outer-join.aql | 30 - .../resources/examples/mugshot/aql/load.aql | 25 - .../resources/examples/mugshot/aql/lookup.aql | 23 - .../examples/mugshot/aql/range-scan.aql | 24 - .../examples/mugshot/aql/simple-aggregation.aql | 26 - .../examples/mugshot/aql/spatial-join.aql | 29 - .../examples/mugshot/aql/ten-of-each.aql | 27 - .../examples/mugshot/aql/universal.aql | 28 - .../examples/mugshot/data/mugshot_messages.adm | 1331 ------------------ .../examples/mugshot/data/mugshot_users.adm | 901 ------------ .../src/main/resources/hadoop-0.20.2/bin/hadoop | 290 ---- .../hadoop-0.20.2/bin/hadoop-config.sh | 85 -- .../resources/hadoop-0.20.2/conf/hadoop-env.sh | 71 - .../src/main/resources/schema/jaxb-bindings.xjb | 28 - .../src/main/resources/scripts/managix | 27 - .../src/main/resources/scripts/validate_ssh.sh | 27 - .../src/main/resources/scripts/verify.sh | 39 - .../src/main/resources/zookeeper/start_zk.sh | 27 - .../src/main/resources/zookeeper/stop_zk | 25 - .../src/main/resources/zookeeper/zk.init | 33 - .../installer/test/AbstractExecutionIT.java | 186 --- .../test/AsterixClusterLifeCycleIT.java | 193 --- .../test/AsterixExternalLibraryIT.java | 98 -- .../test/AsterixInstallerIntegrationUtil.java | 228 --- .../installer/test/AsterixLifecycleIT.java | 52 - .../installer/test/AsterixRestartIT.java | 125 -- .../installer/test/ClusterExecutionIT.java | 111 -- .../installer/test/InstallerLicensingIT.java | 29 - .../installer/test/ManagixExecutionIT.java | 30 - .../installer/test/ManagixSqlppExecutionIT.java | 54 - .../installer/test/MetadataReplicationIT.java | 120 -- .../asterix/installer/test/ReplicationIT.java | 117 -- .../installer/transaction/DmlRecoveryIT.java | 132 -- .../installer/transaction/RecoveryIT.java | 128 -- .../src/test/resources/clusterts/Vagrantfile | 76 - .../src/test/resources/clusterts/cluster.xml | 56 - .../clusterts/cluster_with_replication.xml | 65 - .../src/test/resources/clusterts/hosts | 24 - .../src/test/resources/clusterts/id_rsa | 27 - .../src/test/resources/clusterts/id_rsa.pub | 1 - .../src/test/resources/clusterts/known_hosts | 6 - .../src/test/resources/docker/Dockerfile | 54 - .../test/resources/docker/cluster-config.xml | 80 -- .../test/resources/docker/docker-compose.yml | 116 -- .../src/test/resources/docker/id_rsa | 27 - .../src/test/resources/docker/id_rsa.pub | 1 - .../integrationts/asterix-configuration.xml | 261 ---- .../typed_adapter/typed_adapter.1.ddl.aql | 41 - .../typed_adapter/typed_adapter.2.update.aql | 34 - .../typed_adapter/typed_adapter.3.query.aql | 32 - .../feed_ingest/feed_ingest.1.ddl.aql | 54 - .../feed_ingest/feed_ingest.2.update.aql | 35 - .../feed_ingest/feed_ingest.3.sleep.aql | 26 - .../feed_ingest/feed_ingest.4.query.aql | 32 - .../getCapital/getCapital.1.ddl.aql | 24 - .../getCapital/getCapital.2.query.aql | 23 - .../insert-from-select.1.ddl.aql | 27 - .../insert-from-select.2.update.aql | 24 - .../insert-from-select.3.update.aql | 25 - .../insert-from-select.4.query.aql | 24 - .../library-functions/mysum/mysum.1.query.aql | 22 - .../library-functions/toUpper/toUpper.1.ddl.aql | 25 - .../toUpper/toUpper.2.query.aql | 23 - .../dataverseDataset.1.query.aql | 21 - .../functionDataset/functionDataset.1.query.aql | 21 - .../libraryDataset/libraryDataset.1.query.aql | 21 - .../record-parser/record-parser.1.ddl.aql | 35 - .../record-parser/record-parser.2.query.aql | 28 - .../typed_adapter/typed_adapter.1.adm | 5 - .../library-feeds/feed_ingest/feed_ingest.1.adm | 12 - .../getCapital/getCapital.1.adm | 6 - .../insert-from-select/insert-from-select.1.adm | 1 - .../results/library-functions/mysum/mysum.1.adm | 1 - .../library-functions/toUpper/toUpper.1.adm | 1 - .../dataverseDataset/dataverseDataset.1.adm | 3 - .../functionDataset/functionDataset.1.adm | 8 - .../libraryDataset/libraryDataset.1.adm | 1 - .../record-parser/record-parser.1.adm | 100 -- .../integrationts/library/testsuite.xml | 81 -- .../backupRestore/backupRestore.1.ddl.aql | 19 - .../backupRestore/backupRestore.2.mgx.aql | 19 - .../backupRestore/backupRestore.3.mgx.aql | 19 - .../backupRestore/backupRestore.4.mgx.aql | 19 - .../backupRestore/backupRestore.5.ddl.aql | 20 - .../backupRestore/backupRestore.6.mgx.aql | 19 - .../backupRestore/backupRestore.7.mgx.aql | 19 - .../backupRestore/backupRestore.8.mgx.aql | 19 - .../backupRestore/backupRestore.9.query.aql | 21 - .../installLibrary/installLibrary.1.mgx.aql | 19 - .../installLibrary/installLibrary.2.mgx.aql | 19 - .../installLibrary/installLibrary.3.mgx.aql | 19 - .../installLibrary/installLibrary.4.query.aql | 20 - .../uninstallLibrary/uninstallLibrary.1.mgx.aql | 19 - .../uninstallLibrary/uninstallLibrary.2.mgx.aql | 19 - .../uninstallLibrary/uninstallLibrary.3.mgx.aql | 19 - .../uninstallLibrary.4.query.aql | 20 - .../backupRestore/backupRestore.1.adm | 1 - .../installLibrary/installLibrary.1.adm | 1 - .../uninstallLibrary/uninstallLibrary.1.adm | 1 - .../integrationts/lifecycle/testsuite.xml | 38 - .../metadata_node_recovery.1.ddl.aql | 50 - .../metadata_node_recovery.10.node.aql | 30 - .../metadata_node_recovery.11.sleep.aql | 19 - .../metadata_node_recovery.12.mgx.aql | 19 - .../metadata_node_recovery.13.sleep.aql | 19 - .../metadata_node_recovery.14.ddl.aql | 33 - .../metadata_node_recovery.15.node.aql | 30 - .../metadata_node_recovery.16.sleep.aql | 19 - .../metadata_node_recovery.17.mgx.aql | 19 - .../metadata_node_recovery.18.sleep.aql | 19 - .../metadata_node_recovery.19.query.aql | 35 - .../metadata_node_recovery.2.node.aql | 30 - .../metadata_node_recovery.3.sleep.aql | 19 - .../metadata_node_recovery.4.get.http | 30 - .../metadata_node_recovery.5.mgx.aql | 19 - .../metadata_node_recovery.6.sleep.aql | 19 - .../metadata_node_recovery.7.get.http | 30 - .../metadata_node_recovery.8.query.aql | 34 - .../metadata_node_recovery.9.ddl.aql | 33 - .../metadata_node_recovery.cluster_state.4.adm | 38 - .../metadata_node_recovery.cluster_state.7.adm | 38 - .../metadata_node_recovery.query.19.adm | 1 - .../metadata_node_recovery.query.8.adm | 1 - .../metadata_only_replication/testsuite.xml | 27 - .../integrationts/replication/data/fbu.adm | 10 - .../node_failback/node_failback.1.ddl.aql | 59 - .../node_failback/node_failback.10.get.http | 30 - .../node_failback/node_failback.11.query.aql | 33 - .../node_failback/node_failback.2.update.aql | 36 - .../node_failback/node_failback.3.node.aql | 28 - .../node_failback/node_failback.4.sleep.aql | 19 - .../node_failback/node_failback.5.get.http | 30 - .../node_failback/node_failback.6.query.aql | 33 - .../node_failback/node_failback.7.update.aql | 51 - .../node_failback/node_failback.8.mgx.aql | 19 - .../node_failback/node_failback.9.sleep.aql | 19 - .../failover/bulkload/bulkload.1.ddl.aql | 54 - .../failover/bulkload/bulkload.2.update.aql | 33 - .../failover/bulkload/bulkload.3.node.aql | 28 - .../failover/bulkload/bulkload.4.sleep.aql | 19 - .../failover/bulkload/bulkload.5.query.aql | 31 - .../mem_component_recovery.1.ddl.aql | 58 - .../mem_component_recovery.2.update.aql | 34 - .../mem_component_recovery.3.node.aql | 28 - .../mem_component_recovery.4.sleep.aql | 19 - .../mem_component_recovery.5.query.aql | 32 - .../metadata_node/metadata_node.1.ddl.aql | 55 - .../metadata_node/metadata_node.2.node.aql | 28 - .../metadata_node/metadata_node.3.sleep.aql | 19 - .../metadata_node/metadata_node.4.query.aql | 36 - .../node_failback.cluster_state.10.adm | 38 - .../node_failback.cluster_state.5.adm | 38 - .../node_failback/node_failback.query.11.adm | 1 - .../node_failback/node_failback.query.6.adm | 1 - .../results/failover/bulkload/bulkload.5.adm | 1 - .../mem_component_recovery.5.adm | 1 - .../failover/metadata_node/metadata_node.4.adm | 1 - .../integrationts/replication/testsuite.xml | 44 - .../resources/integrationts/restart/828.h1w.adm | 100 -- .../integrationts/restart/hugeobject.adm | 1 - .../issue-1636/issue-1636.01.ddl.aql | 81 -- .../issue-1636/issue-1636.02.ddl.aql | 29 - .../issue-1636/issue-1636.03.script.aql | 19 - .../issue-1636/issue-1636.04.ddl.aql | 36 - .../issue-1636/issue-1636.05.mgx.aql | 20 - .../issue-1636/issue-1636.06.mgx.aql | 20 - .../issue-1636/issue-1636.07.script.aql | 19 - .../issue-1636/issue-1636.08.ddl.aql | 27 - .../issue-1636/issue-1636.09.sleep.aql | 25 - .../issue-1636/issue-1636.10.script.aql | 19 - .../issue-1636/issue-1636.11.script.aql | 19 - .../issue-1725/issue-1725.1.ddl.aql | 29 - .../issue-1725/issue-1725.2.update.aql | 28 - .../issue-1725/issue-1725.3.mgx.aql | 20 - .../issue-1725/issue-1725.4.mgx.aql | 19 - .../issue-1725/issue-1725.5.query.aql | 27 - .../storage-restart/issue-1725/issue-1725.5.adm | 1 - .../scripts/feed-restart/issue-1636/cat.sh | 18 - .../scripts/feed-restart/issue-1636/grep_log.sh | 20 - .../feed-restart/issue-1636/kill_cc_and_nc.sh | 18 - .../scripts/feed-restart/issue-1636/touch.sh | 21 - .../integrationts/restart/testsuite.xml | 35 - .../resources/integrationts/restart/tweets.json | 39 - .../multiple_secondary_indices.1.script.aql | 18 - .../multiple_secondary_indices.2.ddl.aql | 52 - .../multiple_secondary_indices.3.script.aql | 18 - .../multiple_secondary_indices.4.ddl.aql | 31 - .../multiple_secondary_indices.5.script.aql | 18 - .../big_object_20M/big_object_20M.1.script.aql | 19 - .../big_object_20M/big_object_20M.2.ddl.aql | 36 - .../big_object_20M/big_object_20M.3.update.aql | 32 - .../big_object_20M/big_object_20M.4.script.aql | 19 - .../big_object_20M/big_object_20M.5.query.aql | 23 - .../big_object_20M/big_object_20M.6.script.aql | 19 - .../dataset-with-meta-record.1.script.aql | 19 - .../dataset-with-meta-record.2.ddl.aql | 56 - .../dataset-with-meta-record.3.update.aql | 28 - .../dataset-with-meta-record.4.script.aql | 19 - .../dataset-with-meta-record.5.query.aql | 29 - .../dataset-with-meta-record.6.script.aql | 19 - .../external_index/external_index.1.script.aql | 19 - .../external_index/external_index.2.ddl.aql | 46 - .../external_index/external_index.3.script.aql | 19 - .../external_index/external_index.4.query.aql | 32 - .../external_index/external_index.5.script.aql | 19 - .../primary_index_only.1.script.aql | 19 - .../primary_index_only.2.ddl.aql | 59 - .../primary_index_only.3.update.aql | 29 - .../primary_index_only.4.txneu.aql | 40 - .../primary_index_only.5.txnqbc.aql | 28 - .../primary_index_only.6.script.aql | 19 - .../primary_index_only.7.script.aql | 19 - .../primary_index_only.8.txnqar.aql | 28 - .../primary_index_only.9.script.aql | 19 - .../primary_index_only_filtered.1.script.aql | 19 - .../primary_index_only_filtered.2.ddl.aql | 59 - .../primary_index_only_filtered.3.update.aql | 29 - .../primary_index_only_filtered.4.txneu.aql | 40 - .../primary_index_only_filtered.5.txnqbc.aql | 28 - .../primary_index_only_filtered.6.script.aql | 19 - .../primary_index_only_filtered.7.script.aql | 19 - .../primary_index_only_filtered.8.txnqar.aql | 28 - .../primary_index_only_filtered.9.script.aql | 19 - ...ary_plus_correlated_ngram_index.1.script.aql | 19 - ...ry_plus_correlated_ngram_index.10.script.aql | 19 - ...rimary_plus_correlated_ngram_index.2.ddl.aql | 80 -- ...ary_plus_correlated_ngram_index.3.update.aql | 23 - ...mary_plus_correlated_ngram_index.4.txneu.aql | 37 - ...rimary_plus_correlated_ngram_index.5.ddl.aql | 24 - ...ary_plus_correlated_ngram_index.6.txnqbc.aql | 23 - ...ary_plus_correlated_ngram_index.7.script.aql | 19 - ...ary_plus_correlated_ngram_index.8.script.aql | 19 - ...ary_plus_correlated_ngram_index.9.txnqar.aql | 23 - ...ary_plus_correlated_rtree_index.1.script.aql | 19 - ...ry_plus_correlated_rtree_index.10.script.aql | 19 - ...rimary_plus_correlated_rtree_index.2.ddl.aql | 81 -- ...ary_plus_correlated_rtree_index.3.update.aql | 24 - ...mary_plus_correlated_rtree_index.4.txneu.aql | 38 - ...rimary_plus_correlated_rtree_index.5.ddl.aql | 22 - ...ary_plus_correlated_rtree_index.6.txnqbc.aql | 23 - ...ary_plus_correlated_rtree_index.7.script.aql | 19 - ...ary_plus_correlated_rtree_index.8.script.aql | 19 - ...ary_plus_correlated_rtree_index.9.txnqar.aql | 23 - ...ault_correlated_secondary_index.1.script.aql | 19 - ...ult_correlated_secondary_index.10.script.aql | 19 - ...default_correlated_secondary_index.2.ddl.aql | 79 -- ...ault_correlated_secondary_index.3.update.aql | 29 - ...fault_correlated_secondary_index.4.txneu.aql | 43 - ...default_correlated_secondary_index.5.ddl.aql | 29 - ...ault_correlated_secondary_index.6.txnqbc.aql | 28 - ...ault_correlated_secondary_index.7.script.aql | 19 - ...ault_correlated_secondary_index.8.script.aql | 19 - ...ault_correlated_secondary_index.9.txnqar.aql | 28 - ...ry_plus_default_secondary_index.1.script.aql | 19 - ...imary_plus_default_secondary_index.2.ddl.aql | 71 - ...ry_plus_default_secondary_index.3.update.aql | 29 - ...ary_plus_default_secondary_index.4.txneu.aql | 43 - ...ry_plus_default_secondary_index.5.txnqbc.aql | 28 - ...ry_plus_default_secondary_index.6.script.aql | 19 - ...ry_plus_default_secondary_index.7.script.aql | 19 - ...ry_plus_default_secondary_index.8.txnqar.aql | 28 - ...ry_plus_default_secondary_index.9.script.aql | 19 - ...efault_secondary_index_filtered.1.script.aql | 19 - ...s_default_secondary_index_filtered.2.ddl.aql | 70 - ...efault_secondary_index_filtered.3.update.aql | 29 - ...default_secondary_index_filtered.4.txneu.aql | 43 - ...efault_secondary_index_filtered.5.txnqbc.aql | 28 - ...efault_secondary_index_filtered.6.script.aql | 19 - ...efault_secondary_index_filtered.7.script.aql | 19 - ...efault_secondary_index_filtered.8.txnqar.aql | 28 - ...efault_secondary_index_filtered.9.script.aql | 19 - ...word_correlated_secondary_index.1.script.aql | 19 - ...ord_correlated_secondary_index.10.script.aql | 19 - ...keyword_correlated_secondary_index.2.ddl.aql | 81 -- ...word_correlated_secondary_index.3.update.aql | 24 - ...yword_correlated_secondary_index.4.txneu.aql | 37 - ...keyword_correlated_secondary_index.5.ddl.aql | 24 - ...word_correlated_secondary_index.6.txnqbc.aql | 23 - ...word_correlated_secondary_index.7.script.aql | 19 - ...word_correlated_secondary_index.8.script.aql | 19 - ...word_correlated_secondary_index.9.txnqar.aql | 23 - ...ry_plus_keyword_secondary_index.1.script.aql | 19 - ...imary_plus_keyword_secondary_index.2.ddl.aql | 72 - ...ry_plus_keyword_secondary_index.3.update.aql | 30 - ...ary_plus_keyword_secondary_index.4.txneu.aql | 43 - ...ry_plus_keyword_secondary_index.5.txnqbc.aql | 23 - ...ry_plus_keyword_secondary_index.6.script.aql | 19 - ...ry_plus_keyword_secondary_index.7.script.aql | 19 - ...ry_plus_keyword_secondary_index.8.txnqar.aql | 23 - ...ry_plus_keyword_secondary_index.9.script.aql | 19 - ...eyword_secondary_index_filtered.1.script.aql | 19 - ...s_keyword_secondary_index_filtered.2.ddl.aql | 70 - ...eyword_secondary_index_filtered.3.update.aql | 30 - ...keyword_secondary_index_filtered.4.txneu.aql | 43 - ...eyword_secondary_index_filtered.5.txnqbc.aql | 23 - ...eyword_secondary_index_filtered.6.script.aql | 19 - ...eyword_secondary_index_filtered.7.script.aql | 19 - ...eyword_secondary_index_filtered.8.txnqar.aql | 23 - ...eyword_secondary_index_filtered.9.script.aql | 19 - ...le_correlated_secondary_indices.1.script.aql | 19 - ...e_correlated_secondary_indices.10.script.aql | 19 - ...tiple_correlated_secondary_indices.2.ddl.aql | 81 -- ...le_correlated_secondary_indices.3.update.aql | 24 - ...ple_correlated_secondary_indices.4.txneu.aql | 37 - ...tiple_correlated_secondary_indices.5.ddl.aql | 27 - ...le_correlated_secondary_indices.6.txnqbc.aql | 23 - ...le_correlated_secondary_indices.7.script.aql | 19 - ...le_correlated_secondary_indices.8.script.aql | 19 - ...le_correlated_secondary_indices.9.txnqar.aql | 23 - ...plus_multiple_secondary_indices.1.script.aql | 19 - ...ry_plus_multiple_secondary_indices.2.ddl.aql | 78 - ...plus_multiple_secondary_indices.3.update.aql | 30 - ..._plus_multiple_secondary_indices.4.txneu.aql | 43 - ...plus_multiple_secondary_indices.5.txnqbc.aql | 30 - ...plus_multiple_secondary_indices.6.script.aql | 19 - ...plus_multiple_secondary_indices.7.script.aql | 19 - ...plus_multiple_secondary_indices.8.txnqar.aql | 23 - ...plus_multiple_secondary_indices.9.script.aql | 19 - ...iple_secondary_indices_filtered.1.script.aql | 19 - ...ultiple_secondary_indices_filtered.2.ddl.aql | 76 - ...iple_secondary_indices_filtered.3.update.aql | 30 - ...tiple_secondary_indices_filtered.4.txneu.aql | 43 - ...iple_secondary_indices_filtered.5.txnqbc.aql | 30 - ...iple_secondary_indices_filtered.6.script.aql | 19 - ...iple_secondary_indices_filtered.7.script.aql | 19 - ...iple_secondary_indices_filtered.8.txnqar.aql | 23 - ...iple_secondary_indices_filtered.9.script.aql | 19 - .../primary_plus_ngram_index.1.script.aql | 19 - .../primary_plus_ngram_index.2.ddl.aql | 71 - .../primary_plus_ngram_index.3.update.aql | 29 - .../primary_plus_ngram_index.4.txneu.aql | 43 - .../primary_plus_ngram_index.5.txnqbc.aql | 29 - .../primary_plus_ngram_index.6.script.aql | 19 - .../primary_plus_ngram_index.7.script.aql | 19 - .../primary_plus_ngram_index.8.txnqar.aql | 29 - .../primary_plus_ngram_index.9.script.aql | 19 - ...imary_plus_ngram_index_filtered.1.script.aql | 19 - .../primary_plus_ngram_index_filtered.2.ddl.aql | 71 - ...imary_plus_ngram_index_filtered.3.update.aql | 29 - ...rimary_plus_ngram_index_filtered.4.txneu.aql | 43 - ...imary_plus_ngram_index_filtered.5.txnqbc.aql | 29 - ...imary_plus_ngram_index_filtered.6.script.aql | 19 - ...imary_plus_ngram_index_filtered.7.script.aql | 19 - ...imary_plus_ngram_index_filtered.8.txnqar.aql | 29 - ...imary_plus_ngram_index_filtered.9.script.aql | 19 - .../primary_plus_rtree_index.1.script.aql | 19 - .../primary_plus_rtree_index.2.ddl.aql | 72 - .../primary_plus_rtree_index.3.update.aql | 30 - .../primary_plus_rtree_index.4.txneu.aql | 43 - .../primary_plus_rtree_index.5.txnqbc.aql | 23 - .../primary_plus_rtree_index.6.script.aql | 19 - .../primary_plus_rtree_index.7.script.aql | 19 - .../primary_plus_rtree_index.8.txnqar.aql | 23 - .../primary_plus_rtree_index.9.script.aql | 19 - ...imary_plus_rtree_index_filtered.1.script.aql | 19 - .../primary_plus_rtree_index_filtered.2.ddl.aql | 70 - ...imary_plus_rtree_index_filtered.3.update.aql | 30 - ...rimary_plus_rtree_index_filtered.4.txneu.aql | 43 - ...imary_plus_rtree_index_filtered.5.txnqbc.aql | 23 - ...imary_plus_rtree_index_filtered.6.script.aql | 19 - ...imary_plus_rtree_index_filtered.7.script.aql | 19 - ...imary_plus_rtree_index_filtered.8.txnqar.aql | 23 - ...imary_plus_rtree_index_filtered.9.script.aql | 19 - ...s_rtree_index_insert_and_delete.1.script.aql | 19 - ...plus_rtree_index_insert_and_delete.2.ddl.aql | 71 - ...s_rtree_index_insert_and_delete.3.update.aql | 29 - ...us_rtree_index_insert_and_delete.4.txneu.aql | 67 - ...s_rtree_index_insert_and_delete.5.txnqbc.aql | 23 - ...s_rtree_index_insert_and_delete.6.script.aql | 19 - ...s_rtree_index_insert_and_delete.7.script.aql | 19 - ...s_rtree_index_insert_and_delete.8.txnqar.aql | 23 - ...s_rtree_index_insert_and_delete.9.script.aql | 19 - ...ndex_insert_and_delete_filtered.1.script.aql | 19 - ...e_index_insert_and_delete_filtered.2.ddl.aql | 70 - ...ndex_insert_and_delete_filtered.3.update.aql | 29 - ...index_insert_and_delete_filtered.4.txneu.aql | 67 - ...ndex_insert_and_delete_filtered.5.txnqbc.aql | 23 - ...ndex_insert_and_delete_filtered.6.script.aql | 19 - ...ndex_insert_and_delete_filtered.7.script.aql | 19 - ...ndex_insert_and_delete_filtered.8.txnqar.aql | 23 - ...ndex_insert_and_delete_filtered.9.script.aql | 19 - .../dataset_recovery.1.script.aql | 19 - .../dataset_recovery/dataset_recovery.2.ddl.aql | 37 - .../dataset_recovery.3.script.aql | 19 - .../dataset_recovery.4.script.aql | 19 - .../dataset_recovery/dataset_recovery.5.ddl.aql | 20 - .../dataset_recovery.6.errddl.aql | 20 - .../dataset_recovery.7.script.aql | 19 - .../datatype_recovery.1.script.aql | 19 - .../datatype_recovery.2.ddl.aql | 34 - .../datatype_recovery.3.script.aql | 19 - .../datatype_recovery.4.script.aql | 19 - .../datatype_recovery.5.ddl.aql | 20 - .../datatype_recovery.6.errddl.aql | 20 - .../datatype_recovery.7.script.aql | 19 - .../dataverse_recovery.1.script.aql | 19 - .../dataverse_recovery.2.ddl.aql | 27 - .../dataverse_recovery.3.script.aql | 19 - .../dataverse_recovery.4.script.aql | 19 - .../dataverse_recovery.5.ddl.aql | 19 - .../dataverse_recovery.6.errddl.aql | 19 - .../dataverse_recovery.7.script.aql | 19 - .../delete_after_recovery.1.script.aql | 19 - .../delete_after_recovery.2.ddl.aql | 59 - .../delete_after_recovery.3.update.aql | 29 - .../delete_after_recovery.4.script.aql | 19 - .../delete_after_recovery.5.script.aql | 19 - .../delete_after_recovery.6.update.aql | 23 - .../delete_after_recovery.7.query.aql | 29 - .../delete_after_recovery.8.script.aql | 19 - .../function_recovery.1.script.aql | 19 - .../function_recovery.2.ddl.aql | 25 - .../function_recovery.3.script.aql | 19 - .../function_recovery.4.script.aql | 19 - .../function_recovery.5.query.aql | 30 - .../function_recovery.6.ddl.aql | 21 - .../function_recovery.7.errddl.aql | 21 - .../function_recovery.8.script.aql | 19 - .../insert_after_recovery.1.script.aql | 19 - .../insert_after_recovery.2.ddl.aql | 59 - .../insert_after_recovery.3.update.aql | 29 - .../insert_after_recovery.4.script.aql | 19 - .../insert_after_recovery.5.script.aql | 19 - .../insert_after_recovery.6.update.aql | 33 - .../insert_after_recovery.7.query.aql | 29 - .../insert_after_recovery.8.script.aql | 19 - .../load_after_recovery.1.script.aql | 19 - .../load_after_recovery.2.ddl.aql | 59 - .../load_after_recovery.3.script.aql | 19 - .../load_after_recovery.4.script.aql | 19 - .../load_after_recovery.5.update.aql | 29 - .../load_after_recovery.6.query.aql | 28 - .../load_after_recovery.7.script.aql | 19 - .../secondary_index_recovery.1.script.aql | 19 - .../secondary_index_recovery.2.ddl.aql | 39 - .../secondary_index_recovery.3.script.aql | 19 - .../secondary_index_recovery.4.script.aql | 19 - .../secondary_index_recovery.5.ddl.aql | 20 - .../secondary_index_recovery.6.errddl.aql | 20 - .../secondary_index_recovery.7.script.aql | 19 - .../big_object_20M.1.adm.template | 1 - .../dataset-with-meta-record.5.adm | 1 - .../external_index/external_index.1.adm | 2 - .../delete_after_recovery.1.adm | 1 - .../function_recovery/function_recovery.1.adm | 1 - .../insert_after_recovery.1.adm | 1 - .../load_after_recovery.1.adm | 1 - .../create_and_start.sh | 20 - .../stop_and_delete.sh | 19 - .../stop_and_start.sh | 19 - .../dml_recovery/configure_and_validate.sh | 20 - .../scripts/dml_recovery/create_and_start.sh | 20 - .../scripts/dml_recovery/kill_cc_and_nc.sh | 18 - .../scripts/dml_recovery/shutdown.sh | 18 - .../scripts/dml_recovery/stop_and_delete.sh | 20 - .../scripts/dml_recovery/stop_and_start.sh | 20 - .../big_object_20M/create_and_start.sh | 21 - .../big_object_20M/stop_and_delete.sh | 21 - .../big_object_20M/stop_and_start.sh | 20 - .../create_and_start.sh | 25 - .../dataset-with-meta-record/stop_and_delete.sh | 21 - .../dataset-with-meta-record/stop_and_start.sh | 20 - .../external_index/create_and_start.sh | 21 - .../external_index/stop_and_delete.sh | 21 - .../external_index/stop_and_start.sh | 20 - .../primary_index_only/create_and_start.sh | 18 - .../primary_index_only/kill_cc_and_nc.sh | 18 - .../primary_index_only/stop_and_delete.sh | 20 - .../primary_index_only/stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../primary_plus_ngram_index/kill_cc_and_nc.sh | 18 - .../primary_plus_ngram_index/stop_and_delete.sh | 20 - .../primary_plus_ngram_index/stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../primary_plus_rtree_index/kill_cc_and_nc.sh | 18 - .../primary_plus_rtree_index/stop_and_delete.sh | 20 - .../primary_plus_rtree_index/stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../kill_cc_and_nc.sh | 18 - .../stop_and_delete.sh | 20 - .../stop_and_start.sh | 20 - .../dataset_recovery/create_and_start.sh | 18 - .../dataset_recovery/kill_cc_and_nc.sh | 18 - .../dataset_recovery/stop_and_delete.sh | 20 - .../dataset_recovery/stop_and_start.sh | 20 - .../datatype_recovery/create_and_start.sh | 18 - .../datatype_recovery/kill_cc_and_nc.sh | 18 - .../datatype_recovery/stop_and_delete.sh | 20 - .../datatype_recovery/stop_and_start.sh | 20 - .../dataverse_recovery/create_and_start.sh | 18 - .../dataverse_recovery/kill_cc_and_nc.sh | 18 - .../dataverse_recovery/stop_and_delete.sh | 20 - .../dataverse_recovery/stop_and_start.sh | 20 - .../delete_after_recovery/create_and_start.sh | 18 - .../delete_after_recovery/kill_cc_and_nc.sh | 18 - .../delete_after_recovery/stop_and_delete.sh | 20 - .../delete_after_recovery/stop_and_start.sh | 20 - .../function_recovery/create_and_start.sh | 18 - .../function_recovery/kill_cc_and_nc.sh | 18 - .../function_recovery/stop_and_delete.sh | 20 - .../function_recovery/stop_and_start.sh | 20 - .../insert_after_recovery/create_and_start.sh | 18 - .../insert_after_recovery/kill_cc_and_nc.sh | 18 - .../insert_after_recovery/stop_and_delete.sh | 20 - .../insert_after_recovery/stop_and_start.sh | 20 - .../load_after_recovery/create_and_start.sh | 18 - .../load_after_recovery/kill_cc_and_nc.sh | 18 - .../load_after_recovery/stop_and_delete.sh | 20 - .../load_after_recovery/stop_and_start.sh | 20 - .../create_and_start.sh | 18 - .../secondary_index_recovery/kill_cc_and_nc.sh | 18 - .../secondary_index_recovery/stop_and_delete.sh | 20 - .../secondary_index_recovery/stop_and_start.sh | 20 - .../setup_teardown/configure_and_validate.sh | 20 - .../scripts/setup_teardown/kill_cc_and_nc.sh | 18 - .../scripts/setup_teardown/shutdown.sh | 18 - .../scripts/setup_teardown/stop_and_delete.sh | 20 - .../test/resources/transactionts/testsuite.xml | 219 --- asterixdb/asterix-metadata/pom.xml | 12 +- .../asterix/metadata/api/IClusterManager.java | 59 - .../metadata/bootstrap/MetadataBootstrap.java | 53 +- .../metadata/cluster/ClusterManager.java | 168 --- .../cluster/ClusterManagerProvider.java | 90 -- .../metadata/declared/MetadataProvider.java | 115 +- .../utils/SplitsAndConstraintsUtil.java | 19 +- asterixdb/asterix-replication/pom.xml | 8 + .../management/ReplicaStateChecker.java | 8 +- .../management/ReplicationChannel.java | 63 +- .../management/ReplicationManager.java | 85 +- .../recovery/RemoteRecoveryManager.java | 38 +- .../recovery/ReplicaSynchronizer.java | 3 +- .../test/resources/scripts/kill_cc_and_nc.sh | 1 + .../runtime/message/ReplicaEventMessage.java | 10 +- .../runtime/utils/ClusterStateManager.java | 33 +- asterixdb/asterix-server/pom.xml | 45 +- .../src/main/opt/local/conf/cc.conf | 4 +- .../server/test/AbstractExecutionIT.java | 164 +++ .../asterix/server/test/DmlRecoveryIT.java | 132 ++ .../server/test/MetadataReplicationIT.java | 167 +++ .../server/test/NCServiceExecutionIT.java | 49 +- .../apache/asterix/server/test/RecoveryIT.java | 135 ++ .../asterix/server/test/ReplicationIT.java | 127 ++ .../server/test/SampleLocalClusterIT.java | 10 +- .../asterix/server/test/SqlppExecutionIT.java | 54 + .../resources/MetadataReplicationIT/cc.conf | 52 + .../MetadataReplicationIT/ncservice1.conf | 20 + .../MetadataReplicationIT/ncservice2.conf | 21 + .../src/test/resources/ReplicationIT/cc.conf | 51 + .../resources/ReplicationIT/ncservice1.conf | 20 + .../resources/ReplicationIT/ncservice2.conf | 21 + .../integrationts/asterix-configuration.xml | 261 ++++ .../typed_adapter/typed_adapter.1.ddl.aql | 41 + .../typed_adapter/typed_adapter.2.update.aql | 34 + .../typed_adapter/typed_adapter.3.query.aql | 32 + .../feed_ingest/feed_ingest.1.ddl.aql | 54 + .../feed_ingest/feed_ingest.2.update.aql | 35 + .../feed_ingest/feed_ingest.3.sleep.aql | 26 + .../feed_ingest/feed_ingest.4.query.aql | 32 + .../getCapital/getCapital.1.ddl.aql | 24 + .../getCapital/getCapital.2.query.aql | 23 + .../insert-from-select.1.ddl.aql | 27 + .../insert-from-select.2.update.aql | 24 + .../insert-from-select.3.update.aql | 25 + .../insert-from-select.4.query.aql | 24 + .../library-functions/mysum/mysum.1.query.aql | 22 + .../library-functions/toUpper/toUpper.1.ddl.aql | 25 + .../toUpper/toUpper.2.query.aql | 23 + .../dataverseDataset.1.query.aql | 21 + .../functionDataset/functionDataset.1.query.aql | 21 + .../libraryDataset/libraryDataset.1.query.aql | 21 + .../record-parser/record-parser.1.ddl.aql | 35 + .../record-parser/record-parser.2.query.aql | 28 + .../typed_adapter/typed_adapter.1.adm | 5 + .../library-feeds/feed_ingest/feed_ingest.1.adm | 12 + .../getCapital/getCapital.1.adm | 6 + .../insert-from-select/insert-from-select.1.adm | 1 + .../results/library-functions/mysum/mysum.1.adm | 1 + .../library-functions/toUpper/toUpper.1.adm | 1 + .../dataverseDataset/dataverseDataset.1.adm | 3 + .../functionDataset/functionDataset.1.adm | 8 + .../libraryDataset/libraryDataset.1.adm | 1 + .../record-parser/record-parser.1.adm | 100 ++ .../integrationts/library/testsuite.xml | 81 ++ .../backupRestore/backupRestore.1.ddl.aql | 19 + .../backupRestore/backupRestore.2.mgx.aql | 19 + .../backupRestore/backupRestore.3.mgx.aql | 19 + .../backupRestore/backupRestore.4.mgx.aql | 19 + .../backupRestore/backupRestore.5.ddl.aql | 20 + .../backupRestore/backupRestore.6.mgx.aql | 19 + .../backupRestore/backupRestore.7.mgx.aql | 19 + .../backupRestore/backupRestore.8.mgx.aql | 19 + .../backupRestore/backupRestore.9.query.aql | 21 + .../installLibrary/installLibrary.1.mgx.aql | 19 + .../installLibrary/installLibrary.2.mgx.aql | 19 + .../installLibrary/installLibrary.3.mgx.aql | 19 + .../installLibrary/installLibrary.4.query.aql | 20 + .../uninstallLibrary/uninstallLibrary.1.mgx.aql | 19 + .../uninstallLibrary/uninstallLibrary.2.mgx.aql | 19 + .../uninstallLibrary/uninstallLibrary.3.mgx.aql | 19 + .../uninstallLibrary.4.query.aql | 20 + .../backupRestore/backupRestore.1.adm | 1 + .../installLibrary/installLibrary.1.adm | 1 + .../uninstallLibrary/uninstallLibrary.1.adm | 1 + .../integrationts/lifecycle/testsuite.xml | 38 + .../metadata_node_recovery.1.ddl.aql | 50 + .../metadata_node_recovery.10.node.aql | 30 + .../metadata_node_recovery.11.sleep.aql | 19 + .../metadata_node_recovery.12.node.aql | 19 + .../metadata_node_recovery.13.sleep.aql | 19 + .../metadata_node_recovery.14.ddl.aql | 33 + .../metadata_node_recovery.15.node.aql | 30 + .../metadata_node_recovery.16.sleep.aql | 19 + .../metadata_node_recovery.17.node.aql | 19 + .../metadata_node_recovery.18.sleep.aql | 19 + .../metadata_node_recovery.19.query.aql | 35 + .../metadata_node_recovery.2.node.aql | 30 + .../metadata_node_recovery.3.sleep.aql | 19 + .../metadata_node_recovery.4.get.http | 30 + .../metadata_node_recovery.5.node.aql | 19 + .../metadata_node_recovery.6.sleep.aql | 19 + .../metadata_node_recovery.7.get.http | 30 + .../metadata_node_recovery.8.query.aql | 34 + .../metadata_node_recovery.9.ddl.aql | 33 + .../metadata_node_recovery.cluster_state.4.adm | 38 + .../metadata_node_recovery.cluster_state.7.adm | 38 + .../metadata_node_recovery.query.19.adm | 1 + .../metadata_node_recovery.query.8.adm | 1 + .../metadata_only_replication/testsuite.xml | 27 + .../integrationts/replication/data/fbu.adm | 10 + .../node_failback/node_failback.1.ddl.aql | 59 + .../node_failback/node_failback.10.get.http | 30 + .../node_failback/node_failback.11.query.aql | 33 + .../node_failback/node_failback.2.update.aql | 36 + .../node_failback/node_failback.3.node.aql | 28 + .../node_failback/node_failback.4.sleep.aql | 19 + .../node_failback/node_failback.5.get.http | 30 + .../node_failback/node_failback.6.query.aql | 33 + .../node_failback/node_failback.7.update.aql | 51 + .../node_failback/node_failback.8.node.aql | 28 + .../node_failback/node_failback.9.sleep.aql | 19 + .../failover/bulkload/bulkload.1.ddl.aql | 54 + .../failover/bulkload/bulkload.2.update.aql | 33 + .../failover/bulkload/bulkload.3.node.aql | 28 + .../failover/bulkload/bulkload.4.sleep.aql | 19 + .../failover/bulkload/bulkload.5.query.aql | 31 + .../mem_component_recovery.1.ddl.aql | 58 + .../mem_component_recovery.2.update.aql | 34 + .../mem_component_recovery.3.node.aql | 28 + .../mem_component_recovery.4.sleep.aql | 19 + .../mem_component_recovery.5.query.aql | 32 + .../metadata_node/metadata_node.1.ddl.aql | 55 + .../metadata_node/metadata_node.2.node.aql | 28 + .../metadata_node/metadata_node.3.sleep.aql | 19 + .../metadata_node/metadata_node.4.query.aql | 36 + .../node_failback.cluster_state.10.adm | 38 + .../node_failback.cluster_state.5.adm | 38 + .../node_failback/node_failback.query.11.adm | 1 + .../node_failback/node_failback.query.6.adm | 1 + .../results/failover/bulkload/bulkload.5.adm | 1 + .../mem_component_recovery.5.adm | 1 + .../failover/metadata_node/metadata_node.4.adm | 1 + .../integrationts/replication/testsuite.xml | 44 + .../resources/integrationts/restart/828.h1w.adm | 100 ++ .../integrationts/restart/hugeobject.adm | 1 + .../issue-1636/issue-1636.01.ddl.aql | 81 ++ .../issue-1636/issue-1636.02.ddl.aql | 29 + .../issue-1636/issue-1636.03.script.aql | 19 + .../issue-1636/issue-1636.04.ddl.aql | 36 + .../issue-1636/issue-1636.05.mgx.aql | 20 + .../issue-1636/issue-1636.06.mgx.aql | 20 + .../issue-1636/issue-1636.07.script.aql | 19 + .../issue-1636/issue-1636.08.ddl.aql | 27 + .../issue-1636/issue-1636.09.sleep.aql | 25 + .../issue-1636/issue-1636.10.script.aql | 19 + .../issue-1636/issue-1636.11.script.aql | 19 + .../issue-1725/issue-1725.1.ddl.aql | 29 + .../issue-1725/issue-1725.2.update.aql | 28 + .../issue-1725/issue-1725.3.mgx.aql | 20 + .../issue-1725/issue-1725.4.mgx.aql | 19 + .../issue-1725/issue-1725.5.query.aql | 27 + .../storage-restart/issue-1725/issue-1725.5.adm | 1 + .../scripts/feed-restart/issue-1636/cat.sh | 18 + .../scripts/feed-restart/issue-1636/grep_log.sh | 20 + .../feed-restart/issue-1636/kill_cc_and_nc.sh | 18 + .../scripts/feed-restart/issue-1636/touch.sh | 21 + .../integrationts/restart/testsuite.xml | 35 + .../resources/integrationts/restart/tweets.json | 39 + .../multiple_secondary_indices.1.script.aql | 18 + .../multiple_secondary_indices.2.ddl.aql | 52 + .../multiple_secondary_indices.3.script.aql | 18 + .../multiple_secondary_indices.4.ddl.aql | 31 + .../multiple_secondary_indices.5.script.aql | 18 + .../big_object_20M/big_object_20M.1.script.aql | 19 + .../big_object_20M/big_object_20M.2.ddl.aql | 36 + .../big_object_20M/big_object_20M.3.update.aql | 32 + .../big_object_20M/big_object_20M.4.script.aql | 19 + .../big_object_20M/big_object_20M.5.query.aql | 23 + .../big_object_20M/big_object_20M.6.script.aql | 19 + .../dataset-with-meta-record.1.script.aql | 19 + .../dataset-with-meta-record.2.ddl.aql | 56 + .../dataset-with-meta-record.3.update.aql | 28 + .../dataset-with-meta-record.4.script.aql | 19 + .../dataset-with-meta-record.5.query.aql | 29 + .../dataset-with-meta-record.6.script.aql | 19 + .../external_index/external_index.1.script.aql | 19 + .../external_index/external_index.2.ddl.aql | 46 + .../external_index/external_index.3.script.aql | 19 + .../external_index/external_index.4.query.aql | 32 + .../external_index/external_index.5.script.aql | 19 + .../primary_index_only.1.script.aql | 19 + .../primary_index_only.2.ddl.aql | 59 + .../primary_index_only.3.update.aql | 29 + .../primary_index_only.4.txneu.aql | 40 + .../primary_index_only.5.txnqbc.aql | 28 + .../primary_index_only.6.script.aql | 19 + .../primary_index_only.7.script.aql | 19 + .../primary_index_only.8.txnqar.aql | 28 + .../primary_index_only.9.script.aql | 19 + .../primary_index_only_filtered.1.script.aql | 19 + .../primary_index_only_filtered.2.ddl.aql | 59 + .../primary_index_only_filtered.3.update.aql | 29 + .../primary_index_only_filtered.4.txneu.aql | 40 + .../primary_index_only_filtered.5.txnqbc.aql | 28 + .../primary_index_only_filtered.6.script.aql | 19 + .../primary_index_only_filtered.7.script.aql | 19 + .../primary_index_only_filtered.8.txnqar.aql | 28 + .../primary_index_only_filtered.9.script.aql | 19 + ...ary_plus_correlated_ngram_index.1.script.aql | 19 + ...ry_plus_correlated_ngram_index.10.script.aql | 19 + ...rimary_plus_correlated_ngram_index.2.ddl.aql | 80 ++ ...ary_plus_correlated_ngram_index.3.update.aql | 23 + ...mary_plus_correlated_ngram_index.4.txneu.aql | 37 + ...rimary_plus_correlated_ngram_index.5.ddl.aql | 24 + ...ary_plus_correlated_ngram_index.6.txnqbc.aql | 23 + ...ary_plus_correlated_ngram_index.7.script.aql | 19 + ...ary_plus_correlated_ngram_index.8.script.aql | 19 + ...ary_plus_correlated_ngram_index.9.txnqar.aql | 23 + ...ary_plus_correlated_rtree_index.1.script.aql | 19 + ...ry_plus_correlated_rtree_index.10.script.aql | 19 + ...rimary_plus_correlated_rtree_index.2.ddl.aql | 81 ++ ...ary_plus_correlated_rtree_index.3.update.aql | 24 + ...mary_plus_correlated_rtree_index.4.txneu.aql | 38 + ...rimary_plus_correlated_rtree_index.5.ddl.aql | 22 + ...ary_plus_correlated_rtree_index.6.txnqbc.aql | 23 + ...ary_plus_correlated_rtree_index.7.script.aql | 19 + ...ary_plus_correlated_rtree_index.8.script.aql | 19 + ...ary_plus_correlated_rtree_index.9.txnqar.aql | 23 + ...ault_correlated_secondary_index.1.script.aql | 19 + ...ult_correlated_secondary_index.10.script.aql | 19 + ...default_correlated_secondary_index.2.ddl.aql | 79 ++ ...ault_correlated_secondary_index.3.update.aql | 29 + ...fault_correlated_secondary_index.4.txneu.aql | 43 + ...default_correlated_secondary_index.5.ddl.aql | 29 + ...ault_correlated_secondary_index.6.txnqbc.aql | 28 + ...ault_correlated_secondary_index.7.script.aql | 19 + ...ault_correlated_secondary_index.8.script.aql | 19 + ...ault_correlated_secondary_index.9.txnqar.aql | 28 + ...ry_plus_default_secondary_index.1.script.aql | 19 + ...imary_plus_default_secondary_index.2.ddl.aql | 71 + ...ry_plus_default_secondary_index.3.update.aql | 29 + ...ary_plus_default_secondary_index.4.txneu.aql | 43 + ...ry_plus_default_secondary_index.5.txnqbc.aql | 28 + ...ry_plus_default_secondary_index.6.script.aql | 19 + ...ry_plus_default_secondary_index.7.script.aql | 19 + ...ry_plus_default_secondary_index.8.txnqar.aql | 28 + ...ry_plus_default_secondary_index.9.script.aql | 19 + ...efault_secondary_index_filtered.1.script.aql | 19 + ...s_default_secondary_index_filtered.2.ddl.aql | 70 + ...efault_secondary_index_filtered.3.update.aql | 29 + ...default_secondary_index_filtered.4.txneu.aql | 43 + ...efault_secondary_index_filtered.5.txnqbc.aql | 28 + ...efault_secondary_index_filtered.6.script.aql | 19 + ...efault_secondary_index_filtered.7.script.aql | 19 + ...efault_secondary_index_filtered.8.txnqar.aql | 28 + ...efault_secondary_index_filtered.9.script.aql | 19 + ...word_correlated_secondary_index.1.script.aql | 19 + ...ord_correlated_secondary_index.10.script.aql | 19 + ...keyword_correlated_secondary_index.2.ddl.aql | 81 ++ ...word_correlated_secondary_index.3.update.aql | 24 + ...yword_correlated_secondary_index.4.txneu.aql | 37 + ...keyword_correlated_secondary_index.5.ddl.aql | 24 + ...word_correlated_secondary_index.6.txnqbc.aql | 23 + ...word_correlated_secondary_index.7.script.aql | 19 + ...word_correlated_secondary_index.8.script.aql | 19 + ...word_correlated_secondary_index.9.txnqar.aql | 23 + ...ry_plus_keyword_secondary_index.1.script.aql | 19 + ...imary_plus_keyword_secondary_index.2.ddl.aql | 72 + ...ry_plus_keyword_secondary_index.3.update.aql | 29 + ...ary_plus_keyword_secondary_index.4.txneu.aql | 43 + ...ry_plus_keyword_secondary_index.5.txnqbc.aql | 23 + ...ry_plus_keyword_secondary_index.6.script.aql | 19 + ...ry_plus_keyword_secondary_index.7.script.aql | 19 + ...ry_plus_keyword_secondary_index.8.txnqar.aql | 23 + ...ry_plus_keyword_secondary_index.9.script.aql | 19 + ...eyword_secondary_index_filtered.1.script.aql | 19 + ...s_keyword_secondary_index_filtered.2.ddl.aql | 70 + ...eyword_secondary_index_filtered.3.update.aql | 30 + ...keyword_secondary_index_filtered.4.txneu.aql | 43 + ...eyword_secondary_index_filtered.5.txnqbc.aql | 23 + ...eyword_secondary_index_filtered.6.script.aql | 19 + ...eyword_secondary_index_filtered.7.script.aql | 19 + ...eyword_secondary_index_filtered.8.txnqar.aql | 23 + ...eyword_secondary_index_filtered.9.script.aql | 19 + ...le_correlated_secondary_indices.1.script.aql | 19 + ...e_correlated_secondary_indices.10.script.aql | 19 + ...tiple_correlated_secondary_indices.2.ddl.aql | 81 ++ ...le_correlated_secondary_indices.3.update.aql | 24 + ...ple_correlated_secondary_indices.4.txneu.aql | 37 + ...tiple_correlated_secondary_indices.5.ddl.aql | 27 + ...le_correlated_secondary_indices.6.txnqbc.aql | 23 + ...le_correlated_secondary_indices.7.script.aql | 19 + ...le_correlated_secondary_indices.8.script.aql | 19 + ...le_correlated_secondary_indices.9.txnqar.aql | 23 + ...plus_multiple_secondary_indices.1.script.aql | 19 + ...ry_plus_multiple_secondary_indices.2.ddl.aql | 78 + ...plus_multiple_secondary_indices.3.update.aql | 30 + ..._plus_multiple_secondary_indices.4.txneu.aql | 43 + ...plus_multiple_secondary_indices.5.txnqbc.aql | 30 + ...plus_multiple_secondary_indices.6.script.aql | 19 + ...plus_multiple_secondary_indices.7.script.aql | 19 + ...plus_multiple_secondary_indices.8.txnqar.aql | 23 + ...plus_multiple_secondary_indices.9.script.aql | 19 + ...iple_secondary_indices_filtered.1.script.aql | 19 + ...ultiple_secondary_indices_filtered.2.ddl.aql | 76 + ...iple_secondary_indices_filtered.3.update.aql | 30 + ...tiple_secondary_indices_filtered.4.txneu.aql | 43 + ...iple_secondary_indices_filtered.5.txnqbc.aql | 30 + ...iple_secondary_indices_filtered.6.script.aql | 19 + ...iple_secondary_indices_filtered.7.script.aql | 19 + ...iple_secondary_indices_filtered.8.txnqar.aql | 23 + ...iple_secondary_indices_filtered.9.script.aql | 19 + .../primary_plus_ngram_index.1.script.aql | 19 + .../primary_plus_ngram_index.2.ddl.aql | 71 + .../primary_plus_ngram_index.3.update.aql | 29 + .../primary_plus_ngram_index.4.txneu.aql | 43 + .../primary_plus_ngram_index.5.txnqbc.aql | 29 + .../primary_plus_ngram_index.6.script.aql | 19 + .../primary_plus_ngram_index.7.script.aql | 19 + .../primary_plus_ngram_index.8.txnqar.aql | 29 + .../primary_plus_ngram_index.9.script.aql | 19 + ...imary_plus_ngram_index_filtered.1.script.aql | 19 + .../primary_plus_ngram_index_filtered.2.ddl.aql | 71 + ...imary_plus_ngram_index_filtered.3.update.aql | 29 + ...rimary_plus_ngram_index_filtered.4.txneu.aql | 43 + ...imary_plus_ngram_index_filtered.5.txnqbc.aql | 29 + ...imary_plus_ngram_index_filtered.6.script.aql | 19 + ...imary_plus_ngram_index_filtered.7.script.aql | 19 + ...imary_plus_ngram_index_filtered.8.txnqar.aql | 29 + ...imary_plus_ngram_index_filtered.9.script.aql | 19 + .../primary_plus_rtree_index.1.script.aql | 19 + .../primary_plus_rtree_index.2.ddl.aql | 72 + .../primary_plus_rtree_index.3.update.aql | 29 + .../primary_plus_rtree_index.4.txneu.aql | 43 + .../primary_plus_rtree_index.5.txnqbc.aql | 23 + .../primary_plus_rtree_index.6.script.aql | 19 + .../primary_plus_rtree_index.7.script.aql | 19 + .../primary_plus_rtree_index.8.txnqar.aql | 23 + .../primary_plus_rtree_index.9.script.aql | 19 + ...imary_plus_rtree_index_filtered.1.script.aql | 19 + .../primary_plus_rtree_index_filtered.2.ddl.aql | 70 + ...imary_plus_rtree_index_filtered.3.update.aql | 30 + ...rimary_plus_rtree_index_filtered.4.txneu.aql | 43 + ...imary_plus_rtree_index_filtered.5.txnqbc.aql | 23 + ...imary_plus_rtree_index_filtered.6.script.aql | 19 + ...imary_plus_rtree_index_filtered.7.script.aql | 19 + ...imary_plus_rtree_index_filtered.8.txnqar.aql | 23 + ...imary_plus_rtree_index_filtered.9.script.aql | 19 + ...s_rtree_index_insert_and_delete.1.script.aql | 19 + ...plus_rtree_index_insert_and_delete.2.ddl.aql | 71 + ...s_rtree_index_insert_and_delete.3.update.aql | 29 + ...us_rtree_index_insert_and_delete.4.txneu.aql | 67 + ...s_rtree_index_insert_and_delete.5.txnqbc.aql | 23 + ...s_rtree_index_insert_and_delete.6.script.aql | 19 + ...s_rtree_index_insert_and_delete.7.script.aql | 19 + ...s_rtree_index_insert_and_delete.8.txnqar.aql | 23 + ...s_rtree_index_insert_and_delete.9.script.aql | 19 + ...ndex_insert_and_delete_filtered.1.script.aql | 19 + ...e_index_insert_and_delete_filtered.2.ddl.aql | 70 + ...ndex_insert_and_delete_filtered.3.update.aql | 29 + ...index_insert_and_delete_filtered.4.txneu.aql | 67 + ...ndex_insert_and_delete_filtered.5.txnqbc.aql | 23 + ...ndex_insert_and_delete_filtered.6.script.aql | 19 + ...ndex_insert_and_delete_filtered.7.script.aql | 19 + ...ndex_insert_and_delete_filtered.8.txnqar.aql | 23 + ...ndex_insert_and_delete_filtered.9.script.aql | 19 + .../dataset_recovery.1.script.aql | 19 + .../dataset_recovery/dataset_recovery.2.ddl.aql | 37 + .../dataset_recovery.3.script.aql | 19 + .../dataset_recovery.4.script.aql | 19 + .../dataset_recovery/dataset_recovery.5.ddl.aql | 20 + .../dataset_recovery.6.errddl.aql | 20 + .../dataset_recovery.7.script.aql | 19 + .../datatype_recovery.1.script.aql | 19 + .../datatype_recovery.2.ddl.aql | 34 + .../datatype_recovery.3.script.aql | 19 + .../datatype_recovery.4.script.aql | 19 + .../datatype_recovery.5.ddl.aql | 20 + .../datatype_recovery.6.errddl.aql | 20 + .../datatype_recovery.7.script.aql | 19 + .../dataverse_recovery.1.script.aql | 19 + .../dataverse_recovery.2.ddl.aql | 27 + .../dataverse_recovery.3.script.aql | 19 + .../dataverse_recovery.4.script.aql | 19 + .../dataverse_recovery.5.ddl.aql | 19 + .../dataverse_recovery.6.errddl.aql | 19 + .../dataverse_recovery.7.script.aql | 19 + .../delete_after_recovery.1.script.aql | 19 + .../delete_after_recovery.2.ddl.aql | 59 + .../delete_after_recovery.3.update.aql | 29 + .../delete_after_recovery.4.script.aql | 19 + .../delete_after_recovery.5.script.aql | 19 + .../delete_after_recovery.6.update.aql | 23 + .../delete_after_recovery.7.query.aql | 29 + .../delete_after_recovery.8.script.aql | 19 + .../function_recovery.1.script.aql | 19 + .../function_recovery.2.ddl.aql | 25 + .../function_recovery.3.script.aql | 19 + .../function_recovery.4.script.aql | 19 + .../function_recovery.5.query.aql | 30 + .../function_recovery.6.ddl.aql | 21 + .../function_recovery.7.errddl.aql | 21 + .../function_recovery.8.script.aql | 19 + .../insert_after_recovery.1.script.aql | 19 + .../insert_after_recovery.2.ddl.aql | 59 + .../insert_after_recovery.3.update.aql | 29 + .../insert_after_recovery.4.script.aql | 19 + .../insert_after_recovery.5.script.aql | 19 + .../insert_after_recovery.6.update.aql | 33 + .../insert_after_recovery.7.query.aql | 29 + .../insert_after_recovery.8.script.aql | 19 + .../load_after_recovery.1.script.aql | 19 + .../load_after_recovery.2.ddl.aql | 59 + .../load_after_recovery.3.script.aql | 19 + .../load_after_recovery.4.script.aql | 19 + .../load_after_recovery.5.update.aql | 29 + .../load_after_recovery.6.query.aql | 28 + .../load_after_recovery.7.script.aql | 19 + .../secondary_index_recovery.1.script.aql | 19 + .../secondary_index_recovery.2.ddl.aql | 39 + .../secondary_index_recovery.3.script.aql | 19 + .../secondary_index_recovery.4.script.aql | 19 + .../secondary_index_recovery.5.ddl.aql | 20 + .../secondary_index_recovery.6.errddl.aql | 20 + .../secondary_index_recovery.7.script.aql | 19 + .../big_object_20M.1.adm.template | 1 + .../dataset-with-meta-record.5.adm | 1 + .../external_index/external_index.1.adm | 2 + .../delete_after_recovery.1.adm | 1 + .../function_recovery/function_recovery.1.adm | 1 + .../insert_after_recovery.1.adm | 1 + .../load_after_recovery.1.adm | 1 + .../create_and_start.sh | 18 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../dml_recovery/configure_and_validate.sh | 18 + .../scripts/dml_recovery/create_and_start.sh | 18 + .../scripts/dml_recovery/kill_cc_and_nc.sh | 19 + .../scripts/dml_recovery/stop_and_delete.sh | 20 + .../scripts/dml_recovery/stop_and_start.sh | 19 + .../big_object_20M/create_and_start.sh | 18 + .../big_object_20M/stop_and_delete.sh | 20 + .../big_object_20M/stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../dataset-with-meta-record/stop_and_delete.sh | 20 + .../dataset-with-meta-record/stop_and_start.sh | 19 + .../external_index/create_and_start.sh | 18 + .../external_index/stop_and_delete.sh | 20 + .../external_index/stop_and_start.sh | 19 + .../primary_index_only/create_and_start.sh | 18 + .../primary_index_only/kill_cc_and_nc.sh | 19 + .../primary_index_only/stop_and_delete.sh | 20 + .../primary_index_only/stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../primary_plus_ngram_index/kill_cc_and_nc.sh | 19 + .../primary_plus_ngram_index/stop_and_delete.sh | 20 + .../primary_plus_ngram_index/stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../primary_plus_rtree_index/kill_cc_and_nc.sh | 19 + .../primary_plus_rtree_index/stop_and_delete.sh | 20 + .../primary_plus_rtree_index/stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../temp_primary_index_only/create_and_start.sh | 18 + .../temp_primary_index_only/kill_cc_and_nc.sh | 19 + .../temp_primary_index_only/stop_and_delete.sh | 20 + .../temp_primary_index_only/stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../dataset_recovery/create_and_start.sh | 18 + .../dataset_recovery/kill_cc_and_nc.sh | 19 + .../dataset_recovery/stop_and_delete.sh | 20 + .../dataset_recovery/stop_and_start.sh | 19 + .../datatype_recovery/create_and_start.sh | 18 + .../datatype_recovery/kill_cc_and_nc.sh | 19 + .../datatype_recovery/stop_and_delete.sh | 20 + .../datatype_recovery/stop_and_start.sh | 19 + .../dataverse_recovery/create_and_start.sh | 18 + .../dataverse_recovery/kill_cc_and_nc.sh | 19 + .../dataverse_recovery/stop_and_delete.sh | 20 + .../dataverse_recovery/stop_and_start.sh | 19 + .../delete_after_recovery/create_and_start.sh | 18 + .../delete_after_recovery/kill_cc_and_nc.sh | 19 + .../delete_after_recovery/stop_and_delete.sh | 20 + .../delete_after_recovery/stop_and_start.sh | 19 + .../function_recovery/create_and_start.sh | 18 + .../function_recovery/kill_cc_and_nc.sh | 19 + .../function_recovery/stop_and_delete.sh | 20 + .../function_recovery/stop_and_start.sh | 19 + .../insert_after_recovery/create_and_start.sh | 18 + .../insert_after_recovery/kill_cc_and_nc.sh | 19 + .../insert_after_recovery/stop_and_delete.sh | 20 + .../insert_after_recovery/stop_and_start.sh | 19 + .../load_after_recovery/create_and_start.sh | 18 + .../load_after_recovery/kill_cc_and_nc.sh | 19 + .../load_after_recovery/stop_and_delete.sh | 20 + .../load_after_recovery/stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../secondary_index_recovery/kill_cc_and_nc.sh | 19 + .../secondary_index_recovery/stop_and_delete.sh | 20 + .../secondary_index_recovery/stop_and_start.sh | 19 + .../temp_dataset_recovery/create_and_start.sh | 18 + .../temp_dataset_recovery/kill_cc_and_nc.sh | 19 + .../temp_dataset_recovery/stop_and_delete.sh | 20 + .../temp_dataset_recovery/stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../temp_load_after_recovery/kill_cc_and_nc.sh | 19 + .../temp_load_after_recovery/stop_and_delete.sh | 20 + .../temp_load_after_recovery/stop_and_start.sh | 19 + .../create_and_start.sh | 18 + .../kill_cc_and_nc.sh | 19 + .../stop_and_delete.sh | 20 + .../stop_and_start.sh | 19 + .../setup_teardown/configure_and_validate.sh | 18 + .../scripts/setup_teardown/kill_cc_and_nc.sh | 19 + .../scripts/setup_teardown/shutdown.sh | 18 + .../scripts/setup_teardown/stop_and_delete.sh | 20 + .../test/resources/transactionts/testsuite.xml | 219 +++ .../PersistentLocalResourceRepository.java | 18 +- .../logging/LogManagerWithReplication.java | 6 +- asterixdb/pom.xml | 15 +- .../hyracks/api/application/ICCApplication.java | 2 + .../hyracks/control/cc/BaseCCApplication.java | 7 + .../control/cc/ClusterControllerService.java | 28 +- .../control/cc/web/StartNodeApiServlet.java | 54 + .../hyracks/control/cc/web/WebServer.java | 1 + .../control/common/config/ConfigManager.java | 6 +- .../control/common/controllers/NCConfig.java | 25 +- .../server/process/HyracksCCProcess.java | 3 +- .../server/process/HyracksServerProcess.java | 9 +- 1379 files changed, 17193 insertions(+), 30427 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-app/pom.xml ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-app/pom.xml b/asterixdb/asterix-app/pom.xml index 2d47b62..c250a2a 100644 --- a/asterixdb/asterix-app/pom.xml +++ b/asterixdb/asterix-app/pom.xml @@ -177,10 +177,12 @@ <exclude>src/test/resources/**/results/**</exclude> <exclude>src/test/resources/fuzzyjoin/pub/fuzzy-join-aql*.dot</exclude> <exclude>src/test/resources/fuzzyjoin/pub/fuzzy-join-aql*.json</exclude> - <exclude>data/**</exclude> + <exclude>**/data/**</exclude> + <exclude>src/test//resources/**/data/**</exclude> <exclude>src/main/resources/queryui/**</exclude> <exclude>src/main/resources/webui/**</exclude> <exclude>src/test/resources/**/only*.xml</exclude> + <exclude>src/main/resources/sdk/**</exclude> </excludes> </configuration> </execution> @@ -407,11 +409,6 @@ <artifactId>hyracks-storage-am-lsm-btree</artifactId> </dependency> <dependency> - <groupId>org.apache.asterix</groupId> - <artifactId>asterix-events</artifactId> - <version>${project.version}</version> - </dependency> - <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> </dependency> @@ -574,9 +571,14 @@ <scope>test</scope> </dependency> <dependency> + <groupId>org.apache.commons</groupId> + <artifactId>commons-compress</artifactId> + <version>1.4.1</version> + </dependency> + <dependency> <groupId>org.apache.hyracks</groupId> <artifactId>hyracks-comm</artifactId> <version>${hyracks.version}</version> </dependency> </dependencies> -</project> \ No newline at end of file +</project>
