[JBoss JIRA] (ISPN-8385) Off-heap container entries contain addional bytes
by Vojtech Juranek (JIRA)
Vojtech Juranek created ISPN-8385:
-------------------------------------
Summary: Off-heap container entries contain addional bytes
Key: ISPN-8385
URL: https://issues.jboss.org/browse/ISPN-8385
Project: Infinispan
Issue Type: Bug
Components: Core
Affects Versions: 9.2.0.Alpha1, 9.1.1.Final
Reporter: Vojtech Juranek
Off-heap container entries contain some additional bytes (ASCII 1,2,1,4), which probably shouldn't be there. Besides additional consumption of memory, it can cause problem as entry put into the cache with cache API is not accessible via container API (which is available to the use), i.e. something like this will fail:
{noformat}
cache.put(key, value);
container = AbstractDelegatingCache.unwrapCache(cache).getAdvancedCache().getDataContainer();
InternalCacheEntry entry = container.get(key);
{noformat}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 6 months
[JBoss JIRA] (ISPN-8281) Overload collect() to take Supplier and SerializableSupplier
by William Burns (JIRA)
[ https://issues.jboss.org/browse/ISPN-8281?page=com.atlassian.jira.plugin.... ]
William Burns updated ISPN-8281:
--------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
> Overload collect() to take Supplier and SerializableSupplier
> ------------------------------------------------------------
>
> Key: ISPN-8281
> URL: https://issues.jboss.org/browse/ISPN-8281
> Project: Infinispan
> Issue Type: Enhancement
> Reporter: Galder Zamarreño
> Assignee: Galder Zamarreño
> Fix For: 9.2.0.Final
>
>
> Whenever a collect() is called in a distributed environment, you have to wrap up in a serializable supplier method call to make it serializable, e.g.
> {code}
> Map<Integer, Long> totalPerHour = cache.values().stream()
> .collect(
> CacheCollectors.serializableCollector(() -> Collectors.groupingBy(
> e -> getHourOfDay(e.departureTs),
> Collectors.counting()
> )));
> {code}
> This is a bit clunky. We should overload collect to take a SerializableSupplier in CacheStream.
> It would also be nice to have an overloaded version that takes Supplier in case you want to provide your own serialization for it.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 6 months
[JBoss JIRA] (ISPN-8382) LockedStream timeout doesn't apply for locks
by William Burns (JIRA)
William Burns created ISPN-8382:
-----------------------------------
Summary: LockedStream timeout doesn't apply for locks
Key: ISPN-8382
URL: https://issues.jboss.org/browse/ISPN-8382
Project: Infinispan
Issue Type: Bug
Components: Distributed Execution and Map/Reduce
Affects Versions: 9.1.1.Final
Reporter: William Burns
Assignee: William Burns
The timeout value currently sets the underlying stream timeout which is for replication timeouts. The documentation states that the timeout is for the underlying lock system. We should make it do the latter. Do we need a replication timeout as well?
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 6 months