use LazyLock::force

risingwavelabs · Sep 8, 2023 · adc1a8d · adc1a8d
1 parent 3a39f98
commit adc1a8d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/connector/src/source/cdc/source/reader.rs b/src/connector/src/source/cdc/source/reader.rs
@@ -13,6 +13,7 @@
 // limitations under the License.
 
 use std::str::FromStr;
+use std::sync::LazyLock;
 
 use anyhow::{anyhow, Result};
 use async_trait::async_trait;
@@ -125,7 +126,7 @@ where
         let (tx, mut rx) = mpsc::channel(1024);
         let tx: Box<GetEventStreamJniSender> = Box::new(tx);
 
-        JVM.as_ref()?;
+        LazyLock::force(&JVM).as_ref()?;
 
         let get_event_stream_request = GetEventStreamRequest {
             source_id: self.source_id,