[JBoss JIRA] (ISPN-8822) Major performance hit in the remote iterator
by Gustavo Fernandes (JIRA)
Gustavo Fernandes created ISPN-8822:
---------------------------------------
Summary: Major performance hit in the remote iterator
Key: ISPN-8822
URL: https://issues.jboss.org/browse/ISPN-8822
Project: Infinispan
Issue Type: Bug
Components: Hot Rod
Affects Versions: 9.2.0.CR2
Reporter: Gustavo Fernandes
Priority: Critical
When trying to upgrade the [Spark connector |https://github.com/infinispan/infinispan-spark/] to use Infinispan 9.2.0.CR2, the test suite runs about 10x slower.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 1 month
[JBoss JIRA] (ISPRK-51) Infinispan 9.2.0.CR1 cause failures in the StreamingSuite
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPRK-51?page=com.atlassian.jira.plugin.s... ]
Gustavo Fernandes updated ISPRK-51:
-----------------------------------
Fix Version/s: 0.7
> Infinispan 9.2.0.CR1 cause failures in the StreamingSuite
> ---------------------------------------------------------
>
> Key: ISPRK-51
> URL: https://issues.jboss.org/browse/ISPRK-51
> Project: Infinispan Spark
> Issue Type: Bug
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Fix For: 0.7
>
>
> Always reproducible:
> {noformat}
> 2018-02-15 11:03:44 [dispatcher-event-loop-3] ERROR ReceiverTracker:70 - Deregistered receiver for stream 0: Stopped by driver
> [info] - test stream producer *** FAILED ***
> [info] java.lang.Exception: Timeout waiting for condition.
> [info] at org.infinispan.spark.test.TestingUtil$.waitForCondition$1(TestingUtil.scala:22)
> [info] at org.infinispan.spark.test.TestingUtil$.waitForCondition(TestingUtil.scala:27)
> [info] at org.infinispan.spark.test.TestingUtil$.waitForCondition(TestingUtil.scala:30)
> [info] at org.infinispan.spark.suites.StreamingSuite$$anonfun$2.apply$mcV$sp(StreamingSuite.scala:76)
> [info] at org.infinispan.spark.suites.StreamingSuite$$anonfun$2.apply(StreamingSuite.scala:56)
> [info] at org.infinispan.spark.suites.StreamingSuite$$anonfun$2.apply(StreamingSuite.scala:56)
> [info] at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
> [info] at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
> [info] at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
> [info] at org.scalatest.Transformer.apply(Transformer.scala:22)
> {noformat}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 1 month
[JBoss JIRA] (ISPRK-2) Management of cache lifecycles
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPRK-2?page=com.atlassian.jira.plugin.sy... ]
Gustavo Fernandes updated ISPRK-2:
----------------------------------
Fix Version/s: 0.7
> Management of cache lifecycles
> ------------------------------
>
> Key: ISPRK-2
> URL: https://issues.jboss.org/browse/ISPRK-2
> Project: Infinispan Spark
> Issue Type: Feature Request
> Reporter: RJ Nowling
> Fix For: 0.7
>
>
> For analytics use cases, the caches will rarely be known ahead of time -- they are dependent on the particular jobs being run. As such, jobs should have the ability to manage the lifecycle of caches, in particular:
> * Checking if a cache exists
> * Creating a cache
> * Deleting a cache
> * Clearing a cache
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 1 month
[JBoss JIRA] (ISPRK-2) Management of cache lifecycles
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPRK-2?page=com.atlassian.jira.plugin.sy... ]
Gustavo Fernandes reassigned ISPRK-2:
-------------------------------------
Assignee: Gustavo Fernandes
> Management of cache lifecycles
> ------------------------------
>
> Key: ISPRK-2
> URL: https://issues.jboss.org/browse/ISPRK-2
> Project: Infinispan Spark
> Issue Type: Feature Request
> Reporter: RJ Nowling
> Assignee: Gustavo Fernandes
> Fix For: 0.7
>
>
> For analytics use cases, the caches will rarely be known ahead of time -- they are dependent on the particular jobs being run. As such, jobs should have the ability to manage the lifecycle of caches, in particular:
> * Checking if a cache exists
> * Creating a cache
> * Deleting a cache
> * Clearing a cache
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 1 month
[JBoss JIRA] (ISPRK-48) Improve Java API for filterByQuery
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPRK-48?page=com.atlassian.jira.plugin.s... ]
Gustavo Fernandes updated ISPRK-48:
-----------------------------------
Fix Version/s: 0.7
(was: 0.6)
> Improve Java API for filterByQuery
> ----------------------------------
>
> Key: ISPRK-48
> URL: https://issues.jboss.org/browse/ISPRK-48
> Project: Infinispan Spark
> Issue Type: Enhancement
> Components: Java API
> Affects Versions: 0.5
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Fix For: 0.6
>
>
> When filtering an RDD by a deployed filter, the following Java syntax can be used:
> {code}
> InfinispanJavaRDD<String, MyEntity> infinispanRDD = ...
> JavaPairRDD<String, MyEntity> filtered = infinispanRDD.filterByCustom("my-filter");
> {code}
> but the same syntax cannot be used with the newly introduced methods {{filterByQuery}}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 1 month
[JBoss JIRA] (ISPRK-48) Improve Java API for filterByQuery
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPRK-48?page=com.atlassian.jira.plugin.s... ]
Gustavo Fernandes updated ISPRK-48:
-----------------------------------
Affects Version/s: (was: 0.5)
> Improve Java API for filterByQuery
> ----------------------------------
>
> Key: ISPRK-48
> URL: https://issues.jboss.org/browse/ISPRK-48
> Project: Infinispan Spark
> Issue Type: Enhancement
> Components: Java API
> Affects Versions: 0.5
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Fix For: 0.6
>
>
> When filtering an RDD by a deployed filter, the following Java syntax can be used:
> {code}
> InfinispanJavaRDD<String, MyEntity> infinispanRDD = ...
> JavaPairRDD<String, MyEntity> filtered = infinispanRDD.filterByCustom("my-filter");
> {code}
> but the same syntax cannot be used with the newly introduced methods {{filterByQuery}}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 1 month
[JBoss JIRA] (ISPRK-48) Improve Java API for filterByQuery
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPRK-48?page=com.atlassian.jira.plugin.s... ]
Gustavo Fernandes updated ISPRK-48:
-----------------------------------
Fix Version/s: (was: 0.7)
> Improve Java API for filterByQuery
> ----------------------------------
>
> Key: ISPRK-48
> URL: https://issues.jboss.org/browse/ISPRK-48
> Project: Infinispan Spark
> Issue Type: Enhancement
> Components: Java API
> Affects Versions: 0.5
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Fix For: 0.6
>
>
> When filtering an RDD by a deployed filter, the following Java syntax can be used:
> {code}
> InfinispanJavaRDD<String, MyEntity> infinispanRDD = ...
> JavaPairRDD<String, MyEntity> filtered = infinispanRDD.filterByCustom("my-filter");
> {code}
> but the same syntax cannot be used with the newly introduced methods {{filterByQuery}}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 1 month
[JBoss JIRA] (ISPRK-48) Improve Java API for filterByQuery
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPRK-48?page=com.atlassian.jira.plugin.s... ]
Gustavo Fernandes updated ISPRK-48:
-----------------------------------
Affects Version/s: 0.5
> Improve Java API for filterByQuery
> ----------------------------------
>
> Key: ISPRK-48
> URL: https://issues.jboss.org/browse/ISPRK-48
> Project: Infinispan Spark
> Issue Type: Enhancement
> Components: Java API
> Affects Versions: 0.5
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Fix For: 0.6
>
>
> When filtering an RDD by a deployed filter, the following Java syntax can be used:
> {code}
> InfinispanJavaRDD<String, MyEntity> infinispanRDD = ...
> JavaPairRDD<String, MyEntity> filtered = infinispanRDD.filterByCustom("my-filter");
> {code}
> but the same syntax cannot be used with the newly introduced methods {{filterByQuery}}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 1 month
[JBoss JIRA] (ISPRK-48) Improve Java API for filterByQuery
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPRK-48?page=com.atlassian.jira.plugin.s... ]
Gustavo Fernandes updated ISPRK-48:
-----------------------------------
Fix Version/s: 0.6
> Improve Java API for filterByQuery
> ----------------------------------
>
> Key: ISPRK-48
> URL: https://issues.jboss.org/browse/ISPRK-48
> Project: Infinispan Spark
> Issue Type: Enhancement
> Components: Java API
> Affects Versions: 0.5
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
> Fix For: 0.6
>
>
> When filtering an RDD by a deployed filter, the following Java syntax can be used:
> {code}
> InfinispanJavaRDD<String, MyEntity> infinispanRDD = ...
> JavaPairRDD<String, MyEntity> filtered = infinispanRDD.filterByCustom("my-filter");
> {code}
> but the same syntax cannot be used with the newly introduced methods {{filterByQuery}}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 1 month
[JBoss JIRA] (ISPRK-51) Infinispan 9.2.0.CR1 cause failures in the StreamingSuite
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPRK-51?page=com.atlassian.jira.plugin.s... ]
Gustavo Fernandes reassigned ISPRK-51:
--------------------------------------
Assignee: Gustavo Fernandes
> Infinispan 9.2.0.CR1 cause failures in the StreamingSuite
> ---------------------------------------------------------
>
> Key: ISPRK-51
> URL: https://issues.jboss.org/browse/ISPRK-51
> Project: Infinispan Spark
> Issue Type: Bug
> Reporter: Gustavo Fernandes
> Assignee: Gustavo Fernandes
>
> Always reproducible:
> {noformat}
> 2018-02-15 11:03:44 [dispatcher-event-loop-3] ERROR ReceiverTracker:70 - Deregistered receiver for stream 0: Stopped by driver
> [info] - test stream producer *** FAILED ***
> [info] java.lang.Exception: Timeout waiting for condition.
> [info] at org.infinispan.spark.test.TestingUtil$.waitForCondition$1(TestingUtil.scala:22)
> [info] at org.infinispan.spark.test.TestingUtil$.waitForCondition(TestingUtil.scala:27)
> [info] at org.infinispan.spark.test.TestingUtil$.waitForCondition(TestingUtil.scala:30)
> [info] at org.infinispan.spark.suites.StreamingSuite$$anonfun$2.apply$mcV$sp(StreamingSuite.scala:76)
> [info] at org.infinispan.spark.suites.StreamingSuite$$anonfun$2.apply(StreamingSuite.scala:56)
> [info] at org.infinispan.spark.suites.StreamingSuite$$anonfun$2.apply(StreamingSuite.scala:56)
> [info] at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
> [info] at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
> [info] at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
> [info] at org.scalatest.Transformer.apply(Transformer.scala:22)
> {noformat}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
8 years, 1 month