You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by tw...@apache.org on 2019/04/12 14:13:02 UTC

[tinkerpop] 02/03: Updated config reference after rebase.

This is an automated email from the ASF dual-hosted git repository.

twilmes pushed a commit to branch tp4-jmh
in repository https://gitbox.apache.org/repos/asf/tinkerpop.git

commit ff4351a5240c5140bfe3a8fb00bec1c4c5ffa2dd
Author: Ted Wilmes <tw...@gmail.com>
AuthorDate: Tue Apr 9 16:17:44 2019 -0500

    Updated config reference after rebase.
---
 .../org/apache/tinkerpop/benchmark/util/AbstractProcessorBenchmark.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/java/machine/machine-perf-test/src/main/java/org/apache/tinkerpop/benchmark/util/AbstractProcessorBenchmark.java b/java/machine/machine-perf-test/src/main/java/org/apache/tinkerpop/benchmark/util/AbstractProcessorBenchmark.java
index 1da0d31..64b8af6 100644
--- a/java/machine/machine-perf-test/src/main/java/org/apache/tinkerpop/benchmark/util/AbstractProcessorBenchmark.java
+++ b/java/machine/machine-perf-test/src/main/java/org/apache/tinkerpop/benchmark/util/AbstractProcessorBenchmark.java
@@ -55,7 +55,7 @@ public class AbstractProcessorBenchmark extends AbstractBenchmarkBase {
                 break;
             case RX_PARALLEL:
                 g = g.withProcessor(RxJavaProcessor.class,
-                        Map.of(RxJavaProcessor.RXJAVA_THREADS, Runtime.getRuntime().availableProcessors() - 1));
+                        Map.of(RxJavaProcessor.RX_THREAD_POOL_SIZE, Runtime.getRuntime().availableProcessors() - 1));
                 break;
             default:
                 throw new RuntimeException("Unrecognized processor type");