pointearth opened a new pull request #9686: URL: https://github.com/apache/pulsar/pull/9686
<!-- ### Contribution Checklist **(The sections below can be removed for hotfixes of typos)** --> ### Motivation When I query a topic with presto `presto> select * from xxxTable from pulsar."xxxTenant/xxxNamespace"."last-topic-value"; Query 20210222_101426_00019_jvnf5, FAILED, 2 nodes Splits: 18 total, 0 done (0.00%) **0.79** [0 rows, 0B] [0 rows/s, 0B/s] You can see it cast a long time, and will not stop. And you can see many error messages in presto server: Query 20210222_101426_00019_jvnf5 failed: Duplicate key __pfn_input_topic__ (attempted merging values persistent://first-tenant-value/first-namespace-value/first-topic-value and persistent://second-tenant-value/second-namespace-value/second-topic-value)` **To Reproduce** Steps to reproduce the behavior: 1. create 3 topics: begin-topic-value, last-topic-value, topic3 2. create 2 pulsar functions, f1 pulls messages from first-topic-value, writes to second-topic-value, f2 pulls messages from second-topic-value, writes to last-topic-value. 3. `presto> select * from xxxTable from pulsar."xxxTenant/xxxNamespace"."last-topic-value"; 4. See these errors **Expected behavior** query successfully, and No error. **Screenshots** <img width="1288" alt="Screen Shot 2021-02-24 at 00 16 09" src="https://user-images.githubusercontent.com/1859919/108872874-9af4a280-7635-11eb-8ce5-04c88108b12b.png";> **Desktop (please complete the following information):** - OS: CentOS , pulsar 2.7.0 ### Modifications if key dumplicated, use new one. ### Verifying this change This change added tests and can be verified as follows: - *Added unit test in RawMessageImplTest.java* ### Does this pull request potentially affect one of the following parts: *If `yes` was chosen, please highlight the changes* - Dependencies (does it add or upgrade a dependency): (yes / **no**) - The public API: (yes / **no**) - The schema: (yes / **no** / don't know) - The default values of configurations: (yes / **no**) - The wire protocol: (yes / **no**) - The rest endpoints: (yes / **no**) - The admin cli options: (yes / **no**) - Anything that affects deployment: (yes / **no** / don't know) ### Documentation - Does this pull request introduces a new feature? (yes / **no**) - If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented) - If a feature is not applicable for documentation, explain why? it is a bug - If a feature is not documented yet in this PR, please create a followup issue for adding the documentation - It is just like <#6390>, but it causes presto issue. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
![https://user-images.githubusercontent.com/1859919/108872874-9af4a280-7635-11eb-8ce5-04c88108b12b.png"](https://user-images.githubusercontent.com/1859919/108872874-9af4a280-7635-11eb-8ce5-04c88108b12b.png"){kind=link}