Skip to content
This repository has been archived by the owner on Jan 3, 2023. It is now read-only.

[SQL-DS-CACHE-47]Add plasma native get timeout #56

Merged

Conversation

offthewall123
Copy link
Contributor

What changes were proposed in this pull request?

Add plasma native get timeout

How was this patch tested?

E2E

@github-actions
Copy link

Thanks for opening a pull request!

Could you open an issue for this pull request on Github Issues?
https://github.com/oap-project/sql-ds-cache/issues

Then could you also rename pull request title and commit log in the following format?

[SQL-DS-CACHE-${ISSUES_ID}] ${detailed message}

See also:

@offthewall123 offthewall123 changed the title Add plasma native get timeout [SQL-DS-CACHE-47]Add plasma native get timeout Mar 22, 2021
@github-actions
Copy link

#47

@offthewall123
Copy link
Contributor Author

@jikunshang Let's try this fix first.

@jikunshang jikunshang merged commit 35be456 into oap-project:branch-1.1-spark-3.x Mar 22, 2021
@@ -1067,7 +1067,7 @@ class ExternalCache(fiberType: FiberType) extends OapCache with Logging {
var fiberCache : FiberCache = null
logDebug(s"Cache hit, get from external cache.")
val plasmaClient = plasmaClientPool(clientRoundRobin.getAndAdd(1) % clientPoolSize)
val buf: ByteBuffer = plasmaClient.getObjAsByteBuffer(objectId, -1, false)
val buf: ByteBuffer = plasmaClient.getObjAsByteBuffer(objectId, 1000, false)

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

can we make it configurable?

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants