diff --git a/kyuubi-common/src/test/scala/org/apache/kyuubi/operation/NoopOperationManager.scala b/kyuubi-common/src/test/scala/org/apache/kyuubi/operation/NoopOperationManager.scala
index 961ecf7ca..010440336 100644
--- a/kyuubi-common/src/test/scala/org/apache/kyuubi/operation/NoopOperationManager.scala
+++ b/kyuubi-common/src/test/scala/org/apache/kyuubi/operation/NoopOperationManager.scala
@@ -17,11 +17,13 @@
 
 package org.apache.kyuubi.operation
 
-import org.apache.hive.service.rpc.thrift.TRowSet
+import java.nio.ByteBuffer
+import java.util
+
+import org.apache.hive.service.rpc.thrift.{TColumn, TRow, TRowSet, TStringColumn}
 
 import org.apache.kyuubi.operation.FetchOrientation.FetchOrientation
 import org.apache.kyuubi.session.Session
-import org.apache.kyuubi.util.ThriftUtils
 
 class NoopOperationManager extends OperationManager("noop") {
   private val invalid = "invalid"
@@ -91,5 +93,12 @@ class NoopOperationManager extends OperationManager("noop") {
   override def getOperationLogRowSet(
       opHandle: OperationHandle,
       order: FetchOrientation,
-      maxRows: Int): TRowSet = ThriftUtils.EMPTY_ROW_SET
+      maxRows: Int): TRowSet = {
+    val logs = new util.ArrayList[String]()
+    logs.add("test")
+    val tColumn = TColumn.stringVal(new TStringColumn(logs, ByteBuffer.allocate(0)))
+    val tRow = new TRowSet(0, new util.ArrayList[TRow](logs.size()))
+    tRow.addToColumns(tColumn)
+    tRow
+  }
 }
diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/OperationsResource.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/OperationsResource.scala
index f3a5c4ca1..66c294384 100644
--- a/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/OperationsResource.scala
+++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/OperationsResource.scala
@@ -30,7 +30,7 @@ import org.apache.hive.service.rpc.thrift.TTypeQualifierValue
 
 import org.apache.kyuubi.KyuubiSQLException
 import org.apache.kyuubi.events.KyuubiOperationEvent
-import org.apache.kyuubi.operation.KyuubiOperation
+import org.apache.kyuubi.operation.{FetchOrientation, KyuubiOperation}
 import org.apache.kyuubi.operation.OperationHandle.parseOperationHandle
 import org.apache.kyuubi.server.api.ApiRequestContext
 
@@ -121,4 +121,29 @@ private[v1] class OperationsResource extends ApiRequestContext {
           s"Error getting result set metadata for operation handle $operationHandleStr")
     }
   }
+
+  @ApiResponse(
+    responseCode = "200",
+    content = Array(new Content(
+      mediaType = MediaType.APPLICATION_JSON)),
+    description =
+      "get operation log")
+  @GET
+  @Path("{operationHandle}/log")
+  def getOperationLog(
+      @PathParam("operationHandle") operationHandleStr: String,
+      @QueryParam("maxrows") maxRows: Int): OperationLog = {
+    try {
+      val rowSet = backendService.sessionManager.operationManager.getOperationLogRowSet(
+        parseOperationHandle(operationHandleStr),
+        FetchOrientation.FETCH_NEXT,
+        maxRows)
+      val logRowSet = rowSet.getColumns.get(0).getStringVal.getValues.asScala
+      OperationLog(logRowSet, logRowSet.size)
+    } catch {
+      case NonFatal(_) =>
+        throw new NotFoundException(
+          s"Error getting operation log for operation handle $operationHandleStr")
+    }
+  }
 }
diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/dto.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/dto.scala
index 59179064c..ae3bf9037 100644
--- a/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/dto.scala
+++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/dto.scala
@@ -79,3 +79,5 @@ case class ColumnDesc(
     precision: Int,
     scale: Int,
     comment: String)
+
+case class OperationLog(logRowSet: Seq[String], rowCount: Int)
diff --git a/kyuubi-server/src/test/scala/org/apache/kyuubi/server/api/v1/OperationsResourceSuite.scala b/kyuubi-server/src/test/scala/org/apache/kyuubi/server/api/v1/OperationsResourceSuite.scala
index b0bca332f..7dbaf9a3c 100644
--- a/kyuubi-server/src/test/scala/org/apache/kyuubi/server/api/v1/OperationsResourceSuite.scala
+++ b/kyuubi-server/src/test/scala/org/apache/kyuubi/server/api/v1/OperationsResourceSuite.scala
@@ -92,6 +92,20 @@ class OperationsResourceSuite extends KyuubiFunSuite with RestFrontendTestHelper
     }
   }
 
+  test("test get operation log") {
+    withKyuubiRestServer { (fe, _, _, webTarget: WebTarget) =>
+      val opHandleStr = getOpHandleStr(fe, OperationType.EXECUTE_STATEMENT)
+      val response = webTarget.path(
+        s"api/v1/operations/$opHandleStr/log")
+        .queryParam("maxrows", "10")
+        .request(MediaType.APPLICATION_JSON).get()
+      assert(200 == response.getStatus)
+      val logRowSet = response.readEntity(classOf[OperationLog])
+      assert(logRowSet.logRowSet.head.equals("test"))
+      assert(logRowSet.rowCount == 1)
+    }
+  }
+
   def getOpHandleStr(fe: KyuubiRestFrontendService, typ: OperationType): String = {
     val sessionManager = fe.be.sessionManager
     val sessionHandle = sessionManager.openSession(