Re: Cache Memory Behavior \ GridDhtLocalPartition

[Isaeed Mohanna]

Hi
No, currently I add items much slower than add them, there is no
accumulation of items in the queue, i clear the queue once in 30 seconds
removing all items from the queue, the data in the queue is different from
the data in the EventsCache. can entities from events cache end up in this
internal datastarcutures_0 cache? since in the memory dump I could see
entities from EventsCache and not the queue?
I am seeing the following log , even though i doubt it, could it be somehow
connected, i do implement externalizable interface, should i switch to
binary marshaller? is it relevant at all to the memory issue?
cannot be serialized using BinaryMarshaller because it either implements
Externalizable interface or have writeObject/readObject methods
Regards

On Thu, Nov 24, 2016 at 1:04 PM, dkarachentsev 
wrote:

> Hi,
>
> Yes, you're right, this is a cache that holds data for distributed
> datastructures, and IgniteQueue as well. Is it possible that you add items
> to queue faster than poll?
>
> TxCommittedVersionsSize and TxRolledbackVersionsSize are common for all
> caches and just store versions of finished transactions, so if you have
> transactional cache you'll find that values greater than zero if there was
> made transactions. Don't worry about size, it's number finite (default is
> 262144) and takes small amount of memory.
>
>
>
> --
> View this message in context: http://apache-ignite-users.
> 70518.x6.nabble.com/Cache-Memory-Behavior-GridDhtLocalPartition-
> tp8835p9185.html
> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>

Re: AtomicSequence not performing well with 2 nodes cluster set up

[hitansu]

Thanks for the quick reply.
If I will use range, then it wont be anymore a sequence in cluster-wide.If
the range is 1000,then calling AtomicSequence.increamentAndGet() twice may
give 1 & 1001.But I want it should give 1 & 2 respectively in any situation.
Again Is it the same thing using AtomicLong or AtomicSequence with
reservesize as 0 ?



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/AtomicSequence-not-performing-well-with-2-nodes-cluster-set-up-tp9208p9253.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Package jar file path for sql Query Entity

[rishi007bansod]

I have added warehouse.java containing class warehouse to package schema.
Thats why I wrote schema.warehouse. Query I am executing is SELECT * from
warehouse w WHERE w.w_id = 1 and entry corresponding to w_id = 1 is present
in warehouse cache. schema.jar
  
this is my jar file.



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Getting-null-query-output-after-using-QueryEntity-tp9217p9252.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: MapReduce Job stuck when using ignite hadoop accelerator

[Kaiming Wan]

I can find the WARN in logs. The stuck should be caused by a long running
cache operations. How to locate what cause the long running cache
operations. My map-reduce job can run successfully without ignite hadoop
accelerator. 

[GridCachePartitionExchangeManager] Found long running cache operations,
dump IO statistics.




--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/MapReduce-Job-stuck-when-using-ignite-hadoop-accelerator-tp9216p9251.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Failed to perform request when running MR job with ignite hadoop accelerator

[Kaiming Wan]

I use the following configuration to avoid this problem. However, I after
doing this, I encounter an another problem which makes my job stuck. The
issue is described in another  message:

MapReduce Job stuck when using ignite hadoop accelerator

  










--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Failed-to-perform-request-when-running-MR-job-with-ignite-hadoop-accelerator-tp9193p9250.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Security in Ignite

[vkulichenko]

Ignite does not provide security capabilities out of the box, you need to
implement a plugin for this. Here is a good blog about this that you can use
as an example:
http://smartkey.co.uk/development/securing-an-apache-ignite-cluster/

GridGain provides their own implementation of this plugin as a part of their
paid solution: https://gridgain.readme.io/docs/security-and-audit

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Security-in-Ignite-tp9245p9249.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Secondary Key for ignite cache?

[vkulichenko]

I'm confused. Why does the key contains these additional fields? Shouldn't it
be just object ID?

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Secondary-Key-for-ignite-cache-tp9242p9248.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Cluster hung after a node killed

[vkulichenko]

Hi Sam,

If there is an explicit lock that you acquired and not released properly,
there is not much we can do. Explicit locks must be released explicitly,
doing this by timeout even more error-prone in my view. BTW, only stopping
the node that acquired the lock should've helped as well, because locks are
released in this case automatically.

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Cluster-hung-after-a-node-killed-tp8965p9247.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Secondary Key for ignite cache?

[Himetic]

The cache maps from a key that contains (the object id, the fields being
returned, json/atom/rss format) and maps it to the formatted string for that
object in the specified format.  So when we're searching the cache for the
object, we're querying using all the formatting information, but we want to
invalidate all entries in the cache using just the object id.



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Secondary-Key-for-ignite-cache-tp9242p9246.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Security in Ignite

[Lee Parayno]

Hello,

I’ve been looking for information on how data security is handled in Ignite.

The only mention I’ve seen is this:

https://apacheignite.readme.io/discuss/55006040cfeeea17004717b0 


Can anybody point me to additional docs?

Lee

Re: Secondary Key for ignite cache?

[vkulichenko]

Hi,

I'm not sure I understood the use case, can you please give more detail?
What exactly you mean by 'invalidate'? Can you give an example of a
key-value pair and describe the behavior you want to achieve?

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Secondary-Key-for-ignite-cache-tp9242p9244.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Cluster hung after a node killed

[javastuff....@gmail.com]

Ideally cluster should recover seamlessly.  Is there any locktimeout which I
can configure? or any other configuration which will make sure locks taken
by crashing node gets released and cluster still serves all requests?

Is this a bug?

-Sam



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Cluster-hung-after-a-node-killed-tp8965p9243.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Secondary Key for ignite cache?

[Himetic]

Is there a way to set and use a secondary key in ignite cache?

Our use case is that we cache string representations of objects using a
complex key that provides additional information about formatting, but we
want to invalidate using just the object ID.  There are many combinations of
formatting information, so invalidating by the primary key isn't an option.

