.net decimal -> Ignite is being stored as Other

2018-09-18 Thread wt
i have the following class

[QuerySqlField]
public int vd { get; set; }
[QuerySqlField]
public long sharesinindex { get; set; }
[QuerySqlField]
public string name { get; set; }
[QuerySqlField]
public string isin { get; set; }
[QuerySqlField]
public string sedol { get; set; }
[QuerySqlField]
public string ric { get; set; }
[QuerySqlField]
public decimal close { get; set; }
[QuerySqlField]
public decimal rate { get; set; }

when i configure ignite with this class in .net and start the server it
correctly sets all the other fields just not the decimals. The documentation
states

DECIMAL
Possible values: Data type with fixed precision and scale.

Mapped to:

Java/JDBC: java.math.BigDecimal
.NET/C#: decimal
C/C++: ignite::Decimal
ODBC: SQL_DECIMAL


Why is Ignite not mapping this correctly ->  tables.png
  


here is the config

var cfg = new IgniteConfiguration
{
DiscoverySpi = new TcpDiscoverySpi
{
IpFinder = new TcpDiscoveryStaticIpFinder
{
Endpoints = new[] { "127.0.0.1:47500..47509" }
},
SocketTimeout = TimeSpan.FromSeconds(0.3)
},
CacheConfiguration = new[]
{
new CacheConfiguration("IndexComposition")
{
SqlSchema = "IndexComposition",CacheMode =
CacheMode.Replicated,
QueryEntities = new []
{
new
QueryEntity(typeof(int),typeof(IndexComposition))
}
}
}

};



--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


ignite .net plugin for security

2018-09-17 Thread wt
I have almost completed a plugin in java and was wondering if this plugin
could be made available in .net. I have seen an example online (here -
https://dzone.com/articles/implementing-ignitenet-plugin-distributed-semaphor)
where plugin methods in java are made available in .net. Do you know if it
is possible to implement a security plugin in this fashion or is that level
of integration not possible between java and .net. I can see there are no
security classes available in .net so all the wiring would need to be
developed. would be great to get some of the gridgain developers with .net
knowledge to comment. Perhaps it is planned to be made available in the
future?



--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


Re: loadcache very very slow

2018-09-17 Thread wt
hi

The reason i am asking here and not on the users forum is to get down to the
code details of how loadcache works and specifically what the developers
recommendation is on using it for bulk load operations. In reading up on the
subject, i discovered that it is suggested to override the method and use a
different implementation to the default. Asking on the users forum is only
going to go into details like the env and server and drivers etc. I can tell
you now that i can query the same jdbc driver in beaver on the same database
and get back throughput i would have expected to see with the generated
project. Unfortunately the generated project from the web console is only
useful for basic configs and the loading aspect to it should ultimately
either be removed or updated to support bulk inserts by default. I have lost
confidence in using the web console and generated project due to a series of
issues including this.



--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


Re: IgniteDataStreamer - into table and not key\value

2018-09-17 Thread wt
this is making no sense. There is absolutely nothing in the documentation
that says remove those items from the configuration. All i am looking for is
an example of a table that can be loaded with the data streamer without the
data ending up outside of the table. I have tried with and without that
simple mapper in th config and it makes no difference.

simple example i have:

1) config (has no caches specified - contents placed at the end)
2) create table in jdbc 

CREATE TABLE IF NOT EXISTS Testy (
  id int,
  name varchar,
   PRIMARY KEY (id)
) WITH "template=partitioned,backups=0";

3) table is visible in ignite

{
"successStatus": 0,
"error": null,
"sessionToken": null,
"response": [
{
"cacheName": "SQL_PUBLIC_TESTY",
"types": [

"SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a"
],
"keyClasses": {

"SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a":
"java.lang.Integer"
},
"valClasses": {

"SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a":
"java.lang.Object"
},
"fields": {

"SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a": {
"ID": "java.lang.Integer",
"NAME": "java.lang.String"
}
},
"indexes": {

"SQL_PUBLIC_TESTY_07052f5a_37ac_4992_8a19_79da93e3df8a": []
}
}}}


4) simple .net project


public class Testy
{

[QuerySqlField]
public int id { get; set; }
[QuerySqlField]
public string name { get; set; }

}

