diff --git a/tests/pytest/perfbenchmark/bug3589.py b/tests/pytest/perfbenchmark/bug3589.py
new file mode 100644
index 0000000000000000000000000000000000000000..c54ef8595d0bea1c4984b3f90e282f09659576c3
--- /dev/null
+++ b/tests/pytest/perfbenchmark/bug3589.py
@@ -0,0 +1,156 @@
+###################################################################
+#           Copyright (c) 2016 by TAOS Technologies, Inc.
+#                     All rights reserved.
+#
+#  This file is proprietary and confidential to TAOS Technologies.
+#  No part of this file may be reproduced, stored, transmitted,
+#  disclosed or used in any form or by any means other than as
+#  expressly provided by the written permission from Jianhui Tao
+#
+###################################################################
+
+# -*- coding: utf-8 -*-
+
+import sys
+import json
+
+from util.log import *
+from util.cases import *
+from util.sql import *
+from util.dnodes import *
+
+
+class TDTestCase:
+    def __init__(self):
+        self.path = ""
+
+    def init(self, conn, logSql):
+        tdLog.debug("start to execute %s" % __file__)
+        tdSql.init(conn.cursor(), logSql)
+
+    def getBuildPath(self):
+        selfPath = os.path.dirname(os.path.realpath(__file__))
+
+        if ("community" in selfPath):
+            projPath = selfPath[:selfPath.find("community")]
+        else:
+            projPath = selfPath[:selfPath.find("tests")]
+
+        for root, dirs, files in os.walk(projPath):
+            if ("taosd" in files):
+                rootRealPath = os.path.dirname(os.path.realpath(root))
+                if ("packaging" not in rootRealPath):
+                    buildPath = root[:len(root) - len("/debug/build/bin")]
+                    break
+        return buildPath
+
+    def getCfgDir(self):
+        return self.getBuildPath() + "/sim/psim/cfg"
+
+    def querycfg(self):
+        cfgdir = self.getCfgDir()
+        querycfg={
+            "filetype": "query",
+            "cfgdir": cfgdir,
+            "host": "127.0.0.1",
+            "port": 6030,
+            "user": "root",
+            "password": "taosdata",
+            "confirm_parameter_prompt": "yes",
+            "databases": "db",
+            "specified_table_query": {
+                "query_interval": 0,
+                "concurrent": 1,
+                "sqls": [
+                    {
+                        "sql": "select * from t10, t11 where t10.ts=t11.ts"
+                    }
+                ]
+            }
+        }
+
+        return querycfg
+
+    def querycfgfile(self):
+        querycfg = self.querycfg()
+        date = datetime.datetime.now().strftime("%Y%m%d%H%M")
+        querycfg.get("specified_table_query").get("sqls")[0]["result"] = f"/tmp/query_{date}.log"
+        file_query_table = f"/tmp/query_{date}.json"
+        with open(file_query_table, "w") as f:
+            json.dump(querycfg, f)
+
+        return [file_query_table, querycfg]
+
+    def querytable(self, filepath):
+        buildPath = self.getBuildPath()
+        if (buildPath == ""):
+            tdLog.exit("taosd not found!")
+        else:
+            tdLog.info(f"taosd found in {buildPath}")
+        binPath = buildPath + "/debug/build/bin/"
+
+        query_table_cmd = f"yes | {binPath}taosdemo -f {filepath}"
+        _ = subprocess.check_output(query_table_cmd, shell=True).decode("utf-8")
+
+    def checkqueryresult(self, expectrows):
+        querycfg = self.querycfgfile()[1]
+        result_file = querycfg.get("specified_table_query").get("sqls")[0].get("result") + "-0"
+        if result_file:
+            check_cmd = f"wc -l {result_file}"
+            check_data_init = subprocess.check_output(check_cmd, shell=True).decode("utf-8")
+            check_data = int(check_data_init[0])
+            if check_data == expectrows:
+                tdLog.info(f"queryResultRows:{check_data} == expect:{expectrows}")
+            else:
+                caller = inspect.getframeinfo(inspect.stack()[1][0])
+                args = (caller.filename, caller.lineno, check_data, expectrows)
+                tdLog.exit(f"{args[0]}({args[1]}) failed: result:{args[2]} != expect:{args[3]}")
+
+    def droptmpfile(self):
+        drop_file_cmd = "rm -f /tmp/query_* "
+        _ = subprocess.check_output(drop_file_cmd, shell=True).decode("utf-8")
+        drop_file_cmd = "rm -f querySystemInfo-*"
+        _ = subprocess.check_output(drop_file_cmd, shell=True).decode("utf-8")
+
+    def run(self):
+        tdSql.prepare()
+
+        tdLog.printNoPrefix("==========step1:create table && insert data")
+        tdSql.execute("alter database db keep 36500")
+        tdSql.execute(
+            "create table stb1 (ts timestamp, c1 int) TAGS(t1 int)"
+        )
+        tdSql.execute("create table t10 using stb1 tags(1)")
+        tdSql.execute("create table t11 using stb1 tags(2)")
+
+        tdSql.execute("insert into t10 values (-865000000, 1)")
+        tdSql.execute("insert into t11 values (-865000000, 2)")
+        tdSql.execute("insert into t10 values ('1969-12-31 23:59:59.000', 2)")
+        tdSql.execute("insert into t11 values ('1969-12-31 23:59:59.000', 3)")
+        tdSql.execute("insert into t10 values ('1970-01-01 00:00:00.000', 3)")
+        tdSql.execute("insert into t11 values ('1970-01-01 00:00:00.000', 4)")
+        tdSql.execute("insert into t10 values (-15230000, 4)")
+        tdSql.execute("insert into t11 values (-15230000, 5)")
+        tdSql.execute("insert into t10 values (-15220000, 5)")
+        tdSql.execute("insert into t11 values (-15220000, 6)")
+        tdSql.execute("insert into t10 values (-15210000, 6)")
+        tdSql.execute("insert into t11 values (-15210000, 7)")
+        tdSql.execute("insert into t10 values (0, 7)")
+        tdSql.execute("insert into t11 values (0, 8)")
+        tdSql.execute("insert into t10 values ('2020-10-01 00:00:00.000', 8)")
+        tdSql.execute("insert into t11 values ('2020-10-01 00:00:00.000', 9)")
+
+        tdLog.printNoPrefix("==========step2:query")
+        query_file = self.querycfgfile()[0]
+        self.querytable(query_file)
+        self.checkqueryresult(8)
+
+        self.droptmpfile()
+
+    def stop(self):
+        tdSql.close()
+        tdLog.success("%s successfully executed" % __file__)
+
+
+tdCases.addWindows(__file__, TDTestCase())
+tdCases.addLinux(__file__, TDTestCase())
\ No newline at end of file