Qizx migration

Qizx migration

Hi all ,
How to migrate qizx data to MYSQL DB.

from.host=192.168.1.7
from.user=root
from.password=mysql
from.jndi.port=1199
to.host=192.168.1.14
to.user=admin
to.password=talend
to.jndi.port=1199
to.cluster.batch.size=500

Its not working.
Community Manager

Re: Qizx migration

Hi
Which version are you using? Have you read the user manual about how to migrate MDM projects from XML database to relation database?
https://help.talend.com/search/all?query=Migrating+MDM+instances&content-lang=en
If you have any error during the migration process, paste the log message of the MDM server.
Shong
----------------------------------------------------------
Talend | Data Agility for Modern Business

Re: Qizx migration

Hi shong ,

Im using talend 5.1.1.(now i migrate 5.1.1(qizx) to 5.3.1(sql server))
migration property file
---------------------------
from.host=localhost
from.user=admin
from.password=talend
from.jndi.port=1099
to.host=169.254.43.192
to.user=admin
to.password=talend
to.jndi.port=1199

i got an error
-----------------------------------------------------------------------------------------------------------------------
Couldn't access server localhost
com.amalto.core.util.XtentisException: Error : unable to access the XML Server wrapper: Could not obtain connection to any of thes
e urls: localhost:2099 and discovery failed with error: javax.naming.CommunicationException: error setting options
at org.talend.mdm.db.migration.DBMigrationUtil.getXmlServerCtrlHome(Unknown Source)
at org.talend.mdm.db.migration.DBMigrationTool.doMigration(Unknown Source)
at org.talend.mdm.db.migration.DBMigrationTool.main(Unknown Source)
Caused by: javax.naming.CommunicationException: Could not obtain connection to any of these urls: localhost:2099 and discovery fai
led with error: javax.naming.CommunicationException: error setting options ]]
at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1562)
at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:634)
at org.jnp.interfaces.NamingContext.lookup(NamingContext.java:627)
at javax.naming.InitialContext.lookup(InitialContext.java:392)
at org.talend.mdm.db.migration.DBMigrationUtil.getHome(Unknown Source)
... 3 more
Caused by: javax.naming.CommunicationException: Failed to connect to server localhost:2099 ]
at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:274)
at org.jnp.interfaces.NamingContext.checkRef(NamingContext.java:1533)
... 7 more
Caused by: javax.naming.ServiceUnavailableException: Failed to connect to server localhost:2099
at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:248)
... 8 more
Caused by: java.net.ConnectException: Connection refused: connect
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
at java.net.Socket.connect(Socket.java:529)
at java.net.Socket.connect(Socket.java:478)
at java.net.Socket.<init>(Socket.java:375)
at java.net.Socket.<init>(Socket.java:276)
at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:84)
at org.jnp.interfaces.TimedSocketFactory.createSocket(TimedSocketFactory.java:77)
at org.jnp.interfaces.NamingContext.getServer(NamingContext.java:244)
... 8 more
Employee

Re: Qizx migration

Well... it seems there's a mismatch between:
.. Failed to connect to server localhost:2099 ..

and:
from.host=localhost
...
from.jndi.port=1099

Could you check your configuration?

Re: Qizx migration

Hi all,
I already gave 1099 it also throwed same error...

from.host=192.168.1.14
from.user=admin
from.password=talend
from.jndi.port=1199
to.host=192.168.1.24
to.user=admin
to.password=talend
to.jndi.port=1099
to.cluster.batch.size=500

we tried changing in binding file - C:\Talend\5.2.1\mdm\jboss-4.2.2.GA\server\default\conf but getting same error.
where can we change from.jndi.port and to.jndi.port so that they will stick to changes perminently?
Employee

Re: Qizx migration

Sorry to ask the obvious but you did configure the .14 machine on ports-01 and the .24 on the default port didn't you? Reminder: you change the ports binding in jboss-4.2.2.GA/server/default/conf/jboss-service.xml near the line 215. Comment out the whole <mbean> block to use the default (jndi = 1099).

Re: Qizx migration

Hi Ctoum,
Thanks for your quick reply. I have change the ports binding in jboss-4.2.2.GA/server/default/conf/jboss-service.xml in the line 215. Comment out the whole <mbean> block .But i got same above error.
Employee

Re: Qizx migration

Hi,
Can you try a fresh install and select the correct binding during installation?

Re: Qizx migration

Hi ,


I have tried Qizx to SqlServer Migration Process .While running the migration batch File i got the below error.
------------------------------------------------------------------------
java.lang.reflect.UndeclaredThrowableException
at com.sun.proxy.$Proxy3.existsDataModel(Unknown Source)
at org.talend.mdm.db.migration.DBMigrationTool.doMigration(DBMigrationTool.java:105)
at org.talend.mdm.db.migration.DBMigrationTool.main(DBMigrationTool.java:409)
Caused by: java.io.InvalidClassException: com.amalto.core.ejb.ObjectPOJO; local class incompatible: stream classdesc serialVersionUID = 6448
567774416868288, local class serialVersionUID = 3157316606545297572
at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:604)
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1620)
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1515)
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1620)
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1515)
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1769)
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1348)
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
at org.jboss.invocation.MarshalledValue.get(MarshalledValue.java:91)
at org.jboss.invocation.unified.interfaces.UnifiedInvokerProxy.invoke(UnifiedInvokerProxy.java:195)
at org.jboss.invocation.InvokerInterceptor.invokeInvoker(InvokerInterceptor.java:365)
at org.jboss.invocation.InvokerInterceptor.invoke(InvokerInterceptor.java:197)
at org.jboss.proxy.TransactionInterceptor.invoke(TransactionInterceptor.java:61)
at org.jboss.proxy.SecurityInterceptor.invoke(SecurityInterceptor.java:70)
at org.jboss.proxy.ejb.StatelessSessionInterceptor.invoke(StatelessSessionInterceptor.java:112)
at org.jboss.proxy.ClientContainer.invoke(ClientContainer.java:100)
... 3 more

Re: Qizx migration

Hi All,

Thanks for your suggestion, Migration tool is working fine across XML DB.But, I still having an issue. I have installed Talend 5.1.1 whose MDM is configured to MYSQL. I already have 5.3.1 whose MDM is configured to Qizx XML DB. I am trying to run the DBMigration tool, I am getting the following error:



