Thanks for reply. Please check below log. There is no error message, but target table is not loaded with any records. Same code loads the target table if it's same mySql server.
16/05/24 16:35:14 WARN jdbc.JDBCTap: using sink mode: REPLACE, consider UPDATE to prevent DROP TABLE from being called during Flow or Cascade setup
16/05/24 16:35:14 WARN jdbc.JDBCTap: using sink mode: REPLACE, consider UPDATE to prevent DROP TABLE from being called during Flow or Cascade setup
16/05/24 16:35:15 INFO util.Util: resolving application jar from found main method on: packageName.TableToTable
16/05/24 16:35:15 INFO planner.HadoopPlanner: using application jar: null
16/05/24 16:35:15 INFO property.AppProps: using
app.id: DB0C83B3DAF441908A3D402BBB8B144B
16/05/24 16:35:16 INFO flow.Flow: [insert] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.144
16/05/24 16:35:16 INFO flow.Flow: [insert] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
16/05/24 16:35:16 INFO flow.Flow: [insert] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
16/05/24 16:35:16 INFO jdbc.JDBCScheme: receiving final sink fields 'num', 'lwr', 'upr' | int, String, String
16/05/24 16:35:16 INFO Configuration.deprecation: mapred.used.genericoptionsparser is deprecated. Instead, use mapreduce.client.genericoptionsparser.used
16/05/24 16:35:17 INFO Configuration.deprecation: mapred.job.tracker is deprecated. Instead, use mapreduce.jobtracker.address
16/05/24 16:35:17 INFO Configuration.deprecation: mapred.map.tasks.speculative.execution is deprecated. Instead, use mapreduce.map.speculative
16/05/24 16:35:17 INFO Configuration.deprecation: mapred.reduce.tasks.speculative.execution is deprecated. Instead, use mapreduce.reduce.speculative
16/05/24 16:35:17 INFO jdbc.JDBCTap: creating connection: jdbc:mysql://ip2:3306/jdbc?user=root&password=root
16/05/24 16:35:18 INFO util.Version: Concurrent, Inc - Cascading 3.0.1
16/05/24 16:35:18 INFO flow.Flow: [insert] starting
16/05/24 16:35:18 INFO flow.Flow: [insert] source: JDBCTap{connectionUrl='jdbc:mysql://ip1:3306/jdbc?user=root&password=root', driverClassName='com.mysql.jdbc.Driver', tableDesc=TableDesc{tableName='testingtable12', columnNames=[num, lwr, upr], columnDefs=[INT NOT NULL, VARCHAR(100) NOT NULL, VARCHAR(100) NOT NULL], primaryKeys=[num]}}
16/05/24 16:35:18 INFO flow.Flow: [insert] sink: JDBCTap{connectionUrl='jdbc:mysql://ip2:3306/jdbc?user=root&password=root', driverClassName='com.mysql.jdbc.Driver', tableDesc=TableDesc{tableName='testingtable13', columnNames=[num, lwr, upr], columnDefs=[INT NOT NULL, VARCHAR(100) NOT NULL, VARCHAR(100) NOT NULL], primaryKeys=[num]}}
16/05/24 16:35:18 INFO flow.Flow: [insert] parallel execution of steps is enabled: false
16/05/24 16:35:18 INFO flow.Flow: [insert] executing total steps: 1
16/05/24 16:35:18 INFO flow.Flow: [insert] allocating management threads: 1
16/05/24 16:35:18 INFO jdbc.JDBCTap: creating connection: jdbc:mysql://ip2:3306/jdbc?user=root&password=root
16/05/24 16:35:18 INFO jdbc.JDBCTap: creating connection: jdbc:mysql://ip2:3306/jdbc?user=root&password=root
16/05/24 16:35:18 INFO jdbc.JDBCTap: creating connection: jdbc:mysql://ip2:3306/jdbc?user=root&password=root
16/05/24 16:35:18 INFO jdbc.JDBCUtil: executing update: CREATE TABLE testingtable13 ( num INT NOT NULL, lwr VARCHAR(100) NOT NULL, upr VARCHAR(100) NOT NULL, PRIMARY KEY( num ) )
16/05/24 16:35:18 INFO jdbc.JDBCTap: creating connection: jdbc:mysql://ip2:3306/jdbc?user=root&password=root
16/05/24 16:35:18 INFO flow.Flow: [insert] starting step: (1/1) ...43-4bb3-bb14-3a9b4f304364
16/05/24 16:35:18 INFO jvm.JvmMetrics: Initializing JVM Metrics with processName=JobTracker, sessionId=
16/05/24 16:35:18 INFO jvm.JvmMetrics: Cannot initialize JVM Metrics with processName=JobTracker, sessionId= - already initialized
16/05/24 16:35:19 WARN mapreduce.JobSubmitter: No job jar file set. User classes may not be found. See Job or Job#setJar(String).
16/05/24 16:35:19 INFO db.DBConfiguration: opening db connection: jdbc:mysql://ip1:3306/jdbc?user=root&password=root
16/05/24 16:35:19 INFO db.DBInputFormat: creating DB input split with start: 0, end: 2, chunks: 1
16/05/24 16:35:19 INFO mapreduce.JobSubmitter: number of splits:1
16/05/24 16:35:19 INFO mapreduce.JobSubmitter: Submitting tokens for job: job_local828310614_0001
16/05/24 16:35:20 INFO flow.Flow: [insert] submitted hadoop job: job_local828310614_0001
16/05/24 16:35:20 INFO mapred.LocalJobRunner: OutputCommitter set in config null
16/05/24 16:35:20 INFO mapred.LocalJobRunner: OutputCommitter is org.apache.hadoop.mapred.FileOutputCommitter
16/05/24 16:35:20 WARN output.FileOutputCommitter: Output Path is null in setupJob()
16/05/24 16:35:20 INFO mapred.LocalJobRunner: Waiting for map tasks
16/05/24 16:35:20 INFO mapred.LocalJobRunner: Starting task: attempt_local828310614_0001_m_000000_0
16/05/24 16:35:20 INFO util.ProcfsBasedProcessTree: ProcfsBasedProcessTree currently is supported only on Linux.
16/05/24 16:35:20 INFO mapred.Task: Using ResourceCalculatorProcessTree : org.apache.hadoop.yarn.util.WindowsBasedProcessTree@5463cd7b
16/05/24 16:35:20 INFO mapred.MapTask: Processing split: cascading.tap.hadoop.io.MultiInputSplit@1ae05b3c
16/05/24 16:35:20 INFO db.DBConfiguration: opening db connection: jdbc:mysql://ip1:3306/jdbc?user=root&password=root
16/05/24 16:35:20 INFO db.DBInputFormat: Executing select query
16/05/24 16:35:20 INFO db.DBInputFormat: SELECT num, lwr, upr FROM testingtable12 testingtable12
16/05/24 16:35:20 INFO mapred.MapTask: numReduceTasks: 0
16/05/24 16:35:20 INFO db.DBConfiguration: opening db connection: jdbc:mysql://ip1:3306/jdbc?user=root&password=root
16/05/24 16:35:20 INFO hadoop.FlowMapper: cascading version: 3.0.1
16/05/24 16:35:20 INFO hadoop.FlowMapper: child jvm opts: -Xmx200m
16/05/24 16:35:21 INFO hadoop.FlowMapper: flow node id: B967B6FE2E234E67B363DDCE738EC22A, ordinal: 0
16/05/24 16:35:21 INFO Configuration.deprecation: mapred.task.partition is deprecated. Instead, use mapreduce.task.partition
16/05/24 16:35:21 INFO hadoop.FlowMapper: sourcing from: JDBCTap{connectionUrl='jdbc:mysql://ip1:3306/jdbc?user=root&password=root', driverClassName='com.mysql.jdbc.Driver', tableDesc=TableDesc{tableName='testingtable12', columnNames=[num, lwr, upr], columnDefs=[INT NOT NULL, VARCHAR(100) NOT NULL, VARCHAR(100) NOT NULL], primaryKeys=[num]}}
16/05/24 16:35:21 INFO hadoop.FlowMapper: sinking to: JDBCTap{connectionUrl='jdbc:mysql://ip2:3306/jdbc?user=root&password=root', driverClassName='com.mysql.jdbc.Driver', tableDesc=TableDesc{tableName='testingtable13', columnNames=[num, lwr, upr], columnDefs=[INT NOT NULL, VARCHAR(100) NOT NULL, VARCHAR(100) NOT NULL], primaryKeys=[num]}}
16/05/24 16:35:21 INFO hadoop.FlowMapper: flow node id: B967B6FE2E234E67B363DDCE738EC22A, mem on start (mb), free: 94, total: 116, max: 1365
16/05/24 16:35:21 INFO db.DBOutputFormat: executing batch [totstmts: 1][crntstmts: 1][batch: 1]
16/05/24 16:35:21 INFO db.DBOutputFormat: records:1
16/05/24 16:35:21 INFO db.DBOutputFormat: executing batch [totstmts: 2][crntstmts: 1][batch: 1]
16/05/24 16:35:21 INFO db.DBOutputFormat: records:1
16/05/24 16:35:21 INFO hadoop.FlowMapper: flow node id: B967B6FE2E234E67B363DDCE738EC22A, mem on close (mb), free: 92, total: 116, max: 1365
16/05/24 16:35:21 INFO mapred.LocalJobRunner:
16/05/24 16:35:21 INFO mapred.Task: Task:attempt_local828310614_0001_m_000000_0 is done. And is in the process of committing
16/05/24 16:35:21 INFO mapred.LocalJobRunner: map
16/05/24 16:35:21 INFO mapred.Task: Task 'attempt_local828310614_0001_m_000000_0' done.
16/05/24 16:35:21 INFO mapred.LocalJobRunner: Finishing task: attempt_local828310614_0001_m_000000_0
16/05/24 16:35:21 INFO mapred.LocalJobRunner: map task executor complete.
16/05/24 16:35:21 WARN output.FileOutputCommitter: Output Path is null in commitJob()
16/05/24 16:35:25 INFO flow.Flow: [insert] completed in: 00:06.982