Admin index

107122

account

signin

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"by": "email", "email": "chenxiaoyu@databend.com"}

2026-04-12 03:29:52

107121

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE OR REPLACE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.internal.databend.dev';\n\nselect dev_add(10,20);\n\nCREATE OR REPLACE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.internal.databend.dev';\n\nselect stable_add(10,20);"}

2026-04-11 08:23:55

107120

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE OR REPLACE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.internal.databend.dev';\n\nselect dev_add(10,20);\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.internal.databend.dev';\n\nselect stable_add(10,20);"}

2026-04-11 08:23:39

107119

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE OR REP FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.internal.databend.dev';\n\nselect dev_add(10,20);\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.internal.databend.dev';\n\nselect stable_add(10,20);"}

2026-04-11 08:23:38

107118

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.internal.databend.dev';\n\nselect dev_add(10,20);\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.internal.databend.dev';\n\nselect stable_add(10,20);"}

2026-04-11 08:23:23

107117

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.internal.databend.dev';\n\nselect dev_add(10,20);\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.internal.databend.dev';\n\nselect stable_add(10,20);"}

2026-04-11 08:23:21

107116

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.internal.databend.dev';\n\nselect dev_add(10,20);\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.databend.dev';\n\nselect stable_add(10,20);"}

2026-04-11 08:23:17

107115

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nselect dev_add(10,20);\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.databend.dev';\n\nselect stable_add(10,20);"}

2026-04-11 02:58:45

107114

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nselect dev_add(10,20);\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.databend.dev';\n\n\nselect stable_add(10,20);"}

2026-04-11 02:58:44

107113

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.databend.dev';\n\n\nselect stable_add(10,20);"}

2026-04-11 02:58:42

107112

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.databend.dev';\n\nselect dev_add(10,20);\nselect stable_add(10,20);"}

2026-04-11 02:58:28

107111

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.databend.dev';\n\nselect dev_add(10,20);\nselect dev_add(10,20);"}

2026-04-11 02:58:25

107110

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.databend.dev';\n\nselect dev_add(10,20);"}

2026-04-11 02:58:20

107109

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nCREATE FUNCTION stable_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.databend.dev';\n\nselect my_add(10,20);"}

2026-04-11 02:58:17

107108

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://smallfish-hello-udf.databend.dev';\n\nselect my_add(10,20);"}

2026-04-11 02:58:13

107107

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nselect my_add(10,20);"}

2026-04-11 02:58:08

107106

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION dev_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nselect my_add(10,20);"}

2026-04-11 02:58:03

107105

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nselect my_add(10,20);"}

2026-04-11 02:57:59

107104

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'https://dev-smallfish-hello-udf.databend.dev';\n\nselect my_add(10,20);"}

2026-04-11 02:57:54

107103

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'https://hello-udf.databend.dev';\n\nselect my_add(10,20);"}

2026-04-10 11:39:07

107102

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'https://hello-udf.databend.dev';\n\nselect my_add(10,20)"}

2026-04-10 11:39:06

107101

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'https://hello-udf.databend.dev';\n\n"}

2026-04-10 11:38:58

