DEVOPS-1729 Nexus migration: Update URLs

component(tsalesforcebulkexec)
https://jira.talendforge.org/browse/TUP-4547

i18n/plugins/org.talend.componentdesigner.nl/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Designer Plug-in Nl Fragment
 Bundle-SymbolicName: org.talend.componentdesigner.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.componentdesigner
 Bundle-Localization: plugin
 Bundle-Vendor: .Talend SA.

i18n/plugins/org.talend.componentdesigner.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.componentdesigner.nl</artifactId>

i18n/plugins/org.talend.componentdesigner.rcp.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.componentdesigner.rcp.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.componentdesigner.rcp

i18n/plugins/org.talend.componentdesigner.rcp.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.componentdesigner.rcp.nl</artifactId>

i18n/plugins/org.talend.designer.abstractmap.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.designer.abstractmap.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.abstractmap

i18n/plugins/org.talend.designer.abstractmap.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.abstractmap.nl</artifactId>

i18n/plugins/org.talend.designer.alfrescooutput.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.designer.alfrescooutput.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.alfrescooutput

i18n/plugins/org.talend.designer.alfrescooutput.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.alfrescooutput.nl</artifactId>

i18n/plugins/org.talend.designer.business.diagram.nl/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.designer.business.diagram.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Bundle-Vendor: .Talend SA.
 Fragment-Host: org.talend.designer.business.diagram
 Bundle-Localization: plugin

i18n/plugins/org.talend.designer.business.diagram.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.business.diagram.nl</artifactId>

i18n/plugins/org.talend.designer.codegen.nl/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: org.talend.designer.codegen Nl Fragment
 Bundle-SymbolicName: org.talend.designer.codegen.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.codegen
 Bundle-Localization: plugin
 Bundle-Vendor: .Talend SA.

i18n/plugins/org.talend.designer.codegen.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.codegen.nl</artifactId>

i18n/plugins/org.talend.designer.components.exchange.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl
 Bundle-SymbolicName: org.talend.designer.components.exchange.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.components.exchange

i18n/plugins/org.talend.designer.components.exchange.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.components.exchange.nl</artifactId>

i18n/plugins/org.talend.designer.core.nl/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Designer Plug-in Nl Fragment
 Bundle-SymbolicName: org.talend.designer.core.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.core
 Bundle-Localization: plugin
 Bundle-Vendor: .Talend SA.

i18n/plugins/org.talend.designer.core.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.core.nl</artifactId>

i18n/plugins/org.talend.designer.dbmap.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.designer.dbmap.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.dbmap

i18n/plugins/org.talend.designer.dbmap.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.dbmap.nl</artifactId>

i18n/plugins/org.talend.designer.documentation.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl
 Bundle-SymbolicName: org.talend.designer.documentation.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.documentation

i18n/plugins/org.talend.designer.documentation.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.documentation.nl</artifactId>

i18n/plugins/org.talend.designer.fileoutputxml.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.designer.fileoutputxml.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.fileoutputxml

i18n/plugins/org.talend.designer.fileoutputxml.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.fileoutputxml.nl</artifactId>

i18n/plugins/org.talend.designer.gefabstractmap.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.designer.gefabstractmap.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.gefabstractmap

i18n/plugins/org.talend.designer.gefabstractmap.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.gefabstractmap.nl</artifactId>

i18n/plugins/org.talend.designer.hl7.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl
 Bundle-SymbolicName: org.talend.designer.hl7.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.hl7

i18n/plugins/org.talend.designer.hl7.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.hl7.nl</artifactId>

i18n/plugins/org.talend.designer.mapper.nl/META-INF/MANIFEST.MF

@@ -2,6 +2,6 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Mapper component Plug-in Nl Fragment
 Bundle-SymbolicName: org.talend.designer.mapper.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.mapper
 Bundle-Vendor: .Talend SA.

i18n/plugins/org.talend.designer.mapper.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.mapper.nl</artifactId>

i18n/plugins/org.talend.designer.maven.job.nl/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Maven Job NL
 Bundle-SymbolicName: org.talend.designer.maven.job.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Bundle-Vendor: .Talend SA.
 Fragment-Host: org.talend.designer.maven.job
 Bundle-RequiredExecutionEnvironment: JavaSE-1.7

i18n/plugins/org.talend.designer.maven.job.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.maven.job.nl</artifactId>

i18n/plugins/org.talend.designer.rowgenerator.nl/META-INF/MANIFEST.MF

@@ -2,6 +2,6 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Rowgenerator Nl Fragment
 Bundle-SymbolicName: org.talend.designer.rowgenerator.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.rowgenerator
 Bundle-Vendor: .Talend SA.

i18n/plugins/org.talend.designer.rowgenerator.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.rowgenerator.nl</artifactId>

i18n/plugins/org.talend.designer.runprocess.nl/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: org.talend.designer.runprocess.nl fragment
 Bundle-SymbolicName: org.talend.designer.runprocess.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Bundle-Vendor: .Talend SA.
 Fragment-Host: org.talend.designer.runprocess
 Bundle-Localization: plugin

i18n/plugins/org.talend.designer.runprocess.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.runprocess.nl</artifactId>

i18n/plugins/org.talend.designer.runprocess.nl/src/main/java/messages_en.properties

@@ -63,7 +63,7 @@ ProcessDebugDialog.debugBtn=Debug
 prefs.configuration.title=Run process configuration :
 ProcessComposite.startPattern=Starting job {0} at {1,date,HH:mm dd/MM/yyyy}.\n
 DefaultRunProcessService.methodCalledError=This method should'nt be called here, use it on RunProcessService class.
-ErrorDetailDialog.errorExist=\ Some errors exist in job. Would you like to continue?
+ErrorDetailDialog.errorExist=\ \ Warning\! Some errors exist in job. Would you like to continue?
 ErrorDetailDialog.findError=Error found
 ProcessComposite.hideContext=hide the Context
 ProcessComposite.lineLimited=Line limit

i18n/plugins/org.talend.designer.scd.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.designer.scd.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.scd

i18n/plugins/org.talend.designer.scd.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.scd.nl</artifactId>

i18n/plugins/org.talend.designer.webservice.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.designer.webservice.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.webservice

i18n/plugins/org.talend.designer.webservice.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.webservice.nl</artifactId>

i18n/plugins/org.talend.designer.xmlmap.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl
 Bundle-SymbolicName: org.talend.designer.xmlmap.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.designer.xmlmap

i18n/plugins/org.talend.designer.xmlmap.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.xmlmap.nl</artifactId>

i18n/plugins/org.talend.expressionbuilder.nl/META-INF/MANIFEST.MF

@@ -2,6 +2,6 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Expression Builder Nl Fragment
 Bundle-SymbolicName: org.talend.expressionbuilder.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.expressionbuilder
 Bundle-Vendor: .Talend SA.

i18n/plugins/org.talend.expressionbuilder.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.expressionbuilder.nl</artifactId>

i18n/plugins/org.talend.presentation.onboarding.resource.nl/META-INF/MANIFEST.MF

@@ -2,6 +2,6 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: NL
 Bundle-SymbolicName: org.talend.presentation.onboarding.resource.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.presentation.onboarding.resource
 Bundle-Vendor: .Talend SA.

i18n/plugins/org.talend.presentation.onboarding.resource.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.presentation.onboarding.resource.nl</artifactId>

i18n/plugins/org.talend.presentation.onboarding.resource.tos.nl/META-INF/MANIFEST.MF

@@ -2,6 +2,6 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: NL
 Bundle-SymbolicName: org.talend.presentation.onboarding.resource.tos.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.presentation.onboarding.resource.tos
 Bundle-Vendor: .Talend SA.

i18n/plugins/org.talend.presentation.onboarding.resource.tos.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.presentation.onboarding.resource.tos.nl</artifactId>

i18n/plugins/org.talend.repository.ftp.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl
 Bundle-SymbolicName: org.talend.repository.ftp.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.repository.ftp

i18n/plugins/org.talend.repository.ftp.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.repository.ftp.nl</artifactId>

i18n/plugins/org.talend.repository.json.nl/META-INF/MANIFEST.MF

@@ -2,6 +2,6 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.repository.json.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.repository.json
 Bundle-Vendor: .Talend SA.

i18n/plugins/org.talend.repository.json.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.repository.json.nl</artifactId>

i18n/plugins/org.talend.repository.nl/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.repository.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.repository
 Bundle-Localization: plugin
 Bundle-Vendor: .Talend SA.

i18n/plugins/org.talend.repository.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.repository.nl</artifactId>

i18n/plugins/org.talend.repository.nl/src/main/java/messages_en.properties

@@ -477,7 +477,7 @@ SecurityProjectSettingPage.hidePass=Hide password for document generation
 SelectDeleteProjectDialog.deleteWarning=Do not delete projects physically
 SelectorTableForm.enterType=Enter type name prefix or pattern (*,?).
 SelectorTableForm.nameFilter=Name Filter\:
