2017-05-15 7 views
1

私は"hazelcast.operation.call.timeout.millis = 100"設定を使用して、ハローキャスト操作をタイムアウトします。操作のHazelcastカスタムタイムアウト

しかし、ヘイルキャストの開始時に、マップサイズ操作の一部がこの設定のためタイムアウトになっています。私はマップロード後の操作を基本的にmap get操作でタイムアウトさせたいだけです。これらのmap.get()操作にカスタム操作のタイムアウトを追加する方法はありますか?

これを行う他の方法はありますか?

com.hazelcast.core.OperationTimeoutException: HDMapSizeOperation got rejected before execution due to not starting within the operation-call-timeout of: 100ms. Current time: 2017-05-15 11:41:47.503. Start time: 2017-05-15 11:41:44.189. Total elapsed time: 3314 ms. Invocation{op=com.hazelcast.map.impl.operation.HDMapSizeOperation{serviceName='hz:impl:mapService', identityHash=1941379381, partitionId=0, replicaIndex=0, callId=-24461, invocationTime=1494828707296 (2017-05-15 11:41:47.296), waitTimeout=-1, callTimeout=100, name=blockMap}, tryCount=250, tryPauseMillis=500, invokeCount=11, callTimeoutMillis=100, firstInvocationTimeMs=1494828704189, firstInvocationTime='2017-05-15 11:41:44.189', lastHeartbeatMillis=0, lastHeartbeatTime='1970-01-01 05:30:00.000', target=[192.168.2.204]:5701, pendingResponse={VOID}, backupsAcksExpected=0, backupsAcksReceived=0, connection=null} 
at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.newOperationTimeoutException(InvocationFuture.java:151) 
at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolve(InvocationFuture.java:99) 
at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolveAndThrowIfException(InvocationFuture.java:75) 
at com.hazelcast.spi.impl.AbstractInvocationFuture.get(AbstractInvocationFuture.java:155) 
at com.hazelcast.spi.impl.operationservice.impl.InvokeOnPartitions.retryFailedPartitions(InvokeOnPartitions.java:143) 
at com.hazelcast.spi.impl.operationservice.impl.InvokeOnPartitions.invoke(InvokeOnPartitions.java:73) 
at com.hazelcast.spi.impl.operationservice.impl.OperationServiceImpl.invokeOnAllPartitions(OperationServiceImpl.java:371) 
at com.hazelcast.map.impl.proxy.MapProxySupport.size(MapProxySupport.java:628) 
at com.hazelcast.map.impl.proxy.MapProxyImpl.size(MapProxyImpl.java:102) 
at it.XXXX.tbx.server.MapLoader.run(MapLoader.java:36) 

よろしく、 Tharinda

答えて

4

あなたは、例えばの結果を待っているコントロールしようとしている場合map.get; map.getAsyncのような非同期バージョンを見ることができます。将来を返し、結果を待つ時間を制御することができます。

コールタイムアウトを変更することは推奨されません。

関連する問題