C:\Talend\5.1.1\mdm\jboss-4.2.2.GA\bin\dbtools\migration>java -cp dbmigrationtool.jar;../../../client/jbossall-
client.jar org.talend.mdm.db.migration.DBMigrationTool dbmigration.properties
DB Migration from 192.168.1.201 to 192.168.1.143 starting ...
transfering collection CONF ...
transfering collection Inbox ...
transfering collection JCAAdapters ...
transfering collection MDMDomainObjects ...
transfering collection MDMItemImages ...
transfering collection MDMItemsTrash ...
transfering collection MDMMigration ...
transfering collection PROVISIONING ...
transfering collection Reporting ...
transfering collection Revision ...
transfering collection SearchTemplate ...
transfering collection UpdateReport ...
java.rmi.ServerException: RuntimeException; nested exception is:
java.lang.RuntimeException: Could not create storage 'UpdateReport' with data model 'UpdateReport'.
at org.jboss.ejb.plugins.LogInterceptor.handleException(LogInterceptor.java:421)
at org.jboss.ejb.plugins.LogInterceptor.invoke(LogInterceptor.java:209)
at org.jboss.ejb.plugins.ProxyFactoryFinderInterceptor.invoke(ProxyFactoryFinderInterceptor.java:138)
at org.jboss.ejb.SessionContainer.internalInvoke(SessionContainer.java:648)
at org.jboss.ejb.Container.invoke(Container.java:960)
at sun.reflect.GeneratedMethodAccessor138.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.jboss.mx.interceptor.ReflectedDispatcher.invoke(ReflectedDispatcher.java:155)
at org.jboss.mx.server.Invocation.dispatch(Invocation.java:94)
at org.jboss.mx.server.Invocation.invoke(Invocation.java:86)
at org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:264)
at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:659)
at org.jboss.invocation.unified.server.UnifiedInvoker.invoke(UnifiedInvoker.java:231)
at sun.reflect.GeneratedMethodAccessor142.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.jboss.mx.interceptor.ReflectedDispatcher.invoke(ReflectedDispatcher.java:155)
at org.jboss.mx.server.Invocation.dispatch(Invocation.java:94)
at org.jboss.mx.server.Invocation.invoke(Invocation.java:86)
at org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:264)
at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:659)
at javax.management.MBeanServerInvocationHandler.invoke(MBeanServerInvocationHandler.java:305)
at com.sun.proxy.$Proxy17.invoke(Unknown Source)
at org.jboss.remoting.ServerInvoker.invoke(ServerInvoker.java:769)
at org.jboss.remoting.transport.socket.ServerThread.processInvocation(ServerThread.java:573)
at org.jboss.remoting.transport.socket.ServerThread.dorun(ServerThread.java:387)
at org.jboss.remoting.transport.socket.ServerThread.run(ServerThread.java:166)
Caused by: java.lang.RuntimeException: Could not create storage 'UpdateReport' with data model 'UpdateReport'.
at com.amalto.core.server.StorageAdminImpl.create(StorageAdminImpl.java:110)
at com.amalto.core.storage.StorageWrapper.createCluster(StorageWrapper.java:130)
at com.amalto.core.storage.DispatchWrapper.createCluster(DispatchWrapper.java:159)
at com.amalto.core.ejb.XmlServerSLWrapperBean.createCluster(XmlServerSLWrapperBean.java:191)
at sun.reflect.GeneratedMethodAccessor238.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.jboss.invocation.Invocation.performCall(Invocation.java:359)
at org.jboss.ejb.StatelessSessionContainer$ContainerInterceptor.invoke(StatelessSessionContainer.java:2
37)
at org.jboss.resource.connectionmanager.CachedConnectionInterceptor.invoke(CachedConnectionInterceptor.
java:158)
at org.jboss.ejb.plugins.StatelessSessionInstanceInterceptor.invoke(StatelessSessionInstanceInterceptor
.java:169)
at org.jboss.ejb.plugins.CallValidationInterceptor.invoke(CallValidationInterceptor.java:63)
at org.jboss.ejb.plugins.AbstractTxInterceptor.invokeNext(AbstractTxInterceptor.java:121)
at org.jboss.ejb.plugins.TxInterceptorCMT.runWithTransactions(TxInterceptorCMT.java:350)
at org.jboss.ejb.plugins.TxInterceptorCMT.invoke(TxInterceptorCMT.java:181)
at org.jboss.ejb.plugins.SecurityInterceptor.invoke(SecurityInterceptor.java:168)
at org.jboss.ejb.plugins.LogInterceptor.invoke(LogInterceptor.java:205)
at org.jboss.ejb.plugins.ProxyFactoryFinderInterceptor.invoke(ProxyFactoryFinderInterceptor.java:138)
at org.jboss.ejb.SessionContainer.internalInvoke(SessionContainer.java:648)
at org.jboss.ejb.Container.invoke(Container.java:960)
at sun.reflect.GeneratedMethodAccessor138.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.jboss.mx.interceptor.ReflectedDispatcher.invoke(ReflectedDispatcher.java:155)
at org.jboss.mx.server.Invocation.dispatch(Invocation.java:94)
at org.jboss.mx.server.Invocation.invoke(Invocation.java:86)
at org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:264)
at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:659)
at org.jboss.invocation.unified.server.UnifiedInvoker.invoke(UnifiedInvoker.java:231)
at sun.reflect.GeneratedMethodAccessor142.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.jboss.mx.interceptor.ReflectedDispatcher.invoke(ReflectedDispatcher.java:155)
at org.jboss.mx.server.Invocation.dispatch(Invocation.java:94)
at org.jboss.mx.server.Invocation.invoke(Invocation.java:86)
at org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:264)
at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:659)
at javax.management.MBeanServerInvocationHandler.invoke(MBeanServerInvocationHandler.java:305)
at com.sun.proxy.$Proxy17.invoke(Unknown Source)
at org.jboss.remoting.ServerInvoker.invoke(ServerInvoker.java:769)
at org.jboss.remoting.transport.socket.ServerThread.processInvocation(ServerThread.java:573)
at org.jboss.remoting.transport.socket.ServerThread.dorun(ServerThread.java:387)
at org.jboss.remoting.transport.socket.ServerThread.run(ServerThread.java:166)
at org.jboss.remoting.MicroRemoteClientInvoker.invoke(MicroRemoteClientInvoker.java:163)
at org.jboss.remoting.Client.invoke(Client.java:1634)
at org.jboss.remoting.Client.invoke(Client.java:548)
at org.jboss.invocation.unified.interfaces.UnifiedInvokerProxy.invoke(UnifiedInvokerProxy.java:183)
at org.jboss.invocation.InvokerInterceptor.invokeInvoker(InvokerInterceptor.java:365)
at org.jboss.invocation.MarshallingInvokerInterceptor.invoke(MarshallingInvokerInterceptor.java:63)
at org.jboss.proxy.TransactionInterceptor.invoke(TransactionInterceptor.java:61)
at org.jboss.proxy.SecurityInterceptor.invoke(SecurityInterceptor.java:70)
at org.jboss.proxy.ejb.StatelessSessionInterceptor.invoke(StatelessSessionInterceptor.java:112)
at org.jboss.proxy.ClientContainer.invoke(ClientContainer.java:100)
at com.sun.proxy.$Proxy1.createCluster(Unknown Source)
at org.talend.mdm.db.migration.DBMigrationTool.doMigration(Unknown Source)
at org.talend.mdm.db.migration.DBMigrationTool.main(Unknown Source)
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: Data model is in
valid:
Type 'X_ANONYMOUS0' does not exist. (line: 1412 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 493 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 1380 / column: 15)
Type 'X_ANONYMOUS5' does not exist. (line: 408 / column: 15)
Type 'X_ANONYMOUS5' does not exist. (line: 226 / column: 17)
Type 'X_ANONYMOUS5' does not exist. (line: 438 / column: 15)
Type 'X_ANONYMOUS5' does not exist. (line: 483 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 1411 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 492 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 1379 / column: 15)
at com.amalto.core.server.MetadataRepositoryAdminImpl.<init>(MetadataRepositoryAdminImpl.java:57)
at com.amalto.core.server.ServerContext$DefaultServerLifecycle.createMetadataRepositoryAdmin(ServerCont
ext.java:82)
at com.amalto.core.server.ServerImpl.getMetadataRepositoryAdmin(ServerImpl.java:86)
at com.amalto.core.server.StorageAdminImpl.internalCreateStorage(StorageAdminImpl.java:229)
at com.amalto.core.server.StorageAdminImpl.create(StorageAdminImpl.java:101)
at com.amalto.core.storage.StorageWrapper.createCluster(StorageWrapper.java:130)
at com.amalto.core.storage.DispatchWrapper.createCluster(DispatchWrapper.java:159)
at com.amalto.core.ejb.XmlServerSLWrapperBean.createCluster(XmlServerSLWrapperBean.java:191)
at sun.reflect.GeneratedMethodAccessor238.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.jboss.invocation.Invocation.performCall(Invocation.java:359)
at org.jboss.ejb.StatelessSessionContainer$ContainerInterceptor.invoke(StatelessSessionContainer.java:2
37)
at org.jboss.resource.connectionmanager.CachedConnectionInterceptor.invoke(CachedConnectionInterceptor.
java:158)
at org.jboss.ejb.plugins.StatelessSessionInstanceInterceptor.invoke(StatelessSessionInstanceInterceptor
.java:169)
at org.jboss.ejb.plugins.CallValidationInterceptor.invoke(CallValidationInterceptor.java:63)
at org.jboss.ejb.plugins.AbstractTxInterceptor.invokeNext(AbstractTxInterceptor.java:121)
at org.jboss.ejb.plugins.TxInterceptorCMT.runWithTransactions(TxInterceptorCMT.java:350)
at org.jboss.ejb.plugins.TxInterceptorCMT.invoke(TxInterceptorCMT.java:181)
at org.jboss.ejb.plugins.SecurityInterceptor.invoke(SecurityInterceptor.java:168)
at org.jboss.ejb.plugins.LogInterceptor.invoke(LogInterceptor.java:205)
at org.jboss.ejb.plugins.ProxyFactoryFinderInterceptor.invoke(ProxyFactoryFinderInterceptor.java:138)
at org.jboss.ejb.SessionContainer.internalInvoke(SessionContainer.java:648)
at org.jboss.ejb.Container.invoke(Container.java:960)
at sun.reflect.GeneratedMethodAccessor138.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.jboss.mx.interceptor.ReflectedDispatcher.invoke(ReflectedDispatcher.java:155)
at org.jboss.mx.server.Invocation.dispatch(Invocation.java:94)
at org.jboss.mx.server.Invocation.invoke(Invocation.java:86)
at org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:264)
at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:659)
at org.jboss.invocation.unified.server.UnifiedInvoker.invoke(UnifiedInvoker.java:231)
at sun.reflect.GeneratedMethodAccessor142.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:601)
at org.jboss.mx.interceptor.ReflectedDispatcher.invoke(ReflectedDispatcher.java:155)
at org.jboss.mx.server.Invocation.dispatch(Invocation.java:94)
at org.jboss.mx.server.Invocation.invoke(Invocation.java:86)
at org.jboss.mx.server.AbstractMBeanInvoker.invoke(AbstractMBeanInvoker.java:264)
at org.jboss.mx.server.MBeanServerImpl.invoke(MBeanServerImpl.java:659)
at javax.management.MBeanServerInvocationHandler.invoke(MBeanServerInvocationHandler.java:305)
at com.sun.proxy.$Proxy17.invoke(Unknown Source)
at org.jboss.remoting.ServerInvoker.invoke(ServerInvoker.java:769)
at org.jboss.remoting.transport.socket.ServerThread.processInvocation(ServerThread.java:573)
at org.jboss.remoting.transport.socket.ServerThread.dorun(ServerThread.java:387)
at org.jboss.remoting.transport.socket.ServerThread.run(ServerThread.java:166)
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Data model is invalid:
Type 'X_ANONYMOUS0' does not exist. (line: 1412 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 493 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 1380 / column: 15)
Type 'X_ANONYMOUS5' does not exist. (line: 408 / column: 15)
Type 'X_ANONYMOUS5' does not exist. (line: 226 / column: 17)
Type 'X_ANONYMOUS5' does not exist. (line: 438 / column: 15)
Type 'X_ANONYMOUS5' does not exist. (line: 483 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 1411 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 492 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 1379 / column: 15)
at com.amalto.core.server.MetadataRepositoryAdminImpl.get(MetadataRepositoryAdminImpl.java:152)
at com.amalto.core.server.MetadataRepositoryAdminImpl.<init>(MetadataRepositoryAdminImpl.java:53)
... 46 more
Caused by: java.lang.RuntimeException: Data model is invalid:
Type 'X_ANONYMOUS0' does not exist. (line: 1412 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 493 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 1380 / column: 15)
Type 'X_ANONYMOUS5' does not exist. (line: 408 / column: 15)
Type 'X_ANONYMOUS5' does not exist. (line: 226 / column: 17)
Type 'X_ANONYMOUS5' does not exist. (line: 438 / column: 15)
Type 'X_ANONYMOUS5' does not exist. (line: 483 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 1411 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 492 / column: 15)
Type 'X_ANONYMOUS0' does not exist. (line: 1379 / column: 15)
at org.talend.mdm.commmon.metadata.DefaultValidationHandler.end(DefaultValidationHandler.java:78)
at org.talend.mdm.commmon.metadata.MetadataRepository.load(MetadataRepository.java:206)
at org.talend.mdm.commmon.metadata.MetadataRepository.load(MetadataRepository.java:171)
at com.amalto.core.server.MetadataRepositoryAdminImpl.get(MetadataRepositoryAdminImpl.java:148)
... 47 more

file con
-----------------

from.host=192.168.1.201
from.user=admin
from.password=talend
from.jndi.port=1199
to.host=192.168.1.143
to.password=talend
to.jndi.port=1099
to.cluster.batch.size=500