-connections.form.field.usernameNoMail=User Name
+connections.form.field.usernameNoMail=User name
 ImportProjectSettings.Error=Project settings file is invalid !
 ExportTreeViewer.hideJobTree=Hide job tree
 ExportTreeViewer.selectItems=Select the items to Export:

i18n/plugins/org.talend.repository.view.di.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl
 Bundle-SymbolicName: org.talend.repository.view.di.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.repository.view.di

i18n/plugins/org.talend.repository.view.di.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.repository.view.di.nl</artifactId>

i18n/plugins/org.talend.sbi.engines.client.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.sbi.engines.client.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.sbi.engines.client

i18n/plugins/org.talend.sbi.engines.client.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.sbi.engines.client.nl</artifactId>

i18n/plugins/org.talend.spagic.engines.client.nl/META-INF/MANIFEST.MF

@@ -2,5 +2,5 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Nl Fragment
 Bundle-SymbolicName: org.talend.spagic.engines.client.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Fragment-Host: org.talend.spagic.engines.client

i18n/plugins/org.talend.spagic.engines.client.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.spagic.engines.client.nl</artifactId>

i18n/plugins/org.talend.sqlbuilder.nl/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: org.talend.sqlbuilder Nl Fragment
 Bundle-SymbolicName: org.talend.sqlbuilder.nl
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Bundle-Vendor: .Talend SA.
 Fragment-Host: org.talend.sqlbuilder
 Bundle-Localization: plugin

i18n/plugins/org.talend.sqlbuilder.nl/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.sqlbuilder.nl</artifactId>

main/features/org.talend.componentdesigner.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.componentdesigner.feature"
       label="Componentdesigner_feature Feature"
-      version="6.2.2.qualifier"
+      version="6.2.0.qualifier"
       provider-name=".Talend SA.">
 
    <description url="http://www.example.com/description">

main/features/org.talend.componentdesigner.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.componentdesigner.feature</artifactId>

main/features/org.talend.designer.business.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.designer.business.feature"
       label="Business Feature"
-      version="6.2.2.qualifier"
+      version="6.2.0.qualifier"
       provider-name=".Talend SA.">
 
    <description url="http://www.talend.com/online/featuresdescription.html#business-feature">

main/features/org.talend.designer.business.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.business.feature</artifactId>

main/features/org.talend.designer.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.designer.feature"
       label="Designer Feature"
-      version="6.2.2.qualifier"
+      version="6.2.0.qualifier"
       provider-name=".Talend SA.">
 
    <description url="http://www.talend.com/online/featuresdescription.html#designer-feature">

main/features/org.talend.designer.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.feature</artifactId>

main/features/org.talend.rcp.branding.tos.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.rcp.branding.tos.feature"
       label="Tos branding feature"
-      version="6.2.2.qualifier"
+      version="6.2.0.qualifier"
       provider-name=".Talend SA."
       plugin="org.talend.rcp.branding.tos">
 
@@ -51,12 +51,4 @@
          install-size="0"
          version="0.0.0"
          fragment="true"/>
-
-   <plugin
-         id="org.talend.designer.maven.tos"
-         download-size="0"
-         install-size="0"
-         version="0.0.0"
-         fragment="true"/>
-
 </feature>

main/features/org.talend.rcp.branding.tos.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.rcp.branding.tos.feature</artifactId>

main/features/org.talend.rcp.branding.tos.test.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.rcp.branding.tos.test.feature"
       label="Test feature for TOS"
-      version="6.2.2.qualifier">
+      version="6.2.0.qualifier">
 
    <description url="http://www.example.com/description">
       [Enter Feature Description here.]
@@ -337,28 +337,11 @@
          fragment="true"
          unpack="false"/>
 
-   <plugin
+	<plugin
          id="org.talend.designer.webservice.test"
          download-size="0"
          install-size="0"
          version="0.0.0"
          fragment="true"
          unpack="false"/>
-
-   <plugin
-         id="org.talend.updates.runtime.test"
-         download-size="0"
-         install-size="0"
-         version="0.0.0"
-         fragment="true"
-         unpack="false"/>
-
-   <plugin
-         id="org.talend.repository.view.test"
-         download-size="0"
-         install-size="0"
-         version="0.0.0"
-         fragment="true"
-         unpack="false"/>
-
 </feature>

main/features/org.talend.rcp.branding.tos.test.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.rcp.branding.tos.test.feature</artifactId>

main/features/org.talend.repository.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.repository.feature"
       label="Repository Feature"
-      version="6.2.2.qualifier"
+      version="6.2.0.qualifier"
       provider-name=".Talend SA.">
 
    <description url="http://www.talend.com/online/featuresdescription.html#repository-feature">

main/features/org.talend.repository.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.repository.feature</artifactId>

main/features/org.talend.sbi.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.sbi.feature"
       label="SBI Feature"
-      version="6.2.2.qualifier"
+      version="6.2.0.qualifier"
       provider-name=".Talend SA.">
 
    <description url="http://www.talend.com/online/featuresdescription.html#sbi-feature">

main/features/org.talend.sbi.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.sbi.feature</artifactId>

main/features/org.talend.spagic.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.spagic.feature"
       label="SPAGIC Feature"
-      version="6.2.2.qualifier"
+      version="6.2.0.qualifier"
       provider-name=".Talend SA.">
 
    <description url="http://www.talend.com/online/featuresdescription.html#spagic-feature">

main/features/org.talend.spagic.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.spagic.feature</artifactId>

main/features/org.talend.tos.components.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.tos.components.feature"
       label="Components-feature"
-      version="6.2.2.qualifier">
+      version="6.2.0.qualifier">
 
    <description url="http://www.example.com/description">
       [Enter Feature Description here.]
@@ -254,14 +254,6 @@
          fragment="true"
          unpack="false"/>
 
-   <plugin
-         id="biz.aQute.bnd.annotation"
-         download-size="0"
-         install-size="0"
-         version="0.0.0"
-         fragment="true"
-         unpack="false"/>
-
    <plugin
          id="org.talend.components.api"
          download-size="0"
@@ -270,14 +262,6 @@
          fragment="true"
          unpack="false"/>
 
-   <plugin
-         id="org.talend.components.api.service"
-         download-size="0"
-         install-size="0"
-         version="0.0.0"
-         fragment="true"
-         unpack="false"/>
-
    <plugin
          id="org.talend.components.common"
          download-size="0"
@@ -308,6 +292,12 @@
          version="0.0.0"
          unpack="false"/>
 
+   <plugin
+         id="org.talend.components.salesforce"
+         download-size="0"
+         install-size="0"
+         version="0.0.0"
+         unpack="false"/>
    <plugin
          id="org.talend.components.salesforce"
          download-size="0"
@@ -329,4 +319,10 @@
          version="0.0.0"
          unpack="false"/>
          
+   <plugin
+         id="org.talend.components.dataprep"
+         download-size="0"
+         install-size="0"
+         version="0.0.0"
+         unpack="false"/>
 </feature>

main/features/org.talend.tos.components.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.tos.components.feature</artifactId>

main/features/org.talend.tos.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.tos.feature"
       label="Tos feature"
-      version="6.2.2.qualifier"
+      version="6.2.0.qualifier"
       provider-name=".Talend SA.">
 
    <description url="http://www.example.com/description">

main/features/org.talend.tos.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.tos.feature</artifactId>

main/features/org.talend.tos.libraries.feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.talend.tos.libraries.feature"
       label="Libraries_feature"
-      version="6.2.2.qualifier">
+      version="6.2.0.qualifier">
 
    <description url="http://www.example.com/description">
       [Enter Feature Description here.]
@@ -295,5 +295,11 @@
          install-size="0"
          version="1.0.4.v201101211617"
          unpack="false"/>
-         
+
+   <plugin
+         id="org.talend.libraries.redshift"
+         download-size="0"
+         install-size="0"
+         version="0.0.0"/>
+
 </feature>

main/features/org.talend.tos.libraries.feature/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.tos.libraries.feature</artifactId>

main/plugins/org.talend.componentdesigner.rcp/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Rcp Plug-in
 Bundle-SymbolicName: org.talend.componentdesigner.rcp; singleton:=true
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Bundle-Activator: org.talend.componentdesigner.rcp.Activator
 Require-Bundle: org.eclipse.ui,
  org.eclipse.core.runtime,

main/plugins/org.talend.componentdesigner.rcp/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.componentdesigner.rcp</artifactId>

main/plugins/org.talend.componentdesigner/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Componentdesigner Plug-in
 Bundle-SymbolicName: org.talend.componentdesigner; singleton:=true
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Bundle-Activator: org.talend.componentdesigner.ComponentDesigenerPlugin
 Require-Bundle: org.talend.model,
  org.eclipse.ui,