Is there a way to do this using ignite cache?



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Secondary-Key-for-ignite-cache-tp9242.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Ignite user architecture question - Node Roles

[vkulichenko]

P.S. There is no much difference between loading from one data sources or
three data sources. Just create a cache per data source and point them to
different databases.

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Ignite-user-architecture-question-Node-Roles-tp9181p9241.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Ignite user architecture question - Node Roles

[vkulichenko]

Hi Russ,

Please refer to [1] for information about data loading. Basically, there are
two different approaches for this: using IgniteDataStreamer on client node
or CacheStore on server side (in the latter case all nodes will load all the
data and will filter out rows that should be stored locally). I would say
that the first approach is generally faster (this should be tested though),
but the second one is more durable.

I also recommend to take a close look at partition-aware loading approach
[2]. It uses CacheStore to load the data, but can give good performance
improvement due to not loading all the data to all nodes. However, it
requires database schema change.

[1] https://apacheignite.readme.io/docs/data-loading
[2]
https://apacheignite.readme.io/docs/data-loading#section-partition-aware-data-loading

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Ignite-user-architecture-question-Node-Roles-tp9181p9240.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Performance question

[vkulichenko]

Alisher,

This line does not look correct to me:

int[] partitions =
this.ignite.affinity("test.cache").primaryPartitions(this.ignite.cluster().node());

cluster().node() returns a random node from the group, it should be
localNode() instead if I understand your approach correctly.

I would also try to manually start threads to make sure that parallelization
works properly. I'm not sure how it works if you use streams.

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Performance-question-tp9218p9239.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Problem about "[GridDirectParser] Failed to read message"

[vkulichenko]

I would recommend you to switch off the shared memory first as it can be
unstable in some cases, and check if this helps. To do this add the
following in the configuration:







-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Problem-about-GridDirectParser-Failed-to-read-message-tp9210p9238.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: AtomicSequence not performing well with 2 nodes cluster set up

[vkulichenko]

Hi,

First of all, if you don't need ranges, you should use IgniteAtomicLong
instead of the sequence. But you should keep in mind that updating the
atomic long is actually the same as updating the same cache entry, so you
acquire an exclusive write lock each time you do this. That's why sequence
is much faster - it doesn't do any distributed operations within a reserved
range. If you need performance, you should revisit your approach and try
using sequences with larger ranges.

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/AtomicSequence-not-performing-well-with-2-nodes-cluster-set-up-tp9208p9237.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Behaviour of Apache Ignite instances in case of network isolation

[vkulichenko]

Hi,

Ignite detects segmentation internally, but you will end up with two
separate clusters working independently. You will have to manually resolve
this by stopping one of them. For smarter segmentation resolution you should
use GridGain.

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Behaviour-of-Apache-Ignite-instances-in-case-of-network-isolation-tp9205p9236.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Job scheduling in apache ignite for single node system

[vkulichenko]

Hi,

Please properly subscribe to the mailing list so that the community can
receive email notifications for your messages. To subscribe, send empty
email to user-subscr...@ignite.apache.org and follow simple instructions in
the reply.


pra527vin wrote
> We have a system to crawl a data from 400 different websites .To do this
> task we have created 400 processes for each site to crawlwhen we
> run program after starting about 80 threads there is memory overflow
> ...I want to know if we can use Job scheduling mechanism of Ignite to
> schedule job on the FIFO basis for this system?if yes how should I use for
> the processes I have created by own?

I would agree with Dmitry, what is the reason of doing this in separate
processes? Why not start several Ignite nodes and use Compute Grid [1] for
scaling out the computation?

[1] https://apacheignite.readme.io/docs/compute-grid

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Job-scheduling-in-apache-ignite-for-single-node-system-tp9191p9235.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Failed to perform request when running MR job with ignite hadoop accelerator

[vkulichenko]

Hi,

It looks like a connectivity problem. Can you try to telnet to port 11211
and check if it works? Can there be a firewall in between?

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Failed-to-perform-request-when-running-MR-job-with-ignite-hadoop-accelerator-tp9193p9234.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Throwing and catching user exceptions in Ignite Services

[vkulichenko]

The best way to speed this up is to create your own patch and contribute to
the project ;) If you're willing to do this, go through [1], assign ticket
to yourself and send an email to dev list. Guys there will assist you with
development related questions.

[1] http://ignite.apache.org/community/contribute.html#contribute

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Throwing-and-catching-user-exceptions-in-Ignite-Services-tp9143p9233.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Blocked get operation problem

[vkulichenko]

What's your business use case? If you have only one key, then you will indeed
have lock-the-world on each operation, but this is very not typical use case
for Ignite. Are you sure your approach is correct? What problem are you
trying to solve by switching to Ignite?

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Blocked-get-operation-problem-tp9133p9232.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Swap space

[vkulichenko]

Can you give a link to the thread? If it's a different issue, let's discuss
there.

-Val



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Swap-space-tp8156p9231.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Disabling client notifications

[lawrencefinn]

Sorry i missed this response.  The problem was actually that I was not
setting null correctly in binary objects so the schema kept updating in all
the nodes over and over.  woops



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Disabling-client-notifications-tp8704p9230.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Performance question

[Alisher Alimov]

I found only one way to parallelize read via ScanQuery

int[] partitions = 
this.ignite.affinity("test.cache").primaryPartitions(this.ignite.cluster().node());

startTime = System.currentTimeMillis();

Arrays.stream(partitions)
  .parallel()
  .forEach(partition -> {
  ScanQuery qry = new ScanQuery<>(partition);
  qry.setLocal(true);
  qry.setPageSize(5_000);

  QueryCursor> query = cache.query(qry);
  List> all = query.getAll();
  });