var cfg = new IgniteConfiguration()
{
SpringConfigUrl = @"C:\Cluster-client.xml"
};

var ignite = Ignition.Start(cfg);
using (var ldr = ignite.GetDataStreamer("SQL_PUBLIC_TESTY"))
{
ldr.AddData(1, new Testy() {id=1, name = "" });
}


5) db beaver

SELECT count(*) FROM testy (result is 0)

6) rest query

http://127.0.0.1:8080/ignite?cmd=get&cacheName=SQL_PUBLIC_TESTY&keyType=int&key=1

{
"successStatus": 0,
"affinityNodeId": "9a006702-e11e-4fdc-bf84-7f0b28fc498f",
"error": null,
"sessionToken": null,
"response": {
"name": "",
"id": 1
}
}




-
config file

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";>











127.0.0.1:47500..47510



































--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


Re: IgniteDataStreamer - into table and not key\value

2018-09-17 Thread wt
that is a typo, changing the name of the class to Indexcomposition doesn't
make any difference. I also added the following to the config


 









the class names in .net are matching the java names in the config file


 public class Indexcomposition
{

[QuerySqlField]
public int vd { get; set; }

[QuerySqlField]
public double sharesinindex { get; set; }

[QuerySqlField]
public string name { get; set; }

[QuerySqlField]
public string isin { get; set; }

[QuerySqlField]
public string sedol { get; set; }

[QuerySqlField]
public string ric { get; set; }

[QuerySqlField]
public double close { get; set; }

[QuerySqlField]
public decimal rate { get; set; }

}


  
.











...





--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


Re: IgniteDataStreamer - into table and not key\value

2018-09-17 Thread wt
hi Ilya

Table initialised? it is a rmdbs integrated here is the config file 
Cluster-server.xml

  

here is the class

class IndexHistory
{

[QuerySqlField]
public int VD { get; set; }

[QuerySqlField]
public double SHARESININDEX { get; set; }

[QuerySqlField]
public string NAME { get; set; }

[QuerySqlField]
public string ISIN { get; set; }

[QuerySqlField]
public string SEDOL { get; set; }

[QuerySqlField]
public string RIC { get; set; }

[QuerySqlField]
public double CLOSE { get; set; }

[QuerySqlField]
public decimal RATE { get; set; }

}



--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


IgniteDataStreamer - into table and not key\value

2018-09-17 Thread wt
I am trying to load ignite using the data streamer into an ignite table. The
streamer works but when querying the table it is empty. Upon further
investigation it looks like the streamer is creating a key\value store in
the same cache that the table resided. When querying the metadata it shows
no changes to the cache. If i query the cache parsing in the surrogate key i
injected into the code using the rest service i can see the records are
there but in what looks like a key\value store. Can the IgniteDataStreamer 
load a table?

here is the .net code

   try { connection.Open();
command = new SqlCommand(sql, connection);
dataReader = command.ExecuteReader();
using (var ldr = ignite.GetDataStreamer("IndexcompositionCache"))
{
ldr.PerNodeBufferSize = 1024;
int i = 1;
while (dataReader.Read())
{
var o = new IndexHistory()
{
VD = (int)dataReader.GetValue(0),
SHARESININDEX = (double)dataReader.GetValue(1),
NAME = (string)dataReader.GetValue(2),
ISIN = (string)dataReader.GetValue(3),
SEDOL = (string)dataReader.GetValue(4),
RIC = (string)dataReader.GetValue(5),
CLOSE = (double)dataReader.GetValue(6),
RATE = (decimal)dataReader.GetValue(7)
};
ldr.AddData(i, o );

i = i + 1;
}

}
dataReader.Close();
command.Dispose();
connection.Close(); }
catch (Exception ex)
{ 
Console.WriteLine(ex.Message.ToString());
}



--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


Re: loadcache very very slow

2018-09-17 Thread wt
hi Alexey

When i debug it is like going down a maize. what i can see is that it enters 

class  = IgniteCacheProxyImpl

void = loadCache 
   which calls globalLoadCache
   which calls globalLoadCacheAsync

then it goes all into all sorts of classes back and forth and fails because
debugging breaks the connection timeout and the client is disconnected.

here is the example project  Cluster-project(1).zip

  