107100

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'https://hello-udf.databend.dev';\n\n\nCREATE FUNCTION gcd (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';\n"}

2026-04-10 11:38:51

107099

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish.svc.cluster.local:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'https://hello-udf.databend.dev';\n\n\nCREATE FUNCTION gcd (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';\n"}

2026-04-10 11:38:49

107098

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish.svc.cluster.local:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish.svc.cluster.local:8088';\n\n\nCREATE FUNCTION gcd (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';\n"}

2026-04-10 11:12:12

107097

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish.svc.cluster.local:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish.svc.cluster.local';\n\n\nCREATE FUNCTION gcd (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';\n"}

2026-04-10 11:09:13

107096

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish.svc.cluster.local:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish.svc.cluster.local:8088';\n\n\nCREATE FUNCTION gcd (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';\n"}

2026-04-10 11:01:46

107095

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish.svc.cluster.local:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION gcd (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';\n"}

2026-04-10 11:01:43

107094

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION gcd (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';\n"}

2026-04-10 10:57:28

107093

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish:8088';\n\n\nCREATE FUNCTION gcd AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';\n"}

2026-04-10 10:56:37

107092

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish:8088';"}

2026-04-10 10:56:33

107091

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish:8088';"}

2026-04-10 10:53:58

107090

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish:8088';"}

2026-04-10 10:52:51

107089

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://udf.datafusecloud.com';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish:8088';"}

2026-04-10 10:52:49

107088

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'https://udf.datafusecloud.com';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish:8088';"}

2026-04-10 10:52:36

107087

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://udf.datafusecloud.com';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish:8088';"}

2026-04-10 10:52:35

107086

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'grpc://hello-udf.udf-smallfish:8088';"}

2026-04-10 10:49:22

107085

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish:8088';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish:8088';"}

2026-04-10 10:49:18

107084

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://hello-udf.udf-smallfish:8088';"}

2026-04-10 10:49:07

107083

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'httphello-udf.udf-smallfish:8088';"}

2026-04-10 10:49:05

107082

account

signin

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"by": "email", "email": "chenxiaoyu@databend.com"}

2026-04-10 10:40:14

107081

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:37:03

107080

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION gcd AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:36:59

107079

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION gcd AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:36:54

107078

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION gcd AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:36:40

107077

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION gcd AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:36:38

107076

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:36:15

107075

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:36:12

107074

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) RETURNS INT LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:36:09

107073

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:36:07

107072

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:35:03

107071

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE OR REPLACE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:34:59

107070

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE OR REPLACE FUNCTION my_add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://[::]:8088';"}

2026-04-10 10:34:51

107069

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';\n\nCREATE OR REPLACE FUNCTION add (INT, INT) RETURNS INT LANGUAGE python HANDLER = 'add' ADDRESS = 'http://[::]:8088';"}

2026-04-10 10:34:48

107068

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION my_add AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:32:53

107067

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION gcd AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'add' \n ADDRESS = 'hello-udf.udf-smallfish:8088';"}

2026-04-10 10:32:51

107066

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\nCREATE FUNCTION gcd AS (INT, INT) \n RETURNS INT \n LANGUAGE python \n HANDLER = 'gcd' \n ADDRESS = 'http://localhost:8815';"}

2026-04-10 10:32:35

107065

worksheet

update

2400:56a0:2c2:5ce0:1fba:a43b:b009:b3af

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;\n\n"}

2026-04-10 10:32:28

107064

account

signin

10.1.160.61

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"by": "email", "email": "zhangsenquan@datafuselabs.com"}

2026-04-10 09:50:58

107063

account

signout

10.1.160.61

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"email": "zhangsenquan@datafuselabs.com", "state": "activated"}

2026-04-10 09:50:50

107062

worksheet

update

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "select 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(100000000000) group by all;\n\nCOPY INTO sxt_dws_report_assets\nFROM (\n SELECT $1:job_run_id::STRING AS job_run_id,\n $1:biz_date::STRING AS biz_date,\n $1:archive_uri::STRING AS archive_uri,\n $1:archive_download_url::STRING AS archive_download_url,\n $1:analysis_xlsx_path::STRING AS analysis_xlsx_path,\n $1:analysis_summary_path::STRING AS analysis_summary_path,\n $1:attribution_xlsx_path::STRING AS attribution_xlsx_path,\n $1:report_summary_xlsx_path::STRING AS report_summary_xlsx_path,\n $1:report_markdown_path::STRING AS report_markdown_path,\n $1:report_pptx_path::STRING AS report_pptx_path,\n $1:created_at::TIMESTAMP AS created_at\n FROM 's3://databend-dataload/databend-load/2026-0334-07T13-16-12-904Z/report_assets/' CONNECTION=(\n access_key_id = 'sssddxxx333xx3333xxx',\n enable_virtual_host_style='true',\n endpoint_url='https://s3.oss-cn-hangzhou.aliyuncs.com',\n region='cn-xxxxxx',\n secret_access_key = 'xxddddxxdfdfdxxxxx'\n )\n ) PATTERN='.*[.]ndjson' FILE_FORMAT=(type=NDJSON) PURGE=false FORCE=false DISABLE_VARIANT_CHECK=false ON_ERROR=abort RETURN_FAILED_ONLY=false;"}

