diff --git a/src/include/main/database.h b/src/include/main/database.h index 92d6d833a7..40aef8b443 100644 --- a/src/include/main/database.h +++ b/src/include/main/database.h @@ -71,7 +71,7 @@ struct LBUG_API SystemConfig { * WAL file. It must match the setting the database's WAL was written with: a mismatch fails * the open whatever throwOnWalReplayFailure says. * @param enableMultiWrites If true, multiple concurrent write transactions are allowed. - * Default to false. + * Default to true. * @param enableDefaultHashIndex If true, node tables create the default primary-key hash * index. * @param physicalPlanPoolPerThread How many reusable cloned physical plans each thread @@ -81,7 +81,7 @@ struct LBUG_API SystemConfig { bool enableCompression = true, bool readOnly = false, uint64_t maxDBSize = -1u, bool autoCheckpoint = true, uint64_t checkpointThreshold = 16777216 /* 16MB */, bool forceCheckpointOnClose = true, bool throwOnWalReplayFailure = false, - bool enableChecksums = true, bool enableMultiWrites = false, + bool enableChecksums = true, bool enableMultiWrites = true, bool enableDefaultHashIndex = true, uint64_t physicalPlanPoolPerThread = 5 #if defined(__APPLE__) , diff --git a/src/include/main/settings.h b/src/include/main/settings.h index f6c34f96d0..1a723efdde 100644 --- a/src/include/main/settings.h +++ b/src/include/main/settings.h @@ -96,8 +96,8 @@ struct RecursivePatternFactorSetting { static common::Value getSetting(const ClientContext* context); }; -struct EnableMVCCSetting { - static constexpr auto name = "debug_enable_multi_writes"; +struct EnableMultiWritesSetting { + static constexpr auto name = "enable_multi_writes"; static constexpr auto inputType = common::LogicalTypeID::BOOL; static void setContext(ClientContext* context, const common::Value& parameter); static common::Value getSetting(const ClientContext* context); diff --git a/src/main/db_config.cpp b/src/main/db_config.cpp index 92c988109a..c6400cc01a 100644 --- a/src/main/db_config.cpp +++ b/src/main/db_config.cpp @@ -19,7 +19,7 @@ static ConfigurationOption options[] = { // NOLINT(cert-err58-cpp): GET_CONFIGURATION(DisableMapKeyCheck), GET_CONFIGURATION(EnableZoneMapSetting), GET_CONFIGURATION(HomeDirectorySetting), GET_CONFIGURATION(FileSearchPathSetting), GET_CONFIGURATION(ProgressBarSetting), GET_CONFIGURATION(RecursivePatternSemanticSetting), - GET_CONFIGURATION(RecursivePatternFactorSetting), GET_CONFIGURATION(EnableMVCCSetting), + GET_CONFIGURATION(RecursivePatternFactorSetting), GET_CONFIGURATION(EnableMultiWritesSetting), GET_CONFIGURATION(CheckpointThresholdSetting), GET_CONFIGURATION(AutoCheckpointSetting), GET_CONFIGURATION(ForceCheckpointClosingDBSetting), GET_CONFIGURATION(EnableDefaultHashIndexSetting), GET_CONFIGURATION(SpillToDiskSetting), diff --git a/src/main/settings.cpp b/src/main/settings.cpp index 3382027db0..edfb35580f 100644 --- a/src/main/settings.cpp +++ b/src/main/settings.cpp @@ -164,13 +164,12 @@ common::Value RecursivePatternFactorSetting::getSetting(const ClientContext* con context->getClientConfig()->recursivePatternCardinalityScaleFactor); } -void EnableMVCCSetting::setContext(ClientContext* context, const common::Value& parameter) { +void EnableMultiWritesSetting::setContext(ClientContext* context, const common::Value& parameter) { DASSERT(parameter.getDataType().getLogicalTypeID() == common::LogicalTypeID::BOOL); - // TODO: This is a temporary solution to make tests of multiple write transactions easier. context->getDBConfigUnsafe()->enableMultiWrites = parameter.getValue(); } -common::Value EnableMVCCSetting::getSetting(const ClientContext* context) { +common::Value EnableMultiWritesSetting::getSetting(const ClientContext* context) { return common::Value(context->getDBConfig()->enableMultiWrites); } diff --git a/test/test_files/transaction/concurrency/ddl_concurrent_execution.test b/test/test_files/transaction/concurrency/ddl_concurrent_execution.test index 8347c1c6b1..6a19dcccd2 100644 --- a/test/test_files/transaction/concurrency/ddl_concurrent_execution.test +++ b/test/test_files/transaction/concurrency/ddl_concurrent_execution.test @@ -55,7 +55,7 @@ 16|propA|INT64|False -CASE ConcurrentMultiWriteCreateTable --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -CREATE_CONNECTION conn2 -CREATE_CONNECTION conn3 @@ -75,7 +75,7 @@ #TODO(Howe): After fixing, please update table_info to return default_expr aswell. -CASE ConcurrentMultiWriteAlter --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -CREATE_CONNECTION conn2 -CREATE_CONNECTION conn3 diff --git a/test/test_files/transaction/concurrency/ddl_serial_execution.test b/test/test_files/transaction/concurrency/ddl_serial_execution.test index 340df877eb..c6e59c0696 100644 --- a/test/test_files/transaction/concurrency/ddl_serial_execution.test +++ b/test/test_files/transaction/concurrency/ddl_serial_execution.test @@ -2,6 +2,8 @@ -- -CASE MultiWritesException +-STATEMENT CALL enable_multi_writes=false; +---- ok -STATEMENT BEGIN TRANSACTION; ---- ok -STATEMENT CREATE NODE TABLE t(a INT, b INT, PRIMARY KEY(a)); @@ -49,9 +51,11 @@ Cannot start a new write transaction in the system. Only one write transaction a ---- 1 2 -# Test CALL debug_enable_multi_writes=true +# Test CALL enable_multi_writes=false/true toggle -CASE EnableMultiWrites --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=false; +---- ok +-STATEMENT CALL enable_multi_writes=true; ---- ok -STATEMENT BEGIN TRANSACTION; ---- ok @@ -109,7 +113,7 @@ Catalog exception: t does not exist in catalog. # Test W-W conflict -CASE CreateTableWriteWriteConflict --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -STATEMENT BEGIN TRANSACTION; ---- ok @@ -190,7 +194,7 @@ Catalog exception: t does not exist in catalog. 1|b|INT32|NULL|False -CASE CreateAndDropMultiConnections --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -STATEMENT BEGIN TRANSACTION; ---- ok @@ -238,7 +242,7 @@ Binder exception: Table t does not exist. 1|b|INT32|NULL|False -CASE RenameTable --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -STATEMENT BEGIN TRANSACTION; ---- ok @@ -275,7 +279,7 @@ Catalog exception: t does not exist in catalog. 1|b|INT32|NULL|False -CASE RenameColumn --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -STATEMENT CALL auto_checkpoint=false; ---- ok diff --git a/test/test_files/transaction/concurrency/dml_empty_serial_execution.test b/test/test_files/transaction/concurrency/dml_empty_serial_execution.test index a30c018480..096a8b6c7b 100644 --- a/test/test_files/transaction/concurrency/dml_empty_serial_execution.test +++ b/test/test_files/transaction/concurrency/dml_empty_serial_execution.test @@ -20,7 +20,7 @@ ] -CASE WWConflictNodeCopyUpdate --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -INSERT_STATEMENT_BLOCK COPY_TINYSNB_PERSON -CREATE_CONNECTION conn2 @@ -35,7 +35,7 @@ Runtime exception: Write-write conflict of updating the same row. -CASE NodeUpdateOverlappedRows --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -CREATE_CONNECTION conn2 -STATEMENT CREATE NODE TABLE test(id INT64, val INT64, PRIMARY KEY(id)); @@ -65,7 +65,7 @@ Runtime exception: Write-write conflict of updating the same row. 21 -CASE NodeUpdatesRollback --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -STATEMENT CALL auto_checkpoint=false; ---- ok @@ -95,7 +95,7 @@ Runtime exception: Write-write conflict of updating the same row. 0 -CASE NodeUpdatesMixedCommitAndRollback --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -STATEMENT CALL auto_checkpoint=false; ---- ok @@ -146,7 +146,7 @@ Runtime exception: Write-write conflict of updating the same row. 100 -CASE WWConflictNodeCopyDelete --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -INSERT_STATEMENT_BLOCK COPY_TINYSNB_PERSON -CREATE_CONNECTION conn2 @@ -161,7 +161,7 @@ Runtime exception: Write-write conflict of updating the same row. Runtime exception: Write-write conflict: deleting a row that is already deleted by another transaction. -CASE WWConflictRelCopyUpdate --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -INSERT_STATEMENT_BLOCK COPY_TINYSNB_PERSON -INSERT_STATEMENT_BLOCK COPY_TINYSNB_KNOWS @@ -177,7 +177,7 @@ Runtime exception: Write-write conflict: deleting a row that is already deleted Runtime exception: Write-write conflict of updating the same row. -CASE WWConflictRelCopyDelete --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -INSERT_STATEMENT_BLOCK COPY_TINYSNB_PERSON -INSERT_STATEMENT_BLOCK COPY_TINYSNB_KNOWS @@ -193,7 +193,7 @@ Runtime exception: Write-write conflict of updating the same row. Runtime exception: Write-write conflict: deleting a row that is already deleted by another transaction. -CASE WWConflictNodeInsertUpdate --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -CREATE_DATASET_SCHEMA tinysnb -INSERT_DATASET_BY_ROW tinysnb @@ -209,7 +209,7 @@ Runtime exception: Write-write conflict: deleting a row that is already deleted Runtime exception: Write-write conflict of updating the same row. -CASE WWConflictNodeInsertDelete --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -CREATE_DATASET_SCHEMA tinysnb -INSERT_DATASET_BY_ROW tinysnb @@ -225,7 +225,7 @@ Runtime exception: Write-write conflict of updating the same row. Runtime exception: Write-write conflict: deleting a row that is already deleted by another transaction. -CASE WWConflictRelInsertUpdate --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -CREATE_DATASET_SCHEMA tinysnb -INSERT_DATASET_BY_ROW tinysnb @@ -241,7 +241,7 @@ Runtime exception: Write-write conflict: deleting a row that is already deleted Runtime exception: Write-write conflict of updating the same row. -CASE WWConflictRelInsertDelete --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -CREATE_DATASET_SCHEMA tinysnb -INSERT_DATASET_BY_ROW tinysnb @@ -257,7 +257,7 @@ Runtime exception: Write-write conflict of updating the same row. Runtime exception: Write-write conflict: deleting a row that is already deleted by another transaction. -CASE MultiTransactionNodeInsert --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -STATEMENT CALL auto_checkpoint=false; ---- ok @@ -311,7 +311,7 @@ Runtime exception: Write-write conflict: deleting a row that is already deleted 10 -CASE MultiTransactionRelInsert --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -STATEMENT CALL auto_checkpoint=false; ---- ok @@ -386,7 +386,7 @@ Runtime exception: Write-write conflict: deleting a row that is already deleted -CASE MultiTransactionNodeCopy -SKIP --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -STATEMENT create node table person (ID INt64, fName StRING, gender INT64, isStudent BoOLEAN, isWorker BOOLEAN, age INT64, eyeSight DOUBLE, birthdate DATE, registerTime TIMESTAMP, lastJobDuration interval, workedHours INT64[], usedNames STRING[], courseScoresPerTerm INT64[][], grades INT64[4], height float, u UUID, PRIMARY KEY (ID)); ---- ok @@ -435,7 +435,7 @@ Runtime exception: Write-write conflict: deleting a row that is already deleted -CASE MultiTransactionRelCopy -SKIP --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -INSERT_STATEMENT_BLOCK COPY_TINYSNB_PERSON -STATEMENT create rel table knows (FROM person TO person, date DATE, meetTime TIMESTAMP, validInterval INTERVAL, comments STRING[], summary STRUCT(locations STRING[], transfer STRUCT(day DATE, amount INT64[])), notes UNION(firstmet DATE, type INT16, comment STRING), someMap MAP(STRING, STRING), MANY_MAnY); @@ -502,7 +502,7 @@ Runtime exception: Write-write conflict: deleting a row that is already deleted -CASE MixedMultiTransactionRelCopyInsert -SKIP --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -INSERT_STATEMENT_BLOCK COPY_TINYSNB_PERSON -STATEMENT create rel table knows (FROM person TO person, date DATE, meetTime TIMESTAMP, validInterval INTERVAL, comments STRING[], summary STRUCT(locations STRING[], transfer STRUCT(day DATE, amount INT64[])), notes UNION(firstmet DATE, type INT16, comment STRING), someMap MAP(STRING, STRING), MANY_MAnY); diff --git a/test/test_files/transaction/concurrency/dml_tinysnb_serial_execution.test b/test/test_files/transaction/concurrency/dml_tinysnb_serial_execution.test index 1042d8870b..0a1795b3cb 100644 --- a/test/test_files/transaction/concurrency/dml_tinysnb_serial_execution.test +++ b/test/test_files/transaction/concurrency/dml_tinysnb_serial_execution.test @@ -24,7 +24,7 @@ -CASE ConcurrentSingleWriteUpdate -SKIP_WASM --STATEMENT CALL debug_enable_multi_writes=true; +-STATEMENT CALL enable_multi_writes=true; ---- ok -CREATE_CONNECTION conn2 -BEGIN_CONCURRENT_EXECUTION diff --git a/test/transaction/checkpoint_test.cpp b/test/transaction/checkpoint_test.cpp index 269af81455..4b608d561c 100644 --- a/test/transaction/checkpoint_test.cpp +++ b/test/transaction/checkpoint_test.cpp @@ -3007,7 +3007,7 @@ TEST_F(FlakyCheckpointerTest, ConcurrentDropGraphDuringCommitKeepsCatalogsAlive) } ASSERT_TRUE(conn->query("CALL force_checkpoint_on_close=false;")->isSuccess()); ASSERT_TRUE(conn->query("CALL auto_checkpoint=false;")->isSuccess()); - ASSERT_TRUE(conn->query("CALL debug_enable_multi_writes=true;")->isSuccess()); + ASSERT_TRUE(conn->query("CALL enable_multi_writes=true;")->isSuccess()); main::Connection dropConn(database.get()); constexpr auto iterations = 100; for (auto i = 0; i < iterations; ++i) { @@ -3943,7 +3943,7 @@ TEST_F(FlakyCheckpointerTest, ConcurrentDropGraphDuringStagedInsertCommitFailsCl } ASSERT_TRUE(conn->query("CALL force_checkpoint_on_close=false;")->isSuccess()); ASSERT_TRUE(conn->query("CALL auto_checkpoint=false;")->isSuccess()); - ASSERT_TRUE(conn->query("CALL debug_enable_multi_writes=true;")->isSuccess()); + ASSERT_TRUE(conn->query("CALL enable_multi_writes=true;")->isSuccess()); main::Connection dropConn(database.get()); auto stageRelInsert = [&] { @@ -4966,7 +4966,7 @@ TEST_F(ReviewFixesTest, CheckpointDrainWaitsForInFlightWrite) { GTEST_SKIP(); } conn->query("CALL auto_checkpoint=false;"); - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); conn->query("CREATE NODE TABLE drain_test(id INT64 PRIMARY KEY);"); // Pre-load N committed rows so the table is non-trivial. @@ -7130,7 +7130,7 @@ TEST_F(ReviewFixesTest, DroppedGraphLivenessIdentityRemovedAtDrop) { TEST_F(ReviewFixesTest, RollbackSkipsDroppedGraphCatalogEntryUndo) { conn->query("CALL auto_checkpoint=false;"); conn->query("CALL force_checkpoint_on_close=false;"); - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); ASSERT_TRUE(conn->query("CREATE GRAPH live_graph;")->isSuccess()); ASSERT_TRUE(conn->query("CREATE GRAPH doomed_graph;")->isSuccess()); @@ -7171,7 +7171,7 @@ TEST_F(ReviewFixesTest, RollbackSkipsDroppedGraphCatalogEntryUndo) { TEST_F(ReviewFixesTest, RollbackSkipsDroppedGraphSequenceUndo) { conn->query("CALL auto_checkpoint=false;"); conn->query("CALL force_checkpoint_on_close=false;"); - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); ASSERT_TRUE(conn->query("CREATE GRAPH live_graph;")->isSuccess()); ASSERT_TRUE(conn->query("CREATE GRAPH doomed_graph;")->isSuccess()); ASSERT_TRUE(conn->query("USE GRAPH live_graph;")->isSuccess()); diff --git a/test/transaction/transaction_test.cpp b/test/transaction/transaction_test.cpp index 84a79dfcbd..bbaba407aa 100644 --- a/test/transaction/transaction_test.cpp +++ b/test/transaction/transaction_test.cpp @@ -205,7 +205,7 @@ TEST_F(EmptyDBTransactionTest, ConcurrentNodeInsertions) { if (systemConfig->checkpointThreshold == 0) { GTEST_SKIP(); } - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); // Disable auto-checkpoint so checkpoint overhead doesn't interfere with // concurrent write throughput measurements. Explicit CHECKPOINT at end. conn->query("CALL auto_checkpoint=false;"); @@ -238,7 +238,7 @@ TEST_F(EmptyDBTransactionTest, ConcurrentNodeInsertionsRecoverFromWAL) { if (inMemMode || systemConfig->checkpointThreshold == 0) { GTEST_SKIP(); } - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); conn->query("CALL auto_checkpoint=false;"); conn->query("CALL force_checkpoint_on_close=false;"); auto numThreads = 8; @@ -291,7 +291,7 @@ TEST_F(EmptyDBTransactionTest, ConcurrentNodeInsertionsMixedTypes) { if (systemConfig->checkpointThreshold == 0) { GTEST_SKIP(); } - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); auto numThreads = 4; auto numInsertsPerThread = 1000; conn->query("CREATE NODE TABLE mixed_test(id INT64 PRIMARY KEY, score DOUBLE, active BOOLEAN, " @@ -337,7 +337,7 @@ TEST_F(EmptyDBTransactionTest, ConcurrentRelationshipInsertions) { if (systemConfig->checkpointThreshold == 0) { GTEST_SKIP(); } - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); // Disable auto-checkpoint so checkpoint overhead doesn't interfere with // concurrent write throughput measurements. Explicit CHECKPOINT at end. conn->query("CALL auto_checkpoint=false;"); @@ -403,7 +403,7 @@ TEST_F(EmptyDBTransactionTest, ConcurrentComplexRelationshipInsertions) { if (systemConfig->checkpointThreshold == 0) { GTEST_SKIP(); } - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); auto numThreads = 3; auto numInsertsPerThread = 1500; auto numTotalInsertions = numThreads * numInsertsPerThread; @@ -463,7 +463,7 @@ TEST_F(EmptyDBTransactionTest, ConcurrentNodeUpdates) { if (systemConfig->checkpointThreshold == 0) { GTEST_SKIP(); } - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); // Disable auto-checkpoint so checkpoint overhead doesn't interfere with // concurrent write throughput measurements. Explicit CHECKPOINT at end. conn->query("CALL auto_checkpoint=false;"); @@ -527,7 +527,7 @@ TEST_F(EmptyDBTransactionTest, ConcurrentMixedTypeUpdates) { if (systemConfig->checkpointThreshold == 0) { GTEST_SKIP(); } - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); auto numThreads = 4; auto numUpdatesPerThread = 2500; auto numTotalNodes = numThreads * numUpdatesPerThread; @@ -604,7 +604,7 @@ TEST_F(EmptyDBTransactionTest, ConcurrentRelationshipUpdates) { if (systemConfig->checkpointThreshold == 0) { GTEST_SKIP(); } - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); // Disable auto-checkpoint so checkpoint overhead doesn't interfere with // concurrent write throughput measurements. Explicit CHECKPOINT at end. conn->query("CALL auto_checkpoint=false;"); @@ -685,7 +685,7 @@ TEST_F(EmptyDBTransactionTest, ConcurrentNodeUpdatesWithMixedTransactions) { if (systemConfig->checkpointThreshold == 0) { GTEST_SKIP(); } - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); auto numThreads = 4; auto numUpdatesPerThread = 100; auto numTotalNodes = numThreads * numUpdatesPerThread; @@ -757,7 +757,7 @@ TEST_F(EmptyDBTransactionTest, ConcurrentRelationshipUpdatesWithMixedTransaction if (systemConfig->checkpointThreshold == 0) { GTEST_SKIP(); } - conn->query("CALL debug_enable_multi_writes=true;"); + conn->query("CALL enable_multi_writes=true;"); auto numThreads = 4; auto numUpdatesPerThread = 1000; auto numTotalUpdates = numThreads * numUpdatesPerThread; diff --git a/tools/benchmark/node_write_bench.cpp b/tools/benchmark/node_write_bench.cpp index 67313dfd22..46f32743b6 100644 --- a/tools/benchmark/node_write_bench.cpp +++ b/tools/benchmark/node_write_bench.cpp @@ -100,7 +100,7 @@ static CaseResult runCase(const Config& benchConfig, uint64_t numThreads) { systemConfig.enableCompression = false; Database database(dbPath.string(), systemConfig); Connection setup(&database); - runQuery(setup, "CALL debug_enable_multi_writes=true;"); + runQuery(setup, "CALL enable_multi_writes=true;"); runQuery(setup, "CALL enable_default_hash_index=false;"); runQuery(setup, "CREATE NODE TABLE person(id INT64 PRIMARY KEY, name STRING);"); runQuery(setup, "CHECKPOINT;");