System.out.println(String.format("Complete in: %dms", 
System.currentTimeMillis() - startTime));

But it’s doesn’t help a lot (speed was downgrade on 10-20%) or there is another 
good solution to do it?



With best regards
Alisher Alimov
alimovalis...@gmail.com




> On 28 Nov 2016, at 19:38, Alexey Goncharuk  wrote:
> 
> Hi Alisher,
> 
> As Nicolae suggested, try parallelizing your scan using per-partition 
> iterator. This should give you almost linear performance growth up to the 
> number of available CPUs.
> Also make sure to set CacheConfiguration#copyOnRead flag to false. 
> 
> --AG
> 
> 2016-11-28 19:31 GMT+03:00 Marasoiu Nicolae  >:
> ​Regarding CPU load, a single thread of execution exists in the program so 
> (at most) one core is used. So if you have 8 cores, it means that it is 8 to 
> 16 times slower than a program able to use all the cores & CPU redundancy of 
> the machine.
> In my tests, indeed, a core looks fully utilized. To me, scanning 1M 
> key-values per second is pretty ok, but indeed, if LMAX got 6M transactions 
> per core per second, it can perhaps go up, but something tells me this will 
> not be the limitation of the typical application.
> 
> Met vriendelijke groeten / Meilleures salutations / Best regards
> 
> Nicolae Marasoiu 
> Agile Developer
>   
> E  nicolae.maras...@cegeka.com   
> 
>   CEGEKA 15-17 Ion Mihalache Blvd. Tower Center Building, 
> 4th,5th,6th,8th,9th fl
> RO-011171 Bucharest (RO), Romania
> T +40 21 336 20 65
> WWW.CEGEKA.COM 
>   
> De la: Alisher Alimov  >
> Trimis: 28 noiembrie 2016 15:27
> Către: user@ignite.apache.org 
> Subiect: Performance question
>  
> Hello!
> 
> I have write and run a simple performance test to check 
> IgniteCache#localEntries and found that current method is not enough fast.
> 
> Ignite ignite = Ignition.start();
> 
> CacheConfiguration cacheConfiguration = new 
> CacheConfiguration<>();
> cacheConfiguration.setBackups(0);
> 
> IgniteCache cache = ignite.getOrCreateCache("test.cache");
> 
> for (int i = 0; i < 1_000_000; i++) {
> cache.put(UUID.randomUUID(), UUID.randomUUID());
> }
> 
> long startTime = System.currentTimeMillis();
> 
> cache.localEntries(CachePeekMode.PRIMARY).forEach(entry -> {
> });
> 
> System.out.println(String.format("Complete in: %dms", 
> System.currentTimeMillis() - startTime));
> 
> Reading local entries take about 1s (1000 rows per ms) that’s is low. 
> Test was run on server with provided configuration with default Ignite 
> configs, load average was about 0 and CPU was not busy more than 10%
> Intel(R) Xeon(R) CPU   E5645  @ 2.40GHz
> 
> 
> May be I do  or configure something wrong or current speed is normal?
> 
> 
> With best regards
> Alisher Alimov
> alimovalis...@gmail.com 
> 
> 
> 
> 
> 

Re: Package jar file path for sql Query Entity

[Vladislav Pyatkov]

Hi,

Is it correct class name?



If you want to save several different classes to the cache, you must set
some matched "QueryEntry" 's.
Could you please provide the jar file?

On Mon, Nov 28, 2016 at 2:17 PM, rishi007bansod 
wrote:

> I have written following query entity for my database
>
> up1.xml  >
>
> For this query entity I have created jar file of package schema, which
> contains warehouse class. I kept this jar file in libs folder in apache
> ignite installation path. But when I run query on "warehouse cache" that I
> have created I am always getting null(blank) result. Even if I remove this
> jar file from libs folder(and keeping same xml file), still the query runs
> but gives null(blank) result. I think this packaged jar file is not getting
> included when ignite is running. So where should this jar file kept, so
> that
> i can be automatically loaded when ignite starts?
>
>
>
> --
> View this message in context: http://apache-ignite-users.
> 70518.x6.nabble.com/Package-jar-file-path-for-sql-Query-Entity-tp9217.html
> Sent from the Apache Ignite Users mailing list archive at Nabble.com.
>



-- 
Vladislav Pyatkov

Re: Cache transformations

[vdpyatkov]

And take attention: "DataStreamer" and "Ignite Compute" use one thred pool
(public thread pool). Hence you should execute work with streamer
asynchronously (other side you risk to get a thread starvation).



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Cache-transformations-tp9219p9227.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Cache transformations

[vdpyatkov]

Hi,

Now one node of Ignite execute the operation at only a one thread. You
should use one thread by partition, those. scan query[1] with method
"setPartition" (instance of local entries).
Using affinity[2] for determine partition by nodes and run your task by
each.

You can slightly increase performance if you are explicitly implement
Externalizable interface for the IgniteRunable.

[1]: http://apacheignite.gridgain.org/docs/cache-queries#scan-queries
[2]:
https://ignite.apache.org/releases/1.7.0/javadoc/org/apache/ignite/Ignite.html#affinity(java.lang.String)



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Cache-transformations-tp9219p9226.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Performance question

[Alexey Goncharuk]

Hi Alisher,

As Nicolae suggested, try parallelizing your scan using per-partition
iterator. This should give you almost linear performance growth up to the
number of available CPUs.
Also make sure to set CacheConfiguration#copyOnRead flag to false.

--AG

2016-11-28 19:31 GMT+03:00 Marasoiu Nicolae :

> ​Regarding CPU load, a single thread of execution exists in the program so
> (at most) one core is used. So if you have 8 cores, it means that it is 8
> to 16 times slower than a program able to use all the cores & CPU
> redundancy of the machine.
>
> In my tests, indeed, a core looks fully utilized. To me, scanning 1M
> key-values per second is pretty ok, but indeed, if LMAX got 6M transactions
> per core per second, it can perhaps go up, but something tells me this will
> not be the limitation of the typical application.
>
>
> Met vriendelijke groeten / Meilleures salutations / Best regards
>
> *Nicolae Marasoiu*
> *Agile Developer*
>
> *E*  *nicolae.maras...@cegeka.com *
>
> CEGEKA 15-17 Ion Mihalache Blvd. Tower Center Building,
> 4th,5th,6th,8th,9th fl
> RO-011171 Bucharest (RO), Romania
> *T* +40 21 336 20 65
> *WWW.CEGEKA.COM *  [image: LinkedIn]
> 
> --
> *De la:* Alisher Alimov 
> *Trimis:* 28 noiembrie 2016 15:27
> *Către:* user@ignite.apache.org
> *Subiect:* Performance question
>
> Hello!
>
> I have write and run a simple performance test to check
> IgniteCache#localEntries and found that current method is not enough fast.
>
> Ignite ignite = Ignition.start();
>
>
> CacheConfiguration cacheConfiguration = new 
> CacheConfiguration<>();
> cacheConfiguration.setBackups(0);
>
> IgniteCache cache = ignite.getOrCreateCache("test.cache");
>
> for (int i = 0; i < 1_000_000; i++) {
> cache.put(UUID.randomUUID(), UUID.randomUUID());
> }
>
> long startTime = System.currentTimeMillis();
>
> cache.localEntries(CachePeekMode.PRIMARY).forEach(entry -> {
> });
>
> System.out.println(String.format("Complete in: %dms", 
> System.currentTimeMillis() - startTime));
>
>
> Reading local entries take about 1s (1000 rows per ms) that’s is low.
> Test was run on server with provided configuration with default Ignite
> configs, load average was about 0 and CPU was not busy more than 10%
> Intel(R) Xeon(R) CPU   E5645  @ 2.40GHz
>
>
> May be I do  or configure something wrong or current speed is normal?
>
>
> With best regards
> Alisher Alimov
> alimovalis...@gmail.com
>
>
>
>
>

Re: Cassandra basic setup

[Igor Rudyak]

If you are using ignite.sh it should be fine.

Igor

On Nov 28, 2016 8:29 AM, "Riccardo Iacomini" 
wrote:

> I will try. Yes I am using the ignite.sh command. Any drawbacks?
>
> Il 28 nov 2016 5:26 PM, "Igor Rudyak"  ha scritto:
>
> Try to check your classpath. Find ignite process usig something like  ps
> -es | grep  Ignite and check java command used to launch ignite.
>
> By the way, how you launching Ignite? Do you use ignite.sh script for this?
>
> Igor
>
> On Nov 28, 2016 8:05 AM, "Riccardo Iacomini" 
> wrote:
>
>> Hi Igor,
>> I tried your suggestion, but it does find the class. I've also read from
>> the README files that optional modules must be copied into the libs folder:
>> same outcome. I've tried also the docker image, adding my configuration xml
>> files to it, and running the image as specified here
>>  in the
>> documentation. Do you have any other suggestion?
>>
>> Thanks for your patience.
>>
>> Best regards
>>
>> Riccardo Iacomini
>>
>>
>> *RDSLab*
>>
>> On Sun, Nov 27, 2016 at 8:46 PM, Igor Rudyak  wrote:
>>
>>> Try to include required jars into IGNITE_LIBS environment variable.
>>>
>>> Igor
>>>
>>> On Thu, Nov 24, 2016 at 5:21 AM, Riccardo Iacomini <
>>> riccardo.iacom...@rdslab.com> wrote:
>>>
 Hi Igor,
 thanks for your reply. I've both tried building ignite from source and
 removing CassandraAdminCredentials class specifying username and password
 in the bean's properties. Anyway, I cannot get it work. Ignite still cannot
 find the required classes, this time 
 *org.apache.ignite.cache.store.cassandra.utils.datasource.DataSource.
 *The class is indeed located in the jar ignite-cassandra-1.7.0.jar in
 IGNITE_HOME/modules/cassandra/target. I tried adding the path to
 USER_LIBS and CLASSPATH, no different behavior. Maybe the environment
 variables got ignored?


 Riccardo Iacomini


 *RDSLab*

 On Wed, Nov 23, 2016 at 7:41 PM, Igor Rudyak  wrote:

