[jira] [Created] (IGNITE-4644) Value from IgniteQueue in atomic mode could be lost
Dmitry Karachentsev created IGNITE-4644: --- Summary: Value from IgniteQueue in atomic mode could be lost Key: IGNITE-4644 URL: https://issues.apache.org/jira/browse/IGNITE-4644 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 1.8 Reporter: Dmitry Karachentsev Assume following case (operations are going concurrently): 1) Client1 -> offer. Add new index in queue. 2) On Client1 happens JVM pause or short-time problem with connectivity to cluster longer than 3 sec. 3) Client2 -> poll. Get index from cache, but no value available. 4) Client2 checks for value about 3 sec and if no value appears, just skip it. Should be fixed somehow or make timeout configurable. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4667) Throw exception on starting client cache when indexed types cannot be loaded
Dmitry Karachentsev created IGNITE-4667: --- Summary: Throw exception on starting client cache when indexed types cannot be loaded Key: IGNITE-4667 URL: https://issues.apache.org/jira/browse/IGNITE-4667 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 1.8 Reporter: Dmitry Karachentsev Assume following situation: 1. Server node configured cache indexed types with classes that client node doesn't have. 2. Start server. 3. Start client. Client successfully connected. 4. Try to get cache on client node. 5. Was thrown exception in GridQueryProcessor and request for cache on client node hangs forever. If on some reason cache couldn't be initialized, exception must be thrown on Ignite.cache() operation. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4671) FairAffinityFunction fails on node restart with backupFilter set and no backups
Dmitry Karachentsev created IGNITE-4671: --- Summary: FairAffinityFunction fails on node restart with backupFilter set and no backups Key: IGNITE-4671 URL: https://issues.apache.org/jira/browse/IGNITE-4671 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 1.8 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.0 Setup: FairAffinityFunction with backup or affinity filter, number of cache backups is 0. On nodes restart fails on assertion in isAssignable() method. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4718) Add section in documentation on what actions may cause deadlock
Dmitry Karachentsev created IGNITE-4718: --- Summary: Add section in documentation on what actions may cause deadlock Key: IGNITE-4718 URL: https://issues.apache.org/jira/browse/IGNITE-4718 Project: Ignite Issue Type: Task Affects Versions: 1.8 Reporter: Dmitry Karachentsev Ignite has number of common cases, where wrong usage of API may lead to deadlocks, starvations, cluster hangs, and they should be properly documented. For example, cache operations is not allowed in CacheEntryProcessor, ContinuousQuery's remote filter, etc. And in some callbacks it's possible to use cache API if they annotated with @IgniteAsyncCallback. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4740) Service could be initialized twice on concurrent cancel and discovery event
Dmitry Karachentsev created IGNITE-4740: --- Summary: Service could be initialized twice on concurrent cancel and discovery event Key: IGNITE-4740 URL: https://issues.apache.org/jira/browse/IGNITE-4740 Project: Ignite Issue Type: Bug Components: managed services Affects Versions: 1.8 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.0 In case of concurrent service cancel and discovery event, for example, applying continuous query, may cause double init() and execute() service method invocation. Fix should consist at least in filtering such DiscoveryCustomEvent in GridServiceProcessor.TopologyListener. The best solution is guarantee that despite of any discovery event service won't be intialized more than once. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4833) IngiteClientRejoinTest sometimes fails with enabled peer class loading
Dmitry Karachentsev created IGNITE-4833: --- Summary: IngiteClientRejoinTest sometimes fails with enabled peer class loading Key: IGNITE-4833 URL: https://issues.apache.org/jira/browse/IGNITE-4833 Project: Ignite Issue Type: Bug Components: general Affects Versions: 2.0 Reporter: Dmitry Karachentsev [12:35:15,388][ERROR][sys-stripe-0-#29%server2%][GridCacheIoManager] Failed to process message [senderId=7a9767be-ad09-4f65-b800-aba444e41d0c, messageType=class o.a.i.i.processors.cache.distributed.dht.atomic.GridNearAtomicSingleUpdateRequest] java.lang.AssertionError at org.apache.ignite.internal.processors.cache.GridCacheDeploymentManager$CachedDeploymentInfo.(GridCacheDeploymentManager.java:918) at org.apache.ignite.internal.processors.cache.GridCacheDeploymentManager$CachedDeploymentInfo.(GridCacheDeploymentManager.java:889) at org.apache.ignite.internal.processors.cache.GridCacheDeploymentManager.p2pContext(GridCacheDeploymentManager.java:429) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.unmarshall(GridCacheIoManager.java:1290) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.onMessage0(GridCacheIoManager.java:364) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.handleMessage(GridCacheIoManager.java:293) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.access$000(GridCacheIoManager.java:95) at org.apache.ignite.internal.processors.cache.GridCacheIoManager$1.onMessage(GridCacheIoManager.java:238) at org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1215) at org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:843) at org.apache.ignite.internal.managers.communication.GridIoManager.access$2100(GridIoManager.java:108) at org.apache.ignite.internal.managers.communication.GridIoManager$6.run(GridIoManager.java:783) at org.apache.ignite.internal.util.StripedExecutor$Stripe.run(StripedExecutor.java:428) at java.lang.Thread.run(Thread.java:745) -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4842) IgniteCache.containsKey() may return false if entry is not in local backup yet on atomic cache
Dmitry Karachentsev created IGNITE-4842: --- Summary: IgniteCache.containsKey() may return false if entry is not in local backup yet on atomic cache Key: IGNITE-4842 URL: https://issues.apache.org/jira/browse/IGNITE-4842 Project: Ignite Issue Type: Bug Affects Versions: 1.9 Reporter: Dmitry Karachentsev Fix For: 2.0 -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4862) NPE in reading data from IGFS
Dmitry Karachentsev created IGNITE-4862: --- Summary: NPE in reading data from IGFS Key: IGNITE-4862 URL: https://issues.apache.org/jira/browse/IGNITE-4862 Project: Ignite Issue Type: Bug Components: hadoop Affects Versions: 1.9 Reporter: Dmitry Karachentsev {noformat} D:\app\CodexRT.CodexRT_20170314-1>hadoop\bin\hadoop fs -copyToLocal igfs:///cacheLink/test3.orc D:\test3.orc -copyToLocal: Fatal internal error java.lang.NullPointerException at org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream$FetchBufferPart.flatten(HadoopIgfsInputStream.java:458) at org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream$DoubleFetchBuffer.flatten(HadoopIgfsInputStream.java:511) at org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream.read(HadoopIgfsInputStream.java:177) at java.io.DataInputStream.read(DataInputStream.java:100) at org.apache.hadoop.io.IOUtils.copyBytes(IOUtils.java:91) at org.apache.hadoop.io.IOUtils.copyBytes(IOUtils.java:59) at org.apache.hadoop.io.IOUtils.copyBytes(IOUtils.java:119) at org.apache.hadoop.fs.shell.CommandWithDestination$TargetFileSystem.writeStreamToFile(CommandWithDestination.java:466) at org.apache.hadoop.fs.shell.CommandWithDestination.copyStreamToTarget(CommandWithDestination.java:391) at org.apache.hadoop.fs.shell.CommandWithDestination.copyFileToTarget(CommandWithDestination.java:328) at org.apache.hadoop.fs.shell.CommandWithDestination.processPath(CommandWithDestination.java:263) at org.apache.hadoop.fs.shell.CommandWithDestination.processPath(CommandWithDestination.java:248) at org.apache.hadoop.fs.shell.Command.processPaths(Command.java:317) at org.apache.hadoop.fs.shell.Command.processPathArgument(Command.java:289) at org.apache.hadoop.fs.shell.CommandWithDestination.processPathArgument(CommandWithDestination.java:243) at org.apache.hadoop.fs.shell.Command.processArgument(Command.java:271) at org.apache.hadoop.fs.shell.Command.processArguments(Command.java:255) at org.apache.hadoop.fs.shell.CommandWithDestination.processArguments(CommandWithDestination.java:220) at org.apache.hadoop.fs.shell.Command.processRawArguments(Command.java:201) at org.apache.hadoop.fs.shell.Command.run(Command.java:165) at org.apache.hadoop.fs.FsShell.run(FsShell.java:287) at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70) at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:84) at org.apache.hadoop.fs.FsShell.main(FsShell.java:340) {noformat} Details in discussion: [http://apache-ignite-users.70518.x6.nabble.com/NullPointerException-when-using-IGFS-td11328.html] -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4866) Add lazy value deserialization in GridCacheRawVersionedEntry
Dmitry Karachentsev created IGNITE-4866: --- Summary: Add lazy value deserialization in GridCacheRawVersionedEntry Key: IGNITE-4866 URL: https://issues.apache.org/jira/browse/IGNITE-4866 Project: Ignite Issue Type: Improvement Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4867) CacheMetricsSnapshot ignores 'size' and 'keySize' fields
Dmitry Karachentsev created IGNITE-4867: --- Summary: CacheMetricsSnapshot ignores 'size' and 'keySize' fields Key: IGNITE-4867 URL: https://issues.apache.org/jira/browse/IGNITE-4867 Project: Ignite Issue Type: Bug Reporter: Dmitry Karachentsev 'size' and 'keySize' fields in CacheMetricsSnapshot must be serialized and properly processed to show correct values in CacheClusterMetricsMXBeanImpl. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4911) Fix tests #1
Dmitry Karachentsev created IGNITE-4911: --- Summary: Fix tests #1 Key: IGNITE-4911 URL: https://issues.apache.org/jira/browse/IGNITE-4911 Project: Ignite Issue Type: Bug Components: cache, general Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Test that constantly failing: IgniteServiceDynamicCachesSelfTest.testDeployCalledAfterCacheStart IgniteServiceDynamicCachesSelfTest.testDeployCalledBeforeCacheStart IgniteCachePeekModesAbstractTest.testNonLocalPartitionSize GridCacheDeploymentOffHeapValuesSelfTest.testDeployment GridCacheAtomicPrimaryWriteOrderNearRemoveFailureTest.testPutAndRemove TcpDiscoveryNodeAttributesUpdateOnReconnectTest.testReconnect -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-4912) Fix testDeployCalledAfterCacheStart and testDeployCalledBeforeCacheStart tests
Dmitry Karachentsev created IGNITE-4912: --- Summary: Fix testDeployCalledAfterCacheStart and testDeployCalledBeforeCacheStart tests Key: IGNITE-4912 URL: https://issues.apache.org/jira/browse/IGNITE-4912 Project: Ignite Issue Type: Sub-task Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev IgniteServiceDynamicCachesSelfTest.testDeployCalledAfterCacheStart IgniteServiceDynamicCachesSelfTest.testDeployCalledBeforeCacheStart -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5013) Allow pass custom types to Cassandra store
Dmitry Karachentsev created IGNITE-5013: --- Summary: Allow pass custom types to Cassandra store Key: IGNITE-5013 URL: https://issues.apache.org/jira/browse/IGNITE-5013 Project: Ignite Issue Type: Improvement Components: ignite-cassandra Affects Versions: 2.0 Reporter: Dmitry Karachentsev Fix For: 2.1 Any type that is not in org.apache.ignite.cache.store.cassandra.common.PropertyMappingHelper#JAVA_TO_CASSANDRA_MAPPING will be serialized even if user specified custom codec for Cassandra. Should be ability to configure and bypass custom types to Cassandra. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5032) IgniteLock broken state resets on node restart
Dmitry Karachentsev created IGNITE-5032: --- Summary: IgniteLock broken state resets on node restart Key: IGNITE-5032 URL: https://issues.apache.org/jira/browse/IGNITE-5032 Project: Ignite Issue Type: Bug Components: data structures Affects Versions: 1.9 Reporter: Dmitry Karachentsev 1) Start two nodes. 2) Create distributed lock with failoverSafe = false. 3) Acquire lock on node 1. 4) Restart node 1. 5) Lock acquisition on node 2 throws exception (as expected), but node 1 successfully acquires lock. Correct behavior: 5) node 1 throws exception as node 2, and isBroken() returns true. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5038) Add BinaryObject.deserialize(ClassLoader) method
Dmitry Karachentsev created IGNITE-5038: --- Summary: Add BinaryObject.deserialize(ClassLoader) method Key: IGNITE-5038 URL: https://issues.apache.org/jira/browse/IGNITE-5038 Project: Ignite Issue Type: New Feature Components: cache Affects Versions: 2.0 Reporter: Dmitry Karachentsev Fix For: 2.1 In case if used custom class loader object could be serialized to BinaryObject, but de-serialization will fail with ClassNotFoundException. There should be possibility to explicitly set ClassLoader on object de-serialization: BinaryObject.deserialize(ClassLoader) -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5077) Support service permissions
Dmitry Karachentsev created IGNITE-5077: --- Summary: Support service permissions Key: IGNITE-5077 URL: https://issues.apache.org/jira/browse/IGNITE-5077 Project: Ignite Issue Type: New Feature Components: managed services Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.1 Need to add capability to specify permissions to allow/disallow executions of particular services (similar to compute tasks). The following permissions should be added to the SecurityPermission enum: SERVICE_DEPLOY - for IgniteServices.deployXXX methods. SERVICE_CANCEL - for IgniteServices.cancel and IgniteServices.cancelAll methods. SERVICE_INVOKE - for IgniteServices.service, IgniteServices.services and IgniteServices.serviceProxy methods. SERVICE_INVOKE should allow fine-grained authorization based on service name, similar to TASK_EXECUTE. E.g., a particular user should be able to execute service A, but not service B. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5144) Do not start remappings in DataStreamer on client node leave/arrive
Dmitry Karachentsev created IGNITE-5144: --- Summary: Do not start remappings in DataStreamer on client node leave/arrive Key: IGNITE-5144 URL: https://issues.apache.org/jira/browse/IGNITE-5144 Project: Ignite Issue Type: Improvement Components: cache Reporter: Dmitry Karachentsev Priority: Minor DataStreamerImpl shouldn't start remappings if topology changed by node that is not participate in cache (or at least by client node). Currently data streamer compares topology versions despite of what node caused this change: !topVer.equals(reqTopVer). -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5145) Support multiple service deployment in API
Dmitry Karachentsev created IGNITE-5145: --- Summary: Support multiple service deployment in API Key: IGNITE-5145 URL: https://issues.apache.org/jira/browse/IGNITE-5145 Project: Ignite Issue Type: Improvement Affects Versions: 2.0 Reporter: Dmitry Karachentsev Fix For: None IgniteServices should support possibility of deploying batch of services at once to speed up deployment. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5210) If enabled security authentication, server is unable to restart if client tries to reconnect
Dmitry Karachentsev created IGNITE-5210: --- Summary: If enabled security authentication, server is unable to restart if client tries to reconnect Key: IGNITE-5210 URL: https://issues.apache.org/jira/browse/IGNITE-5210 Project: Ignite Issue Type: Bug Components: general Affects Versions: 2.0 Reporter: Dmitry Karachentsev Steps to reproduce: # Configure security authentication. # Start server node. # Start client node. # Restart server node. # Server fails with ClassCastException {noformat} java.lang.ClassCastException: org.apache.ignite.plugin.security.SecurityCredentials cannot be cast to [B at org.apache.ignite.spi.discovery.tcp.ServerImpl.unmarshalCredentials(ServerImpl.java:1316) at org.apache.ignite.spi.discovery.tcp.ServerImpl.access$2500(ServerImpl.java:168) at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.processJoinRequestMessage(ServerImpl.java:3362) at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.processMessage(ServerImpl.java:2573) at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.processMessage(ServerImpl.java:2393) at org.apache.ignite.spi.discovery.tcp.ServerImpl$MessageWorkerAdapter.body(ServerImpl.java:6491) at org.apache.ignite.spi.discovery.tcp.ServerImpl$RingMessageWorker.body(ServerImpl.java:2479) at org.apache.ignite.spi.IgniteSpiThread.run(IgniteSpiThread.java:62) {noformat} -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5223) Allow use local binary metadata cache if it's possible
Dmitry Karachentsev created IGNITE-5223: --- Summary: Allow use local binary metadata cache if it's possible Key: IGNITE-5223 URL: https://issues.apache.org/jira/browse/IGNITE-5223 Project: Ignite Issue Type: Bug Affects Versions: 1.9 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 1.9 Add system property that will use local binary metadata cache instead of distributed one, when all classes available on all nodes and don't change. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5259) Support backward compatibility with versions without service permissions
Dmitry Karachentsev created IGNITE-5259: --- Summary: Support backward compatibility with versions without service permissions Key: IGNITE-5259 URL: https://issues.apache.org/jira/browse/IGNITE-5259 Project: Ignite Issue Type: Bug Affects Versions: 2.1 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.1 [IGNITE-5077|https://issues.apache.org/jira/browse/IGNITE-5077] adds service security permissions, but breaks compatibility with older versions. This must be fixed somehow. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5332) Add toString() to GridNearAtomicAbstractSingleUpdateRequest and it's inheritors
Dmitry Karachentsev created IGNITE-5332: --- Summary: Add toString() to GridNearAtomicAbstractSingleUpdateRequest and it's inheritors Key: IGNITE-5332 URL: https://issues.apache.org/jira/browse/IGNITE-5332 Project: Ignite Issue Type: Bug Affects Versions: 1.7 Reporter: Dmitry Karachentsev Fix For: 1.9 GridNearAtomicAbstractSingleUpdateRequest and all his inheritors should implement toString() method. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5342) Skip permission check for TASK_EXECUTE for service jobs
Dmitry Karachentsev created IGNITE-5342: --- Summary: Skip permission check for TASK_EXECUTE for service jobs Key: IGNITE-5342 URL: https://issues.apache.org/jira/browse/IGNITE-5342 Project: Ignite Issue Type: Bug Affects Versions: 2.1 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.1 Services work as compute tasks, and when SERVICE_INVOKE is available, service execution should not throw TASK_EXECUTE authorization error -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5424) GridServiceProxy does not unwraps exception message from InvocationTargetException
Dmitry Karachentsev created IGNITE-5424: --- Summary: GridServiceProxy does not unwraps exception message from InvocationTargetException Key: IGNITE-5424 URL: https://issues.apache.org/jira/browse/IGNITE-5424 Project: Ignite Issue Type: Bug Components: managed services Affects Versions: 2.1 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.2 Instead of correct message 'null' passed. {noformat} class org.apache.ignite.IgniteException: null at org.apache.ignite.internal.util.IgniteUtils.convertException(IgniteUtils.java:957) at org.apache.ignite.internal.processors.service.GridServiceProxy.invokeMethod(GridServiceProxy.java:208) at org.apache.ignite.internal.processors.service.GridServiceProxy$ProxyInvocationHandler.invoke(GridServiceProxy.java:356) at org.apache.ignite.internal.processors.service.$Proxy25.go(Unknown Source) at org.apache.ignite.internal.processors.service.GridServiceProcessorProxySelfTest.testException(GridServiceProcessorProxySelfTest.java:78) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at junit.framework.TestCase.runTest(TestCase.java:176) at org.apache.ignite.testframework.junits.GridAbstractTest.runTestInternal(GridAbstractTest.java:1979) at org.apache.ignite.testframework.junits.GridAbstractTest.access$000(GridAbstractTest.java:130) at org.apache.ignite.testframework.junits.GridAbstractTest$5.run(GridAbstractTest.java:1894) at java.lang.Thread.run(Thread.java:745) Caused by: class org.apache.ignite.IgniteCheckedException: null at org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils.java:7262) at org.apache.ignite.internal.util.future.GridFutureAdapter.resolve(GridFutureAdapter.java:258) at org.apache.ignite.internal.util.future.GridFutureAdapter.get0(GridFutureAdapter.java:189) at org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:139) at org.apache.ignite.internal.processors.service.GridServiceProxy.invokeMethod(GridServiceProxy.java:197) ... 12 more Caused by: java.lang.reflect.InvocationTargetException at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.ignite.internal.processors.service.GridServiceProxy$ServiceProxyCallable.call(GridServiceProxy.java:417) at org.apache.ignite.internal.processors.closure.GridClosureProcessor$C2.execute(GridClosureProcessor.java:1847) at org.apache.ignite.internal.processors.job.GridJobWorker$2.call(GridJobWorker.java:566) at org.apache.ignite.internal.util.IgniteUtils.wrapThreadLoader(IgniteUtils.java:6641) at org.apache.ignite.internal.processors.job.GridJobWorker.execute0(GridJobWorker.java:560) at org.apache.ignite.internal.processors.job.GridJobWorker.body(GridJobWorker.java:489) at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) at org.apache.ignite.internal.processors.job.GridJobProcessor.processJobExecuteRequest(GridJobProcessor.java:1180) at org.apache.ignite.internal.processors.job.GridJobProcessor$JobExecutionListener.onMessage(GridJobProcessor.java:1907) at org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1550) at org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:1178) at org.apache.ignite.internal.managers.communication.GridIoManager.access$4200(GridIoManager.java:124) at org.apache.ignite.internal.managers.communication.GridIoManager$9.run(GridIoManager.java:1095) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) ... 1 more Caused by: java.lang.Exception: Test exception at org.apache.ignite.internal.processors.service.GridServiceProcessorAbstractSelfTest$ErrorServiceImpl.go(GridServiceProcessorAbstractSelfTest.java:823) ... 20 more {noformat} -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (IGNITE-5570) IgniteMessaging should have sendAsync() method
Dmitry Karachentsev created IGNITE-5570: --- Summary: IgniteMessaging should have sendAsync() method Key: IGNITE-5570 URL: https://issues.apache.org/jira/browse/IGNITE-5570 Project: Ignite Issue Type: Improvement Components: messaging Affects Versions: 2.1 Reporter: Dmitry Karachentsev Fix For: 2.2 With old API IgniteMessaging.send() checks async mode, and if it's true, invokes local listener asynchronously in public pool. Support of async listener invocation should be added in IgniteMessaging, f.e.: IgniteFuture sendAsync() -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-5768) Retry resolving class name from marshaller cache and .classname file
Dmitry Karachentsev created IGNITE-5768: --- Summary: Retry resolving class name from marshaller cache and .classname file Key: IGNITE-5768 URL: https://issues.apache.org/jira/browse/IGNITE-5768 Project: Ignite Issue Type: Bug Components: cache Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-5795) @AffinityKeyMapped ignored if QueryEntity used
Dmitry Karachentsev created IGNITE-5795: --- Summary: @AffinityKeyMapped ignored if QueryEntity used Key: IGNITE-5795 URL: https://issues.apache.org/jira/browse/IGNITE-5795 Project: Ignite Issue Type: Bug Affects Versions: 2.0 Reporter: Dmitry Karachentsev Fix For: 2.2 When cache configured with QueryEntity and used key type with @AffinityKeyMapped field, it will be ignored and wrong partition calculated. This happens because QueryEntity processing precedes key type registering in binary meta cache. On that step CacheObjectBinaryProcessorImpl#affinityKeyField called and unable to resolve type, so null returned and null putted in affKeyFields. On next put/get operation CacheObjectBinaryProcessorImpl#affinityKeyField will return null from affKeyFields, but should be affinity key field. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-5840) IgniteUuid could not be used as a cache key
Dmitry Karachentsev created IGNITE-5840: --- Summary: IgniteUuid could not be used as a cache key Key: IGNITE-5840 URL: https://issues.apache.org/jira/browse/IGNITE-5840 Project: Ignite Issue Type: Bug Reporter: Dmitry Karachentsev Following test fails in 2.0+ {code:java} IgniteUuid id = IgniteUuid.randomUuid(); cache.put(id, "1"); assertNotNull(cache.get(id)); {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-5953) Missed off-heap unswapping in GridCacheMap.versionedValue()
Dmitry Karachentsev created IGNITE-5953: --- Summary: Missed off-heap unswapping in GridCacheMap.versionedValue() Key: IGNITE-5953 URL: https://issues.apache.org/jira/browse/IGNITE-5953 Project: Ignite Issue Type: Bug Affects Versions: 1.9 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.2 -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-6165) Use SSL connection in IpcClientTcpEndpoint when it's configured for grid
Dmitry Karachentsev created IGNITE-6165: --- Summary: Use SSL connection in IpcClientTcpEndpoint when it's configured for grid Key: IGNITE-6165 URL: https://issues.apache.org/jira/browse/IGNITE-6165 Project: Ignite Issue Type: Improvement Components: igfs Affects Versions: 2.1 Reporter: Dmitry Karachentsev Fix For: 2.2 HadoopIgfsIpcIo in start() method always opens insecure connection, even if SSL is configured (should be like in TcpDiscoverySpi.createSocket()), IpcServerTcpEndpoint must be protected as well. {code} if (isSslEnabled()) sock = sslSockFactory.createSocket(); else sock = new Socket(); {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-6166) Exceptions are printed to console, instead of log
Dmitry Karachentsev created IGNITE-6166: --- Summary: Exceptions are printed to console, instead of log Key: IGNITE-6166 URL: https://issues.apache.org/jira/browse/IGNITE-6166 Project: Ignite Issue Type: Bug Components: igfs Affects Versions: 2.1 Reporter: Dmitry Karachentsev Priority: Trivial Fix For: 2.2 IgniteSourceTask.TaskLocalListener,apply() IgfsThread.run() Exceptions should be logged. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-6431) Web Console: "Partition loss policy" field is duplicated
Dmitry Karachentsev created IGNITE-6431: --- Summary: Web Console: "Partition loss policy" field is duplicated Key: IGNITE-6431 URL: https://issues.apache.org/jira/browse/IGNITE-6431 Project: Ignite Issue Type: Bug Components: UI Affects Versions: 2.1 Reporter: Dmitry Karachentsev Assignee: Vasiliy Sisko -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-6487) Affinity may return more backups that set during exchange
Dmitry Karachentsev created IGNITE-6487: --- Summary: Affinity may return more backups that set during exchange Key: IGNITE-6487 URL: https://issues.apache.org/jira/browse/IGNITE-6487 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 2.1 Reporter: Dmitry Karachentsev Reproducer is in attachment. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-6671) [Web Console] Wrong java type used in generated config from DB schema
Dmitry Karachentsev created IGNITE-6671: --- Summary: [Web Console] Wrong java type used in generated config from DB schema Key: IGNITE-6671 URL: https://issues.apache.org/jira/browse/IGNITE-6671 Project: Ignite Issue Type: Bug Security Level: Public (Viewable by anyone) Affects Versions: 2.2 Reporter: Dmitry Karachentsev Fix For: 2.3 We should be confident that java types in generated config are able to fit in values from DB. For example, WC generates short for Oracle's NUMBER(5), when short could be max 32767, but NUMBER(5) - 9. That may produce errors like below during DB import: {noformat} Exception in thread "main" javax.cache.integration.CacheLoaderException: Failed to load cache: test at org.apache.ignite.cache.store.jdbc.CacheAbstractJdbcStore.loadCache(CacheAbstractJdbcStore.java:798) at org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter.loadCache(GridCacheStoreManagerAdapter.java:502) at org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheAdapter.localLoadCache(GridDhtCacheAdapter.java:486) at org.apache.ignite.internal.processors.cache.GridCacheProxyImpl.localLoadCache(GridCacheProxyImpl.java:217) at org.apache.ignite.internal.processors.cache.GridCacheAdapter$LoadCacheJob.localExecute(GridCacheAdapter.java:5439) at org.apache.ignite.internal.processors.cache.GridCacheAdapter$LoadCacheJobV2.localExecute(GridCacheAdapter.java:5488) at org.apache.ignite.internal.processors.cache.GridCacheAdapter$TopologyVersionAwareJob.execute(GridCacheAdapter.java:6103) at org.apache.ignite.compute.ComputeJobAdapter.call(ComputeJobAdapter.java:132) at org.apache.ignite.internal.processors.closure.GridClosureProcessor$C2.execute(GridClosureProcessor.java:1842) at org.apache.ignite.internal.processors.job.GridJobWorker$2.call(GridJobWorker.java:566) at org.apache.ignite.internal.util.IgniteUtils.wrapThreadLoader(IgniteUtils.java:6621) at org.apache.ignite.internal.processors.job.GridJobWorker.execute0(GridJobWorker.java:560) at org.apache.ignite.internal.processors.job.GridJobWorker.body(GridJobWorker.java:489) at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) at org.apache.ignite.internal.processors.job.GridJobProcessor.processJobExecuteRequest(GridJobProcessor.java:1114) at org.apache.ignite.internal.processors.job.GridJobProcessor$JobExecutionListener.onMessage(GridJobProcessor.java:1907) at org.apache.ignite.internal.managers.communication.GridIoManager.invokeListener(GridIoManager.java:1257) at org.apache.ignite.internal.managers.communication.GridIoManager.processRegularMessage0(GridIoManager.java:885) at org.apache.ignite.internal.managers.communication.GridIoManager.access$2100(GridIoManager.java:114) at org.apache.ignite.internal.managers.communication.GridIoManager$7.run(GridIoManager.java:802) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: javax.cache.CacheException: Failed to read binary object: org.apache.TestModel at org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore.buildBinaryObject(CacheJdbcPojoStore.java:255) at org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore.buildObject(CacheJdbcPojoStore.java:136) at org.apache.ignite.cache.store.jdbc.CacheAbstractJdbcStore$1.call(CacheAbstractJdbcStore.java:463) at org.apache.ignite.cache.store.jdbc.CacheAbstractJdbcStore$1.call(CacheAbstractJdbcStore.java:430) at java.util.concurrent.FutureTask.run(FutureTask.java:266) ... 3 more Caused by: java.sql.SQLException: Numeric Overflow at oracle.jdbc.driver.NumberCommonAccessor.throwOverflow(NumberCommonAccessor.java:4170) at oracle.jdbc.driver.NumberCommonAccessor.getShort(NumberCommonAccessor.java:311) at oracle.jdbc.driver.GeneratedStatement.getShort(GeneratedStatement.java:305) at oracle.jdbc.driver.GeneratedScrollableResultSet.getShort(GeneratedScrollableResultSet.java:879) at org.apache.ignite.cache.store.jdbc.JdbcTypesDefaultTransformer.getColumnValue(JdbcTypesDefaultTransformer.java:84) at org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore.buildBinaryObject(CacheJdbcPojoStore.java:247) ... 7 more {noformat} *This should be checked for all supported databases.* -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-6818) In case of incoming communication connection ping the old one if it's alive
Dmitry Karachentsev created IGNITE-6818: --- Summary: In case of incoming communication connection ping the old one if it's alive Key: IGNITE-6818 URL: https://issues.apache.org/jira/browse/IGNITE-6818 Project: Ignite Issue Type: Bug Security Level: Public (Viewable by anyone) Affects Versions: 2.3 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Priority: Critical Fix For: 2.4 Assume the following scenario: 1. Client opens connection to the server. 2. Server checks that it is a first connection to that node and accepts it. 3. By some reason firewall starts rejecting client messages with TCP reset flag set. 4. Client closes connection, but server doesn't know about it. 5. Client tries connect again. 6. Server rejects new connection, because it already has connection to that node. Possible fix: on step 6 server must check old connection if it's alive by sending some communication message and check response. If old connection is dead - close it and accept new one. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-2995) putAll() and removeAll() operations on transactional cache are very slow on big number of entries
Dmitry Karachentsev created IGNITE-2995: --- Summary: putAll() and removeAll() operations on transactional cache are very slow on big number of entries Key: IGNITE-2995 URL: https://issues.apache.org/jira/browse/IGNITE-2995 Project: Ignite Issue Type: Improvement Components: cache Affects Versions: 1.5.0.final Reporter: Dmitry Karachentsev Priority: Minor Saving and removing 100_000 cache entries using putAll() and removeAll() methods is much slower than save/remove 10 times 10_000 entries. F.e. on my test environment second case (10_000 x 10) took 3 mins and first case (100_000) - 24 mins. That issue is observed only for transactional cache. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-3117) Weblogic manual tests for HttpSession caching.
Dmitry Karachentsev created IGNITE-3117: --- Summary: Weblogic manual tests for HttpSession caching. Key: IGNITE-3117 URL: https://issues.apache.org/jira/browse/IGNITE-3117 Project: Ignite Issue Type: Test Components: websession Affects Versions: 1.6 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 1.7 Simple tests that allow deploy and check that HttpSession is cached properly in grid. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-3339) get() in explicit READ_COMMITTED transaction on OFFHEAP_TIERED cache copies data from offheap to onheap.
Dmitry Karachentsev created IGNITE-3339: --- Summary: get() in explicit READ_COMMITTED transaction on OFFHEAP_TIERED cache copies data from offheap to onheap. Key: IGNITE-3339 URL: https://issues.apache.org/jira/browse/IGNITE-3339 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 1.6 Reporter: Dmitry Karachentsev Fix For: 1.7 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-3590) Create test and first simple implementation of secondary file system.
Dmitry Karachentsev created IGNITE-3590: --- Summary: Create test and first simple implementation of secondary file system. Key: IGNITE-3590 URL: https://issues.apache.org/jira/browse/IGNITE-3590 Project: Ignite Issue Type: Sub-task Components: IGFS Affects Versions: 1.6 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 1.7 Create new simple (copy paste from IgniteHadoopIgfsSecondaryFileSystem) inplementation and tests for it as start point. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-3722) Cached in a file text must be written with UTF-8 charset, not default
Dmitry Karachentsev created IGNITE-3722: --- Summary: Cached in a file text must be written with UTF-8 charset, not default Key: IGNITE-3722 URL: https://issues.apache.org/jira/browse/IGNITE-3722 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 1.7 Reporter: Dmitry Karachentsev Fix For: 1.8 Writing/reading text files is error prone and UTF-8 must be set explicitly. F.e. org.apache.ignite.internal.MarshallerContextImpl#className() and org.apache.ignite.internal.MarshallerContextImpl.ContinuousQueryListener#onUpdated() InputStreamReader() and OutputStreamWriter() must have charset set. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-3813) High contention on GridCacheMapEntry.obsolete() on loading data to data stremer with composite keys
Dmitry Karachentsev created IGNITE-3813: --- Summary: High contention on GridCacheMapEntry.obsolete() on loading data to data stremer with composite keys Key: IGNITE-3813 URL: https://issues.apache.org/jira/browse/IGNITE-3813 Project: Ignite Issue Type: Improvement Affects Versions: 1.7 Reporter: Dmitry Karachentsev Fix For: 1.8 On loading entries with non-primitive key to data streamer too many calls to metadata cache which causes high contention on GridCacheMapEntry. Example thread dump in attachment. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-4231) Hangs on compute result serialization error
Dmitry Karachentsev created IGNITE-4231: --- Summary: Hangs on compute result serialization error Key: IGNITE-4231 URL: https://issues.apache.org/jira/browse/IGNITE-4231 Project: Ignite Issue Type: Bug Affects Versions: 1.7 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 1.8 Compute task may hang if was thrown exception on result serialization. This should be properly handled and responded to client. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-4284) Failed second client node join with continuous query and peer class loading enabled
Dmitry Karachentsev created IGNITE-4284: --- Summary: Failed second client node join with continuous query and peer class loading enabled Key: IGNITE-4284 URL: https://issues.apache.org/jira/browse/IGNITE-4284 Project: Ignite Issue Type: Bug Affects Versions: 1.7 Reporter: Dmitry Karachentsev Fix For: 2.0 Steps to reproduce: 1) Start server with cache and peer class loading enabled. 2) Start client with peer class loading enabled. 3) Start continuous query with custom event filter factory. 4) Start second client -- Fail with NPE or AsserionError. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-4395) Implement communication backpressure per policy - SYSTEM or PUBLIC
Dmitry Karachentsev created IGNITE-4395: --- Summary: Implement communication backpressure per policy - SYSTEM or PUBLIC Key: IGNITE-4395 URL: https://issues.apache.org/jira/browse/IGNITE-4395 Project: Ignite Issue Type: Improvement Components: cache, compute Affects Versions: 1.7 Reporter: Dmitry Karachentsev 1) Start two data nodes with some cache. 2) From one node in async mode post some big number of jobs to another. That jobs do some cache operations. 3) Grid hangs almost immediately and all threads are sleeping except public ones, they are waiting for response. This happens because all cache and job messages are queued on communication and limited with default number (1024). It looks like jobs are waiting for cache responses that could not be received due to this limit. Proper solution here is to have communication backpressure per policy - SYSTEM or PUBLIC, but not single point as it is now. It could be achieved with having two queues per communication session or (which looks a bit easier to implement) to have separate connections. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-4455) Node restarts may hang grid on exchange process
Dmitry Karachentsev created IGNITE-4455: --- Summary: Node restarts may hang grid on exchange process Key: IGNITE-4455 URL: https://issues.apache.org/jira/browse/IGNITE-4455 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 1.8 Reporter: Dmitry Karachentsev Node connect or disconnect may force grid hang on exchange process. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-4487) NPE on query execution
Dmitry Karachentsev created IGNITE-4487: --- Summary: NPE on query execution Key: IGNITE-4487 URL: https://issues.apache.org/jira/browse/IGNITE-4487 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 1.8 Reporter: Dmitry Karachentsev Fix For: 2.0 NPE may be thrown when called destroyCache() and started querying. Attached example reproduces this case when GridDiscoveryManager#removeCacheFilter called but cache state haven't been changed to STOPPED org.apache.ignite.internal.processors.cache.GridCacheGateway#onStopped. {code:none} javax.cache.CacheException: class org.apache.ignite.IgniteCheckedException: null at org.apache.ignite.internal.processors.cache.IgniteCacheProxy.query(IgniteCacheProxy.java:740) at com.intellica.evam.engine.event.future.FutureEventWorker.processFutureEvents(FutureEventWorker.java:117) at com.intellica.evam.engine.event.future.FutureEventWorker.run(FutureEventWorker.java:66) Caused by: class org.apache.ignite.IgniteCheckedException: null at org.apache.ignite.internal.processors.query.GridQueryProcessor.executeQuery(GridQueryProcessor.java:1693) at org.apache.ignite.internal.processors.cache.IgniteCacheProxy.query(IgniteCacheProxy.java:494) at org.apache.ignite.internal.processors.cache.IgniteCacheProxy.query(IgniteCacheProxy.java:732) ... 2 more Caused by: java.lang.NullPointerException at org.apache.ignite.internal.processors.cache.query.GridCacheQueryAdapter$ScanQueryFallbackClosableIterator.init(GridCacheQueryAdapter.java:712) at org.apache.ignite.internal.processors.cache.query.GridCacheQueryAdapter$ScanQueryFallbackClosableIterator.(GridCacheQueryAdapter.java:677) at org.apache.ignite.internal.processors.cache.query.GridCacheQueryAdapter$ScanQueryFallbackClosableIterator.(GridCacheQueryAdapter.java:628) at org.apache.ignite.internal.processors.cache.query.GridCacheQueryAdapter.executeScanQuery(GridCacheQueryAdapter.java:548) at org.apache.ignite.internal.processors.cache.IgniteCacheProxy$2.applyx(IgniteCacheProxy.java:497) at org.apache.ignite.internal.processors.cache.IgniteCacheProxy$2.applyx(IgniteCacheProxy.java:495) at org.apache.ignite.internal.util.lang.IgniteOutClosureX.apply(IgniteOutClosureX.java:36) at org.apache.ignite.internal.processors.query.GridQueryProcessor.executeQuery(GridQueryProcessor.java:1670) ... 4 more {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-4515) Throw exception when key and value fields mapped to the same DB columns
Dmitry Karachentsev created IGNITE-4515: --- Summary: Throw exception when key and value fields mapped to the same DB columns Key: IGNITE-4515 URL: https://issues.apache.org/jira/browse/IGNITE-4515 Project: Ignite Issue Type: Improvement Components: cache Affects Versions: 1.8 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2,0 In case of (pseudocode): KeyClass { field1; field2; field3 }, ValClass { field1; field2; field3 } Map fields to DB table TABLE_NAME columns: field1 -> col1, field2 -> col2, field3 -> col3. On node startup throw an exception with message that restricts such case. Field mappings should not intersect. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-8500) [Cassandra] Allow dynamic cache creation with Cassandra Store
Dmitry Karachentsev created IGNITE-8500: --- Summary: [Cassandra] Allow dynamic cache creation with Cassandra Store Key: IGNITE-8500 URL: https://issues.apache.org/jira/browse/IGNITE-8500 Project: Ignite Issue Type: Improvement Components: cassandra Affects Versions: 2.5 Reporter: Dmitry Karachentsev Fix For: 2.6 It's not possible for now dynamically create caches with Cassandra cache store: {noformat} class org.apache.ignite.IgniteCheckedException: null at org.apache.ignite.internal.util.IgniteUtils.cast(IgniteUtils.java:7307) at org.apache.ignite.internal.util.future.GridFutureAdapter.resolve(GridFutureAdapter.java:259) at org.apache.ignite.internal.util.future.GridFutureAdapter.get0(GridFutureAdapter.java:207) at org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:159) at org.apache.ignite.internal.util.future.GridFutureAdapter.get(GridFutureAdapter.java:151) at org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body0(GridCachePartitionExchangeManager.java:2433) at org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body(GridCachePartitionExchangeManager.java:2299) at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.NullPointerException at org.apache.ignite.cache.store.cassandra.persistence.PojoField.calculatedField(PojoField.java:155) at org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.prepareLoadStatements(PersistenceController.java:313) at org.apache.ignite.cache.store.cassandra.persistence.PersistenceController.(PersistenceController.java:85) at org.apache.ignite.cache.store.cassandra.CassandraCacheStore.(CassandraCacheStore.java:106) at org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:59) at org.apache.ignite.cache.store.cassandra.CassandraCacheStoreFactory.create(CassandraCacheStoreFactory.java:34) at org.apache.ignite.internal.processors.cache.GridCacheProcessor.createCache(GridCacheProcessor.java:1437) at org.apache.ignite.internal.processors.cache.GridCacheProcessor.prepareCacheStart(GridCacheProcessor.java:1945) at org.apache.ignite.internal.processors.cache.GridCacheProcessor.startReceivedCaches(GridCacheProcessor.java:1864) at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartitionsExchangeFuture.java:674) at org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body0(GridCachePartitionExchangeManager.java:2419) ... 3 more {noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-8813) Add ComputeJobResultPolicy to JobEvent
Dmitry Karachentsev created IGNITE-8813: --- Summary: Add ComputeJobResultPolicy to JobEvent Key: IGNITE-8813 URL: https://issues.apache.org/jira/browse/IGNITE-8813 Project: Ignite Issue Type: Improvement Components: compute Affects Versions: 2.5 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.6 There is no way to determine on node-mapper what action would be performed on EVT_JOB_RESULTED event, as got result could return different policies: WAIT, REDUCE, FAILOVER. This knowledge might be critical for user if it relies on events, and, for instance, he need to know if EVT_JOB_RESULTED is final event, or it will be failed over and will be fired again. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-8851) StoredCacheData and CacheJoinNodeDiscoveryData.CacheInfo duplicate "sql" flag
Dmitry Karachentsev created IGNITE-8851: --- Summary: StoredCacheData and CacheJoinNodeDiscoveryData.CacheInfo duplicate "sql" flag Key: IGNITE-8851 URL: https://issues.apache.org/jira/browse/IGNITE-8851 Project: Ignite Issue Type: Improvement Affects Versions: 2.5 Reporter: Dmitry Karachentsev Fix For: 3.0 Node when joins cluster sends cache configurations. Configuration is wrapped into StoredCacheData, and StoredCacheData into CacheJoinNodeDiscoveryData.CacheInfo. Both CacheInfo and StoredCacheData have "sql" flag that seems means the same. It should appear only once. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-8852) CacheJoinNodeDiscoveryData.CacheInfo has boolean flags and long field for flags
Dmitry Karachentsev created IGNITE-8852: --- Summary: CacheJoinNodeDiscoveryData.CacheInfo has boolean flags and long field for flags Key: IGNITE-8852 URL: https://issues.apache.org/jira/browse/IGNITE-8852 Project: Ignite Issue Type: Improvement Affects Versions: 2.5 Reporter: Dmitry Karachentsev Fix For: 3.0 CacheJoinNodeDiscoveryData.CacheInfo has two types of flags: boolean stored in fields and long. Latter is not used. Should be picked one approach: or boolean fields, or bitmask, not both. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-8858) Client none may not stop
Dmitry Karachentsev created IGNITE-8858: --- Summary: Client none may not stop Key: IGNITE-8858 URL: https://issues.apache.org/jira/browse/IGNITE-8858 Project: Ignite Issue Type: Bug Affects Versions: 2.5 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.6 There is possible case when client node is not stopped and blocked on waiting when SocketReader will be completed. Looks like interruption was lost, and the only place where it could happen is in unmarshaling message from input stream. The way to overcome/fix it is to check if InterruptedException was in cause of IgniteCheckedException and repeatedly interrupt reader on stop. {noformat} java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) at java.lang.Thread.join(Thread.java:1245) - locked <0x00041016a140> (a org.apache.ignite.spi.discovery.tcp.ClientImpl$SocketReader) at java.lang.Thread.join(Thread.java:1319) at org.apache.ignite.internal.util.IgniteUtils.join(IgniteUtils.java:4604) at org.apache.ignite.spi.discovery.tcp.ClientImpl.spiStop(ClientImpl.java:315) at org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi.spiStop(TcpDiscoverySpi.java:2061) at org.apache.ignite.internal.managers.GridManagerAdapter.stopSpi(GridManagerAdapter.java:330) at org.apache.ignite.internal.managers.discovery.GridDiscoveryManager.stop(GridDiscoveryManager.java:1608) at org.apache.ignite.internal.IgniteKernal.stop0(IgniteKernal.java:2216) at org.apache.ignite.internal.IgniteKernal.stop(IgniteKernal.java:2094) at org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance.stop0(IgnitionEx.java:2545) - locked <0x000410065e80> (a org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance) at org.apache.ignite.internal.IgnitionEx$IgniteNamedInstance.stop(IgnitionEx.java:2508) at org.apache.ignite.internal.IgnitionEx.stop(IgnitionEx.java:365) at org.apache.ignite.Ignition.stop(Ignition.java:229) at org.apache.ignite.internal.IgniteKernal.close(IgniteKernal.java:3417) "tcp-client-disco-sock-reader-#35%Default%" #746 prio=5 os_prio=0 tid=0x7f6090561800 nid=0x3441 in Object.wait() [0x7f60f23d8000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) at java.lang.Object.wait(Object.java:502) at org.apache.ignite.spi.discovery.tcp.ClientImpl$SocketReader.body(ClientImpl.java:1006) - locked <0x00041016a2e0> (a java.lang.Object) at org.apache.ignite.spi.IgniteSpiThread.run(IgniteSpiThread.java:62) {noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-8859) Open upper Java verison bounds
Dmitry Karachentsev created IGNITE-8859: --- Summary: Open upper Java verison bounds Key: IGNITE-8859 URL: https://issues.apache.org/jira/browse/IGNITE-8859 Project: Ignite Issue Type: Improvement Reporter: Dmitry Karachentsev Fix For: 2.6 JDK is going to be release twice a year and it will be always an issue for users to start Ignite on newer Java version as we have explicit bounds. Ignite should not disallow starting in latest JDK, but show warning that it wasn't tested against running version. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-8896) Wrong javadoc for TcpCommunicationSpi.setSlowClientQueueLimit()
Dmitry Karachentsev created IGNITE-8896: --- Summary: Wrong javadoc for TcpCommunicationSpi.setSlowClientQueueLimit() Key: IGNITE-8896 URL: https://issues.apache.org/jira/browse/IGNITE-8896 Project: Ignite Issue Type: Bug Affects Versions: 2.5 Reporter: Dmitry Karachentsev Fix For: 2.7 Javadoc for TcpCommunicationSpi.setSlowClientQueueLimit() says that is should be set to value equal to TcpCommunicationSpi.getMessageQueueLimit(). But this is wrong, because first checks back pressure limit and sender thread will be blocked before slow client check. Also, warning checks the value correctly, but message should be "...greater or equal...": {code:java} if (slowClientQueueLimit > 0 && msgQueueLimit > 0 && slowClientQueueLimit >= msgQueueLimit) { U.quietAndWarn(log, "Slow client queue limit is set to a value greater than message queue limit " + "(slow client queue limit will have no effect) [msgQueueLimit=" + msgQueueLimit + ", slowClientQueueLimit=" + slowClientQueueLimit + ']'); } {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-8944) TcpDiscoverySpi: set connection check frequency to fixed value
Dmitry Karachentsev created IGNITE-8944: --- Summary: TcpDiscoverySpi: set connection check frequency to fixed value Key: IGNITE-8944 URL: https://issues.apache.org/jira/browse/IGNITE-8944 Project: Ignite Issue Type: Improvement Reporter: Dmitry Karachentsev Now connCheckFreq value calculated by some not obvious code: {code:java} private void initConnectionCheckFrequency() { if (spi.failureDetectionTimeoutEnabled()) connCheckThreshold = spi.failureDetectionTimeout(); else connCheckThreshold = Math.min(spi.getSocketTimeout(), spi.metricsUpdateFreq); for (int i = 3; i > 0; i--) { connCheckFreq = connCheckThreshold / i; if (connCheckFreq > 10) break; } assert connCheckFreq > 0; if (log.isInfoEnabled()) log.info("Connection check frequency is calculated: " + connCheckFreq); } {code} It should be replaced with constant. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-9011) RendezvousAffinity.excludeNeighbors should be removed and be a default behavior
Dmitry Karachentsev created IGNITE-9011: --- Summary: RendezvousAffinity.excludeNeighbors should be removed and be a default behavior Key: IGNITE-9011 URL: https://issues.apache.org/jira/browse/IGNITE-9011 Project: Ignite Issue Type: Improvement Components: cache Affects Versions: 2.6 Reporter: Dmitry Karachentsev Fix For: 3.0 According to this [discussion | http://apache-ignite-developers.2346864.n4.nabble.com/Neighbors-exclusion-td32550.html], cache backup distribution should be more straightforward. Right now we have not obvious logic on how backups will be stored across nodes. For example: 1. If set nodeFilter, it will filter backup nodes and if there are not enough nodes there will be less backups... 2. If set property excludeNeighbors, it will ignore manually set backupFilter. 3. By default excludeNeighbors is false. There seems no need to keep excludeNeighbors property at all and it should be removed. Instead, node always must do the best to distribute backups to different machines. If user set backupFilter, it must be used, otherwise distribute backups to other machines if it's possible. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-9038) Node join serialization defaults
Dmitry Karachentsev created IGNITE-9038: --- Summary: Node join serialization defaults Key: IGNITE-9038 URL: https://issues.apache.org/jira/browse/IGNITE-9038 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 2.6 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.7 staticallyConfigured flag in CacheJoinNodeDiscoveryData.CacheInfo should be true by default to keep it consistent to previous protocol. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-9257) LOCAL cache doesn't evict entries from heap
Dmitry Karachentsev created IGNITE-9257: --- Summary: LOCAL cache doesn't evict entries from heap Key: IGNITE-9257 URL: https://issues.apache.org/jira/browse/IGNITE-9257 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 2.6 Reporter: Dmitry Karachentsev Fix For: 2.7 Reproducer http://apache-ignite-users.70518.x6.nabble.com/When-using-CacheMode-LOCAL-OOM-td23285.html This happens because all entries are kept in GridCacheAdapter#map. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-9259) Wrong log message in IgniteKernal#ackMemoryConfiguration
Dmitry Karachentsev created IGNITE-9259: --- Summary: Wrong log message in IgniteKernal#ackMemoryConfiguration Key: IGNITE-9259 URL: https://issues.apache.org/jira/browse/IGNITE-9259 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 2.6 Reporter: Dmitry Karachentsev Fix For: 2.7 Message should be changed: DataStorageConfiguration.systemCacheMemorySize -> DataStorageConfiguration.systemRegionInitialSize Userlist thread: http://apache-ignite-users.70518.x6.nabble.com/System-cache-s-DataRegion-size-is-configured-to-40-MB-td23305.html -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-9425) NPE on index rebuild
Dmitry Karachentsev created IGNITE-9425: --- Summary: NPE on index rebuild Key: IGNITE-9425 URL: https://issues.apache.org/jira/browse/IGNITE-9425 Project: Ignite Issue Type: Bug Affects Versions: 2.6 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.7 Summary: This issue is seen when we have two caches mapped to two different regions (one with persistence and one without persistence) The client-side config should have the cache definitions The server-side config should have the data regions only Affinity should be defined on the cache without persistence We need to populate the data into both the caches and then restart the server and clients The issue will be seen when the client reconnects. Workaround: Add the cache configurations (for the caches without persistence) to the server-side config. Steps to reproduce: Ignite server - region1 (with persistence) - region2 (without persistence) client - cache1a from region1 – with custom affinity - cache2a fom region2 – with custom affinity 1. Populate data in both cache1a and cache2a. 2. Restart ignite server. It knows about cache1a from the persistent store. It doesn’t know about cache2a. 3. Restart client. When it connects to ignite, the server sees a nullpointer {noformat} java.lang.NullPointerException at org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$11.apply(GridCacheDatabaseSharedManager.java:1243) at org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager$11.apply(GridCacheDatabaseSharedManager.java:1239) at org.apache.ignite.internal.util.future.GridFutureAdapter.notifyListener(GridFutureAdapter.java:383) at org.apache.ignite.internal.util.future.GridFutureAdapter.listen(GridFutureAdapter.java:353) at org.apache.ignite.internal.processors.cache.persistence.GridCacheDatabaseSharedManager.rebuildIndexesIfNeeded(GridCacheDatabaseSharedManager.java:1239) at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.onDone(GridDhtPartitionsExchangeFuture.java:1711) at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.onDone(GridDhtPartitionsExchangeFuture.java:126) at org.apache.ignite.internal.util.future.GridFutureAdapter.onDone(GridFutureAdapter.java:451) at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture.init(GridDhtPartitionsExchangeFuture.java:729) at org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body0(GridCachePartitionExchangeManager.java:2419) at org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$ExchangeWorker.body(GridCachePartitionExchangeManager.java:2299) at org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110) at java.lang.Thread.run(Thread.java:748) {noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-7159) Fix IGNITE-7086 fails IgniteCacheAtomicExpiryPolicyWithStoreTest.testGetReadThrough
Dmitry Karachentsev created IGNITE-7159: --- Summary: Fix IGNITE-7086 fails IgniteCacheAtomicExpiryPolicyWithStoreTest.testGetReadThrough Key: IGNITE-7159 URL: https://issues.apache.org/jira/browse/IGNITE-7159 Project: Ignite Issue Type: Bug Reporter: Dmitry Karachentsev -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-7181) Fix IGNITE-7086 doesn't work with PESSIMISTIC REPEATABLE_READ transaction
Dmitry Karachentsev created IGNITE-7181: --- Summary: Fix IGNITE-7086 doesn't work with PESSIMISTIC REPEATABLE_READ transaction Key: IGNITE-7181 URL: https://issues.apache.org/jira/browse/IGNITE-7181 Project: Ignite Issue Type: Bug Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-7206) Nodes may ping each other on stop for a failureDetectionTimeout period
Dmitry Karachentsev created IGNITE-7206: --- Summary: Nodes may ping each other on stop for a failureDetectionTimeout period Key: IGNITE-7206 URL: https://issues.apache.org/jira/browse/IGNITE-7206 Project: Ignite Issue Type: Bug Affects Versions: 2.3 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.4 On communication connection breakage TcpCommunicationSpi may try to reestablish connection and if it's failed try to ping remote node. But if remote node is stopping it refuses incoming ping connections. In case of concurrent few node stopping there possible case when nodes ping each other and refuse any incoming pings. This lasts for failureDetectionTimeout or reconenctCount that checks in ServerImpl.pingNode() method. pingNode() should check if local node is stopping and interrupt pings. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-7239) In case of not serializable cache update response, future on node requester will never complete
Dmitry Karachentsev created IGNITE-7239: --- Summary: In case of not serializable cache update response, future on node requester will never complete Key: IGNITE-7239 URL: https://issues.apache.org/jira/browse/IGNITE-7239 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 2.3 Reporter: Dmitry Karachentsev Priority: Minor To avoid such hang, if response could not be serialized, create other response with text of the error. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-7340) Fix flaky org.apache.ignite.internal.processors.service.GridServiceProcessorMultiNodeConfigSelfTest#checkDeployOnEachNodeUpdateTopology
Dmitry Karachentsev created IGNITE-7340: --- Summary: Fix flaky org.apache.ignite.internal.processors.service.GridServiceProcessorMultiNodeConfigSelfTest#checkDeployOnEachNodeUpdateTopology Key: IGNITE-7340 URL: https://issues.apache.org/jira/browse/IGNITE-7340 Project: Ignite Issue Type: Bug Affects Versions: 2.3 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (IGNITE-7673) Remove using of Collections.UnmodifiableCollection from GridTaskSessionImpl
Dmitry Karachentsev created IGNITE-7673: --- Summary: Remove using of Collections.UnmodifiableCollection from GridTaskSessionImpl Key: IGNITE-7673 URL: https://issues.apache.org/jira/browse/IGNITE-7673 Project: Ignite Issue Type: Improvement Components: compute Affects Versions: 2.3 Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Fix For: 2.5 GridTaskWorker marshals GridTaskSessionImpl.siblings which is UnmodifiableCollection which forces use of OptimizedMarshaller that may have performance impact. It should be replaced with original collection. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (IGNITE-2691) Wrap all Marshaller interface usage to set thread local context in IgnitionEx
Dmitry Karachentsev created IGNITE-2691: --- Summary: Wrap all Marshaller interface usage to set thread local context in IgnitionEx Key: IGNITE-2691 URL: https://issues.apache.org/jira/browse/IGNITE-2691 Project: Ignite Issue Type: Sub-task Components: general Affects Versions: 1.5.0.final Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Priority: Critical Fix For: 1.6 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-2692) Set thread local context in IgnitionEx to affect cache functions
Dmitry Karachentsev created IGNITE-2692: --- Summary: Set thread local context in IgnitionEx to affect cache functions Key: IGNITE-2692 URL: https://issues.apache.org/jira/browse/IGNITE-2692 Project: Ignite Issue Type: Sub-task Components: general Affects Versions: 1.5.0.final Reporter: Dmitry Karachentsev Assignee: Dmitry Karachentsev Priority: Critical Fix For: 1.6 For any usage of cache from single user thread must be initialized thread local context in IgnitionEx to support Ignition.localIgnite() in marshalling functions. In other words, any code that might be called during marshaling must be able to get Ignite instance from Ignition.localIgnite(). -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (IGNITE-2763) GridDhtPartitionDemander fails with assertion on partition move
Dmitry Karachentsev created IGNITE-2763: --- Summary: GridDhtPartitionDemander fails with assertion on partition move Key: IGNITE-2763 URL: https://issues.apache.org/jira/browse/IGNITE-2763 Project: Ignite Issue Type: Bug Components: cache Affects Versions: 1.5.0.final Reporter: Dmitry Karachentsev Fix For: 1.6 When starts single node and is filled with cache items, then are started three new nodes GridDhtPartitionDemander fails with assertion error. java.lang.AssertionError: Partition already done [cache=cache_name, fromNode=1073a1d0-5139-44d3-9dee-399637bfd001, part=0, left=[2, 259, 771, 5, 6, 518, 774, 263, 775, 780, 271, 275, 540, 797, 30, 32, 802, 547, 807, 810, 556, 45, 301, 813, 302, 305, 561, 55, 312, 57, 59, 575, 324, 327, 331, 336, 594, 597, 598, 88, 859, 605, 606, 353, 867, 357, 871, 873, 363, 875, 371, 631, 887, 383, 640, 896, 898, 899, 644, 900, 646, 903, 905, 652, 908, 653, 912, 660, 662, 919, 153, 419, 422, 934, 172, 173, 429, 941, 176, 177, 180, 694, 953, 955, 445, 957, 959, 448, 451, 707, 199, 201, 972, 205, 718, 974, 207, 208, 721, 725, 471, 728, 985, 986, 475, 987, 477, 478, 225, 230, 233, 747, 237, 750, 497, 756, 503, 505, 1018, 1019, 764, 510, 1022]] at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander$RebalanceFuture.partitionDone(GridDhtPartitionDemander.java:978) at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander$RebalanceFuture.access$1100(GridDhtPartitionDemander.java:751) at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander.handleSupplyMessage(GridDhtPartitionDemander.java:600) at org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPreloader.handleSupplyMessage(GridDhtPreloader.java:408) at org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$5.apply(GridCachePartitionExchangeManager.java:342) at org.apache.ignite.internal.processors.cache.GridCachePartitionExchangeManager$5.apply(GridCachePartitionExchangeManager.java:335) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.processMessage(GridCacheIoManager.java:605) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.onMessage0(GridCacheIoManager.java:303) at org.apache.ignite.internal.processors.cache.GridCacheIoManager.access$400(GridCacheIoManager.java:81) at org.apache.ignite.internal.processors.cache.GridCacheIoManager$OrderedMessageListener.onMessage(GridCacheIoManager.java:1108) at org.apache.ignite.internal.managers.communication.GridIoManager$GridCommunicationMessageSet.unwind(GridIoManager.java:2239) at org.apache.ignite.internal.managers.communication.GridIoManager.unwindMessageSet(GridIoManager.java:1004) at org.apache.ignite.internal.managers.communication.GridIoManager.access$1800(GridIoManager.java:103) at org.apache.ignite.internal.managers.communication.GridIoManager$6.run(GridIoManager.java:973) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) -- This message was sent by Atlassian JIRA (v6.3.4#6332)