2026-04-10 06:48:13

107061

worksheet

update

10.1.160.61

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "selec 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(100000000000) group by all;\n\nCOPY INTO sxt_dws_report_assets\nFROM (\n SELECT $1:job_run_id::STRING AS job_run_id,\n $1:biz_date::STRING AS biz_date,\n $1:archive_uri::STRING AS archive_uri,\n $1:archive_download_url::STRING AS archive_download_url,\n $1:analysis_xlsx_path::STRING AS analysis_xlsx_path,\n $1:analysis_summary_path::STRING AS analysis_summary_path,\n $1:attribution_xlsx_path::STRING AS attribution_xlsx_path,\n $1:report_summary_xlsx_path::STRING AS report_summary_xlsx_path,\n $1:report_markdown_path::STRING AS report_markdown_path,\n $1:report_pptx_path::STRING AS report_pptx_path,\n $1:created_at::TIMESTAMP AS created_at\n FROM 's3://databend-dataload/databend-load/2026-0334-07T13-16-12-904Z/report_assets/' CONNECTION=(\n access_key_id = 'sssddxxx333xx3333xxx',\n enable_virtual_host_style='true',\n endpoint_url='https://s3.oss-cn-hangzhou.aliyuncs.com',\n region='cn-xxxxxx',\n secret_access_key = 'xxddddxxdfdfdxxxxx'\n )\n ) PATTERN='.*[.]ndjson' FILE_FORMAT=(type=NDJSON) PURGE=false FORCE=false DISABLE_VARIANT_CHECK=false ON_ERROR=abort RETURN_FAILED_ONLY=false;"}

2026-04-10 06:44:30

107060

worksheet

update

10.1.160.61

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2954, "title": "2026-03-18 02:48:59", "queryText": "\nSELECT 1;\n\nSELECT (number % 3)::STRING,\n number % 4,\n number % 100,\n sum(number)\nFROM numbers (100000000000)\nGROUP BY ALL;\nSELECT 2"}

2026-04-10 06:34:22

107059

org_member

permission

188.253.126.212

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"updated": "{\"EXPORT\":1}", "member_id": 32, "permission": "EXPORT"}

2026-04-10 06:19:00

107058

account

signin

10.1.160.61

Chuan Peng (pengchuan@datafuselabs.com)

{"by": "email", "email": "pengchuan@datafuselabs.com"}

2026-04-10 02:41:29

107057

account

signin

188.253.126.212

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"by": "email", "email": "zhangsenquan@datafuselabs.com"}

2026-04-09 13:30:37

107056

org_member

delete

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"role": "account_admin", "email": "17324384169@1633.com", "state": "invited"}

2026-04-09 08:43:27

107055

org_member

invite

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"role": "account_admin", "email": "17324384169@1633.com"}

2026-04-09 08:43:21

107054

worksheet

update

2400:56a0:2c1:a1d3:b458:aad8:beaf:8299

smallfish (chenxiaoyu@databend.com)