> Hi Riccardo,
>
> *CassandraAdminCredentials *class is only available in Ignite unit
> tests sources. If you want to use it you should build Ignite from source
> code. Such way, it will create
> *ignite-cassandra-tests-${project.version}.zip* where jar may find
> jar file containing all the test classes.
>
> Also if you want to use Cassandra as a persistent store you actually
> don't need *CassandraAdminCredentials  *cause it's just used for
> tests.
>
> Igor
>
> On Wed, Nov 23, 2016 at 7:33 AM, Riccardo Iacomini <
> riccardo.iacom...@rdslab.com> wrote:
>
>> Following the example 
>> provided in the docs, I am trying to setup a basic Ignite cluster using
>> Cassandra as persistent store. I've downloaded ignite 1.7 and created the
>> configuration files. Ignite does read them at startup, but I get this 
>> error
>> message:
>>
>> *class org.apache.ignite.IgniteException: Failed to instantiate
>> Spring XML application context (make sure all classes used in Spring
>> configuration are present at CLASSPATH*
>>
>> CassandraAdminCredentials is the class not being found. Commenting
>> the bean, I get the same for the next class. I tried adding the path to 
>> the
>> jar *ignite-cassandra-1.7.0.jar *to both CLASSPATH and USER_LIBS,
>> still not getting found. Opening the jar I cannot find the requested 
>> class.
>> Am I missing some dependencies?
>>
>> Thank you for your help.
>>
>> Riccardo Iacomini
>>
>>
>> *RDSLab*
>>
>
>

>>>
>>
>

Re: Performance question

[Marasoiu Nicolae]

?Regarding CPU load, a single thread of execution exists in the program so (at 
most) one core is used. So if you have 8 cores, it means that it is 8 to 16 
times slower than a program able to use all the cores & CPU redundancy of the 
machine.

In my tests, indeed, a core looks fully utilized. To me, scanning 1M key-values 
per second is pretty ok, but indeed, if LMAX got 6M transactions per core per 
second, it can perhaps go up, but something tells me this will not be the 
limitation of the typical application.


Met vriendelijke groeten / Meilleures salutations / Best regards


Nicolae Marasoiu
Agile Developer

[http://signature.cegeka.com/2016/stripe-small.jpg]


E  nicolae.maras...@cegeka.com


[http://signature.cegeka.com/2016/stripe-large.jpg]


[http://signature.cegeka.com/2016/logo.jpg] CEGEKA 15-17 Ion Mihalache 
Blvd. Tower Center Building, 4th,5th,6th,8th,9th fl
RO-011171 Bucharest (RO), Romania
T +40 21 336 20 65
WWW.CEGEKA.COM   [LinkedIn]  




De la: Alisher Alimov 
Trimis: 28 noiembrie 2016 15:27
Către: user@ignite.apache.org
Subiect: Performance question

Hello!

I have write and run a simple performance test to check 
IgniteCache#localEntries and found that current method is not enough fast.


Ignite ignite = Ignition.start();

CacheConfiguration cacheConfiguration = new CacheConfiguration<>();
cacheConfiguration.setBackups(0);

IgniteCache cache = ignite.getOrCreateCache("test.cache");

for (int i = 0; i < 1_000_000; i++) {
cache.put(UUID.randomUUID(), UUID.randomUUID());
}


long startTime = System.currentTimeMillis();

cache.localEntries(CachePeekMode.PRIMARY).forEach(entry -> {
});


System.out.println(String.format("Complete in: %dms", 
System.currentTimeMillis() - startTime));

Reading local entries take about 1s (1000 rows per ms) that's is low.
Test was run on server with provided configuration with default Ignite configs, 
load average was about 0 and CPU was not busy more than 10%
Intel(R) Xeon(R) CPU   E5645  @ 2.40GHz


May be I do  or configure something wrong or current speed is normal?


With best regards
Alisher Alimov
alimovalis...@gmail.com

Re: Cassandra basic setup

[Riccardo Iacomini]

I will try. Yes I am using the ignite.sh command. Any drawbacks?

Il 28 nov 2016 5:26 PM, "Igor Rudyak"  ha scritto:

Try to check your classpath. Find ignite process usig something like  ps
-es | grep  Ignite and check java command used to launch ignite.

By the way, how you launching Ignite? Do you use ignite.sh script for this?

Igor

On Nov 28, 2016 8:05 AM, "Riccardo Iacomini" 
wrote:

> Hi Igor,
> I tried your suggestion, but it does find the class. I've also read from
> the README files that optional modules must be copied into the libs folder:
> same outcome. I've tried also the docker image, adding my configuration xml
> files to it, and running the image as specified here
>  in the
> documentation. Do you have any other suggestion?
>
> Thanks for your patience.
>
> Best regards
>
> Riccardo Iacomini
>
>
> *RDSLab*
>
> On Sun, Nov 27, 2016 at 8:46 PM, Igor Rudyak  wrote:
>
>> Try to include required jars into IGNITE_LIBS environment variable.
>>
>> Igor
>>
>> On Thu, Nov 24, 2016 at 5:21 AM, Riccardo Iacomini <
>> riccardo.iacom...@rdslab.com> wrote:
>>
>>> Hi Igor,
>>> thanks for your reply. I've both tried building ignite from source and
>>> removing CassandraAdminCredentials class specifying username and password
>>> in the bean's properties. Anyway, I cannot get it work. Ignite still cannot
>>> find the required classes, this time 
>>> *org.apache.ignite.cache.store.cassandra.utils.datasource.DataSource.
>>> *The class is indeed located in the jar ignite-cassandra-1.7.0.jar in
>>> IGNITE_HOME/modules/cassandra/target. I tried adding the path to
>>> USER_LIBS and CLASSPATH, no different behavior. Maybe the environment
>>> variables got ignored?
>>>
>>>
>>> Riccardo Iacomini
>>>
>>>
>>> *RDSLab*
>>>
>>> On Wed, Nov 23, 2016 at 7:41 PM, Igor Rudyak  wrote:
>>>
 Hi Riccardo,

 *CassandraAdminCredentials *class is only available in Ignite unit
 tests sources. If you want to use it you should build Ignite from source
 code. Such way, it will create
 *ignite-cassandra-tests-${project.version}.zip* where jar may find jar
 file containing all the test classes.

 Also if you want to use Cassandra as a persistent store you actually
 don't need *CassandraAdminCredentials  *cause it's just used for tests.

 Igor

 On Wed, Nov 23, 2016 at 7:33 AM, Riccardo Iacomini <
 riccardo.iacom...@rdslab.com> wrote:

> Following the example 
> provided in the docs, I am trying to setup a basic Ignite cluster using
> Cassandra as persistent store. I've downloaded ignite 1.7 and created the
> configuration files. Ignite does read them at startup, but I get this 
> error
> message:
>
> *class org.apache.ignite.IgniteException: Failed to instantiate Spring
> XML application context (make sure all classes used in Spring 
> configuration
> are present at CLASSPATH*
>
> CassandraAdminCredentials is the class not being found. Commenting the
> bean, I get the same for the next class. I tried adding the path to the 
> jar *ignite-cassandra-1.7.0.jar
> *to both CLASSPATH and USER_LIBS, still not getting found. Opening
> the jar I cannot find the requested class. Am I missing some dependencies?
>
> Thank you for your help.
>
> Riccardo Iacomini
>
>
> *RDSLab*
>


>>>
>>
>

Re: Cassandra basic setup

[Igor Rudyak]

Try to check your classpath. Find ignite process usig something like  ps
-es | grep  Ignite and check java command used to launch ignite.

By the way, how you launching Ignite? Do you use ignite.sh script for this?

Igor

On Nov 28, 2016 8:05 AM, "Riccardo Iacomini" 
wrote:

> Hi Igor,
> I tried your suggestion, but it does find the class. I've also read from
> the README files that optional modules must be copied into the libs folder:
> same outcome. I've tried also the docker image, adding my configuration xml
> files to it, and running the image as specified here
>  in the
> documentation. Do you have any other suggestion?
>
> Thanks for your patience.
>
> Best regards
>
> Riccardo Iacomini
>
>
> *RDSLab*
>
> On Sun, Nov 27, 2016 at 8:46 PM, Igor Rudyak  wrote:
>
>> Try to include required jars into IGNITE_LIBS environment variable.
>>
>> Igor
>>
>> On Thu, Nov 24, 2016 at 5:21 AM, Riccardo Iacomini <
>> riccardo.iacom...@rdslab.com> wrote:
>>
>>> Hi Igor,
>>> thanks for your reply. I've both tried building ignite from source and
>>> removing CassandraAdminCredentials class specifying username and password
>>> in the bean's properties. Anyway, I cannot get it work. Ignite still cannot
>>> find the required classes, this time 
>>> *org.apache.ignite.cache.store.cassandra.utils.datasource.DataSource.
>>> *The class is indeed located in the jar ignite-cassandra-1.7.0.jar in
>>> IGNITE_HOME/modules/cassandra/target. I tried adding the path to
>>> USER_LIBS and CLASSPATH, no different behavior. Maybe the environment
>>> variables got ignored?
>>>
>>>
>>> Riccardo Iacomini
>>>
>>>
>>> *RDSLab*
>>>
>>> On Wed, Nov 23, 2016 at 7:41 PM, Igor Rudyak  wrote:
>>>
 Hi Riccardo,

 *CassandraAdminCredentials *class is only available in Ignite unit
 tests sources. If you want to use it you should build Ignite from source
 code. Such way, it will create
 *ignite-cassandra-tests-${project.version}.zip* where jar may find jar
 file containing all the test classes.

 Also if you want to use Cassandra as a persistent store you actually
 don't need *CassandraAdminCredentials  *cause it's just used for tests.

 Igor

 On Wed, Nov 23, 2016 at 7:33 AM, Riccardo Iacomini <
 riccardo.iacom...@rdslab.com> wrote:

> Following the example 
> provided in the docs, I am trying to setup a basic Ignite cluster using
> Cassandra as persistent store. I've downloaded ignite 1.7 and created the
> configuration files. Ignite does read them at startup, but I get this 
> error
> message:
>
> *class org.apache.ignite.IgniteException: Failed to instantiate Spring
> XML application context (make sure all classes used in Spring 
> configuration
> are present at CLASSPATH*
>
> CassandraAdminCredentials is the class not being found. Commenting the
> bean, I get the same for the next class. I tried adding the path to the 
> jar *ignite-cassandra-1.7.0.jar
> *to both CLASSPATH and USER_LIBS, still not getting found. Opening
> the jar I cannot find the requested class. Am I missing some dependencies?
>
> Thank you for your help.
>
> Riccardo Iacomini
>
>
> *RDSLab*
>


>>>
>>
>

Re: Cassandra basic setup

[Riccardo Iacomini]

Hi Igor,
I tried your suggestion, but it does find the class. I've also read from
the README files that optional modules must be copied into the libs folder:
same outcome. I've tried also the docker image, adding my configuration xml
files to it, and running the image as specified here
 in the
documentation. Do you have any other suggestion?

Thanks for your patience.

Best regards

Riccardo Iacomini


*RDSLab*

On Sun, Nov 27, 2016 at 8:46 PM, Igor Rudyak  wrote:

> Try to include required jars into IGNITE_LIBS environment variable.
>
> Igor
>
> On Thu, Nov 24, 2016 at 5:21 AM, Riccardo Iacomini <
> riccardo.iacom...@rdslab.com> wrote:
>
>> Hi Igor,
>> thanks for your reply. I've both tried building ignite from source and
>> removing CassandraAdminCredentials class specifying username and password
>> in the bean's properties. Anyway, I cannot get it work. Ignite still cannot
>> find the required classes, this time 
>> *org.apache.ignite.cache.store.cassandra.utils.datasource.DataSource.
>> *The class is indeed located in the jar ignite-cassandra-1.7.0.jar in
>> IGNITE_HOME/modules/cassandra/target. I tried adding the path to
>> USER_LIBS and CLASSPATH, no different behavior. Maybe the environment
>> variables got ignored?
>>
>>
>> Riccardo Iacomini
>>
>>
>> *RDSLab*
>>
>> On Wed, Nov 23, 2016 at 7:41 PM, Igor Rudyak  wrote:
>>
>>> Hi Riccardo,
>>>
>>> *CassandraAdminCredentials *class is only available in Ignite unit
>>> tests sources. If you want to use it you should build Ignite from source
>>> code. Such way, it will create
>>> *ignite-cassandra-tests-${project.version}.zip* where jar may find jar
>>> file containing all the test classes.
>>>
>>> Also if you want to use Cassandra as a persistent store you actually
>>> don't need *CassandraAdminCredentials  *cause it's just used for tests.
>>>
>>> Igor
>>>
>>> On Wed, Nov 23, 2016 at 7:33 AM, Riccardo Iacomini <
>>> riccardo.iacom...@rdslab.com> wrote:
>>>
 Following the example 
 provided in the docs, I am trying to setup a basic Ignite cluster using
 Cassandra as persistent store. I've downloaded ignite 1.7 and created the
 configuration files. Ignite does read them at startup, but I get this error
 message:

 *class org.apache.ignite.IgniteException: Failed to instantiate Spring
 XML application context (make sure all classes used in Spring configuration
 are present at CLASSPATH*

 CassandraAdminCredentials is the class not being found. Commenting the
 bean, I get the same for the next class. I tried adding the path to the 
 jar *ignite-cassandra-1.7.0.jar
 *to both CLASSPATH and USER_LIBS, still not getting found. Opening the
 jar I cannot find the requested class. Am I missing some dependencies?

 Thank you for your help.

 Riccardo Iacomini


 *RDSLab*

>>>
>>>
>>
>

Cache transformations

[nskovpin]

Hello!
My current goal is to transform initial cache to different types of caches.
For example, I have IgniteCache initCache ( BinaryObject
value consists of *4* fields) and i want to create IgniteCache secondCache (BinaryObject value consists of *2* fields). I use
BinaryObject type, because it is impossible to me to predict input scheme.
I've created IgniteRunnable class that suits my prupose (copy fields from
inputCache and insert them to a new cache):
 
I run this code on 4 nodes with 2Gb and 4 CPU, input data - 1.3 Gb. But the
execusion is very slow (2 min+).
So, i have 3 questions:
1) How can i improve a speed?
2) How can i load data directly on local server nodes (i think that my
approach makes data transfers between server nodes).
Thanks



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Cache-transformations-tp9219.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Performance question

[Alisher Alimov]

Hello!

I have write and run a simple performance test to check 
IgniteCache#localEntries and found that current method is not enough fast.

Ignite ignite = Ignition.start();

CacheConfiguration cacheConfiguration = new CacheConfiguration<>();
cacheConfiguration.setBackups(0);

IgniteCache cache = ignite.getOrCreateCache("test.cache");

for (int i = 0; i < 1_000_000; i++) {
cache.put(UUID.randomUUID(), UUID.randomUUID());
}

long startTime = System.currentTimeMillis();

cache.localEntries(CachePeekMode.PRIMARY).forEach(entry -> {
});

System.out.println(String.format("Complete in: %dms", 
System.currentTimeMillis() - startTime));

Reading local entries take about 1s (1000 rows per ms) that’s is low. 
Test was run on server with provided configuration with default Ignite configs, 
load average was about 0 and CPU was not busy more than 10%
Intel(R) Xeon(R) CPU   E5645  @ 2.40GHz


May be I do  or configure something wrong or current speed is normal?


With best regards
Alisher Alimov
alimovalis...@gmail.com

Package jar file path for sql Query Entity

[rishi007bansod]

I have written following query entity for my database

up1.xml   

For this query entity I have created jar file of package schema, which
contains warehouse class. I kept this jar file in libs folder in apache
ignite installation path. But when I run query on "warehouse cache" that I
have created I am always getting null(blank) result. Even if I remove this
jar file from libs folder(and keeping same xml file), still the query runs
but gives null(blank) result. I think this packaged jar file is not getting
included when ignite is running. So where should this jar file kept, so that
i can be automatically loaded when ignite starts? 



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Package-jar-file-path-for-sql-Query-Entity-tp9217.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

MapReduce Job stuck when using ignite hadoop accelerator

[Kaiming Wan]

Hi,


Recently, I did some experiments to test the map-reduce job's
performance with ignite hadoop accelerator. It really make sense to
accelerate a map-reduce job. In my previous experiment, I store a 10GB file
into IGFS. I design a I/O intensive job whose duty is only to read the 10GB
file. I find that using IGFS can accelerate my job obviously.


However, when I change to test on the map-reduce job which is used in
our production environment. The job is stuck when running. The job will read
more than 30GB data and produce more than 150GB intermediate data.


My basic info:

I have three node cluster.
host1:10.8.12.16:  40 cores 125GB memory
host2:10.8.12.17:  40 cores 125GB memory
host3:10.8.12.18:  40 cores 125GB memory


The full configuration file on host1:






http://www.springframework.org/schema/beans";
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:util="http://www.springframework.org/schema/util";
   xsi:schemaLocation="http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans.xsd
   http://www.springframework.org/schema/util
   http://www.springframework.org/schema/util/spring-util.xsd";>



Spring file for Ignite node configuration with IGFS and Apache
Hadoop map-reduce support enabled.
Ignite node will start with this configuration by default.























 


























































































































 





The only difference in configuration among the hosts are "eviction maxsize".
host1 use small "maxSize" because there is not enough memory to use on
host1.

host2 and host3's only difference in configuration:











The only difference in ignite.sh is the JVM option(I use JDK8):

host1:

if [ -z "$JVM_OPTS" ] ; then
if [[ `"$JAVA" -version 2>&1 | egrep "1\.[7]\."` ]]; then
JVM_OPTS="-Xms1g -Xmx1g -server -XX:+AggressiveOpts
-XX:MaxPermSize=256m"
else
JVM_OPTS="-Xms5g -Xmx30g -server -XX:+AggressiveOpts
-XX:MaxMetaspaceSize=10g"
fi
fi


host2 and host3:
if [ -z "$JVM_OPTS" ] ; then
if [[ `"$JAVA" -version 2>&1 | egrep "1\.[7]\."` ]]; then
JVM_OPTS="-Xms1g -Xmx1g -server -XX:+AggressiveOpts
-XX:MaxPermSize=256m"
else
JVM_OPTS="-Xms8g -Xmx60g -server -XX:+AggressiveOpts
-XX:MaxMetaspaceSize=10g"
fi
fi



Our production map-reduce job usually will finish in 30 minutes. However,
when using IGFS, I have waiting for about 2 hours.


The job is stuck in :

...
Nov 28, 2016 4:58:52 PM
org.apache.ignite.internal.client.impl.connection.GridClientNioTcpConnection

INFO: Client TCP connection established: /10.8.12.16:11211
Nov 28, 2016 4:58:52 PM
org.apache.ignite.internal.client.impl.GridClientImpl 
INFO: Client started [id=337ab72f-4c01-4fc6-849c-1e3920dbfcbb, protocol=TCP]
16/11/28 16:58:52 WARN mapreduce.JobResourceUploader: Hadoop command-line
option parsing not performed. Implement the Tool interface and execute your
application with ToolRunner to remedy this.
16/11/28 16:58:53 INFO input.FileInputFormat: Total input paths to process :
25
16/11/28 16:58:54 INF

Re: How to config timeout configuration?

[Kaiming Wan]

I use the following configuration to avoid this problem.










--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/How-to-config-timeout-configuration-tp9206p9215.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Why ignite hadoop accelerator can't improve performance with cluster mode?

[Kaiming Wan]

Maybe it is caused by the configuration. And the first load is always slow. I
tuned the configuration and the job goes well on my cluster.



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Why-ignite-hadoop-accelerator-can-t-improve-performance-with-cluster-mode-tp9192p9214.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Behaviour of Apache Ignite instances in case of network isolation

[Navneet Kumar]

TYPO all I need to know Is there any Network Segmentation Protection support
is there in free



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Behaviour-of-Apache-Ignite-instances-in-case-of-network-isolation-tp9205p9213.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: Behaviour of Apache Ignite instances in case of network isolation

[Navneet Kumar]

I don't think is there network segregation support is there in free edition.
I see in GG the similar support is there.



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Behaviour-of-Apache-Ignite-instances-in-case-of-network-isolation-tp9205p9212.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Re: CacheConfiguration. AffinityFunction or node filter

[Vladislav Pyatkov]

Hi Alisher,

Of course, you should use the filter assembly (CacheConfiguration #
setNodeFilter), it provides an easy way to deploy a cache on a particular
node.
Affinity function takes care of the balance of these sections between
nodes. Implementation of the functions may not be so  easy.



On Mon, Nov 28, 2016 at 10:04 AM, Alisher Alimov 
wrote:

> Hello!
>
> I have a cluster and want to store cache (primary and backups) on
> concretes nodes by filter. I can do it by providing AffinityFunction in
> org.apache.ignite.configuration.CacheConfiguration#setAffinity or
> IgnitePredicate in 
> org.apache.ignite.configuration.CacheConfiguration#setNodeFilter.
> Does they work the same way or what is the best practise?
>
> With best regards
> Alisher Alimov
> alimovalis...@gmail.com
>
>
>
>
>


-- 
Vladislav Pyatkov

Problem about "[GridDirectParser] Failed to read message"

[ght230]

One Ignite client disconnected from the cluster when it was doing continuous
query,
 the error message of the client as following:

[14:42:07,630][ERROR][shmem-worker-#1642%null%][GridDirectParser] Failed to
read message [msg=GridIoMessage [plc=0, topic=null, topicOrd=-1,
ordered=false, timeout=0, skipOnTimeout=false, msg=null],
buf=java.nio.HeapByteBuffer[pos=22 lim=107 cap=8192], reader=null,
ses=GridNioSessionImpl [locAddr=null, rmtAddr=null,
createTime=1479969726540, closeTime=1479969726611, bytesSent=0, bytesRcvd=0,
sndSchedTime=1479969726540, lastSndTime=1479969726540,
lastRcvTime=1479969726540, readsPaused=false,
filterChain=FilterChain[filters=[GridNioCodecFilter
[parser=o.a.i.i.util.nio.GridDirectParser@3b9c89b, directMode=true],
GridConnectionBytesVerifyFilter], accepted=true]]
java.lang.NullPointerException
at
org.apache.ignite.internal.managers.communication.GridIoMessage.readFrom(GridIoMessage.java:247)
~[ignite-core-1.6.8.jar:1.6.8]
at
org.apache.ignite.internal.util.nio.GridDirectParser.decode(GridDirectParser.java:84)
[ignite-core-1.6.8.jar:1.6.8]
at
org.apache.ignite.internal.util.nio.GridNioCodecFilter.onMessageReceived(GridNioCodecFilter.java:104)
[ignite-core-1.6.8.jar:1.6.8]
at
org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:107)
[ignite-core-1.6.8.jar:1.6.8]
at
org.apache.ignite.internal.util.nio.GridConnectionBytesVerifyFilter.onMessageReceived(GridConnectionBytesVerifyFilter.java:113)
[ignite-core-1.6.8.jar:1.6.8]
at
org.apache.ignite.internal.util.nio.GridNioFilterAdapter.proceedMessageReceived(GridNioFilterAdapter.java:107)
[ignite-core-1.6.8.jar:1.6.8]
at
org.apache.ignite.internal.util.ipc.IpcToNioAdapter$HeadFilter.onMessageReceived(IpcToNioAdapter.java:212)
[ignite-core-1.6.8.jar:1.6.8]
at
org.apache.ignite.internal.util.nio.GridNioFilterChain.onMessageReceived(GridNioFilterChain.java:173)
[ignite-core-1.6.8.jar:1.6.8]
at
org.apache.ignite.internal.util.ipc.IpcToNioAdapter.serve(IpcToNioAdapter.java:122)
[ignite-core-1.6.8.jar:1.6.8]
at
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$ShmemWorker.body(TcpCommunicationSpi.java:3047)
[ignite-core-1.6.8.jar:1.6.8]
at
org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110)
[ignite-core-1.6.8.jar:1.6.8]
at java.lang.Thread.run(Thread.java:745) [?:1.7.0_80] 

But In server side, there is no special error message at that time.



--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Problem-about-GridDirectParser-Failed-to-read-message-tp9210.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.