main/plugins/org.talend.componentdesigner/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.componentdesigner</artifactId>

main/plugins/org.talend.designer.abstractmap/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Abstract Map Plug-in
 Bundle-SymbolicName: org.talend.designer.abstractmap;singleton:=true
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Bundle-Activator: org.talend.designer.abstractmap.MapPlugin
 Require-Bundle: org.eclipse.core.runtime,
  org.talend.core,

main/plugins/org.talend.designer.abstractmap/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.abstractmap</artifactId>

main/plugins/org.talend.designer.alfrescooutput/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: Alfresco Output Component Plug-in
 Bundle-SymbolicName: org.talend.designer.alfrescooutput;singleton:=true
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Bundle-Vendor: .Talend SA.
 Require-Bundle: org.eclipse.core.runtime,
  org.talend.core,

main/plugins/org.talend.designer.alfrescooutput/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.alfrescooutput</artifactId>

main/plugins/org.talend.designer.business.diagram/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: %pluginName
 Bundle-SymbolicName: org.talend.designer.business.diagram; singleton:=true
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Bundle-ClassPath: .
 Bundle-Activator: org.talend.designer.business.model.business.diagram.part.BusinessDiagramEditorPlugin
 Bundle-Vendor: %providerName

main/plugins/org.talend.designer.business.diagram/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>org.talend.studio</groupId>
     <artifactId>tdi-studio-se</artifactId>
-    <version>6.2.2</version>
+    <version>6.2.0</version>
     <relativePath>../../../</relativePath>
   </parent>
   <artifactId>org.talend.designer.business.diagram</artifactId>

main/plugins/org.talend.designer.codegen/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: CodeGen Plug-in
 Bundle-SymbolicName: org.talend.designer.codegen;singleton:=true
-Bundle-Version: 6.2.2.qualifier
+Bundle-Version: 6.2.0.qualifier
 Bundle-Localization: plugin
 Require-Bundle: org.talend.core.repository,
  org.eclipse.emf.codegen,

main/plugins/org.talend.designer.codegen/jet_stub/footer.javajet

@@ -300,7 +300,6 @@
             <%
         for(String testData : ProcessUtils.getTestData(process,instance)){
             String path =  ProcessUtils.getTestDataValue(process, instance, testData);
-            String paramemterName = ProcessUtils.getTestDataParamemter(process, instance, testData);
             if(path!=null&&path.length()>0){
             %>
             
@@ -327,12 +326,6 @@
                     e.printStackTrace();
                 }
                 
-            <%
-            }else if(paramemterName!=null){
-            %>
-                java.net.URL url_<%=testData%> = getClass().getResource("<%=path%>");
-                instance_<%=testData%>="<%=paramemterName%>=" + java.net.URLDecoder.decode(url_<%=testData%>.getPath(), "<%=encoding%>");
-            
             <%
             }else{
             %>
@@ -718,7 +711,6 @@ this.globalResumeTicket = false;//to run others jobs
 
     //5. all others sub-job (MultiThread mode)
     if(isRunInMultiThread){
-        %>final Thread launchingThread = Thread.currentThread();<%
         for (INode rootNode : rootNodes) {
             String componentName = rootNode.getComponent().getName();
             String uniqueName = rootNode.getUniqueName();
@@ -756,10 +748,6 @@ this.globalResumeTicket = false;//to run others jobs
                         status = localStatus;
                     }
 
-                    if ("true".equals(((java.util.Map) threadLocal.get()).get("JobInterrupted"))) {
-                        launchingThread.interrupt();
-                    }
-
                     runningThreadCount.add(-1);
                 }
             }
@@ -769,22 +757,13 @@ this.globalResumeTicket = false;//to run others jobs
             }
         }
 %>
-    boolean interrupted = false;
     while (runningThreadCount.getCount() > 0) {
         try {
             Thread.sleep(10);
-        } catch (java.lang.InterruptedException e) {
-            interrupted = true;
         } catch (java.lang.Exception e) {
             e.printStackTrace();
         }
     }