{"id": 2526, "title": "2025-08-27 12:55:21", "queryText": "CREATE OR REPLACE TASK task_111\n WAREHOUSE='system' \n SCHEDULE = USING CRON '0 0 * * * *' 'UTC'\nAS SELECT 111;\n\nCREATE STREAM databend_books_changes2 ON TABLE databend_books;\n\nCREATE OR REPLACE TASK task_222\n WAREHOUSE='system' \n SCHEDULE = USING CRON '1 0 * * * *' 'UTC'\nAS SELECT 222;\n\nCREATE OR REPLACE TASK task_333\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 333;\n\nCREATE OR REPLACE TASK task_4444\n WAREHOUSE='system' \n AFTER 'task_111'\nAS SELECT 4444;\n\nCREATE OR \nREPLACE TASK task_444 WAREHOUSE='system' AFTER 'task_333' AS\nSELECT 333;\n\nSHOW TASKS;\n\n\nALTER TASK task_444 SET WAREHOUSE='bohu-small';\nDESC TASK task_444;\nDROP TASK task_444;\n\ndrop task __taskflow_localtest___2_t3_ListTaskFlowVersions;\n\nDROP TASK __taskflow_1_22;\nDROP TASK task_111;\nDROP TASK __taskflow_3_11;\nDROP TASK smallfish_test1;\n\nALTER TASK task_444 SUSPEND;\nALTER TASK test_numbers SUSPEND;\n\nCREATE TABLE orders (\n order_id INT,\n product_name VARCHAR,\n quantity INT,\n order_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n);\n\nselect1 aa from xx.db;\n\nCREATE STREAM order_changes ON TABLE orders;\n\nSHOW FULL STREAMS;\n\nselect *, '啊啊啊' as t from test_book;\n\nshow CONNECTIONS;\nshow STAGES;\n\ndesc stage bohu_20231;\n\nshow ROLES;\n\n\n\nCREATE TABLE IF NOT EXISTS `default`.`test_book` (\n `Index` VARCHAR NULL DEFAULT 'aaa',\n `CustomerId` VARCHAR NULL DEFAULT 'bbb',\n `FirstName` VARCHAR NULL DEFAULT '',\n `LastName` VARCHAR NULL DEFAULT '',\n `Company` VARCHAR NULL DEFAULT '',\n `City` VARCHAR NULL DEFAULT '',\n `Country` VARCHAR NULL DEFAULT '',\n `Phone1` VARCHAR NULL DEFAULT '',\n `Phone2` VARCHAR NULL DEFAULT '',\n `Email` VARCHAR NULL DEFAULT '',\n `SubscriptionDate` VARCHAR NULL DEFAULT '',\n `Website` VARCHAR NULL DEFAULT ''\n);\n\nCOPY INTO `default`.`test_book` (`Index`,`CustomerId`,`FirstName`,`LastName`,`Company`,`City`,`Country`,`Phone1`,`Phone2`,`Email`,`SubscriptionDate`,`Website`)\n FROM 's3://smallfish-bk/testdata/book1.csv'\n CONNECTION = (\n ACCESS_KEY_ID = 'AKIA53WT5ZIAJNFRSA57'\n SECRET_ACCESS_KEY = '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'\n )\n FILE_FORMAT = ( TYPE = CSV, FIELD_DELIMITER = ',', RECORD_DELIMITER = '\\n', SKIP_HEADER = 1 );\n\n\nSELECT count(*) FROM `default`.`tttt1` ;\nSELECT *,*,*,*,*,*,* FROM `default`.`tttt1` limit 20;\n\n BEGIN;\n select 11111;\n select 22222;\n COMMIT;\n\n BEGIN; select 3333; select 444; COMMIT;\n\n\nshow SETTINGS like '%result%';\n\nshow tables1 like '%csv%';\n\nSELECT * FROM TASK_HISTORY();\n\nSHOW ROLES;\nSHOW USERS;\nSHOW GRANTS;\n\nSHOW GRANTS FOR USER 'chenxiaoyu@databend.com';\nSHOW GRANTS FOR ROLE 'aaa_test_role1';\nSHOW GRANTS OF ROLE account_admin;\nSHOW GRANTS ON DATABASE default;\n\nSHOW WAREHOUSES;\n\n-- ALTER WAREHOUSE <warehouse_name> SET TAG <tag_name> = '<tag_value>' [ , <tag_name> = '<tag_value>' ... ]\n\nALTER WAREHOUSE 'default' SET TAG 'owner'='smallfish1';\n\nALTER WAREHOUSE 'default' SET TAG 'k1'='aa';\nALTER WAREHOUSE 'default' UNSET TAG 'env';\n\n\nSELECT 'aa' AS a, 'bb' AS b, now() AS now;"}

