From afe8439095abadb8e559f3a644a46b3ef46f176c Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Tue, 22 Mar 2022 18:58:43 +0800
Subject: [PATCH] fix typo

---
 example/src/tstream.c                   | 4 +++-
 source/libs/executor/src/executorimpl.c | 2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/example/src/tstream.c b/example/src/tstream.c
index 73ab655fbd..a606024cf1 100644
--- a/example/src/tstream.c
+++ b/example/src/tstream.c
@@ -215,10 +215,12 @@ int main(int argc, char* argv[]) {
     printf("env init\n");
     code = init_env();
   }
-  create_topic();
+  create_stream();
+#if 0
   tmq_t*      tmq = build_consumer();
   tmq_list_t* topic_list = build_topic_list();
   /*perf_loop(tmq, topic_list);*/
   /*basic_consume_loop(tmq, topic_list);*/
   sync_consume_loop(tmq, topic_list);
+#endif
 }
diff --git a/source/libs/executor/src/executorimpl.c b/source/libs/executor/src/executorimpl.c
index befb210b80..0e3e76faf0 100644
--- a/source/libs/executor/src/executorimpl.c
+++ b/source/libs/executor/src/executorimpl.c
@@ -4873,7 +4873,7 @@ static SSDataBlock* doStreamBlockScan(SOperatorInfo *pOperator, bool* newgroup)
   SExecTaskInfo* pTaskInfo = pOperator->pTaskInfo;
   SStreamBlockScanInfo* pInfo = pOperator->info;
 
-  if (pInfo->blockType == STREAM_DATA_TYPE_SSDAT_BLOCK) {
+  if (pInfo->blockType == STREAM_DATA_TYPE_SSDATA_BLOCK) {
     if (pInfo->blockValid) {
       pInfo->blockValid = false;  // this block can only be used once.
       return pInfo->pRes;