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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