here is sample data data.csv
  





--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


loadcache very very slow

2018-09-17 Thread wt
Hi

I have a project that is generated by the web console (2.5) and it is
loading an integrated db (SQL Server) table that has 4.5 million rows. When
running the load cache it is loading 1-3 records per second which is
unacceptable. Looking at the documentation i see examples of the overridden
load cache mechanism which makes me think that the default loading mechanism
in this project is not optimal for bulk loads. If i run a query on the jdbc
db driver it is returning 100k of rows per second. 

Looking for advice here as i want to maintain the strategy of not needing to
write load code but obviously want something that wont take forever to load. 



--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


Re: Failed to activate node components

2018-09-04 Thread wt
this is how i am starting the service - 

IgniteConfiguration cfg =
Ignition.loadSpringBean("POC5-server.xml","grid.cfg");
Ignite ig =Ignition.start(cfg);
ig.cluster().active(true);


*i should point out that if i start it like this i don't get the error*

Ignite ig = Ignition.start("POC5-server.xml");
ig.cluster().active(true);






--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


Re: Failed to activate node components

2018-09-04 Thread wt
POC5-server.xml

  

Here is my config file



--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


Failed to activate node components

2018-09-03 Thread wt
I am getting the following error when starting a single node cluster
(intellij) and then the instance crashes. I did have some persistence issues
so cleaned up the work dir after which this started happening

ignite-5885b9e6.log

  

console output:

"C:\Program Files\Java\jdk1.8.0_151\bin\java" "-javaagent:C:\Program
Files\JetBrains\IntelliJ IDEA Community Edition
2017.3\lib\idea_rt.jar=51505:C:\Program Files\JetBrains\IntelliJ IDEA
Community Edition 2017.3\bin" -Dfile.encoding=UTF-8 -classpath "C:\Program
Files\Java\jdk1.8.0_151\jre\lib\charsets.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\deploy.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\access-bridge-64.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\cldrdata.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\dnsns.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\jaccess.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\jfxrt.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\localedata.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\nashorn.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\sunec.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\sunjce_provider.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\sunmscapi.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\sunpkcs11.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\ext\zipfs.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\javaws.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\jce.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\jfr.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\jfxswt.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\jsse.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\management-agent.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\plugin.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\resources.jar;C:\Program
Files\Java\jdk1.8.0_151\jre\lib\rt.jar;C:\Program
Files\Java\jdk1.8.0_151\lib\tools.jar;C:\Users\ww309\Downloads\POC5-project\target\classes;C:\Users\ww309\.m2\repository\org\apache\ignite\ignite-core\2.6.0\ignite-core-2.6.0.jar;C:\Users\ww309\.m2\repository\javax\cache\cache-api\1.0.0\cache-api-1.0.0.jar;C:\Users\ww309\.m2\repository\org\jetbrains\annotations\13.0\annotations-13.0.jar;C:\Users\ww309\.m2\repository\org\gridgain\ignite-shmem\1.0.0\ignite-shmem-1.0.0.jar;C:\Users\ww309\.m2\repository\org\apache\ignite\ignite-spring\2.6.0\ignite-spring-2.6.0.jar;C:\Users\ww309\.m2\repository\org\springframework\spring-core\4.3.16.RELEASE\spring-core-4.3.16.RELEASE.jar;C:\Users\ww309\.m2\repository\org\springframework\spring-aop\4.3.16.RELEASE\spring-aop-4.3.16.RELEASE.jar;C:\Users\ww309\.m2\repository\org\springframework\spring-beans\4.3.16.RELEASE\spring-beans-4.3.16.RELEASE.jar;C:\Users\ww309\.m2\repository\org\springframework\spring-context\4.3.16.RELEASE\spring-context-4.3.16.RELEASE.jar;C:\Users\ww309\.m2\repository\org\springframework\spring-expression\4.3.16.RELEASE\spring-expression-4.3.16.RELEASE.jar;C:\Users\ww309\.m2\repository\org\springframework\spring-tx\4.3.16.RELEASE\spring-tx-4.3.16.RELEASE.jar;C:\Users\ww309\.m2\repository\org\springframework\spring-jdbc\4.3.16.RELEASE\spring-jdbc-4.3.16.RELEASE.jar;C:\Users\ww309\.m2\repository\commons-logging\commons-logging\1.1.1\commons-logging-1.1.1.jar;C:\Users\ww309\.m2\repository\org\apache\ignite\ignite-indexing\2.6.0\ignite-indexing-2.6.0.jar;C:\Users\ww309\.m2\repository\commons-codec\commons-codec\1.11\commons-codec-1.11.jar;C:\Users\ww309\.m2\repository\org\apache\lucene\lucene-core\5.5.2\lucene-core-5.5.2.jar;C:\Users\ww309\.m2\repository\org\apache\lucene\lucene-analyzers-common\5.5.2\lucene-analyzers-common-5.5.2.jar;C:\Users\ww309\.m2\repository\org\apache\lucene\lucene-queryparser\5.5.2\lucene-queryparser-5.5.2.jar;C:\Users\ww309\.m2\repository\org\apache\lucene\lucene-queries\5.5.2\lucene-queries-5.5.2.jar;C:\Users\ww309\.m2\repository\org\apache\lucene\lucene-sandbox\5.5.2\lucene-sandbox-5.5.2.jar;C:\Users\ww309\.m2\repository\com\h2database\h2\1.4.195\h2-1.4.195.jar;C:\Users\ww309\.m2\repository\org\apache\ignite\ignite-rest-http\2.6.0\ignite-rest-http-2.6.0.jar;C:\Users\ww309\.m2\repository\org\apache\tomcat\tomcat-servlet-api\8.0.23\tomcat-servlet-api-8.0.23.jar;C:\Users\ww309\.m2\repository\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;C:\Users\ww309\.m2\repository\org\eclipse\jetty\jetty-continuation\9.2.11.v20150529\jetty-continuation-9.2.11.v20150529.jar;C:\Users\ww309\.m2\repository\org\eclipse\jetty\jetty-http\9.2.11.v20150529\jetty-http-9.2.11.v20150529.jar;C:\Users\ww309\.m2\repository\org\eclipse\jetty\jetty-io\9.2.11.v20150529\jetty-io-9.2.11.v20150529.jar;C:\Users\ww309\.m2\repository\org\eclipse\jetty\jetty-server\9.2.11.v20150529\jetty-server-9.2.11.v20150529.jar;C:\Users\ww309\.m2\repository\javax\servlet\javax.servlet-api\3.1.0\javax.servlet-api-3.1.0.jar;C:\Users\ww309\.m2\repository\org\eclipse\jetty\jetty-util\9.2.11.v20150529\jetty-util-9.2.11.v20150529.jar;C:\Users\ww309\.m2\re