2026-04-09 08:27:18

107053

worksheet

update

154.64.227.33

cloud (hanshanjie@datafuselabs.com)

{"id": 2957, "title": "2026-04-09 02:26:46", "queryText": "show tables;\n\nselect count(1) from default.cdc_test_orders;\n\n\nselect * from cdc_test_orders where id = 10001;\n\n\ndrop table cdc_test_orders;"}

2026-04-09 07:56:44

107052

dataintegration_task

update

cloud (hanshanjie@datafuselabs.com)

{"Operate": "Start", "TaskIDs": [102]}

2026-04-09 07:56:14

107051

dataintegration_task

update

cloud (hanshanjie@datafuselabs.com)

{"Operate": "Stop", "TaskIDs": [102]}

2026-04-09 07:56:04

107050

worksheet

update

154.64.227.33

cloud (hanshanjie@datafuselabs.com)

{"id": 2957, "title": "2026-04-09 02:26:46", "queryText": "show tables;\n\nselect count(1) from default.cdc_test_orders;\n\n\nselect * from cdc_test_orders where id = 10001;\ndrop table cdc_test_orders;"}

2026-04-09 07:50:22

107049

worksheet

update

154.64.227.33

cloud (hanshanjie@datafuselabs.com)

{"id": 2957, "title": "2026-04-09 02:26:46", "queryText": "show tables;\n\nselect count(1) from default.cdc_test_orders;\n\n\nselect * from cdc_test_orders where id = \ndrop table cdc_test_orders;"}

2026-04-09 07:50:18

107048

worksheet

update

154.64.227.33

cloud (hanshanjie@datafuselabs.com)

{"id": 2957, "title": "2026-04-09 02:26:46", "queryText": "show tables;\n\nselect count(1) from default.cdc_test_orders;\n\n\nselect * from cdc_test\ndrop table cdc_test_orders;"}

2026-04-09 07:50:14

107047

worksheet

update

154.64.227.33

cloud (hanshanjie@datafuselabs.com)

{"id": 2957, "title": "2026-04-09 02:26:46", "queryText": "show tables;\n\nselect count(1) from default.cdc_test_orders;\n\n\nselect * from \ndrop table cdc_test_orders;"}

2026-04-09 07:50:11

107046

dataintegration_task

update

cloud (hanshanjie@datafuselabs.com)

{"Operate": "Start", "TaskIDs": [102]}

2026-04-09 07:47:58

107045

dataintegration_task

create

cloud (hanshanjie@datafuselabs.com)

{"ID": 102, "Desc": "{\"id\":102,\"org_id\":1,\"account_id\":31,\"name\":\"test-sjh-pg2\",\"datasource_id\":46,\"provider_id\":0,\"service_id\":3,\"service_args\":\"{\\\"syncMode\\\":3,\\\"includeTables\\\":[\\\"public.cdc_test_orders\\\"],\\\"conflictKey\\\":\\\"id\\\",\\\"allowDelete\\\":true,\\\"mergeIntervalSeconds\\\":10,\\\"batchSize\\\":1000}\",\"warehouse\":\"default\",\"database\":\"default\",\"table_name\":\"cdc_test_orders\",\"table_fields\":\"[]\",\"continuous_ingestion\":1,\"status\":1,\"updated_account_id\":0,\"created_at\":\"2026-04-09T07:47:52.347952057Z\",\"updated_at\":\"2026-04-09T07:47:52.347952057Z\",\"deleted_at\":null}", "Name": "test-sjh-pg2", "Database": "default", "TableName": "cdc_test_orders", "Warehouse": "default", "DatasourceID": 46}

2026-04-09 07:47:52

107044

worksheet

update

154.64.227.33

cloud (hanshanjie@datafuselabs.com)

{"id": 2957, "title": "2026-04-09 02:26:46", "queryText": "show tables;\n\nselect count(1) from default.cdc_test_orders;\n\n\ndrop table cdc_test_orders;"}

2026-04-09 07:47:17

107043

dataintegration_task

