From 744a942ae98d007b41cc1b08a6c8b4feec8eb986 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 28 Feb 2023 19:03:15 +0800 Subject: [PATCH] fix(query): remove the invalid null check. --- source/libs/executor/src/dataSinkMgt.c | 6 ------ 1 file changed, 6 deletions(-) diff --git a/source/libs/executor/src/dataSinkMgt.c b/source/libs/executor/src/dataSinkMgt.c index cc09efdf83..7fbde07f59 100644 --- a/source/libs/executor/src/dataSinkMgt.c +++ b/source/libs/executor/src/dataSinkMgt.c @@ -38,15 +38,9 @@ int32_t dsCreateDataSinker(const SDataSinkNode* pDataSink, DataSinkHandle* pHand case QUERY_NODE_PHYSICAL_PLAN_DISPATCH: return createDataDispatcher(&gDataSinkManager, pDataSink, pHandle); case QUERY_NODE_PHYSICAL_PLAN_DELETE: { - if (pParam == NULL) { - return TSDB_CODE_QRY_INVALID_INPUT; - } return createDataDeleter(&gDataSinkManager, pDataSink, pHandle, pParam); } case QUERY_NODE_PHYSICAL_PLAN_QUERY_INSERT: { - if (pParam == NULL) { - return TSDB_CODE_QRY_INVALID_INPUT; - } return createDataInserter(&gDataSinkManager, pDataSink, pHandle, pParam); } } -- GitLab