You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by "gaoran10 (via GitHub)" <gi...@apache.org> on 2023/07/03 04:32:20 UTC
[GitHub] [pulsar] gaoran10 commented on issue #12284: Pulsar SQL BufferUnderflowException after upgrading from 2.7.0 to 2.8.1
gaoran10 commented on issue #12284:
URL: https://github.com/apache/pulsar/issues/12284#issuecomment-1617275046
@Raven888888 Which version do you use? I test with Pulsar 3.0.0, it works well, could you try to use Pulsar 3.0.0?
#### Test steps
1. Use websocket client to produce a message without schema to a topic
2. Upload string schema to the topic
3. Query with Pulsar SQL
Before upload string schema
```
presto> select * from pulsar."public/default"."t1";
__value__ | __partition__ | __event_time__ | __publish_time__ | __message_id__ | __sequence_id__ | __producer_name__ | __key__ | __properties__
----------------------------------+---------------+----------------+-------------------------+----------------+-----------------+-------------------+---------+-----------------------------------
48 65 6c 6c 6f 20 57 6f 72 6c 64 | -1 | NULL | 2023-07-03 03:56:43.873 | (15,5,0) | 5 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
48 65 6c 6c 6f 20 57 6f 72 6c 64 | -1 | NULL | 2023-07-03 03:56:43.873 | (15,6,0) | 6 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
48 65 6c 6c 6f 20 57 6f 72 6c 64 | -1 | NULL | 2023-07-03 03:56:43.873 | (15,7,0) | 7 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
48 65 6c 6c 6f 20 57 6f 72 6c 64 | -1 | NULL | 2023-07-03 03:56:43.873 | (15,8,0) | 8 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
48 65 6c 6c 6f 20 57 6f 72 6c 64 | -1 | NULL | 2023-07-03 03:56:43.874 | (15,9,0) | 9 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
48 65 6c 6c 6f 20 57 6f 72 6c 64 | -1 | NULL | 2023-07-03 03:56:43.870 | (15,0,0) | 0 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
48 65 6c 6c 6f 20 57 6f 72 6c 64 | -1 | NULL | 2023-07-03 03:56:43.871 | (15,1,0) | 1 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
48 65 6c 6c 6f 20 57 6f 72 6c 64 | -1 | NULL | 2023-07-03 03:56:43.871 | (15,2,0) | 2 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
48 65 6c 6c 6f 20 57 6f 72 6c 64 | -1 | NULL | 2023-07-03 03:56:43.872 | (15,3,0) | 3 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
48 65 6c 6c 6f 20 57 6f 72 6c 64 | -1 | NULL | 2023-07-03 03:56:43.872 | (15,4,0) | 4 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
(10 rows)
Query 20230703_040424_00001_2a95d, FINISHED, 1 node
Splits: 18 total, 18 done (100.00%)
0:00 [10 rows, 1.17KB] [46 rows/s, 5.48KB/s]
```
After upload string schema
```
presto> select * from pulsar."public/default"."t1";
__value__ | __partition__ | __event_time__ | __publish_time__ | __message_id__ | __sequence_id__ | __producer_name__ | __key__ | __properties__
-------------+---------------+----------------+-------------------------+----------------+-----------------+-------------------+---------+-----------------------------------
Hello World | -1 | NULL | 2023-07-03 03:56:43.873 | (15,5,0) | 5 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
Hello World | -1 | NULL | 2023-07-03 03:56:43.873 | (15,6,0) | 6 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
Hello World | -1 | NULL | 2023-07-03 03:56:43.873 | (15,7,0) | 7 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
Hello World | -1 | NULL | 2023-07-03 03:56:43.873 | (15,8,0) | 8 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
Hello World | -1 | NULL | 2023-07-03 03:56:43.874 | (15,9,0) | 9 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
Hello World | -1 | NULL | 2023-07-03 03:56:43.870 | (15,0,0) | 0 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
Hello World | -1 | NULL | 2023-07-03 03:56:43.871 | (15,1,0) | 1 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
Hello World | -1 | NULL | 2023-07-03 03:56:43.871 | (15,2,0) | 2 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
Hello World | -1 | NULL | 2023-07-03 03:56:43.872 | (15,3,0) | 3 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
Hello World | -1 | NULL | 2023-07-03 03:56:43.872 | (15,4,0) | 4 | standalone-0-9 | NULL | {"key1":"value1","key2":"value2"}
(10 rows)
Query 20230703_042603_00002_2a95d, FINISHED, 1 node
Splits: 18 total, 18 done (100.00%)
0:00 [10 rows, 1.17KB] [41 rows/s, 4.9KB/s]
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org