delete

cloud (hanshanjie@datafuselabs.com)

{"Operate": "Drop", "TaskIDs": [101]}

2026-04-09 07:47:07

107042

account

signin

154.64.227.33

cloud (hanshanjie@datafuselabs.com)

{"by": "email", "email": "hanshanjie@datafuselabs.com"}

2026-04-09 07:46:05

107041

worksheet

update

154.64.227.33

cloud (hanshanjie@datafuselabs.com)

{"id": 2957, "title": "2026-04-09 02:26:46", "queryText": "show tables;\n\nselect count(1) from default.cdc_test_orders;"}

2026-04-09 07:45:02

107040

worksheet

update

154.64.227.33

cloud (hanshanjie@datafuselabs.com)

{"id": 2957, "title": "2026-04-09 02:26:46", "queryText": "show tables;\n\nselect count() from default.cdc_test_orders;"}

2026-04-09 07:45:01

107039

dataintegration_task

update

cloud (hanshanjie@datafuselabs.com)

{"Operate": "Start", "TaskIDs": [101]}

2026-04-09 07:44:07

107038

dataintegration_task

create

cloud (hanshanjie@datafuselabs.com)

{"ID": 101, "Desc": "{\"id\":101,\"org_id\":1,\"account_id\":31,\"name\":\"test-sjh-pg1\",\"datasource_id\":46,\"provider_id\":0,\"service_id\":3,\"service_args\":\"{\\\"syncMode\\\":1,\\\"includeTables\\\":[\\\"public.cdc_test_orders\\\"],\\\"conflictKey\\\":\\\"id\\\",\\\"mergeIntervalSeconds\\\":10,\\\"batchSize\\\":1000,\\\"snapshotWhereCondition\\\":\\\"id \\\\u003e 0\\\"}\",\"warehouse\":\"default\",\"database\":\"default\",\"table_name\":\"cdc_test_orders\",\"table_fields\":\"[]\",\"continuous_ingestion\":0,\"status\":1,\"updated_account_id\":0,\"created_at\":\"2026-04-09T07:44:03.528302891Z\",\"updated_at\":\"2026-04-09T07:44:03.528302891Z\",\"deleted_at\":null}", "Name": "test-sjh-pg1", "Database": "default", "TableName": "cdc_test_orders", "Warehouse": "default", "DatasourceID": 46}

2026-04-09 07:44:04

107037

dataintegration_task

delete

cloud (hanshanjie@datafuselabs.com)

{"Operate": "Drop", "TaskIDs": [100]}

2026-04-09 07:43:30

107036

account

signin

154.64.227.33

cloud (hanshanjie@datafuselabs.com)

{"by": "email", "email": "hanshanjie@datafuselabs.com"}

2026-04-09 07:43:15

107035

account

signin

2a05:f480:1000:49:5400:5ff:fe9c:34a7

Chuan Peng (pengchuan@datafuselabs.com)

{"by": "email", "email": "pengchuan@datafuselabs.com"}

2026-04-09 07:22:03

107034

worksheet

update

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "select 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(100000000000) group by all;\n\nCOPY INTO sxt_dws_report_assets\nFROM (\n SELECT $1:job_run_id::STRING AS job_run_id,\n $1:biz_date::STRING AS biz_date,\n $1:archive_uri::STRING AS archive_uri,\n $1:archive_download_url::STRING AS archive_download_url,\n $1:analysis_xlsx_path::STRING AS analysis_xlsx_path,\n $1:analysis_summary_path::STRING AS analysis_summary_path,\n $1:attribution_xlsx_path::STRING AS attribution_xlsx_path,\n $1:report_summary_xlsx_path::STRING AS report_summary_xlsx_path,\n $1:report_markdown_path::STRING AS report_markdown_path,\n $1:report_pptx_path::STRING AS report_pptx_path,\n $1:created_at::TIMESTAMP AS created_at\n FROM 's3://databend-dataload/databend-load/2026-0334-07T13-16-12-904Z/report_assets/' CONNECTION=(\n access_key_id = 'sssddxxx333xx3333xxx',\n enable_virtual_host_style='true',\n endpoint_url='https://s3.oss-cn-hangzhou.aliyuncs.com',\n region='cn-xxxxxx',\n secret_access_key = 'xxddddxxdfdfdxxxxx'\n )\n ) PATTERN='.*[.]ndjson' FILE_FORMAT=(type=NDJSON) PURGE=false FORCE=false DISABLE_VARIANT_CHECK=false ON_ERROR=abort RETURN_FAILED_ONLY=false;"}

