a9693631f7d47871c3b2e5f9c4e99e13c0e577c5 - asterixdb-bad

commit: a9693631f7d47871c3b2e5f9c4e99e13c0e577c5
[log]
author: Steven Glenn Jacobs <sjaco002@ucr.edu>
Mon May 21 11:52:12 2018 -0700
committer: Steven Glenn Jacobs <sjaco002@ucr.edu>
Mon May 21 11:52:12 2018 -0700
tree: e73ba052e3543a2f0992f3868ac0686fac604344
parent: 846ac6c843ae9f9d21f753391d634a0f64ffc44b [diff]

Redeploy channels and procedures during recovery

Use the GlobalRecoveryManager extension to redeploy channels/procedures
Restart execution of channels during recovery
Some code cleanup
Added recovery test

Change-Id: I6897ccf9cddb9ec8d10256e252ee893afe6db145

asterix-bad/pom.xml[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/BADConstants.java[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/BADJobService.java[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/BADStatementExecutor.java[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateChannelStatement.java[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/CreateProcedureStatement.java[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/lang/statement/ExecuteProcedureStatement.java[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/BADMetadataRecordTypes.java[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/Procedure.java[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/metadata/ProcedureTupleTranslator.java[diff]
asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java[Added - diff]
asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADRecoveryExtension.java[Added - diff]
asterix-bad/src/main/resources/cc.conf[diff]
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADAsterixHyracksIntegrationUtil.java[diff]
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADListenerTest.java[diff]
asterix-bad/src/test/java/org/apache/asterix/bad/test/BADRecoveryTest.java[Added - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.1.ddl.sqlpp[Added - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.10.update.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.11.query.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.12.update.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.13.query.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.14.ddl.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.2.script.sqlpp[Added - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.3.query.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.4.query.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.5.update.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.6.sleep.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.7.query.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.8.query.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/queries/recovery/restart_cluster/restart_cluster.9.query.sqlpp[Copied from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/recoveryts/results/recovery/restart_cluster/restart_cluster.11.adm[Added - diff]
asterix-bad/src/test/resources/recoveryts/results/recovery/restart_cluster/restart_cluster.13.adm[Added - diff]
asterix-bad/src/test/resources/recoveryts/results/recovery/restart_cluster/restart_cluster.3.adm[Added - diff]
asterix-bad/src/test/resources/recoveryts/results/recovery/restart_cluster/restart_cluster.4.adm[Added - diff]
asterix-bad/src/test/resources/recoveryts/results/recovery/restart_cluster/restart_cluster.7.adm[Added - diff]
asterix-bad/src/test/resources/recoveryts/results/recovery/restart_cluster/restart_cluster.8.adm[Added - diff]
asterix-bad/src/test/resources/recoveryts/results/recovery/restart_cluster/restart_cluster.9.adm[Added - diff]
asterix-bad/src/test/resources/recoveryts/scripts/recovery/restart_cluster/stop_and_start.sh[Added - diff]
asterix-bad/src/test/resources/recoveryts/scripts/setup_teardown/configure_and_validate.sh[Added - diff]
asterix-bad/src/test/resources/recoveryts/scripts/setup_teardown/stop_and_delete.sh[Added - diff]
asterix-bad/src/test/resources/recoveryts/testsuite.xml[Added - diff]
asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.3.query.sqlpp[Renamed from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.3.update.sqlpp - diff]
asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.5.query.sqlpp[Renamed from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure/query_procedure.5.update.sqlpp - diff]
asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.2.query.sqlpp[Renamed from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.2.update.sqlpp - diff]
asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.query.sqlpp[Renamed from asterix-bad/src/test/resources/runtimets/queries/procedure/query_procedure_with_parameters/query_procedure_with_parameters.3.update.sqlpp - diff]
asterix-bad/src/test/resources/runtimets/results/procedure/create_procedure_check_metadata/create_procedure_check_metadata.1.adm[diff]
asterix-bad/src/test/resources/runtimets/results/procedure/query_procedure/query_procedure.3.adm[diff]
asterix-bad/src/test/resources/runtimets/results/procedure/query_procedure/query_procedure.5.adm[diff]
asterix-bad/src/test/resources/runtimets/results/procedure/query_procedure_with_parameters/query_procedure_with_parameters.2.adm[diff]

50 files changed

tree: e73ba052e3543a2f0992f3868ac0686fac604344