diff --git a/lib/rocksdb/env_spdk.cc b/lib/rocksdb/env_spdk.cc index 095fa37d7..e631742ad 100644 --- a/lib/rocksdb/env_spdk.cc +++ b/lib/rocksdb/env_spdk.cc @@ -643,6 +643,9 @@ void SpdkInitializeThread(void) struct spdk_thread *thread; if (g_fs != NULL) { + if (g_sync_args.channel) { + spdk_fs_free_thread_ctx(g_sync_args.channel); + } thread = spdk_thread_create("spdk_rocksdb", NULL); spdk_set_thread(thread); g_sync_args.channel = spdk_fs_alloc_thread_ctx(g_fs);