You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ignite.apache.org by debasish pradhan <de...@gmail.com> on 2017/05/22 12:00:56 UTC
Persistent data store error
Hi ,
I am new to apache ignite. I was trying to connect Timesten DB to fetch
data , but its failing . I downloaded the project from web console . As per
instruction I started the server node . After that I am trying to run
loadcache . but its failing with following error.
cache load code:
=========
*try* (Ignite ignite = Ignition.*start*("TestDB1-client.xml")) {
System.*out*.println(">>> Loading caches...");
System.*out*.println(">>> Loading cache:...EmployeeCache");
//ignite.cache("EmployeeCache").loadCache(null);
ignite.cache("EmployeeCache").loadCache(*null*,
Employee.*class*.getName(), "select
* from DG.Employee");
configuration:jdbc driver :
public static class DataSources {
public static final TimesTenDataSource INSTANCE_dataStore =
createdataStore();
private static TimesTenDataSource createdataStore() {
TimesTenDataSource dataStore = new TimesTenDataSource();
dataStore.setUrl("jdbc:timesten:client:TTC_Server=
localhost;TCP_PORT=53397;TTC_Server_DSN=TESTDSN;UID=test;
PWD=test;TTC_Timeout=180");
dataStore.setUser("test");
dataStore.setPassword("test");
return dataStore;
}
}
TestDB1-client.xml-->
<bean id="dataSource" class="com.timesten.jdbc.TimesTenDataSource">
<property name="url" value="jdbc:timesten:client:
TTC_Server=localhost;TCP_PORT=53397;TTC_Server_DSN=TestDSN;
UID=test;PWD=test;TTC_Timeout=180" />
<property name="username" value="kodiak" />
<property name="password" value="kodiak" />
</bean>
[17:04:12,860][SEVERE][main][GridJobWorker] Failed to execute job
[jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b,
ses=GridJobSessionImpl [ses=GridTaskSessionImpl
[taskName=o.a.i.i.processors.cache.GridCacheAdapter$LoadCacheJobV2,
dep=LocalDeployment [super=GridDeployment [ts=1495452846874,
depMode=SHARED, clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a,
clsLdrId=6608fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b, userVer=0,
loc=true, sampleClsName=java.lang.String, pendingUndeploy=false,
undeployed=false, usage=0]], taskClsName=o.a.i.i.processors.cache.
GridCacheAdapter$LoadCacheJobV2,
sesId=0a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b,
startTime=1495452852829, endTime=9223372036854775807,
taskNodeId=8b249f71-34cd-4ec7-8056-c32a3e61034b, clsLdr=sun.misc.Launcher$
AppClassLoader@4e0e2f2a, closed=false, cpSpi=null, failSpi=null,
loadSpi=null, usage=1, fullSup=false, internal=true,
subjId=8b249f71-34cd-4ec7-8056-c32a3e61034b, mapFut=IgniteFuture
[orig=GridFutureAdapter [resFlag=0, res=null, startTime=1495452852839,
endTime=0, ignoreInterrupts=false, state=INIT]]],
jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b]]
class *org.apache.ignite.IgniteException*: *java.lang.NullPointerException*
at org.apache.ignite.internal.processors.closure.GridClosureProcessor$C2V2.
execute(*GridClosureProcessor.java:2059*)
at org.apache.ignite.internal.processors.job.GridJobWorker$2.call(
*GridJobWorker.java:560*)
at org.apache.ignite.internal.util.IgniteUtils.wrapThreadLoader(
*IgniteUtils.java:6620*)
at org.apache.ignite.internal.processors.job.GridJobWorker.execute0(
*GridJobWorker.java:554*)
at org.apache.ignite.internal.processors.job.GridJobWorker.body(
*GridJobWorker.java:483*)
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.task.GridTaskWorker.sendRequest(
*GridTaskWorker.java:1383*)
at org.apache.ignite.internal.processors.task.GridTaskWorker.
processMappedJobs(*GridTaskWorker.java:645*)
at org.apache.ignite.internal.processors.task.GridTaskWorker.body(
*GridTaskWorker.java:537*)
at org.apache.ignite.internal.util.worker.GridWorker.run(
*GridWorker.java:110*)
at org.apache.ignite.internal.processors.task.GridTaskProcessor.startTask(
*GridTaskProcessor.java:679*)
at org.apache.ignite.internal.processors.task.GridTaskProcessor.execute(
*GridTaskProcessor.java:403*)
at org.apache.ignite.internal.processors.closure.GridClosureProcessor.
callAsync(*GridClosureProcessor.java:418*)
at org.apache.ignite.internal.processors.closure.GridClosureProcessor.
callAsync(*GridClosureProcessor.java:391*)
at org.apache.ignite.internal.processors.cache.GridCacheAdapter.
globalLoadCacheAsync(*GridCacheAdapter.java:3718*)
at org.apache.ignite.internal.processors.cache.GridCacheAdapter.
globalLoadCache(*GridCacheAdapter.java:3657*)
at org.apache.ignite.internal.processors.cache.IgniteCacheProxy.loadCache(
*IgniteCacheProxy.java:390*)
at load.LoadCaches.main(*LoadCaches.java:28*)
Re: Persistent data store error
Posted by afedotov <al...@gmail.com>.
Hi.
Looks like you are specifying value type instead of key type into loadCache
ignite.cache("EmployeeCache").loadCache(*null*,
Employee.*class*.getName(), "select
* from DG.Employee");
Kindly try the following:
ignite.cache("EmployeeCache").loadCache(*null*, EmployeeKey.*class*
.getName(), "select * from DG.Employee");
Kind regards,
Alex.
On Thu, May 25, 2017 at 7:51 AM, dprbglr [via Apache Ignite Users] <
ml+s70518n13131h95@n6.nabble.com> wrote:
> Hi ,
>
> Can you please suggest on this...whether i have to remove the
> configuration details from xml,but i tried that way ..its showing the same
> error. It would be great if you can share some pseudo code through which we
> can retrieve data from any RDBMS database to cache . As per video tutorial
> i logged in to web console i created a project which has generated code for
> cache creation and configuration . After starting the server node i ran
> loadcache ....which is not working. I am using gridgain version 7.8.6
> (apache ignite version 1.9).
>
>
>
> ------------------------------
> If you reply to this email, your message will be added to the discussion
> below:
> http://apache-ignite-users.70518.x6.nabble.com/
> Persistent-data-store-error-tp13067p13131.html
> To start a new topic under Apache Ignite Users, email
> ml+s70518n1h65@n6.nabble.com
> To unsubscribe from Apache Ignite Users, click here
> <http://apache-ignite-users.70518.x6.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=1&code=YWxleGFuZGVyLmZlZG90b2ZmQGdtYWlsLmNvbXwxfC0xMzYxNTU0NTg=>
> .
> NAML
> <http://apache-ignite-users.70518.x6.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml>
>
--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Persistent-data-store-error-tp13067p13146.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
Re: Persistent data store error
Posted by dprbglr <de...@gmail.com>.
Hi ,
Can you please suggest on this...whether i have to remove the configuration
details from xml,but i tried that way ..its showing the same error. It would
be great if you can share some pseudo code through which we can retrieve
data from any RDBMS database to cache . As per video tutorial i logged in to
web console i created a project which has generated code for cache creation
and configuration . After starting the server node i ran loadcache ....which
is not working. I am using gridgain version 7.8.6 (apache ignite version
1.9).
--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Persistent-data-store-error-tp13067p13131.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
Re: Persistent data store error
Posted by debasish pradhan <de...@gmail.com>.
Hi,
I have used Ignite version 1.9 and gridgain version 7.8.6. So i don't have
to declare any datastore/jdbc connection details as well as cache
configuration details in spring XML.
On Wed, May 24, 2017 at 12:15 AM, Andrey Gura <ag...@apache.org> wrote:
> Hi,
>
> Make sure that you have cache store configuration on server and client
> nodes.
>
> Also use only one type of node configuration: declarative (Spring XML)
> or programmatically configuration.
>
> What version of Ignite do you use? I need it for applying provided
> stack trace to proper version of code.
>
>
> On Tue, May 23, 2017 at 2:16 PM, debasish pradhan <de...@gmail.com>
> wrote:
> > hi ,
> >
> >
> > Please find the config file for client .
> >
> > import com.mchange.v2.c3p0.ComboPooledDataSource;
> > import java.io.InputStream;
> > import java.math.BigDecimal;
> > import java.sql.Types;
> > import java.util.ArrayList;
> > import java.util.Arrays;
> > import java.util.LinkedHashMap;
> > import java.util.Properties;
> > import javax.cache.configuration.Factory;
> > import javax.sql.DataSource;
> > import org.apache.ignite.cache.CacheAtomicityMode;
> > import org.apache.ignite.cache.CacheMode;
> > import org.apache.ignite.cache.QueryEntity;
> > import org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory;
> > import org.apache.ignite.cache.store.jdbc.JdbcType;
> > import org.apache.ignite.cache.store.jdbc.JdbcTypeField;
> > import org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect;
> > import org.apache.ignite.configuration.BinaryConfiguration;
> > import org.apache.ignite.configuration.CacheConfiguration;
> > import org.apache.ignite.configuration.IgniteConfiguration;
> > import org.apache.ignite.configuration.OdbcConfiguration;
> > import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
> > import
> > org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
> > //import com.timesten.jdbc.JdbcOdbcConnection;
> > //import com.timesten.jdbc.TimesTenDataSource;
> >
> > public class ClientConfigurationFactory {
> > /** Secret properties loading. **/
> > private static final Properties props = new Properties();
> >
> > static {
> > try (InputStream in =
> > IgniteConfiguration.class.getClassLoader().getResourceAsStream("secret.
> properties"))
> > {
> > props.load(in);
> > }
> > catch (Exception ignored) {
> > // No-op.
> > }
> > }
> >
> > /** Helper class for datasource creation. **/
> > public static class DataSources {
> > public static final ComboPooledDataSource INSTANCE_dataStore =
> > createdataStore();
> >
> > private static ComboPooledDataSource createdataStore() {
> > ComboPooledDataSource dataStore = new
> ComboPooledDataSource();
> >
> >
> > dataStore.setJdbcUrl("jdbc:timesten:client:TTC_Server=
> localhost;TCP_PORT=53397;TTC_Server_DSN=EMSDSN;UID=test;
> PWD=test;TTC_Timeout=180");
> > dataStore.setUser("kodiak");
> > dataStore.setPassword("kodiak");
> >
> > return dataStore;
> > }
> > }
> >
> >
> > /**
> > * Configure grid.
> > *
> > * @return Ignite configuration.
> > * @throws Exception If failed to construct Ignite configuration
> > instance.
> > **/
> > public static IgniteConfiguration createConfiguration() throws
> Exception
> > {
> > IgniteConfiguration cfg = new IgniteConfiguration();
> >
> > cfg.setClientMode(true);
> > cfg.setGridName("TestDB1");
> >
> > TcpDiscoverySpi discovery = new TcpDiscoverySpi();
> >
> > TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
> >
> > ipFinder.setAddresses(Arrays.asList("127.0.0.1:47500..47510"));
> >
> > discovery.setIpFinder(ipFinder);
> >
> > cfg.setDiscoverySpi(discovery);
> >
> > BinaryConfiguration binaryCfg = new BinaryConfiguration();
> >
> > binaryCfg.setCompactFooter(false);
> >
> > cfg.setBinaryConfiguration(binaryCfg);
> >
> > cfg.setOdbcConfiguration(new OdbcConfiguration());
> >
> > cfg.setCacheConfiguration(cacheEmployeeCache());
> >
> > return cfg;
> > }
> >
> > /**
> > * Create configuration for cache "EmployeeCache".
> > *
> > * @return Configured cache.
> > * @throws Exception if failed to create cache configuration.
> > **/
> > public static CacheConfiguration cacheEmployeeCache() throws
> Exception {
> > CacheConfiguration ccfg = new CacheConfiguration();
> >
> > ccfg.setName("EmployeeCache");
> > ccfg.setCacheMode(CacheMode.PARTITIONED);
> > ccfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
> >
> > CacheJdbcPojoStoreFactory cacheStoreFactory = new
> > CacheJdbcPojoStoreFactory();
> >
> > cacheStoreFactory.setDataSourceFactory(new
> Factory<DataSource>() {
> > /** {@inheritDoc} **/
> > @Override public DataSource create() {
> > return DataSources.INSTANCE_dataStore;
> > };
> > });
> >
> > cacheStoreFactory.setDialect(new BasicJdbcDialect());
> >
> > cacheStoreFactory.setTypes(jdbcTypeEmployee(ccfg.getName()));
> >
> > ccfg.setCacheStoreFactory(cacheStoreFactory);
> >
> > ccfg.setReadThrough(true);
> > ccfg.setWriteThrough(true);
> >
> > ArrayList<QueryEntity> qryEntities = new ArrayList<>();
> >
> > QueryEntity qryEntity = new QueryEntity();
> >
> > qryEntity.setKeyType("com.gmail.orl.debasis.model.EmployeeKey");
> > qryEntity.setValueType("com.gmail.orl.debasis.model.Employee");
> >
> > LinkedHashMap<String, String> fields = new LinkedHashMap<>();
> >
> > fields.put("id", "java.math.BigDecimal");
> > fields.put("firstname", "java.lang.String");
> > fields.put("lastname", "java.lang.String");
> >
> > qryEntity.setFields(fields);
> > qryEntities.add(qryEntity);
> >
> > ccfg.setQueryEntities(qryEntities);
> >
> > return ccfg;
> > }
> >
> > /**
> > * Create JDBC type for "jdbcTypeEmployee".
> > *
> > * @param cacheName Cache name.
> > * @return Configured JDBC type.
> > **/
> > private static JdbcType jdbcTypeEmployee(String cacheName) {
> > JdbcType type = new JdbcType();
> >
> > type.setCacheName(cacheName);
> > type.setKeyType("com.gmail.orl.debasis.model.EmployeeKey");
> > type.setValueType("com.gmail.orl.debasis.model.Employee");
> > type.setDatabaseSchema("DG");
> > type.setDatabaseTable("EMPLOYEE");
> >
> > type.setValueFields(
> > new JdbcTypeField(Types.DECIMAL, "ID", BigDecimal.class,
> "id"),
> > new JdbcTypeField(Types.VARCHAR, "FIRSTNAME", String.class,
> > "firstname"),
> > new JdbcTypeField(Types.VARCHAR, "LASTNAME", String.class,
> > "lastname")
> > );
> >
> > return type;
> > }
> > }
> >
> > ******************
> > client-config.xml
> >
> > <?xml version="1.0" encoding="UTF-8"?>
> >
> > <beans xmlns="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">
> > <!-- Load external properties file. -->
> > <bean id="placeholderConfig"
> > class="org.springframework.beans.factory.config.
> PropertyPlaceholderConfigurer">
> > <property name="location" value="classpath:secret.properties"/>
> > </bean>
> >
> > <!-- Data source beans will be initialized from external properties
> > file. -->
> > <bean id="dataStore" class="com.mchange.v2.c3p0.
> ComboPooledDataSource">
> > <property name="jdbcUrl" value="${dataStore.jdbc.url}"/>
> > <property name="user" value="${dataStore.jdbc.username}"/>
> > <property name="password" value="${dataStore.jdbc.password}"/>
> > </bean>
> >
> > <!-- Data source beans will be initialized from external properties
> > file. -->
> > <!-- <bean id="dataStore" class="com.timesten.jdbc.
> TimesTenDataSource">
> > <property name="jdbcUrl"
> > value="jdbc:timesten:client:TTC_Server=localhost;TCP_PORT=
> 53397;TTC_Server_DSN=emsdsn;UID=kodiak;PWD=kodiak;TTC_Timeout=180"/>
> > <property name="user" value="kodiak"/>
> > <property name="password" value="kodiak"/>
> > </bean>-->
> >
> > <bean class="org.apache.ignite.configuration.IgniteConfiguration">
> > <property name="clientMode" value="false"/>
> > <property name="gridName" value="TestDB1"/>
> >
> > <property name="discoverySpi">
> > <bean
> > class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
> > <property name="ipFinder">
> > <bean
> > class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.
> TcpDiscoveryVmIpFinder">
> > <property name="addresses">
> > <list>
> > <value>127.0.0.1:47500..47510</value>
> > </list>
> > </property>
> > </bean>
> > </property>
> > </bean>
> > </property>
> >
> > <property name="binaryConfiguration">
> > <bean
> > class="org.apache.ignite.configuration.BinaryConfiguration">
> > <property name="compactFooter" value="false"/>
> > </bean>
> > </property>
> >
> > <property name="odbcConfiguration">
> > <bean class="org.apache.ignite.configuration.
> OdbcConfiguration">
> > </bean>
> > </property>
> >
> > <property name="cacheConfiguration">
> > <list>
> > <bean
> > class="org.apache.ignite.configuration.CacheConfiguration">
> > <property name="name" value="EmployeeCache"/>
> > <property name="cacheMode" value="PARTITIONED"/>
> > <property name="atomicityMode" value="ATOMIC"/>
> >
> > <property name="cacheStoreFactory">
> > <bean
> > class="org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory">
> > <property name="dataSourceBean"
> > value="dataStore"/>
> > <property name="dialect">
> > <bean
> > class="org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect">
> > </bean>
> > </property>
> >
> > <property name="types">
> > <list>
> > <bean
> > class="org.apache.ignite.cache.store.jdbc.JdbcType">
> > <property name="cacheName"
> > value="EmployeeCache"/>
> > <property name="keyType"
> > value="com.gmail.orl.debasis.model.EmployeeKey"/>
> > <property name="valueType"
> > value="com.gmail.orl.debasis.model.Employee"/>
> > <property name="databaseSchema"
> > value="DG"/>
> > <property name="databaseTable"
> > value="EMPLOYEE"/>
> >
> > <property name="valueFields">
> > <list>
> > <bean
> > class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
> > <constructor-arg>
> > <util:constant
> > static-field="java.sql.Types.DECIMAL"/>
> > </constructor-arg>
> > <constructor-arg
> > value="ID"/>
> > <constructor-arg
> > value="java.math.BigDecimal"/>
> > <constructor-arg
> > value="id"/>
> > </bean>
> >
> > <bean
> > class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
> > <constructor-arg>
> > <util:constant
> > static-field="java.sql.Types.VARCHAR"/>
> > </constructor-arg>
> > <constructor-arg
> > value="FIRSTNAME"/>
> > <constructor-arg
> > value="java.lang.String"/>
> > <constructor-arg
> > value="firstname"/>
> > </bean>
> >
> > <bean
> > class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
> > <constructor-arg>
> > <util:constant
> > static-field="java.sql.Types.VARCHAR"/>
> > </constructor-arg>
> > <constructor-arg
> > value="LASTNAME"/>
> > <constructor-arg
> > value="java.lang.String"/>
> > <constructor-arg
> > value="lastname"/>
> > </bean>
> > </list>
> > </property>
> > </bean>
> > </list>
> > </property>
> > </bean>
> > </property>
> >
> > <property name="readThrough" value="true"/>
> > <property name="writeThrough" value="true"/>
> >
> > <property name="queryEntities">
> > <list>
> > <bean
> > class="org.apache.ignite.cache.QueryEntity">
> > <property name="keyType"
> > value="com.gmail.orl.debasis.model.EmployeeKey"/>
> > <property name="valueType"
> > value="com.gmail.orl.debasis.model.Employee"/>
> >
> > <property name="fields">
> > <map>
> > <entry key="id"
> > value="java.math.BigDecimal"/>
> > <entry key="firstname"
> > value="java.lang.String"/>
> > <entry key="lastname"
> > value="java.lang.String"/>
> > </map>
> > </property>
> > </bean>
> > </list>
> > </property>
> > </bean>
> > </list>
> > </property>
> > </bean>
> > </beans>
> >
> > On Tue, May 23, 2017 at 4:34 PM, Evgenii Zhuravlev
> > <e....@gmail.com> wrote:
> >>
> >> Hi,
> >>
> >> Could you provide your full config file?
> >>
> >> 2017-05-22 15:00 GMT+03:00 debasish pradhan <de...@gmail.com>:
> >>>
> >>> Hi ,
> >>>
> >>> I am new to apache ignite. I was trying to connect Timesten DB to fetch
> >>> data , but its failing . I downloaded the project from web console .
> As per
> >>> instruction I started the server node . After that I am trying to run
> >>> loadcache . but its failing with following error.
> >>>
> >>> cache load code:
> >>> =========
> >>>
> >>> try (Ignite ignite = Ignition.start("TestDB1-client.xml")) {
> >>>
> >>> System.out.println(">>> Loading caches...");
> >>>
> >>> System.out.println(">>> Loading cache:...EmployeeCache");
> >>>
> >>> //ignite.cache("EmployeeCache").loadCache(null);
> >>>
> >>> ignite.cache("EmployeeCache").loadCache(null,
> Employee.class.getName(),
> >>> "select * from DG.Employee");
> >>>
> >>>
> >>> configuration:jdbc driver :
> >>>
> >>> public static class DataSources {
> >>> public static final TimesTenDataSource INSTANCE_dataStore =
> >>> createdataStore();
> >>> private static TimesTenDataSource createdataStore() {
> >>> TimesTenDataSource dataStore = new TimesTenDataSource();
> >>>
> >>> dataStore.setUrl("jdbc:timesten:client:TTC_Server=
> localhost;TCP_PORT=53397;TTC_Server_DSN=TESTDSN;UID=test;
> PWD=test;TTC_Timeout=180");
> >>> dataStore.setUser("test");
> >>> dataStore.setPassword("test");
> >>> return dataStore;
> >>> }
> >>> }
> >>>
> >>>
> >>> TestDB1-client.xml-->
> >>>
> >>> <bean id="dataSource" class="com.timesten.jdbc.TimesTenDataSource">
> >>> <property name="url"
> >>> value="jdbc:timesten:client:TTC_Server=localhost;TCP_PORT=
> 53397;TTC_Server_DSN=TestDSN;UID=test;PWD=test;TTC_Timeout=180"
> >>> />
> >>> <property name="username" value="kodiak" />
> >>> <property name="password" value="kodiak" />
> >>> </bean>
> >>>
> >>>
> >>> [17:04:12,860][SEVERE][main][GridJobWorker] Failed to execute job
> >>> [jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b,
> >>> ses=GridJobSessionImpl [ses=GridTaskSessionImpl
> >>> [taskName=o.a.i.i.processors.cache.GridCacheAdapter$LoadCacheJobV2,
> >>> dep=LocalDeployment [super=GridDeployment [ts=1495452846874,
> depMode=SHARED,
> >>> clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a,
> >>> clsLdrId=6608fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b, userVer=0,
> >>> loc=true, sampleClsName=java.lang.String, pendingUndeploy=false,
> >>> undeployed=false, usage=0]],
> >>> taskClsName=o.a.i.i.processors.cache.GridCacheAdapter$LoadCacheJobV2,
> >>> sesId=0a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b,
> >>> startTime=1495452852829, endTime=9223372036854775807,
> >>> taskNodeId=8b249f71-34cd-4ec7-8056-c32a3e61034b,
> >>> clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a, closed=false,
> cpSpi=null,
> >>> failSpi=null, loadSpi=null, usage=1, fullSup=false, internal=true,
> >>> subjId=8b249f71-34cd-4ec7-8056-c32a3e61034b, mapFut=IgniteFuture
> >>> [orig=GridFutureAdapter [resFlag=0, res=null, startTime=1495452852839,
> >>> endTime=0, ignoreInterrupts=false, state=INIT]]],
> >>> jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b]]
> >>>
> >>> class org.apache.ignite.IgniteException:
> java.lang.NullPointerException
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.closure.
> GridClosureProcessor$C2V2.execute(GridClosureProcessor.java:2059)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.job.GridJobWorker$
> 2.call(GridJobWorker.java:560)
> >>>
> >>> at
> >>> org.apache.ignite.internal.util.IgniteUtils.
> wrapThreadLoader(IgniteUtils.java:6620)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.job.GridJobWorker.
> execute0(GridJobWorker.java:554)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.job.GridJobWorker.
> body(GridJobWorker.java:483)
> >>>
> >>> 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.task.GridTaskWorker.sendRequest(
> GridTaskWorker.java:1383)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.task.GridTaskWorker.
> processMappedJobs(GridTaskWorker.java:645)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.task.GridTaskWorker.body(
> GridTaskWorker.java:537)
> >>>
> >>> at
> >>> org.apache.ignite.internal.util.worker.GridWorker.run(
> GridWorker.java:110)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.task.
> GridTaskProcessor.startTask(GridTaskProcessor.java:679)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.task.GridTaskProcessor.execute(
> GridTaskProcessor.java:403)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.closure.GridClosureProcessor.
> callAsync(GridClosureProcessor.java:418)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.closure.GridClosureProcessor.
> callAsync(GridClosureProcessor.java:391)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.cache.GridCacheAdapter.
> globalLoadCacheAsync(GridCacheAdapter.java:3718)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.cache.GridCacheAdapter.
> globalLoadCache(GridCacheAdapter.java:3657)
> >>>
> >>> at
> >>> org.apache.ignite.internal.processors.cache.
> IgniteCacheProxy.loadCache(IgniteCacheProxy.java:390)
> >>>
> >>> at load.LoadCaches.main(LoadCaches.java:28)
> >>>
> >>>
> >>>
> >>
> >
>
Re: Persistent data store error
Posted by Andrey Gura <ag...@apache.org>.
Hi,
Make sure that you have cache store configuration on server and client nodes.
Also use only one type of node configuration: declarative (Spring XML)
or programmatically configuration.
What version of Ignite do you use? I need it for applying provided
stack trace to proper version of code.
On Tue, May 23, 2017 at 2:16 PM, debasish pradhan <de...@gmail.com> wrote:
> hi ,
>
>
> Please find the config file for client .
>
> import com.mchange.v2.c3p0.ComboPooledDataSource;
> import java.io.InputStream;
> import java.math.BigDecimal;
> import java.sql.Types;
> import java.util.ArrayList;
> import java.util.Arrays;
> import java.util.LinkedHashMap;
> import java.util.Properties;
> import javax.cache.configuration.Factory;
> import javax.sql.DataSource;
> import org.apache.ignite.cache.CacheAtomicityMode;
> import org.apache.ignite.cache.CacheMode;
> import org.apache.ignite.cache.QueryEntity;
> import org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory;
> import org.apache.ignite.cache.store.jdbc.JdbcType;
> import org.apache.ignite.cache.store.jdbc.JdbcTypeField;
> import org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect;
> import org.apache.ignite.configuration.BinaryConfiguration;
> import org.apache.ignite.configuration.CacheConfiguration;
> import org.apache.ignite.configuration.IgniteConfiguration;
> import org.apache.ignite.configuration.OdbcConfiguration;
> import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
> import
> org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
> //import com.timesten.jdbc.JdbcOdbcConnection;
> //import com.timesten.jdbc.TimesTenDataSource;
>
> public class ClientConfigurationFactory {
> /** Secret properties loading. **/
> private static final Properties props = new Properties();
>
> static {
> try (InputStream in =
> IgniteConfiguration.class.getClassLoader().getResourceAsStream("secret.properties"))
> {
> props.load(in);
> }
> catch (Exception ignored) {
> // No-op.
> }
> }
>
> /** Helper class for datasource creation. **/
> public static class DataSources {
> public static final ComboPooledDataSource INSTANCE_dataStore =
> createdataStore();
>
> private static ComboPooledDataSource createdataStore() {
> ComboPooledDataSource dataStore = new ComboPooledDataSource();
>
>
> dataStore.setJdbcUrl("jdbc:timesten:client:TTC_Server=localhost;TCP_PORT=53397;TTC_Server_DSN=EMSDSN;UID=test;PWD=test;TTC_Timeout=180");
> dataStore.setUser("kodiak");
> dataStore.setPassword("kodiak");
>
> return dataStore;
> }
> }
>
>
> /**
> * Configure grid.
> *
> * @return Ignite configuration.
> * @throws Exception If failed to construct Ignite configuration
> instance.
> **/
> public static IgniteConfiguration createConfiguration() throws Exception
> {
> IgniteConfiguration cfg = new IgniteConfiguration();
>
> cfg.setClientMode(true);
> cfg.setGridName("TestDB1");
>
> TcpDiscoverySpi discovery = new TcpDiscoverySpi();
>
> TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
>
> ipFinder.setAddresses(Arrays.asList("127.0.0.1:47500..47510"));
>
> discovery.setIpFinder(ipFinder);
>
> cfg.setDiscoverySpi(discovery);
>
> BinaryConfiguration binaryCfg = new BinaryConfiguration();
>
> binaryCfg.setCompactFooter(false);
>
> cfg.setBinaryConfiguration(binaryCfg);
>
> cfg.setOdbcConfiguration(new OdbcConfiguration());
>
> cfg.setCacheConfiguration(cacheEmployeeCache());
>
> return cfg;
> }
>
> /**
> * Create configuration for cache "EmployeeCache".
> *
> * @return Configured cache.
> * @throws Exception if failed to create cache configuration.
> **/
> public static CacheConfiguration cacheEmployeeCache() throws Exception {
> CacheConfiguration ccfg = new CacheConfiguration();
>
> ccfg.setName("EmployeeCache");
> ccfg.setCacheMode(CacheMode.PARTITIONED);
> ccfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
>
> CacheJdbcPojoStoreFactory cacheStoreFactory = new
> CacheJdbcPojoStoreFactory();
>
> cacheStoreFactory.setDataSourceFactory(new Factory<DataSource>() {
> /** {@inheritDoc} **/
> @Override public DataSource create() {
> return DataSources.INSTANCE_dataStore;
> };
> });
>
> cacheStoreFactory.setDialect(new BasicJdbcDialect());
>
> cacheStoreFactory.setTypes(jdbcTypeEmployee(ccfg.getName()));
>
> ccfg.setCacheStoreFactory(cacheStoreFactory);
>
> ccfg.setReadThrough(true);
> ccfg.setWriteThrough(true);
>
> ArrayList<QueryEntity> qryEntities = new ArrayList<>();
>
> QueryEntity qryEntity = new QueryEntity();
>
> qryEntity.setKeyType("com.gmail.orl.debasis.model.EmployeeKey");
> qryEntity.setValueType("com.gmail.orl.debasis.model.Employee");
>
> LinkedHashMap<String, String> fields = new LinkedHashMap<>();
>
> fields.put("id", "java.math.BigDecimal");
> fields.put("firstname", "java.lang.String");
> fields.put("lastname", "java.lang.String");
>
> qryEntity.setFields(fields);
> qryEntities.add(qryEntity);
>
> ccfg.setQueryEntities(qryEntities);
>
> return ccfg;
> }
>
> /**
> * Create JDBC type for "jdbcTypeEmployee".
> *
> * @param cacheName Cache name.
> * @return Configured JDBC type.
> **/
> private static JdbcType jdbcTypeEmployee(String cacheName) {
> JdbcType type = new JdbcType();
>
> type.setCacheName(cacheName);
> type.setKeyType("com.gmail.orl.debasis.model.EmployeeKey");
> type.setValueType("com.gmail.orl.debasis.model.Employee");
> type.setDatabaseSchema("DG");
> type.setDatabaseTable("EMPLOYEE");
>
> type.setValueFields(
> new JdbcTypeField(Types.DECIMAL, "ID", BigDecimal.class, "id"),
> new JdbcTypeField(Types.VARCHAR, "FIRSTNAME", String.class,
> "firstname"),
> new JdbcTypeField(Types.VARCHAR, "LASTNAME", String.class,
> "lastname")
> );
>
> return type;
> }
> }
>
> ******************
> client-config.xml
>
> <?xml version="1.0" encoding="UTF-8"?>
>
> <beans xmlns="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">
> <!-- Load external properties file. -->
> <bean id="placeholderConfig"
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
> <property name="location" value="classpath:secret.properties"/>
> </bean>
>
> <!-- Data source beans will be initialized from external properties
> file. -->
> <bean id="dataStore" class="com.mchange.v2.c3p0.ComboPooledDataSource">
> <property name="jdbcUrl" value="${dataStore.jdbc.url}"/>
> <property name="user" value="${dataStore.jdbc.username}"/>
> <property name="password" value="${dataStore.jdbc.password}"/>
> </bean>
>
> <!-- Data source beans will be initialized from external properties
> file. -->
> <!-- <bean id="dataStore" class="com.timesten.jdbc.TimesTenDataSource">
> <property name="jdbcUrl"
> value="jdbc:timesten:client:TTC_Server=localhost;TCP_PORT=53397;TTC_Server_DSN=emsdsn;UID=kodiak;PWD=kodiak;TTC_Timeout=180"/>
> <property name="user" value="kodiak"/>
> <property name="password" value="kodiak"/>
> </bean>-->
>
> <bean class="org.apache.ignite.configuration.IgniteConfiguration">
> <property name="clientMode" value="false"/>
> <property name="gridName" value="TestDB1"/>
>
> <property name="discoverySpi">
> <bean
> class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
> <property name="ipFinder">
> <bean
> class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
> <property name="addresses">
> <list>
> <value>127.0.0.1:47500..47510</value>
> </list>
> </property>
> </bean>
> </property>
> </bean>
> </property>
>
> <property name="binaryConfiguration">
> <bean
> class="org.apache.ignite.configuration.BinaryConfiguration">
> <property name="compactFooter" value="false"/>
> </bean>
> </property>
>
> <property name="odbcConfiguration">
> <bean class="org.apache.ignite.configuration.OdbcConfiguration">
> </bean>
> </property>
>
> <property name="cacheConfiguration">
> <list>
> <bean
> class="org.apache.ignite.configuration.CacheConfiguration">
> <property name="name" value="EmployeeCache"/>
> <property name="cacheMode" value="PARTITIONED"/>
> <property name="atomicityMode" value="ATOMIC"/>
>
> <property name="cacheStoreFactory">
> <bean
> class="org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory">
> <property name="dataSourceBean"
> value="dataStore"/>
> <property name="dialect">
> <bean
> class="org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect">
> </bean>
> </property>
>
> <property name="types">
> <list>
> <bean
> class="org.apache.ignite.cache.store.jdbc.JdbcType">
> <property name="cacheName"
> value="EmployeeCache"/>
> <property name="keyType"
> value="com.gmail.orl.debasis.model.EmployeeKey"/>
> <property name="valueType"
> value="com.gmail.orl.debasis.model.Employee"/>
> <property name="databaseSchema"
> value="DG"/>
> <property name="databaseTable"
> value="EMPLOYEE"/>
>
> <property name="valueFields">
> <list>
> <bean
> class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
> <constructor-arg>
> <util:constant
> static-field="java.sql.Types.DECIMAL"/>
> </constructor-arg>
> <constructor-arg
> value="ID"/>
> <constructor-arg
> value="java.math.BigDecimal"/>
> <constructor-arg
> value="id"/>
> </bean>
>
> <bean
> class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
> <constructor-arg>
> <util:constant
> static-field="java.sql.Types.VARCHAR"/>
> </constructor-arg>
> <constructor-arg
> value="FIRSTNAME"/>
> <constructor-arg
> value="java.lang.String"/>
> <constructor-arg
> value="firstname"/>
> </bean>
>
> <bean
> class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
> <constructor-arg>
> <util:constant
> static-field="java.sql.Types.VARCHAR"/>
> </constructor-arg>
> <constructor-arg
> value="LASTNAME"/>
> <constructor-arg
> value="java.lang.String"/>
> <constructor-arg
> value="lastname"/>
> </bean>
> </list>
> </property>
> </bean>
> </list>
> </property>
> </bean>
> </property>
>
> <property name="readThrough" value="true"/>
> <property name="writeThrough" value="true"/>
>
> <property name="queryEntities">
> <list>
> <bean
> class="org.apache.ignite.cache.QueryEntity">
> <property name="keyType"
> value="com.gmail.orl.debasis.model.EmployeeKey"/>
> <property name="valueType"
> value="com.gmail.orl.debasis.model.Employee"/>
>
> <property name="fields">
> <map>
> <entry key="id"
> value="java.math.BigDecimal"/>
> <entry key="firstname"
> value="java.lang.String"/>
> <entry key="lastname"
> value="java.lang.String"/>
> </map>
> </property>
> </bean>
> </list>
> </property>
> </bean>
> </list>
> </property>
> </bean>
> </beans>
>
> On Tue, May 23, 2017 at 4:34 PM, Evgenii Zhuravlev
> <e....@gmail.com> wrote:
>>
>> Hi,
>>
>> Could you provide your full config file?
>>
>> 2017-05-22 15:00 GMT+03:00 debasish pradhan <de...@gmail.com>:
>>>
>>> Hi ,
>>>
>>> I am new to apache ignite. I was trying to connect Timesten DB to fetch
>>> data , but its failing . I downloaded the project from web console . As per
>>> instruction I started the server node . After that I am trying to run
>>> loadcache . but its failing with following error.
>>>
>>> cache load code:
>>> =========
>>>
>>> try (Ignite ignite = Ignition.start("TestDB1-client.xml")) {
>>>
>>> System.out.println(">>> Loading caches...");
>>>
>>> System.out.println(">>> Loading cache:...EmployeeCache");
>>>
>>> //ignite.cache("EmployeeCache").loadCache(null);
>>>
>>> ignite.cache("EmployeeCache").loadCache(null, Employee.class.getName(),
>>> "select * from DG.Employee");
>>>
>>>
>>> configuration:jdbc driver :
>>>
>>> public static class DataSources {
>>> public static final TimesTenDataSource INSTANCE_dataStore =
>>> createdataStore();
>>> private static TimesTenDataSource createdataStore() {
>>> TimesTenDataSource dataStore = new TimesTenDataSource();
>>>
>>> dataStore.setUrl("jdbc:timesten:client:TTC_Server=localhost;TCP_PORT=53397;TTC_Server_DSN=TESTDSN;UID=test;PWD=test;TTC_Timeout=180");
>>> dataStore.setUser("test");
>>> dataStore.setPassword("test");
>>> return dataStore;
>>> }
>>> }
>>>
>>>
>>> TestDB1-client.xml-->
>>>
>>> <bean id="dataSource" class="com.timesten.jdbc.TimesTenDataSource">
>>> <property name="url"
>>> value="jdbc:timesten:client:TTC_Server=localhost;TCP_PORT=53397;TTC_Server_DSN=TestDSN;UID=test;PWD=test;TTC_Timeout=180"
>>> />
>>> <property name="username" value="kodiak" />
>>> <property name="password" value="kodiak" />
>>> </bean>
>>>
>>>
>>> [17:04:12,860][SEVERE][main][GridJobWorker] Failed to execute job
>>> [jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b,
>>> ses=GridJobSessionImpl [ses=GridTaskSessionImpl
>>> [taskName=o.a.i.i.processors.cache.GridCacheAdapter$LoadCacheJobV2,
>>> dep=LocalDeployment [super=GridDeployment [ts=1495452846874, depMode=SHARED,
>>> clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a,
>>> clsLdrId=6608fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b, userVer=0,
>>> loc=true, sampleClsName=java.lang.String, pendingUndeploy=false,
>>> undeployed=false, usage=0]],
>>> taskClsName=o.a.i.i.processors.cache.GridCacheAdapter$LoadCacheJobV2,
>>> sesId=0a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b,
>>> startTime=1495452852829, endTime=9223372036854775807,
>>> taskNodeId=8b249f71-34cd-4ec7-8056-c32a3e61034b,
>>> clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a, closed=false, cpSpi=null,
>>> failSpi=null, loadSpi=null, usage=1, fullSup=false, internal=true,
>>> subjId=8b249f71-34cd-4ec7-8056-c32a3e61034b, mapFut=IgniteFuture
>>> [orig=GridFutureAdapter [resFlag=0, res=null, startTime=1495452852839,
>>> endTime=0, ignoreInterrupts=false, state=INIT]]],
>>> jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b]]
>>>
>>> class org.apache.ignite.IgniteException: java.lang.NullPointerException
>>>
>>> at
>>> org.apache.ignite.internal.processors.closure.GridClosureProcessor$C2V2.execute(GridClosureProcessor.java:2059)
>>>
>>> at
>>> org.apache.ignite.internal.processors.job.GridJobWorker$2.call(GridJobWorker.java:560)
>>>
>>> at
>>> org.apache.ignite.internal.util.IgniteUtils.wrapThreadLoader(IgniteUtils.java:6620)
>>>
>>> at
>>> org.apache.ignite.internal.processors.job.GridJobWorker.execute0(GridJobWorker.java:554)
>>>
>>> at
>>> org.apache.ignite.internal.processors.job.GridJobWorker.body(GridJobWorker.java:483)
>>>
>>> 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.task.GridTaskWorker.sendRequest(GridTaskWorker.java:1383)
>>>
>>> at
>>> org.apache.ignite.internal.processors.task.GridTaskWorker.processMappedJobs(GridTaskWorker.java:645)
>>>
>>> at
>>> org.apache.ignite.internal.processors.task.GridTaskWorker.body(GridTaskWorker.java:537)
>>>
>>> at
>>> org.apache.ignite.internal.util.worker.GridWorker.run(GridWorker.java:110)
>>>
>>> at
>>> org.apache.ignite.internal.processors.task.GridTaskProcessor.startTask(GridTaskProcessor.java:679)
>>>
>>> at
>>> org.apache.ignite.internal.processors.task.GridTaskProcessor.execute(GridTaskProcessor.java:403)
>>>
>>> at
>>> org.apache.ignite.internal.processors.closure.GridClosureProcessor.callAsync(GridClosureProcessor.java:418)
>>>
>>> at
>>> org.apache.ignite.internal.processors.closure.GridClosureProcessor.callAsync(GridClosureProcessor.java:391)
>>>
>>> at
>>> org.apache.ignite.internal.processors.cache.GridCacheAdapter.globalLoadCacheAsync(GridCacheAdapter.java:3718)
>>>
>>> at
>>> org.apache.ignite.internal.processors.cache.GridCacheAdapter.globalLoadCache(GridCacheAdapter.java:3657)
>>>
>>> at
>>> org.apache.ignite.internal.processors.cache.IgniteCacheProxy.loadCache(IgniteCacheProxy.java:390)
>>>
>>> at load.LoadCaches.main(LoadCaches.java:28)
>>>
>>>
>>>
>>
>
Re: Persistent data store error
Posted by debasish pradhan <de...@gmail.com>.
hi ,
Please find the config file for client .
import com.mchange.v2.c3p0.ComboPooledDataSource;
import java.io.InputStream;
import java.math.BigDecimal;
import java.sql.Types;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.LinkedHashMap;
import java.util.Properties;
import javax.cache.configuration.Factory;
import javax.sql.DataSource;
import org.apache.ignite.cache.CacheAtomicityMode;
import org.apache.ignite.cache.CacheMode;
import org.apache.ignite.cache.QueryEntity;
import org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory;
import org.apache.ignite.cache.store.jdbc.JdbcType;
import org.apache.ignite.cache.store.jdbc.JdbcTypeField;
import org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect;
import org.apache.ignite.configuration.BinaryConfiguration;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.configuration.OdbcConfiguration;
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
import
org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
//import com.timesten.jdbc.JdbcOdbcConnection;
//import com.timesten.jdbc.TimesTenDataSource;
public class ClientConfigurationFactory {
/** Secret properties loading. **/
private static final Properties props = new Properties();
static {
try (InputStream in =
IgniteConfiguration.class.getClassLoader().getResourceAsStream("secret.properties"))
{
props.load(in);
}
catch (Exception ignored) {
// No-op.
}
}
/** Helper class for datasource creation. **/
public static class DataSources {
public static final ComboPooledDataSource INSTANCE_dataStore =
createdataStore();
private static ComboPooledDataSource createdataStore() {
ComboPooledDataSource dataStore = new ComboPooledDataSource();
dataStore.setJdbcUrl("jdbc:timesten:client:TTC_Server=localhost;TCP_PORT=53397;TTC_Server_DSN=EMSDSN;UID=test;PWD=test;TTC_Timeout=180");
dataStore.setUser("kodiak");
dataStore.setPassword("kodiak");
return dataStore;
}
}
/**
* Configure grid.
*
* @return Ignite configuration.
* @throws Exception If failed to construct Ignite configuration
instance.
**/
public static IgniteConfiguration createConfiguration() throws
Exception {
IgniteConfiguration cfg = new IgniteConfiguration();
cfg.setClientMode(true);
cfg.setGridName("TestDB1");
TcpDiscoverySpi discovery = new TcpDiscoverySpi();
TcpDiscoveryVmIpFinder ipFinder = new TcpDiscoveryVmIpFinder();
ipFinder.setAddresses(Arrays.asList("127.0.0.1:47500..47510"));
discovery.setIpFinder(ipFinder);
cfg.setDiscoverySpi(discovery);
BinaryConfiguration binaryCfg = new BinaryConfiguration();
binaryCfg.setCompactFooter(false);
cfg.setBinaryConfiguration(binaryCfg);
cfg.setOdbcConfiguration(new OdbcConfiguration());
cfg.setCacheConfiguration(cacheEmployeeCache());
return cfg;
}
/**
* Create configuration for cache "EmployeeCache".
*
* @return Configured cache.
* @throws Exception if failed to create cache configuration.
**/
public static CacheConfiguration cacheEmployeeCache() throws Exception {
CacheConfiguration ccfg = new CacheConfiguration();
ccfg.setName("EmployeeCache");
ccfg.setCacheMode(CacheMode.PARTITIONED);
ccfg.setAtomicityMode(CacheAtomicityMode.ATOMIC);
CacheJdbcPojoStoreFactory cacheStoreFactory = new
CacheJdbcPojoStoreFactory();
cacheStoreFactory.setDataSourceFactory(new Factory<DataSource>() {
/** {@inheritDoc} **/
@Override public DataSource create() {
return DataSources.INSTANCE_dataStore;
};
});
cacheStoreFactory.setDialect(new BasicJdbcDialect());
cacheStoreFactory.setTypes(jdbcTypeEmployee(ccfg.getName()));
ccfg.setCacheStoreFactory(cacheStoreFactory);
ccfg.setReadThrough(true);
ccfg.setWriteThrough(true);
ArrayList<QueryEntity> qryEntities = new ArrayList<>();
QueryEntity qryEntity = new QueryEntity();
qryEntity.setKeyType("com.gmail.orl.debasis.model.EmployeeKey");
qryEntity.setValueType("com.gmail.orl.debasis.model.Employee");
LinkedHashMap<String, String> fields = new LinkedHashMap<>();
fields.put("id", "java.math.BigDecimal");
fields.put("firstname", "java.lang.String");
fields.put("lastname", "java.lang.String");
qryEntity.setFields(fields);
qryEntities.add(qryEntity);
ccfg.setQueryEntities(qryEntities);
return ccfg;
}
/**
* Create JDBC type for "jdbcTypeEmployee".
*
* @param cacheName Cache name.
* @return Configured JDBC type.
**/
private static JdbcType jdbcTypeEmployee(String cacheName) {
JdbcType type = new JdbcType();
type.setCacheName(cacheName);
type.setKeyType("com.gmail.orl.debasis.model.EmployeeKey");
type.setValueType("com.gmail.orl.debasis.model.Employee");
type.setDatabaseSchema("DG");
type.setDatabaseTable("EMPLOYEE");
type.setValueFields(
new JdbcTypeField(Types.DECIMAL, "ID", BigDecimal.class, "id"),
new JdbcTypeField(Types.VARCHAR, "FIRSTNAME", String.class,
"firstname"),
new JdbcTypeField(Types.VARCHAR, "LASTNAME", String.class,
"lastname")
);
return type;
}
}
******************
client-config.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="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">
<!-- Load external properties file. -->
<bean id="placeholderConfig"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="location" value="classpath:secret.properties"/>
</bean>
<!-- Data source beans will be initialized from external properties
file. -->
<bean id="dataStore" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="jdbcUrl" value="${dataStore.jdbc.url}"/>
<property name="user" value="${dataStore.jdbc.username}"/>
<property name="password" value="${dataStore.jdbc.password}"/>
</bean>
<!-- Data source beans will be initialized from external properties
file. -->
<!-- <bean id="dataStore" class="com.timesten.jdbc.TimesTenDataSource">
<property name="jdbcUrl"
value="jdbc:timesten:client:TTC_Server=localhost;TCP_PORT=53397;TTC_Server_DSN=emsdsn;UID=kodiak;PWD=kodiak;TTC_Timeout=180"/>
<property name="user" value="kodiak"/>
<property name="password" value="kodiak"/>
</bean>-->
<bean class="org.apache.ignite.configuration.IgniteConfiguration">
<property name="clientMode" value="false"/>
<property name="gridName" value="TestDB1"/>
<property name="discoverySpi">
<bean
class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
<property name="ipFinder">
<bean
class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">
<property name="addresses">
<list>
<value>127.0.0.1:47500..47510</value>
</list>
</property>
</bean>
</property>
</bean>
</property>
<property name="binaryConfiguration">
<bean
class="org.apache.ignite.configuration.BinaryConfiguration">
<property name="compactFooter" value="false"/>
</bean>
</property>
<property name="odbcConfiguration">
<bean class="org.apache.ignite.configuration.OdbcConfiguration">
</bean>
</property>
<property name="cacheConfiguration">
<list>
<bean
class="org.apache.ignite.configuration.CacheConfiguration">
<property name="name" value="EmployeeCache"/>
<property name="cacheMode" value="PARTITIONED"/>
<property name="atomicityMode" value="ATOMIC"/>
<property name="cacheStoreFactory">
<bean
class="org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStoreFactory">
<property name="dataSourceBean"
value="dataStore"/>
<property name="dialect">
<bean
class="org.apache.ignite.cache.store.jdbc.dialect.BasicJdbcDialect">
</bean>
</property>
<property name="types">
<list>
<bean
class="org.apache.ignite.cache.store.jdbc.JdbcType">
<property name="cacheName"
value="EmployeeCache"/>
<property name="keyType"
value="com.gmail.orl.debasis.model.EmployeeKey"/>
<property name="valueType"
value="com.gmail.orl.debasis.model.Employee"/>
<property name="databaseSchema"
value="DG"/>
<property name="databaseTable"
value="EMPLOYEE"/>
<property name="valueFields">
<list>
<bean
class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
<constructor-arg>
<util:constant
static-field="java.sql.Types.DECIMAL"/>
</constructor-arg>
<constructor-arg
value="ID"/>
<constructor-arg
value="java.math.BigDecimal"/>
<constructor-arg
value="id"/>
</bean>
<bean
class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
<constructor-arg>
<util:constant
static-field="java.sql.Types.VARCHAR"/>
</constructor-arg>
<constructor-arg
value="FIRSTNAME"/>
<constructor-arg
value="java.lang.String"/>
<constructor-arg
value="firstname"/>
</bean>
<bean
class="org.apache.ignite.cache.store.jdbc.JdbcTypeField">
<constructor-arg>
<util:constant
static-field="java.sql.Types.VARCHAR"/>
</constructor-arg>
<constructor-arg
value="LASTNAME"/>
<constructor-arg
value="java.lang.String"/>
<constructor-arg
value="lastname"/>
</bean>
</list>
</property>
</bean>
</list>
</property>
</bean>
</property>
<property name="readThrough" value="true"/>
<property name="writeThrough" value="true"/>
<property name="queryEntities">
<list>
<bean
class="org.apache.ignite.cache.QueryEntity">
<property name="keyType"
value="com.gmail.orl.debasis.model.EmployeeKey"/>
<property name="valueType"
value="com.gmail.orl.debasis.model.Employee"/>
<property name="fields">
<map>
<entry key="id"
value="java.math.BigDecimal"/>
<entry key="firstname"
value="java.lang.String"/>
<entry key="lastname"
value="java.lang.String"/>
</map>
</property>
</bean>
</list>
</property>
</bean>
</list>
</property>
</bean>
</beans>
On Tue, May 23, 2017 at 4:34 PM, Evgenii Zhuravlev <e.zhuravlev.wk@gmail.com
> wrote:
> Hi,
>
> Could you provide your full config file?
>
> 2017-05-22 15:00 GMT+03:00 debasish pradhan <de...@gmail.com>:
>
>> Hi ,
>>
>> I am new to apache ignite. I was trying to connect Timesten DB to fetch
>> data , but its failing . I downloaded the project from web console . As per
>> instruction I started the server node . After that I am trying to run
>> loadcache . but its failing with following error.
>>
>> cache load code:
>> =========
>>
>> *try* (Ignite ignite = Ignition.*start*("TestDB1-client.xml")) {
>>
>> System.*out*.println(">>> Loading caches...");
>>
>> System.*out*.println(">>> Loading cache:...EmployeeCache");
>>
>> //ignite.cache("EmployeeCache").loadCache(null);
>>
>> ignite.cache("EmployeeCache").loadCache(*null*, Employee.*class*.getName(),
>> "select * from DG.Employee");
>>
>>
>> configuration:jdbc driver :
>>
>> public static class DataSources {
>> public static final TimesTenDataSource INSTANCE_dataStore =
>> createdataStore();
>> private static TimesTenDataSource createdataStore() {
>> TimesTenDataSource dataStore = new TimesTenDataSource();
>> dataStore.setUrl("jdbc:timesten:client:TTC_Server=localhost;
>> TCP_PORT=53397;TTC_Server_DSN=TESTDSN;UID=test;PWD=test;TTC_
>> Timeout=180");
>> dataStore.setUser("test");
>> dataStore.setPassword("test");
>> return dataStore;
>> }
>> }
>>
>>
>> TestDB1-client.xml-->
>>
>> <bean id="dataSource" class="com.timesten.jdbc.TimesTenDataSource">
>> <property name="url" value="jdbc:timesten:client:TT
>> C_Server=localhost;TCP_PORT=53397;TTC_Server_DSN=TestDSN;UID
>> =test;PWD=test;TTC_Timeout=180" />
>> <property name="username" value="kodiak" />
>> <property name="password" value="kodiak" />
>> </bean>
>>
>> [17:04:12,860][SEVERE][main][GridJobWorker] Failed to execute job
>> [jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b,
>> ses=GridJobSessionImpl [ses=GridTaskSessionImpl
>> [taskName=o.a.i.i.processors.cache.GridCacheAdapter$LoadCacheJobV2,
>> dep=LocalDeployment [super=GridDeployment [ts=1495452846874,
>> depMode=SHARED, clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a,
>> clsLdrId=6608fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b, userVer=0,
>> loc=true, sampleClsName=java.lang.String, pendingUndeploy=false,
>> undeployed=false, usage=0]], taskClsName=o.a.i.i.processors
>> .cache.GridCacheAdapter$LoadCacheJobV2, sesId=0a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b,
>> startTime=1495452852829, endTime=9223372036854775807,
>> taskNodeId=8b249f71-34cd-4ec7-8056-c32a3e61034b,
>> clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a, closed=false,
>> cpSpi=null, failSpi=null, loadSpi=null, usage=1, fullSup=false,
>> internal=true, subjId=8b249f71-34cd-4ec7-8056-c32a3e61034b,
>> mapFut=IgniteFuture [orig=GridFutureAdapter [resFlag=0, res=null,
>> startTime=1495452852839, endTime=0, ignoreInterrupts=false, state=INIT]]],
>> jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b]]
>>
>> class *org.apache.ignite.IgniteException*:
>> *java.lang.NullPointerException*
>>
>> at org.apache.ignite.internal.processors.closure.GridClosurePro
>> cessor$C2V2.execute(*GridClosureProcessor.java:2059*)
>>
>> at org.apache.ignite.internal.processors.job.GridJobWorker$2.call(
>> *GridJobWorker.java:560*)
>>
>> at org.apache.ignite.internal.util.IgniteUtils.wrapThreadLoader(
>> *IgniteUtils.java:6620*)
>>
>> at org.apache.ignite.internal.processors.job.GridJobWorker.execute0(
>> *GridJobWorker.java:554*)
>>
>> at org.apache.ignite.internal.processors.job.GridJobWorker.body(
>> *GridJobWorker.java:483*)
>>
>> at org.apache.ignite.internal.util.worker.GridWorker.run(
>> *GridWorker.java:110*)
>>
>> at org.apache.ignite.internal.processors.job.GridJobProcessor.p
>> rocessJobExecuteRequest(*GridJobProcessor.java:1114*)
>>
>> at org.apache.ignite.internal.processors.task.GridTaskWorker.sendRequest(
>> *GridTaskWorker.java:1383*)
>>
>> at org.apache.ignite.internal.processors.task.GridTaskWorker.pr
>> ocessMappedJobs(*GridTaskWorker.java:645*)
>>
>> at org.apache.ignite.internal.processors.task.GridTaskWorker.body(
>> *GridTaskWorker.java:537*)
>>
>> at org.apache.ignite.internal.util.worker.GridWorker.run(
>> *GridWorker.java:110*)
>>
>> at org.apache.ignite.internal.processors.task.GridTaskProcessor
>> .startTask(*GridTaskProcessor.java:679*)
>>
>> at org.apache.ignite.internal.processors.task.GridTaskProcessor.execute(
>> *GridTaskProcessor.java:403*)
>>
>> at org.apache.ignite.internal.processors.closure.GridClosurePro
>> cessor.callAsync(*GridClosureProcessor.java:418*)
>>
>> at org.apache.ignite.internal.processors.closure.GridClosurePro
>> cessor.callAsync(*GridClosureProcessor.java:391*)
>>
>> at org.apache.ignite.internal.processors.cache.GridCacheAdapter
>> .globalLoadCacheAsync(*GridCacheAdapter.java:3718*)
>>
>> at org.apache.ignite.internal.processors.cache.GridCacheAdapter
>> .globalLoadCache(*GridCacheAdapter.java:3657*)
>>
>> at org.apache.ignite.internal.processors.cache.IgniteCacheProxy
>> .loadCache(*IgniteCacheProxy.java:390*)
>>
>> at load.LoadCaches.main(*LoadCaches.java:28*)
>>
>>
>>
>>
>
Re: Persistent data store error
Posted by Evgenii Zhuravlev <e....@gmail.com>.
Hi,
Could you provide your full config file?
2017-05-22 15:00 GMT+03:00 debasish pradhan <de...@gmail.com>:
> Hi ,
>
> I am new to apache ignite. I was trying to connect Timesten DB to fetch
> data , but its failing . I downloaded the project from web console . As per
> instruction I started the server node . After that I am trying to run
> loadcache . but its failing with following error.
>
> cache load code:
> =========
>
> *try* (Ignite ignite = Ignition.*start*("TestDB1-client.xml")) {
>
> System.*out*.println(">>> Loading caches...");
>
> System.*out*.println(">>> Loading cache:...EmployeeCache");
>
> //ignite.cache("EmployeeCache").loadCache(null);
>
> ignite.cache("EmployeeCache").loadCache(*null*, Employee.*class*.getName(),
> "select * from DG.Employee");
>
>
> configuration:jdbc driver :
>
> public static class DataSources {
> public static final TimesTenDataSource INSTANCE_dataStore =
> createdataStore();
> private static TimesTenDataSource createdataStore() {
> TimesTenDataSource dataStore = new TimesTenDataSource();
> dataStore.setUrl("jdbc:timesten:client:TTC_Server=localhost;
> TCP_PORT=53397;TTC_Server_DSN=TESTDSN;UID=test;PWD=test;TTC_Timeout=180");
> dataStore.setUser("test");
> dataStore.setPassword("test");
> return dataStore;
> }
> }
>
>
> TestDB1-client.xml-->
>
> <bean id="dataSource" class="com.timesten.jdbc.TimesTenDataSource">
> <property name="url" value="jdbc:timesten:client:TT
> C_Server=localhost;TCP_PORT=53397;TTC_Server_DSN=TestDSN;UID
> =test;PWD=test;TTC_Timeout=180" />
> <property name="username" value="kodiak" />
> <property name="password" value="kodiak" />
> </bean>
>
> [17:04:12,860][SEVERE][main][GridJobWorker] Failed to execute job
> [jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b,
> ses=GridJobSessionImpl [ses=GridTaskSessionImpl
> [taskName=o.a.i.i.processors.cache.GridCacheAdapter$LoadCacheJobV2,
> dep=LocalDeployment [super=GridDeployment [ts=1495452846874,
> depMode=SHARED, clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a,
> clsLdrId=6608fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b, userVer=0,
> loc=true, sampleClsName=java.lang.String, pendingUndeploy=false,
> undeployed=false, usage=0]], taskClsName=o.a.i.i.processors
> .cache.GridCacheAdapter$LoadCacheJobV2, sesId=0a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b,
> startTime=1495452852829, endTime=9223372036854775807,
> taskNodeId=8b249f71-34cd-4ec7-8056-c32a3e61034b,
> clsLdr=sun.misc.Launcher$AppClassLoader@4e0e2f2a, closed=false,
> cpSpi=null, failSpi=null, loadSpi=null, usage=1, fullSup=false,
> internal=true, subjId=8b249f71-34cd-4ec7-8056-c32a3e61034b,
> mapFut=IgniteFuture [orig=GridFutureAdapter [resFlag=0, res=null,
> startTime=1495452852839, endTime=0, ignoreInterrupts=false, state=INIT]]],
> jobId=1a08fef2c51-8b249f71-34cd-4ec7-8056-c32a3e61034b]]
>
> class *org.apache.ignite.IgniteException*:
> *java.lang.NullPointerException*
>
> at org.apache.ignite.internal.processors.closure.GridClosurePro
> cessor$C2V2.execute(*GridClosureProcessor.java:2059*)
>
> at org.apache.ignite.internal.processors.job.GridJobWorker$2.call(
> *GridJobWorker.java:560*)
>
> at org.apache.ignite.internal.util.IgniteUtils.wrapThreadLoader(
> *IgniteUtils.java:6620*)
>
> at org.apache.ignite.internal.processors.job.GridJobWorker.execute0(
> *GridJobWorker.java:554*)
>
> at org.apache.ignite.internal.processors.job.GridJobWorker.body(
> *GridJobWorker.java:483*)
>
> at org.apache.ignite.internal.util.worker.GridWorker.run(
> *GridWorker.java:110*)
>
> at org.apache.ignite.internal.processors.job.GridJobProcessor.p
> rocessJobExecuteRequest(*GridJobProcessor.java:1114*)
>
> at org.apache.ignite.internal.processors.task.GridTaskWorker.sendRequest(
> *GridTaskWorker.java:1383*)
>
> at org.apache.ignite.internal.processors.task.GridTaskWorker.pr
> ocessMappedJobs(*GridTaskWorker.java:645*)
>
> at org.apache.ignite.internal.processors.task.GridTaskWorker.body(
> *GridTaskWorker.java:537*)
>
> at org.apache.ignite.internal.util.worker.GridWorker.run(
> *GridWorker.java:110*)
>
> at org.apache.ignite.internal.processors.task.GridTaskProcessor.startTask(
> *GridTaskProcessor.java:679*)
>
> at org.apache.ignite.internal.processors.task.GridTaskProcessor.execute(
> *GridTaskProcessor.java:403*)
>
> at org.apache.ignite.internal.processors.closure.GridClosurePro
> cessor.callAsync(*GridClosureProcessor.java:418*)
>
> at org.apache.ignite.internal.processors.closure.GridClosurePro
> cessor.callAsync(*GridClosureProcessor.java:391*)
>
> at org.apache.ignite.internal.processors.cache.GridCacheAdapter
> .globalLoadCacheAsync(*GridCacheAdapter.java:3718*)
>
> at org.apache.ignite.internal.processors.cache.GridCacheAdapter
> .globalLoadCache(*GridCacheAdapter.java:3657*)
>
> at org.apache.ignite.internal.processors.cache.IgniteCacheProxy.loadCache(
> *IgniteCacheProxy.java:390*)
>
> at load.LoadCaches.main(*LoadCaches.java:28*)
>
>
>
>