2026-04-09 06:24:38

107033

worksheet

update

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "select 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(100000000000) group by all;\n\nCOPY INTO sxt_dws_report_assets\nFROM (\n SELECT $1:job_run_id::STRING AS job_run_id,\n $1:biz_date::STRING AS biz_date,\n $1:archive_uri::STRING AS archive_uri,\n $1:archive_download_url::STRING AS archive_download_url,\n $1:analysis_xlsx_path::STRING AS analysis_xlsx_path,\n $1:analysis_summary_path::STRING AS analysis_summary_path,\n $1:attribution_xlsx_path::STRING AS attribution_xlsx_path,\n $1:report_summary_xlsx_path::STRING AS report_summary_xlsx_path,\n $1:report_markdown_path::STRING AS report_markdown_path,\n $1:report_pptx_path::STRING AS report_pptx_path,\n $1:created_at::TIMESTAMP AS created_at\n FROM 's3://databend-dataload/databend-load/2026-0334-07T13-16-12-904Z/report_assets/' CONNECTION=(\n access_key_id = 'sssddxxxxxxxx',\n enable_virtual_host_style='true',\n endpoint_url='https://s3.oss-cn-hangzhou.aliyuncs.com',\n region='cn-xxxxxx',\n secret_access_key = 'xxxxxxxxx'\n )\n ) PATTERN='.*[.]ndjson' FILE_FORMAT=(type=NDJSON) PURGE=false FORCE=false DISABLE_VARIANT_CHECK=false ON_ERROR=abort RETURN_FAILED_ONLY=false;"}

2026-04-09 06:24:34

107032

worksheet

update

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "select 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(100000000000) group by all;\n\nCOPY INTO sxt_dws_report_assets\nFROM (\n SELECT $1:job_run_id::STRING AS job_run_id,\n $1:biz_date::STRING AS biz_date,\n $1:archive_uri::STRING AS archive_uri,\n $1:archive_download_url::STRING AS archive_download_url,\n $1:analysis_xlsx_path::STRING AS analysis_xlsx_path,\n $1:analysis_summary_path::STRING AS analysis_summary_path,\n $1:attribution_xlsx_path::STRING AS attribution_xlsx_path,\n $1:report_summary_xlsx_path::STRING AS report_summary_xlsx_path,\n $1:report_markdown_path::STRING AS report_markdown_path,\n $1:report_pptx_path::STRING AS report_pptx_path,\n $1:created_at::TIMESTAMP AS created_at\n FROM 's3://databend-dataload/databend-load/2026-0334-07T13-16-12-904Z/report_assets/' CONNECTION=(\n access_key_id = 'xxxxxxxxxx',\n enable_virtual_host_style='true',\n endpoint_url='https://s3.oss-cn-hangzhou.aliyuncs.com',\n region='cn-xxxxxx',\n secret_access_key = 'xxxxxxxxx'\n )\n ) PATTERN='.*[.]ndjson' FILE_FORMAT=(type=NDJSON) PURGE=false FORCE=false DISABLE_VARIANT_CHECK=false ON_ERROR=abort RETURN_FAILED_ONLY=false;"}

2026-04-09 06:24:31

107031

worksheet

