You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/02/23 16:32:18 UTC
[GitHub] [pulsar] pointearth opened a new pull request #9686: Duplicate key __pfn_input_topic__ in presto server
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:
users@infra.apache.org
[GitHub] [pulsar] pointearth removed a comment on pull request #9686: Duplicate key __pfn_input_topic__ in presto server
Posted by GitBox <gi...@apache.org>.
pointearth removed a comment on pull request #9686:
URL: https://github.com/apache/pulsar/pull/9686#issuecomment-784332281
@codelipenghui Would you help to review it.
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [pulsar] codelipenghui merged pull request #9686: Duplicate key __pfn_input_topic__ in presto server
Posted by GitBox <gi...@apache.org>.
codelipenghui merged pull request #9686:
URL: https://github.com/apache/pulsar/pull/9686
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [pulsar] pointearth closed pull request #9686: Duplicate key __pfn_input_topic__ in presto server
Posted by GitBox <gi...@apache.org>.
pointearth closed pull request #9686:
URL: https://github.com/apache/pulsar/pull/9686
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [pulsar] sijie commented on pull request #9686: Duplicate key __pfn_input_topic__ in presto server
Posted by GitBox <gi...@apache.org>.
sijie commented on pull request #9686:
URL: https://github.com/apache/pulsar/pull/9686#issuecomment-784379252
@pointearth Great contribution!
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [pulsar] pointearth commented on pull request #9686: Duplicate key __pfn_input_topic__ in presto server
Posted by GitBox <gi...@apache.org>.
pointearth commented on pull request #9686:
URL: https://github.com/apache/pulsar/pull/9686#issuecomment-784332281
@codelipenghui Would you help to review it.
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [pulsar] pointearth commented on pull request #9686: Duplicate key __pfn_input_topic__ in presto server
Posted by GitBox <gi...@apache.org>.
pointearth commented on pull request #9686:
URL: https://github.com/apache/pulsar/pull/9686#issuecomment-784347395
@codelipenghui please review the code.
----------------------------------------------------------------
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:
users@infra.apache.org