Re: How can i make my custom plugin serializable - Failed to serialize object: plugins.CustomSecurityProcessor

2018-09-03 Thread wt
thanks, found the anonymous class and created new ones with serializable



--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


Ignition.loadSpringBean("POC5-server.xml","grid.cfg") - error Failed to activate node components

2018-09-03 Thread wt
I have a project that starts fine if i start it like this

Ignite ig = Ignition.start("POC5-server.xml");
ig.cluster().active(true);

I need to however use the config file and also set other details before
starting so When i do this i get an error:

IgniteConfiguration cfg =
Ignition.loadSpringBean("POC5-server.xml","grid.cfg");
--set other things here (they are commented out in the code for now)
Ignite ig =Ignition.start(cfg);
ig.cluster().active(true);

here is the error in the log file:



[2018-09-03 14:20:18,866][INFO ][main][IgniteKernal%POC5] 

>>>__    
>>>   /  _/ ___/ |/ /  _/_  __/ __/  
>>>  _/ // (7 7// /  / / / _/
>>> /___/\___/_/|_/___/ /_/ /___/   
>>> 
>>> ver. 2.6.0#20180710-sha1:669feacc
>>> 2018 Copyright(C) Apache Software Foundation
>>> 
>>> Ignite documentation: http://ignite.apache.org