update

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "select 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(100000000000) group by all;\n\nCOPY INTO sxt_dws_report_assets\nFROM (\n SELECT $1:job_run_id::STRING AS job_run_id,\n $1:biz_date::STRING AS biz_date,\n $1:archive_uri::STRING AS archive_uri,\n $1:archive_download_url::STRING AS archive_download_url,\n $1:analysis_xlsx_path::STRING AS analysis_xlsx_path,\n $1:analysis_summary_path::STRING AS analysis_summary_path,\n $1:attribution_xlsx_path::STRING AS attribution_xlsx_path,\n $1:report_summary_xlsx_path::STRING AS report_summary_xlsx_path,\n $1:report_markdown_path::STRING AS report_markdown_path,\n $1:report_pptx_path::STRING AS report_pptx_path,\n $1:created_at::TIMESTAMP AS created_at\n FROM 's3://databend-dataload/databend-load/2026-0334-07T13-16-12-904Z/report_assets/' CONNECTION=(\n access_key_id='xxxxxxxxxx',\n enable_virtual_host_style='true',\n endpoint_url='https://s3.oss-cn-hangzhou.aliyuncs.com',\n region='cn-xxxxxx',\n secret_access_key = 'xxxxxxxxx'\n )\n ) PATTERN='.*[.]ndjson' FILE_FORMAT=(type=NDJSON) PURGE=false FORCE=false DISABLE_VARIANT_CHECK=false ON_ERROR=abort RETURN_FAILED_ONLY=false;"}

2026-04-09 06:24:28

107030

worksheet

update

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "select 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(100000000000) group by all;\n\nCOPY INTO sxt_dws_report_assets\nFROM (\n SELECT $1:job_run_id::STRING AS job_run_id,\n $1:biz_date::STRING AS biz_date,\n $1:archive_uri::STRING AS archive_uri,\n $1:archive_download_url::STRING AS archive_download_url,\n $1:analysis_xlsx_path::STRING AS analysis_xlsx_path,\n $1:analysis_summary_path::STRING AS analysis_summary_path,\n $1:attribution_xlsx_path::STRING AS attribution_xlsx_path,\n $1:report_summary_xlsx_path::STRING AS report_summary_xlsx_path,\n $1:report_markdown_path::STRING AS report_markdown_path,\n $1:report_pptx_path::STRING AS report_pptx_path,\n $1:created_at::TIMESTAMP AS created_at\n FROM 's3://databend-dataload/databend-load/2026-0334-07T13-16-12-904Z/report_assets/' CONNECTION=(\n access_key_id='xxxxxxxxxx',\n enable_virtual_host_style='true',\n endpoint_url='https://s3.oss-cn-hangzhou.aliyuncs.com',\n region='cn-xxxxxx',\n secret_access_key='xxxxxxxxx'\n )\n ) PATTERN='.*[.]ndjson' FILE_FORMAT=(type=NDJSON) PURGE=false FORCE=false DISABLE_VARIANT_CHECK=false ON_ERROR=abort RETURN_FAILED_ONLY=false;"}

2026-04-09 06:18:53

107029

worksheet

update

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "select 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(100000000000) group by all;"}

2026-04-09 03:47:50

107028

worksheet

update

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "select 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(10000000000) group by all;"}

2026-04-09 03:46:52

107027

worksheet

update

10.1.158.166

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "select 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(1000000000) group by all;"}

2026-04-09 03:46:47

107026

worksheet

update

10.1.160.61

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "role": "account_admin", "title": "2026-03-18 08:20:18", "database": "default", "warehouse": "reload"}

2026-04-09 03:18:52

107025

worksheet

update

10.1.160.61

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "role": "account_admin", "title": "2026-03-18 08:20:18", "database": "default", "warehouse": "test-123"}

2026-04-09 03:18:33

107024

worksheet

update

10.1.160.61

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "role": "account_admin", "title": "2026-03-18 08:20:18", "database": "default", "warehouse": "xsmall-xi6i"}

2026-04-09 03:18:19

107023

worksheet

update

10.1.160.61

zhang senquan2 (zhangsenquan@datafuselabs.com)

{"id": 2955, "title": "2026-03-18 08:20:18", "queryText": "select 1;\nselect (number % 3)::string, number % 4 , number % 100, sum(number) from numbers(100000000) group by all;"}

2026-04-09 03:18:17

List ()