-
-    if (interrupted) {
-        Thread.currentThread().interrupt();
-    }
-
-
 <%
     } else { // isRunInMultiThread  //5. all others sub-job (SingleThread  mode)
         for (INode rootNode : rootNodes) {
@@ -1131,16 +1110,13 @@ if (execStat) {
 <%  if(exist_tMDM) { %>
     private void closeMDMConnections() {
         try {
-            java.util.Iterator keySets = globalMap.keySet().iterator();
-            while (keySets.hasNext()) {
-                String key = keySets.next().toString();
-                if (key.startsWith("TMDMService_tMDMConnection_")) {
-                    org.talend.mdm.webservice.TMDMService service = (org.talend.mdm.webservice.TMDMService)globalMap.get(key);
-                    if (service != null) {
-                        service.logout(new org.talend.mdm.webservice.WSLogout());
-                    }
-                }
-            }
+<%    for (INode mdmComponent : mdmComponentsList) { %>
+        org.talend.mdm.webservice.TMDMService service_<%=mdmComponent.getUniqueName() %> = (org.talend.mdm.webservice.TMDMService)globalMap.get("TMDMService_<%=mdmComponent.getUniqueName() %>");
+		if(service_<%=mdmComponent.getUniqueName() %> != null)
+		{
+			service_<%=mdmComponent.getUniqueName() %>.logout(new org.talend.mdm.webservice.WSLogout());
+		}
+<%    } %>
         } catch (java.lang.Exception e) {
         }
     }
@@ -1252,14 +1228,12 @@ if (execStat) {
             connections.put("connBaseDN_<%=ldapNode.getUniqueName() %>", globalMap.get("connBaseDN_<%=ldapNode.getUniqueName() %>"));
 <%      } %>
 
-<%      for (INode mdmNode : mdmComponentsList) {%>
-            connections.put("mdmUrl_<%=mdmNode.getUniqueName() %>", globalMap.get("mdmUrl_<%=mdmNode.getUniqueName() %>"));
-            connections.put("username_<%=mdmNode.getUniqueName() %>", globalMap.get("username_<%=mdmNode.getUniqueName() %>"));
-            connections.put("password_<%=mdmNode.getUniqueName() %>", globalMap.get("password_<%=mdmNode.getUniqueName() %>"));
-            connections.put("useTransaction_<%=mdmNode.getUniqueName() %>", globalMap.get("useTransaction_<%=mdmNode.getUniqueName() %>"));
-            connections.put("useClientTranId_<%=mdmNode.getUniqueName() %>", globalMap.get("useClientTranId_<%=mdmNode.getUniqueName() %>"));
-<%      } %>
-
+<%        for (INode mdmNode : mdmComponentsList) {%>
+            connections.put("TMDMService_<%=mdmNode.getUniqueName() %>", globalMap.get("TMDMService_<%=mdmNode.getUniqueName() %>"));
+<%          if( "false".equals(ElementParameterParser.getValue(mdmNode, "__AUTO_COMMIT__"))) {%>
+	            connections.put("mdmTransaction_<%=mdmNode.getUniqueName() %>", globalMap.get("mdmTransaction_<%=mdmNode.getUniqueName() %>"));
+<%            }
+        } %>
 <%      for (INode paloNode : paloComponentsList) { %>
             connections.put("p_<%=paloNode.getUniqueName() %>", globalMap.get("p_<%=paloNode.getUniqueName() %>"));
             connections.put("pConn_<%=paloNode.getUniqueName() %>", globalMap.get("pConn_<%=paloNode.getUniqueName() %>"));

main/plugins/org.talend.designer.codegen/jet_stub/footer_java.skeleton

@@ -49,8 +49,7 @@ public class CLASS
         if(isMultiThread){
             toReturn += "\n}catch (java.lang.Error e_" + rootNode.getUniqueName() + ") {\n";
             toReturn += "globalMap.put(\""+rootNode.getUniqueName()+ "_SUBPROCESS_STATE\", -1);\n";
-            toReturn += failure_multiThread;
-            toReturn += "throw e_" + rootNode.getUniqueName() + ";\n";
+            toReturn += "\ne_" + rootNode.getUniqueName() + ".printStackTrace();\n";
         }
        toReturn += "\n}"; 
        return toReturn;

main/plugins/org.talend.designer.codegen/jet_stub/generic/component_begin.javajet

@@ -1,37 +1,36 @@
 <%@ jet
 imports="
-        org.talend.designer.core.generic.model.Component
-        java.util.ArrayList
-        java.util.HashMap
-        java.util.HashSet
         java.util.List
+        java.util.ArrayList
         java.util.Map
         java.util.Set
+        java.util.HashSet
+        java.util.HashMap
         java.util.Stack
         org.talend.components.api.component.ComponentDefinition
         org.talend.components.api.component.EndpointComponentDefinition
         org.talend.components.api.component.InputComponentDefinition
         org.talend.components.api.component.OutputComponentDefinition
-        org.talend.components.api.container.RuntimeContainer
         org.talend.components.api.properties.ComponentProperties
+        org.talend.components.api.container.RuntimeContainer
+        org.talend.daikon.properties.Property
+        org.talend.daikon.NamedThing
+		org.talend.designer.core.generic.model.Component
         org.talend.core.model.metadata.IMetadataColumn
         org.talend.core.model.metadata.IMetadataTable
         org.talend.core.model.metadata.types.JavaType
         org.talend.core.model.metadata.types.JavaTypesManager
-        org.talend.core.model.process.EConnectionType
         org.talend.core.model.process.ElementParameterParser
-        org.talend.core.model.process.EParameterFieldType
+        org.talend.core.model.process.IElementParameter
         org.talend.core.model.process.IConnection
         org.talend.core.model.process.IConnectionCategory
-        org.talend.core.model.process.IElementParameter
+        org.talend.core.model.process.EConnectionType
         org.talend.core.model.process.INode
         org.talend.core.model.utils.TalendTextUtils
-        org.talend.daikon.NamedThing
-        org.talend.daikon.properties.property.Property
         org.talend.designer.codegen.config.CodeGeneratorArgument
+        org.talend.core.model.process.EParameterFieldType
         "
 %>
-<%@include file="@{org.talend.designer.codegen}/jet_stub/generic/component_util_indexedrecord_to_rowstruct.javajet"%>
 <%
 CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
 INode node = (INode)codeGenArgument.getArgument();
@@ -43,98 +42,93 @@ ComponentDefinition def = component.getComponentDefinition();
 List<IMetadataTable> metadatas = node.getMetadataList();
 IMetadataTable metadata = null;
 List<IMetadataColumn> columnList = null;
+boolean hasDynamic = false;
+String dynamicColName = null;
+int dynamicPos = -1;
 if ((metadatas != null) && (metadatas.size() > 0)) { // metadata
-    metadata = metadatas.get(0);
-    if(metadata != null){
-        columnList = metadata.getListColumns();
-    }
+
+	metadata = metadatas.get(0);
+	if(metadata != null){
+	    columnList = metadata.getListColumns();
+		int nbSchemaColumns = columnList.size();
+
+		hasDynamic = false;
+
+		int pos = 0;
+		for (IMetadataColumn column : columnList) {
+			if (column.getTalendType().equals("id_Dynamic")) {
+				hasDynamic = true;
+				dynamicPos = pos;
+				dynamicColName = column.getLabel();
+				break;
+			}
+			pos++;
+		}
+	}
 }
-
-// Set up the component definition, and the properties for all types of
-// components.
-
 %>
 
 org.talend.components.api.component.ComponentDefinition def_<%=cid %> =
-        new <%= def.getClass().getName()%>();
+   new <%= def.getClass().getName()%>();
 <%
 List<Component.CodegenPropInfo> propsToProcess = component.getCodegenPropInfos(componentProps);
 %>
 
-<%= componentProps.getClass().getName()%> props_<%=cid %> =
-        (<%= componentProps.getClass().getName()%>) def_<%=cid %>.createRuntimeProperties();
+<%= componentProps.getClass().getName()%> props_<%=cid %> = (<%= componentProps.getClass().getName()%>) def_<%=cid %>.createRuntimeProperties();
 <%
 
 for (Component.CodegenPropInfo propInfo : propsToProcess) { // propInfo
-    List<NamedThing> properties = propInfo.props.getProperties();
-    for (NamedThing prop : properties) { // property
+	List<NamedThing> properties = propInfo.props.getProperties();
+	for (NamedThing prop : properties) { // property
         if (prop instanceof Property) { // if, only deal with valued Properties
             Property property = (Property)prop;
             if (property.getFlags() != null && (property.getFlags().contains(Property.Flags.DESIGN_TIME_ONLY) || property.getFlags().contains(Property.Flags.HIDDEN)))
-                continue;
-            Object value = property.getStoredValue();
-            if (value != null) {
-                if (value instanceof List) {
+            	continue;
+		    Object value = property.getValue();
+            if (value != null && (value instanceof List)) { // if
                     // added for the support of tables
-                    String tmpVarName = cid+propInfo.fieldName.replace('.','_')+"_"+property.getName();
-                    %>
-                    java.util.List<Object> <%=tmpVarName %> = new java.util.ArrayList<Object>();
-                    <%
-                    for (Object subPropertyValue : (java.util.List<Object>)property.getValue()) {
-                        if (property.getPossibleValues() != null && property.getPossibleValues().size() > 0) {
-                            %>
-                            <%=tmpVarName %>.add("<%=subPropertyValue %>");
-                            <%
-                        } else if(!"".equals(subPropertyValue)) {
-                                %>
-                                <%=tmpVarName %>.add(<%=subPropertyValue %>);
-                                <%
-                        } else {
-                            %>
-                            <%=tmpVarName %>.add("");
-                            <%
-                        }
-                    }
-                    %>
-                    ((org.talend.daikon.properties.Properties)props_<%=cid %><%=propInfo.fieldName%>).setValue("<%=property.getName()%>",<%=tmpVarName %>);
-                    <%
-                }  else if (value instanceof String && property.isFlag(Property.Flags.ENCRYPT) && ElementParameterParser.canEncryptValue((String) value)) {
-                    if (!"".equals(property.getStringValue())) {
+                        String tmpVarName = cid+propInfo.fieldName.replace('.','_')+"_"+property.getName();
                         %>
-                        props_<%=cid %><%=propInfo.fieldName%>.setValue("<%=property.getName()%>",
-                        routines.system.PasswordEncryptUtil.decryptPassword(<%=component.getCodegenValue(property, (String) value)%>));
+                        java.util.List<String> <%=tmpVarName %> = new java.util.ArrayList<String>();
                         <%
-                    }
-                } else if (value != null && "java.util.Date".equals(property.getType())){
+                        for (String subPropertyValue : (java.util.List<String>)property.getValue()) {
+                            if ((property.getType() == Property.Type.BOOLEAN) || (property.getType() == Property.Type.ENUM)) {
+                            %>
+                                <%=tmpVarName %>.add("<%=subPropertyValue %>");
+                            <%
+                            } else {
+                            	if(!"".equals(subPropertyValue)) {
+                            %>
+                                <%=tmpVarName %>.add(<%=subPropertyValue %>);
+                            <%
+                            	} else {
+                            %>
+                                <%=tmpVarName %>.add("");
+                            <%
+                            	}
+                            }
+                        }
+                        %>
+                        ((org.talend.daikon.properties.Properties)props_<%=cid %><%=propInfo.fieldName%>).setValue("<%=property.getName()%>",<%=tmpVarName %>);
+                    <%
+            }  else if (property.isFlag(Property.Flags.ENCRYPT) && ElementParameterParser.canEncryptValue(property.getStringValue())) {
                     %>
                     props_<%=cid %><%=propInfo.fieldName%>.setValue("<%=property.getName()%>",
-                        TalendDate.parseDate("yyyy-MM-dd HH:mm:ss",<%=component.getCodegenValue(property, value.toString())%>));
+                    routines.system.PasswordEncryptUtil.decryptPassword(<%=component.getCodegenValue(property, property.getStringValue())%>));
                     <%
-                } else if (property instanceof org.talend.daikon.properties.property.EnumProperty) {
-                    %>
+            } else if (value != null && Property.Type.DATE.equals(property.getType())){
+            		%>
+    				props_<%=cid %><%=propInfo.fieldName%>.setValue("<%=property.getName()%>",
+	                	TalendDate.parseDate("yyyy-MM-dd HH:mm:ss",<%=component.getCodegenValue(property, property.getStringValue())%>));
+    				<%
+            } else if (value != null && (!(value instanceof String) || !((String)value).equals(""))) { // if
+					%>
                     props_<%=cid %><%=propInfo.fieldName%>.setValue("<%=property.getName()%>",
-                        <%=property.getType()%>.<%=property.getValue()%>);
+                    <%=component.getCodegenValue(property, property.getStringValue())%>);
                     <%
-                } else if (property instanceof org.talend.daikon.properties.property.SchemaProperty) {
-                    %>
-                    props_<%=cid %><%=propInfo.fieldName%>.setValue("<%=property.getName()%>",
-                        new org.apache.avro.Schema.Parser().parse(<%=component.getCodegenValue(property, property.getStringValue())%>));
-                    <%
-                } else if (!(value instanceof String) || !((String)value).equals("")) {
-                    %>
-                    props_<%=cid %><%=propInfo.fieldName%>.setValue("<%=property.getName()%>",
-                    <%=component.getCodegenValue(property, value.toString())%>);
-                    <%
-                }
-            }
-            
-            if("java.lang.Integer".equals(property.getType()) && (value == null || ((value instanceof String) && ((String)value).isEmpty()))) {//need to overwrite the default value when the passed value is null or empty string from the model
-        	%>
-                props_<%=cid %><%=propInfo.fieldName%>.setValue("<%=property.getName()%>", null);
-            <%
-            }
+    		} // if
         }//else may be a ComponentProperties so ignore
-    } // property
+	} // property
 } // propInfo
 %>
 org.talend.components.api.container.RuntimeContainer container_<%=cid%> = new org.talend.components.api.container.RuntimeContainer() {
@@ -151,206 +145,320 @@ org.talend.components.api.container.RuntimeContainer container_<%=cid%> = new or
     }
 };
 
-int nb_line_<%=cid %> = 0;
-
 <%
 if (def instanceof EndpointComponentDefinition) {
-    %>
-    org.talend.components.api.component.runtime.SourceOrSink sourceOrSink_<%=cid%> = ((org.talend.components.api.component.EndpointComponentDefinition)def_<%=cid%>).getRuntime();
-    sourceOrSink_<%=cid%>.initialize(container_<%=cid%>, props_<%=cid%>);
-    org.talend.daikon.properties.ValidationResult vr_<%=cid%> = sourceOrSink_<%=cid%>.validate(container_<%=cid%>);
-    if (vr_<%=cid%>.getStatus() == org.talend.daikon.properties.ValidationResult.Result.ERROR ) {
-        throw new RuntimeException(vr_<%=cid%>.getMessage());
-    }
-    <%
+%>
+	org.talend.components.api.component.runtime.SourceOrSink sourceOrSink_<%=cid%> = ((org.talend.components.api.component.EndpointComponentDefinition)def_<%=cid%>).getRuntime();
+	sourceOrSink_<%=cid%>.initialize(container_<%=cid%>, props_<%=cid%>);
+	org.talend.daikon.properties.ValidationResult vr_<%=cid%> = sourceOrSink_<%=cid%>.validate(container_<%=cid%>);
+	if (vr_<%=cid%>.getStatus() == org.talend.daikon.properties.ValidationResult.Result.ERROR ) {
+		throw new RuntimeException(vr_<%=cid%>.getMessage());
+	}
+<%
 }
 
-// Return at this point if there is no metadata.
-if (metadata == null)
-    return stringBuffer.toString();
+if (metadata != null) {
+	if (def instanceof InputComponentDefinition) {
+%>
+		org.talend.components.api.component.runtime.Source source_<%=cid%> = (org.talend.components.api.component.runtime.Source)sourceOrSink_<%=cid%>;
+		org.talend.components.api.component.runtime.Reader reader_<%=cid%> = source_<%=cid%>.createReader(container_<%=cid%>);
 
-if (def instanceof InputComponentDefinition) {
-    %>
-    org.talend.components.api.component.runtime.Source source_<%=cid%> =
-            (org.talend.components.api.component.runtime.Source)sourceOrSink_<%=cid%>;
-    org.talend.components.api.component.runtime.Reader reader_<%=cid%> =
-            source_<%=cid%>.createReader(container_<%=cid%>);
+		<%
+		IConnection main = null;
+		List<? extends IConnection> mains = node.getOutgoingConnections(EConnectionType.FLOW_MAIN);
+		if(mains!=null && !mains.isEmpty()) {
+			main = mains.get(0);
+		}
+		
+		IConnection reject = null;
+    	for(IConnection outConn : node.getOutgoingConnections()) {
+    		if(!outConn.getLineStyle().hasConnectionCategory(IConnectionCategory.DATA)) {
+    			continue;
+    		}
+    		
+    		if(main!=null && main.getName().equals(outConn.getName())) {
+    			continue;
+    		}
+    		
+    		reject = outConn;
+    		
+    		break;
+    	}
+		
+		boolean hasDataOutput = main!=null || reject!=null;
+		
+		// FIXME - multiple outgoing connections?
+		
+        if(hasDataOutput) {
+        	if(hasDynamic){
+        	%>
+        		boolean initDyn_<%=cid%> = false;
+        		routines.system.Dynamic dynamic_<%=cid%> = new routines.system.Dynamic();
+        	<%
+        	}
+        	
+        	IConnection schemaSourceConnector = (main!=null ? main : reject);
+			String schemaSourceConnectorName = schemaSourceConnector.getMetadataTable().getAttachedConnector();
+        	%>
+        		boolean multi_output_is_allowed_<%=cid%> = false;
+            	<% //take care SourceOrSink.validate will change the schema if it contains include-all-fields, so need to get design Avro schema before validate %>
+                org.talend.components.api.component.Connector c_<%=cid%> = null;
+                for (org.talend.components.api.component.Connector currentConnector : props_<%=cid %>.getAvailableConnectors(null, true)) {
+                    if (currentConnector.getName().equals("<%=schemaSourceConnectorName%>")) {
+                        c_<%=cid%> = currentConnector;
+                    }
+                    
+                    if (currentConnector.getName().equals("REJECT")) {//it's better to move the code to javajet
+                        multi_output_is_allowed_<%=cid%> = true;
+                    }
+                }
+                org.apache.avro.Schema schema_<%=cid%> = props_<%=cid %>.getSchema(c_<%=cid%>, true);
 
-    <%
-    IConnection main = null;
-    List<? extends IConnection> mains = node.getOutgoingConnections("MAIN");
-    if (mains!=null && !mains.isEmpty()) {
-        main = mains.get(0);
-    }
+                org.talend.daikon.talend6.Talend6OutgoingSchemaEnforcer current_<%=cid%> = new org.talend.daikon.talend6.Talend6OutgoingSchemaEnforcer(schema_<%=cid%>, false);
+                
+                // Create a reusable factory that converts the output of the reader to an IndexedRecord.
+                org.talend.daikon.avro.IndexedRecordAdapterFactory<Object, ? extends org.apache.avro.generic.IndexedRecord> factory_<%=cid%> = null;
 
-    IConnection reject = null;
-    List<? extends IConnection> rejects = node.getOutgoingConnections("REJECT");
-    if (rejects != null && !rejects.isEmpty()) {
-        reject = rejects.get(0);
-    }
-    
-	boolean hasDataOutput = (main != null || reject != null);
-	IndexedRecordToRowStructGenerator irToRow = null;
+		<%
+		}
+		%>
+                // Iterate through the incoming data.
+                for(boolean available = reader_<%=cid%>.start(); available; available = reader_<%=cid%>.advance()) {//}
+		<%
+		if(hasDataOutput) {
+		%>
+					if(multi_output_is_allowed_<%=cid%>) {
+						<%if(main!=null){%>
+						<%=main.getName()%> = null;
+						<%}%>
+						
+						<%if(reject!=null){%>
+						<%=reject.getName()%> = null;
+						<%}%>
+					}
+					
+					try {
+						Object data_<%=cid%> = reader_<%=cid%>.getCurrent();
+						
+						<%if(main!=null){%>
+						
+						if(multi_output_is_allowed_<%=cid%>) {
+							<%=main.getName()%> = new <%=main.getName() %>Struct();
+						}
+					
+	                    // Construct the factory once when the first data arrives.
+	                    if (factory_<%=cid%> == null)
+	                        factory_<%=cid%> = (org.talend.daikon.avro.IndexedRecordAdapterFactory<Object, ? extends org.apache.avro.generic.IndexedRecord>) new org.talend.daikon.avro.AvroRegistry()
+	                                .createAdapterFactory(data_<%=cid%>.getClass());
 	
-	if(hasDataOutput) {
-    	IConnection schemaSourceConnector = (main!=null ? main : reject);
-    	String schemaSourceConnectorName = schemaSourceConnector.getMetadataTable().getAttachedConnector();
+	                    // Enforce the outgoing schema on the input.
+	                    org.apache.avro.generic.IndexedRecord unenforced_<%=cid%> = factory_<%=cid%>.convertToAvro(data_<%=cid%>);
+	                    current_<%=cid%>.setWrapped(unenforced_<%=cid%>);
+	                    
+	                    <%
+						if(hasDynamic){
+						%>
+							if(!initDyn_<%=cid%>){
+								org.apache.avro.Schema dynSchema_<%=cid%> = current_<%=cid%>.getOutgoingDynamicRuntimeSchema();
+	
+								for(org.apache.avro.Schema.Field childDynamic_<%=cid%> : dynSchema_<%=cid%>.getFields()){
+									routines.system.DynamicMetadata dynamicMetadata_<%=cid%> = new routines.system.DynamicMetadata();
+							    	dynamicMetadata_<%=cid%>.setName(childDynamic_<%=cid%>.name());
+							    	dynamicMetadata_<%=cid%>.setDbName(childDynamic_<%=cid%>.name());
+							    	String talendType_<%=cid%> = null;
+							    	if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.ARRAY){
+							    		talendType_<%=cid%> = "<%=JavaTypesManager.LIST.getId()%>";
+							    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.BOOLEAN){
+							    		talendType_<%=cid%> = "<%=JavaTypesManager.BOOLEAN.getId()%>";
+							    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.BYTES){
+							    		talendType_<%=cid%> = "<%=JavaTypesManager.BYTE_ARRAY.getId()%>";
+							    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.FIXED){
+							    		talendType_<%=cid%> = "<%=JavaTypesManager.BYTE_ARRAY.getId()%>";
+							    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.DOUBLE){
+							    		talendType_<%=cid%> = "<%=JavaTypesManager.DOUBLE.getId()%>";
+							    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.FLOAT){
+							    		talendType_<%=cid%> = "<%=JavaTypesManager.FLOAT.getId()%>";
+							    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.INT){
+							    		talendType_<%=cid%> = "<%=JavaTypesManager.INTEGER.getId()%>";
+							    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.LONG){
+							    		talendType_<%=cid%> = "<%=JavaTypesManager.LONG.getId()%>";
+							    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.ENUM){
+							    		talendType_<%=cid%> = "<%=JavaTypesManager.STRING.getId()%>";
+							    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.STRING){
+							    		talendType_<%=cid%> = "<%=JavaTypesManager.STRING.getId()%>";
+							    	}
+							    	dynamicMetadata_<%=cid%>.setType(talendType_<%=cid%>);
+							    	dynamic_<%=cid%>.metadatas.add(dynamicMetadata_<%=cid%>);
+								}
+								initDyn_<%=cid%> = true;
+							}
+							dynamic_<%=cid%>.clearColumnValues();
+	                    <%
+	                    }
+	                    
+	                    List<IMetadataColumn> main_output_columnList = main.getMetadataTable().getListColumns();
+	                    
+	                    for (int i = 0; i < main_output_columnList.size(); i++) {
+	                        IMetadataColumn column = main_output_columnList.get(i);
+	                        String columnName = column.getLabel();
+	                        JavaType javaType = JavaTypesManager.getJavaTypeFromId(column.getTalendType());
+	                        String typeToGenerate = JavaTypesManager.getTypeToGenerate(column.getTalendType(), column.isNullable());
+	                        if(columnName.equals(dynamicColName)){
+	                        %>
+	                        	java.util.Map<String, Object> dynamicValue_<%=cid%> = (java.util.Map<String, Object>)current_<%=cid%>.get(<%=i%>);
+	                        	for(String dynamicValue_Key_<%=cid%> : dynamicValue_<%=cid%>.keySet()){
+	                        		dynamic_<%=cid%>.setColumnValue(dynamic_<%=cid%>.getIndex(dynamicValue_Key_<%=cid%>), dynamicValue_<%=cid%>.get(dynamicValue_Key_<%=cid%>));
+	                        	}
+								<%=main.getName()%>.<%=dynamicColName%> = dynamic_<%=cid%>;
+	                        <%
+	                        }else{
+	                        %>
+	                        	if(current_<%=cid%>.get(<%=i%>) == null){
+	                        		<%=main.getName()%>.<%=columnName%> = <%=JavaTypesManager.getDefaultValueFromJavaType(typeToGenerate)%>;
+	                        	}else{
+	                        		<%if(javaType == JavaTypesManager.STRING){%>
+	                        			<%=main.getName()%>.<%=columnName%> = String.valueOf(current_<%=cid%>.get(<%=i%>));
+	                        		<%}else{%>
+		                        		<%=main.getName()%>.<%=columnName%> = (<%=typeToGenerate%>)(current_<%=cid%>.get(<%=i%>));
+		                        	<%}%>
+	                        	}
+	                    	<%
+	                    	}
+	                    }
+	                    %>
+	                    
+                	<%}%>
+        		} catch (org.talend.components.api.exception.DataRejectException e_<%=cid%>) {
+					<%if(reject!=null){%>
+					java.util.Map<String,Object> info_<%=cid%> = e_<%=cid%>.getRejectInfo();
+					Object data_<%=cid%> = info_<%=cid%>.get("talend_record");
+					
+					if(multi_output_is_allowed_<%=cid%>) {
+						<%=reject.getName()%> = new <%=reject.getName() %>Struct();
+					}
+				
+                    // Construct the factory once when the first data arrives.
+                    if (factory_<%=cid%> == null)
+                        factory_<%=cid%> = (org.talend.daikon.avro.IndexedRecordAdapterFactory<Object, ? extends org.apache.avro.generic.IndexedRecord>) new org.talend.daikon.avro.AvroRegistry()
+                                .createAdapterFactory(data_<%=cid%>.getClass());
+
+                    // Enforce the outgoing schema on the input.
+                    org.apache.avro.generic.IndexedRecord unenforced_<%=cid%> = factory_<%=cid%>.convertToAvro(data_<%=cid%>);
+                    current_<%=cid%>.setWrapped(unenforced_<%=cid%>);
+                    
+                    <%
+					if(hasDynamic){
+					%>
+						if(!initDyn_<%=cid%>){
+							org.apache.avro.Schema dynSchema_<%=cid%> = current_<%=cid%>.getOutgoingDynamicRuntimeSchema();
+
+							for(org.apache.avro.Schema.Field childDynamic_<%=cid%> : dynSchema_<%=cid%>.getFields()){
+								routines.system.DynamicMetadata dynamicMetadata_<%=cid%> = new routines.system.DynamicMetadata();
+						    	dynamicMetadata_<%=cid%>.setName(childDynamic_<%=cid%>.name());
+						    	dynamicMetadata_<%=cid%>.setDbName(childDynamic_<%=cid%>.name());
+						    	String talendType_<%=cid%> = null;
+						    	if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.ARRAY){
+						    		talendType_<%=cid%> = "<%=JavaTypesManager.LIST.getId()%>";
+						    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.BOOLEAN){
+						    		talendType_<%=cid%> = "<%=JavaTypesManager.BOOLEAN.getId()%>";
+						    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.BYTES){
+						    		talendType_<%=cid%> = "<%=JavaTypesManager.BYTE_ARRAY.getId()%>";
+						    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.FIXED){
+						    		talendType_<%=cid%> = "<%=JavaTypesManager.BYTE_ARRAY.getId()%>";
+						    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.DOUBLE){
+						    		talendType_<%=cid%> = "<%=JavaTypesManager.DOUBLE.getId()%>";
+						    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.FLOAT){
+						    		talendType_<%=cid%> = "<%=JavaTypesManager.FLOAT.getId()%>";
+						    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.INT){
+						    		talendType_<%=cid%> = "<%=JavaTypesManager.INTEGER.getId()%>";
+						    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.LONG){
+						    		talendType_<%=cid%> = "<%=JavaTypesManager.LONG.getId()%>";
+						    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.ENUM){
+						    		talendType_<%=cid%> = "<%=JavaTypesManager.STRING.getId()%>";
+						    	}else if(childDynamic_<%=cid%>.schema().getType() == org.apache.avro.Schema.Type.STRING){
+						    		talendType_<%=cid%> = "<%=JavaTypesManager.STRING.getId()%>";
+						    	}
+						    	dynamicMetadata_<%=cid%>.setType(talendType_<%=cid%>);
+						    	dynamic_<%=cid%>.metadatas.add(dynamicMetadata_<%=cid%>);
+							}
+							initDyn_<%=cid%> = true;
+						}
+						dynamic_<%=cid%>.clearColumnValues();
+                    <%
+                    }
+                    
+                    Set<String> commonColumns = new HashSet<String>();
+                    
+                    for (int i = 0; i < columnList.size(); i++) {
+                        IMetadataColumn column = columnList.get(i);
+                        String columnName = column.getLabel();
+                        
+                        commonColumns.add(columnName);
+                        
+                        JavaType javaType = JavaTypesManager.getJavaTypeFromId(column.getTalendType());
+                        String typeToGenerate = JavaTypesManager.getTypeToGenerate(column.getTalendType(), column.isNullable());
+                        if(columnName.equals(dynamicColName)){
+                        %>
+                        	java.util.Map<String, Object> dynamicValue_<%=cid%> = (java.util.Map<String, Object>)current_<%=cid%>.get(<%=i%>);
+                        	for(String dynamicValue_Key_<%=cid%> : dynamicValue_<%=cid%>.keySet()){
+                        		dynamic_<%=cid%>.setColumnValue(dynamic_<%=cid%>.getIndex(dynamicValue_Key_<%=cid%>), dynamicValue_<%=cid%>.get(dynamicValue_Key_<%=cid%>));
+                        	}
+							<%=main.getName()%>.<%=dynamicColName%> = dynamic_<%=cid%>;
+                        <%
+                        }else{
+                        %>
+                        	if(current_<%=cid%>.get(<%=i%>) == null){
+                        		<%=main.getName()%>.<%=columnName%> = <%=JavaTypesManager.getDefaultValueFromJavaType(typeToGenerate)%>;
+                        	}else{
+                        		<%if(javaType == JavaTypesManager.STRING){%>
+                        			<%=main.getName()%>.<%=columnName%> = String.valueOf(current_<%=cid%>.get(<%=i%>));
+                        		<%}else{%>
+	                        		<%=main.getName()%>.<%=columnName%> = (<%=typeToGenerate%>)(current_<%=cid%>.get(<%=i%>));
+	                        	<%}%>
+                        	}
+                    	<%
+                    	}
+                    }
+                    
+                    //pass error columns
+            		List<IMetadataColumn> rejectColumns = reject.getMetadataTable().getListColumns();
+            		for(IMetadataColumn column : rejectColumns) {
+            			String columnName = column.getLabel();
+            			
+            			JavaType javaType = JavaTypesManager.getJavaTypeFromId(column.getTalendType());
+                        String typeToGenerate = JavaTypesManager.getTypeToGenerate(column.getTalendType(), column.isNullable());
+                        
+            			//error columns
+            			if(!commonColumns.contains(columnName)) {
+            			%>
+            			<%=reject.getName()%>.<%=columnName%> = (<%=typeToGenerate%>)info_<%=cid%>.get("<%=columnName%>");
+            			<%
+            			}
+            		}
+                    %>
+	                    
+					<%}%>
+				}
+        <%
+		}
+	} else if (def instanceof OutputComponentDefinition) {
 	%>
-        boolean multi_output_is_allowed_<%=cid%> = false;
-        <% //take care SourceOrSink.validate will change the schema if it contains include-all-fields, so need to get design Avro schema before validate %>
+		org.talend.components.api.component.runtime.Sink sink_<%=cid%> = (org.talend.components.api.component.runtime.Sink)sourceOrSink_<%=cid%>;
+		org.talend.components.api.component.runtime.WriteOperation writeOperation_<%=cid%> = sink_<%=cid%>.createWriteOperation();
+		writeOperation_<%=cid%>.initialize(container_<%=cid%>);<%//create folder for file; create database/table for db%>
+		org.talend.components.api.component.runtime.Writer writer_<%=cid%> = writeOperation_<%=cid%>.createWriter(container_<%=cid%>);
+		writer_<%=cid%>.open("<%=cid%>");
         org.talend.components.api.component.Connector c_<%=cid%> = null;
         for (org.talend.components.api.component.Connector currentConnector : props_<%=cid %>.getAvailableConnectors(null, true)) {
-            if (currentConnector.getName().equals("<%=schemaSourceConnectorName%>")) {
+            if (currentConnector.getName().equals("MAIN")) {
                 c_<%=cid%> = currentConnector;
-            }
-    
-            if (currentConnector.getName().equals("REJECT")) {//it's better to move the code to javajet
-                multi_output_is_allowed_<%=cid%> = true;
+                break;
             }
         }
-        org.apache.avro.Schema schema_<%=cid%> = props_<%=cid %>.getSchema(c_<%=cid%>, true);
-
-    <%
-    	irToRow = new IndexedRecordToRowStructGenerator(cid, null, columnList);
-    	irToRow.generateInitialVariables("schema_" + cid, false);
-    }
-    %>
-	
-    // Iterate through the incoming data.
-    boolean available_<%=cid%> = reader_<%=cid%>.start();
-    
-    resourceMap.put("reader_<%=cid%>", reader_<%=cid%>);
-    
-    for (; available_<%=cid%>; available_<%=cid%> = reader_<%=cid%>.advance()) {
-    	nb_line_<%=cid %>++;
-    	
-    	<%if(hasDataOutput) {%>
-        if (multi_output_is_allowed_<%=cid%>) {
-            <%if(main!=null){%>
-                <%=main.getName()%> = null;
-            <%}%>
-
-            <%if(reject!=null){%>
-                <%=reject.getName()%> = null;
-            <%}%>
-        }
-        <%}%>
-
-        try {
-            Object data_<%=cid%> = reader_<%=cid%>.getCurrent();
-            <%
-            if (main != null) {
-                %>
-
-                if(multi_output_is_allowed_<%=cid%>) {
-                    <%=main.getName()%> = new <%=main.getName() %>Struct();
-                }
-
-                <%
-                irToRow.generateConvertRecord("data_" + cid, main.getName(), main.getMetadataTable().getListColumns());
-            }
-            %>
-        } catch (org.talend.components.api.exception.DataRejectException e_<%=cid%>) {
-        	java.util.Map<String,Object> info_<%=cid%> = e_<%=cid%>.getRejectInfo();
-            <%
-            if (reject!=null) {
-                %>
-                Object data_<%=cid%> = info_<%=cid%>.get("talend_record");
-
-                if (multi_output_is_allowed_<%=cid%>) {
-                    <%=reject.getName()%> = new <%=reject.getName() %>Struct();
-                }
-
-                <%
-                irToRow.generateConvertRecord("data_" + cid, reject.getName());
-                Set<String> commonColumns = new HashSet<String>();
-
-                for (IMetadataColumn column : columnList) {
-                    commonColumns.add(column.getLabel());
-                }
-
-                //pass error columns
-                List<IMetadataColumn> rejectColumns = reject.getMetadataTable().getListColumns();
-                for(IMetadataColumn column : rejectColumns) {
-                    String columnName = column.getLabel();
-
-                    // JavaType javaType = JavaTypesManager.getJavaTypeFromId(column.getTalendType());
-                    String typeToGenerate = JavaTypesManager.getTypeToGenerate(column.getTalendType(), column.isNullable());
-
-                    //error columns
-                    if(!commonColumns.contains(columnName)) {
-                        %>
-                        <%=reject.getName()%>.<%=columnName%> = (<%=typeToGenerate%>)info_<%=cid%>.get("<%=columnName%>");
-                        <%
-                    }
-                }
-            } else {
-            %>
-            	//TODO use a method instead of getting method by the special key "error"
-            	String errorMessage_<%=cid%> = "Row "+ nb_line_<%=cid %> + ":" + info_<%=cid%>.get("error");
-    			System.err.println(errorMessage_<%=cid%>);
-            <%
-            }
-        %>
-    }
-    <%
-    // The for loop around the incoming records from the reader is left open.
-
-
-} else if (def instanceof OutputComponentDefinition) {
-    %>
-    org.talend.components.api.component.runtime.Sink sink_<%=cid%> =
-            (org.talend.components.api.component.runtime.Sink)sourceOrSink_<%=cid%>;
-    org.talend.components.api.component.runtime.WriteOperation writeOperation_<%=cid%> = sink_<%=cid%>.createWriteOperation();
-    writeOperation_<%=cid%>.initialize(container_<%=cid%>);
-    org.talend.components.api.component.runtime.Writer writer_<%=cid%> = writeOperation_<%=cid%>.createWriter(container_<%=cid%>);
-    writer_<%=cid%>.open("<%=cid%>");
-    
-    resourceMap.put("writer_<%=cid%>", writer_<%=cid%>);
-    
-    org.talend.components.api.component.Connector c_<%=cid%> = null;
-    for (org.talend.components.api.component.Connector currentConnector : props_<%=cid %>.getAvailableConnectors(null, false)) {
-        if (currentConnector.getName().equals("MAIN")) {
-            c_<%=cid%> = currentConnector;
-            break;
-        }
-    }
-    org.apache.avro.Schema designSchema_<%=cid%> = props_<%=cid %>.getSchema(c_<%=cid%>, false);
-    org.talend.daikon.di.DiIncomingSchemaEnforcer current_<%=cid%>
-            = new org.talend.daikon.di.DiIncomingSchemaEnforcer(designSchema_<%=cid%>);
-    <%
-    List<? extends IConnection> outgoingConns = node.getOutgoingSortedConnections();
-    if (outgoingConns!=null){
-        for (IConnection outgoingConn : outgoingConns) {
-            if ("MAIN".equals(outgoingConn.getConnectorName())) {
-                %>
-                c_<%=cid%> = null;
-                for (org.talend.components.api.component.Connector currentConnector : props_<%=cid %>.getAvailableConnectors(null, true)) {
-                    if (currentConnector.getName().equals("MAIN")) {
-                        c_<%=cid%> = currentConnector;
-                    }
-                }
-                org.apache.avro.Schema mainSchema_<%=cid%> = props_<%=cid %>.getSchema(c_<%=cid%>, true);
-                <%
-                IndexedRecordToRowStructGenerator mainIrToRow = new IndexedRecordToRowStructGenerator(
-                        cid + "OutMain", outgoingConn);
-                mainIrToRow.generateInitialVariables("mainSchema_" + cid, false);
-            }
-            if ("REJECT".equals(outgoingConn.getConnectorName())) {
-                %>
-                c_<%=cid%> = null;
-                for (org.talend.components.api.component.Connector currentConnector : props_<%=cid %>.getAvailableConnectors(null, true)) {
-                    if (currentConnector.getName().equals("REJECT")) {
-                        c_<%=cid%> = currentConnector;
-                    }
-                }
-                org.apache.avro.Schema rejectSchema_<%=cid%> = props_<%=cid %>.getSchema(c_<%=cid%>, true);
-                <%
-                IndexedRecordToRowStructGenerator rejectIrToRow = new IndexedRecordToRowStructGenerator(
-                        cid + "OutReject", outgoingConn);
-                rejectIrToRow.generateInitialVariables("rejectSchema_" + cid, false);
-            }
-        }
-    }
+        org.apache.avro.Schema designSchema_<%=cid%> = props_<%=cid %>.getSchema(c_<%=cid%>, true);
+        org.talend.daikon.talend6.Talend6IncomingSchemaEnforcer current_<%=cid%>
+                = new org.talend.daikon.talend6.Talend6IncomingSchemaEnforcer(designSchema_<%=cid%>);
+	<%
+	}
 }
 %>

main/plugins/org.talend.designer.codegen/jet_stub/generic/component_end.javajet

@@ -1,16 +1,16 @@
-<%@ jet
+<%@ jet 
 imports="
-        java.util.List
-        org.talend.components.api.component.ComponentDefinition
-        org.talend.core.model.metadata.IMetadataColumn
-        org.talend.core.model.metadata.IMetadataTable
-        org.talend.core.model.process.ElementParameterParser
-        org.talend.core.model.process.IConnection
-        org.talend.core.model.process.IConnectionCategory
-        org.talend.core.model.process.INode
-        org.talend.designer.codegen.config.CodeGeneratorArgument
-        org.talend.designer.core.generic.model.Component
-        "
+		org.talend.components.api.component.ComponentDefinition
+		org.talend.designer.core.generic.model.Component
+    	org.talend.core.model.process.INode 
+    	org.talend.core.model.process.ElementParameterParser 
+		org.talend.core.model.metadata.IMetadataTable 
+		org.talend.core.model.metadata.IMetadataColumn		
+		org.talend.designer.codegen.config.CodeGeneratorArgument
+		org.talend.core.model.process.IConnection
+		org.talend.core.model.process.IConnectionCategory
+		java.util.List
+		"
 %>
 // end of generic
 
@@ -24,57 +24,25 @@ ComponentDefinition def = component.getComponentDefinition();
 IMetadataTable metadata = null;
 List<IMetadataTable> metadatas = node.getMetadataList();
 if ((metadatas != null) && (metadatas.size() > 0)) {
-    metadata = metadatas.get(0);
+	metadata = metadatas.get(0);
 }
 
-// Return at this point if there is no metadata.
 if (metadata == null) {
-    return stringBuffer.toString();
+	return stringBuffer.toString();
 }
-%>
 
-resourceMap.put("finish_<%=cid%>", Boolean.TRUE);
-
-<%
 if(def instanceof org.talend.components.api.component.InputComponentDefinition){
 %>
-    } // while
-    reader_<%=cid%>.close();
-    final java.util.Map<String, Object> resultMap_<%=cid%> = reader_<%=cid%>.getReturnValues();
+	} // while
+<%
+%>
+
+	reader_<%=cid%>.close();
 <%
 }else if(def instanceof org.talend.components.api.component.OutputComponentDefinition){
+// Output
 %>
-    org.talend.components.api.component.runtime.Result resultObject_<%=cid%> = (org.talend.components.api.component.runtime.Result)writer_<%=cid%>.close();
-    final java.util.Map<String, Object> resultMap_<%=cid%> = writer_<%=cid%>.getWriteOperation().finalize(java.util.Arrays.<org.talend.components.api.component.runtime.Result>asList(resultObject_<%=cid%>), container_<%=cid%>);
+	writer_<%=cid%>.close();
 <%
 }
 %>
-if(resultMap_<%=cid%>!=null) {
-	for(java.util.Map.Entry<String,Object> entry_<%=cid%> : resultMap_<%=cid%>.entrySet()) {
-		switch(entry_<%=cid%>.getKey()) {
-		case org.talend.components.api.component.ComponentDefinition.RETURN_ERROR_MESSAGE :
-			container_<%=cid%>.setComponentData("<%=cid%>", "ERROR_MESSAGE", entry_<%=cid%>.getValue());
-			break;
-		case org.talend.components.api.component.ComponentDefinition.RETURN_TOTAL_RECORD_COUNT :
-			container_<%=cid%>.setComponentData("<%=cid%>", "NB_LINE", entry_<%=cid%>.getValue());
-			break;
-		case org.talend.components.api.component.ComponentDefinition.RETURN_SUCCESS_RECORD_COUNT :
-			container_<%=cid%>.setComponentData("<%=cid%>", "NB_SUCCESS", entry_<%=cid%>.getValue());
-			break;
-		case org.talend.components.api.component.ComponentDefinition.RETURN_REJECT_RECORD_COUNT :
-			container_<%=cid%>.setComponentData("<%=cid%>", "NB_REJECT", entry_<%=cid%>.getValue());
-			break;
-		default :
-            StringBuilder studio_key_<%=cid%> = new StringBuilder();
-            for (int i_<%=cid%> = 0; i_<%=cid%> < entry_<%=cid%>.getKey().length(); i_<%=cid%>++) {
-                char ch_<%=cid%> = entry_<%=cid%>.getKey().charAt(i_<%=cid%>);
-                if(Character.isUpperCase(ch_<%=cid%>) && i_<%=cid%>> 0) {
-                	studio_key_<%=cid%>.append('_');
-                }
-                studio_key_<%=cid%>.append(ch_<%=cid%>);
-            }
-			container_<%=cid%>.setComponentData("<%=cid%>", studio_key_<%=cid%>.toString().toUpperCase(java.util.Locale.ENGLISH), entry_<%=cid%>.getValue());
-			break;
-		}
-	}
-}

main/plugins/org.talend.designer.codegen/jet_stub/generic/component_finally.javajet

@@ -1,62 +0,0 @@
-<%@ jet
-imports="
-        java.util.List
-        org.talend.components.api.component.ComponentDefinition
-        org.talend.core.model.metadata.IMetadataColumn
-        org.talend.core.model.metadata.IMetadataTable
-        org.talend.core.model.process.ElementParameterParser
-        org.talend.core.model.process.IConnection
-        org.talend.core.model.process.IConnectionCategory
-        org.talend.core.model.process.INode
-        org.talend.designer.codegen.config.CodeGeneratorArgument
-        org.talend.designer.core.generic.model.Component
-        "
-%>
-// finally of generic
-
-<%
-CodeGeneratorArgument codeGenArgument = (CodeGeneratorArgument) argument;
-INode node = (INode)codeGenArgument.getArgument();
-String cid = node.getUniqueName();
-Component component = (Component)node.getComponent();
-ComponentDefinition def = component.getComponentDefinition();
-
-IMetadataTable metadata = null;
-List<IMetadataTable> metadatas = node.getMetadataList();
-if ((metadatas != null) && (metadatas.size() > 0)) {
-    metadata = metadatas.get(0);
-}
-
-// Return at this point if there is no metadata.
-if (metadata == null) {
-    return stringBuffer.toString();
-}
-%>
-
-if(resourceMap.get("finish_<%=cid%>")==null){
-<%
-if(def instanceof org.talend.components.api.component.InputComponentDefinition){
-%>
-    if(resourceMap.get("reader_<%=cid%>")!=null){
-		try {
-			((org.talend.components.api.component.runtime.Reader)resourceMap.get("reader_<%=cid%>")).close();
-		} catch (java.io.IOException e_<%=cid %>) {
-			String errorMessage_<%=cid%> = "failed to release the resource in <%=cid %> :" + e_<%=cid %>.getMessage();
-			System.err.println(errorMessage_<%=cid%>);
-		}
-	}
-<%
-}else if(def instanceof org.talend.components.api.component.OutputComponentDefinition){
-%>
-    if(resourceMap.get("writer_<%=cid%>")!=null){
-		try {
-			((org.talend.components.api.component.runtime.Writer)resourceMap.get("writer_<%=cid%>")).close();
-		} catch (java.io.IOException e_<%=cid %>) {
-			String errorMessage_<%=cid%> = "failed to release the resource in <%=cid %> :" + e_<%=cid %>.getMessage();
-			System.err.println(errorMessage_<%=cid%>);
-		}
-	}
-<%
-}
-%>
-}