[2018-09-03 14:20:18,882][INFO ][main][IgniteKernal%POC5] Config URL: n/a
[2018-09-03 14:20:18,898][INFO ][main][IgniteKernal%POC5]
IgniteConfiguration [igniteInstanceName=POC5, pubPoolSize=8, svcPoolSize=8,
callbackPoolSize=8, stripedPoolSize=8, sysPoolSize=8, mgmtPoolSize=4,
igfsPoolSize=2, dataStreamerPoolSize=8, utilityCachePoolSize=8,
utilityCacheKeepAliveTime=6, p2pPoolSize=2, qryPoolSize=8,
igniteHome=c:\ignite\, igniteWorkDir=c:\ignite\work,
mbeanSrv=com.sun.jmx.mbeanserver.JmxMBeanServer@23529fee,
nodeId=b36055b7-426d-4975-bf5b-cb54fbb06dbc,
marsh=org.apache.ignite.internal.binary.BinaryMarshaller@3c73951,
marshLocJobs=false, daemon=false, p2pEnabled=false, netTimeout=5000,
sndRetryDelay=1000, sndRetryCnt=3, metricsHistSize=1,
metricsUpdateFreq=2000, metricsExpTime=9223372036854775807,
discoSpi=TcpDiscoverySpi [addrRslvr=null, sockTimeout=0, ackTimeout=0,
marsh=null, reconCnt=10, reconDelay=2000, maxAckTimeout=60,
forceSrvMode=false, clientReconnectDisabled=false, internalLsnr=null],
segPlc=STOP, segResolveAttempts=2, waitForSegOnStart=true,
allResolversPassReq=true, segChkFreq=1, commSpi=TcpCommunicationSpi
[connectGate=null, connPlc=null, enableForcibleNodeKill=false,
enableTroubleshootingLog=false,
srvLsnr=org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi$2@32b260fa,
locAddr=null, locHost=null, locPort=47100, locPortRange=100, shmemPort=-1,
directBuf=true, directSndBuf=false, idleConnTimeout=60,
connTimeout=5000, maxConnTimeout=60, reconCnt=10, sockSndBuf=32768,
sockRcvBuf=32768, msgQueueLimit=0, slowClientQueueLimit=0, nioSrvr=null,
shmemSrv=null, usePairedConnections=false, connectionsPerNode=1,
tcpNoDelay=true, filterReachableAddresses=false, ackSndThreshold=32,
unackedMsgsBufSize=0, sockWriteTimeout=2000, lsnr=null, boundTcpPort=-1,
boundTcpShmemPort=-1, selectorsCnt=4, selectorSpins=0, addrRslvr=null,
ctxInitLatch=java.util.concurrent.CountDownLatch@581ac8a8[Count = 1],
stopping=false,
metricsLsnr=org.apache.ignite.spi.communication.tcp.TcpCommunicationMetricsListener@6d4e5011],
evtSpi=org.apache.ignite.spi.eventstorage.NoopEventStorageSpi@57d7f8ca,
colSpi=NoopCollisionSpi [], deploySpi=LocalDeploymentSpi [lsnr=null],
indexingSpi=org.apache.ignite.spi.indexing.noop.NoopIndexingSpi@662b4c69,
addrRslvr=null, clientMode=false, rebalanceThreadPoolSize=1,
txCfg=org.apache.ignite.configuration.TransactionConfiguration@fa49800,
cacheSanityCheckEnabled=true, discoStartupDelay=6, deployMode=SHARED,
p2pMissedCacheSize=100, locHost=null, timeSrvPortBase=31100,
timeSrvPortRange=100, failureDetectionTimeout=1,
clientFailureDetectionTimeout=3, metricsLogFreq=6, hadoopCfg=null,
connectorCfg=org.apache.ignite.configuration.ConnectorConfiguration@71238fc2,
odbcCfg=null, warmupClos=null, atomicCfg=AtomicConfiguration
[seqReserveSize=1000, cacheMode=PARTITIONED, backups=1, aff=null,
grpName=null], classLdr=null, sslCtxFactory=null, platformCfg=null,
binaryCfg=null, memCfg=null, pstCfg=null, dsCfg=DataStorageConfiguration
[sysRegionInitSize=41943040, sysCacheMaxSize=104857600, pageSize=0,
concLvl=0, dfltDataRegConf=DataRegionConfiguration [name=default,
maxSize=1073741824, initSize=268435456, swapPath=null,
pageEvictionMode=DISABLED, evictionThreshold=0.9, emptyPagesPoolSize=100,
metricsEnabled=false, metricsSubIntervalCount=5,
metricsRateTimeInterval=6, persistenceEnabled=true,
checkpointPageBufSize=0], storagePath=null, checkpointFreq=18,
lockWaitTime=1, checkpointThreads=4, checkpointWriteOrder=SEQUENTIAL,
walHistSize=20, walSegments=10, walSegmentSize=67108864, walPath=db/wal,
walArchivePath=db/wal/archive, metricsEnabled=false, walMode=LOG_ONLY,
walTlbSize=131072, walBuffSize=0, walFlushFreq=2000, walFsyncDelay=1000,
walRecordIterBuffSize=67108864, alwaysWriteFullPages=false,
fileIOFactory=org.apache.ignite.internal.processors.cache.persistence.file.AsyncFileIOFactory@16a0ee18,
metricsSubIntervalCnt=5, metricsRateTimeInterval=6,
walAutoArchiveAfterInactivity=-1, writeThrottlingEnabled=false,
walCompactionEnabled=false], activeOnStart=true, autoActivation=true,
longQryWarnTimeout=3000, sqlConnCfg=nu

How can i make my custom plugin serializable - Failed to serialize object: plugins.CustomSecurityProcessor

2018-08-31 Thread wt
How can i make my custom plugin serializable?


Caused by: class org.apache.ignite.spi.IgniteSpiException: Failed to
authenticate local node (will shutdown local node).
at
org.apache.ignite.spi.discovery.tcp.ServerImpl.localAuthentication(ServerImpl.java:1008)
at
org.apache.ignite.spi.discovery.tcp.ServerImpl.joinTopology(ServerImpl.java:879)
at
org.apache.ignite.spi.discovery.tcp.ServerImpl.spiStart(ServerImpl.java:373)
at
org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi.spiStart(TcpDiscoverySpi.java:1948)
at
org.apache.ignite.internal.managers.GridManagerAdapter.startSpi(GridManagerAdapter.java:297)
... 10 more
Caused by: class org.apache.ignite.IgniteCheckedException: Failed to
serialize object: plugins.CustomSecurityProcessor$1@350b3a17
at
org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal0(JdkMarshaller.java:103)
at
org.apache.ignite.marshaller.AbstractNodeNameAwareMarshaller.marshal(AbstractNodeNameAwareMarshaller.java:70)
at
org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal0(JdkMarshaller.java:117)
at
org.apache.ignite.marshaller.AbstractNodeNameAwareMarshaller.marshal(AbstractNodeNameAwareMarshaller.java:58)
at
org.apache.ignite.internal.util.IgniteUtils.marshal(IgniteUtils.java:10044)
at
org.apache.ignite.spi.discovery.tcp.ServerImpl.localAuthentication(ServerImpl.java:1002)
... 14 more
Caused by: java.io.NotSerializableException:
plugins.CustomSecurityProcessor$1
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1184)
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348)
at
org.apache.ignite.marshaller.jdk.JdkMarshaller.marshal0(JdkMarshaller.java:98)
... 19 more



--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/


Looking for information on these methods

2018-08-31 Thread wt
okay i have a white list plugin class that is now working - ThankYou Ilya 
(GridGain) 

I can now control nodes joining the cluster be it clients or servers. My 
next task is to manage user requests to specific caches and what they can do 
on those. I already have the GridSecurityProcessor class as part of my 
implementation and the class has the following methods 

SecurityContext authenticate(AuthenticationContext var1) 

SecuritySubject authenticatedSubject(UUID var1) 

void authorize(String var1, SecurityPermission var2, @Nullable 
SecurityContext var3) 


my questions are: 

1) do these methods get called when requests come in from nodes and clients 
and are they used anywhere else 

2) i have the GridSecurityProcessor  working already for node 
authentication, is there anything that is needed besides implementing the 
logic on these methods. For this i am focusing on the server side only and 
will implement the client side logic on the jdbc and odbc later. 

3) if i am wrong in my assumption on request authentication and 
authorization in context to these methods, what classes\methods should i be 
looking at. 


As always, thank you in advanced (i couldn't do this without the support of 
this awesome community) 



--
Sent from: http://apache-ignite-developers.2346864.n4.nabble.com/