Skip to content

Commit dd6d260

Browse files
viragtripathiviragtripathi
committed
Updated mysql demo
1 parent b4bd074 commit dd6d260

File tree

4 files changed

+45
-4
lines changed

4 files changed

+45
-4
lines changed

‎connectors/db2/demo/config/samples/loader/env.yml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ connections:
1212
type: RDB
1313
name: RedisConnect #database pool name
1414
database: BLUDB #database
15-
url: "jdbc:db2://dashdb-txn-sbox-yp-dal09-11.services.dal.bluemix.net:50000/BLUDB"
15+
url: "jdbc:db2://dashdb-txn-sbox-yp-dal09-11.services.dal.bluemix.net:50000/BLUDB:sslConnection=true;"
1616
host: dashdb-txn-sbox-yp-dal09-11.services.dal.bluemix.net
1717
port: 50000
1818
username: ${REDISCONNECT_SOURCE_USERNAME}

‎connectors/mysql/demo/README.md‎

Lines changed: 42 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,48 @@ redislabs/redis-connect-mysql:pre-release-alpine start
248248
<p>
249249
250250
```bash
251-
251+
-------------------------------
252+
Starting Redis Connect redis-connect-mysql v0.4.0.7 instance using Java 11.0.13 on virag-cdc started by root in /opt/redislabs/redis-connect-mysql/bin
253+
Loading Redis Connect redis-connect-mysql Configurations from /opt/redislabs/redis-connect-mysql/config/samples/loader
254+
02:48:13,831 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Found resource [/opt/redislabs/redis-connect-mysql/config/logback.xml] at [file:/opt/redislabs/redis-connect-mysql/config/logback.xml]
255+
....
256+
....
257+
02:48:14.145 [main] INFO startup -
258+
02:48:14.149 [main] INFO startup - /$$$$$$$ /$$ /$$ /$$$$$$ /$$
259+
02:48:14.149 [main] INFO startup - | $$__ $$ | $$|__/ /$$__ $$ | $$
260+
02:48:14.149 [main] INFO startup - | $$ \ $$ /$$$$$$ /$$$$$$$ /$$ /$$$$$$$ | $$ \__/ /$$$$$$ /$$$$$$$ /$$$$$$$ /$$$$$$ /$$$$$$$ /$$$$$$
261+
02:48:14.150 [main] INFO startup - | $$$$$$$/ /$$__ $$ /$$__ $$| $$ /$$_____/ | $$ /$$__ $$| $$__ $$| $$__ $$ /$$__ $$ /$$_____/|_ $$_/
262+
02:48:14.150 [main] INFO startup - | $$__ $$| $$$$$$$$| $$ | $$| $$| $$$$$$ | $$ | $$ \ $$| $$ \ $$| $$ \ $$| $$$$$$$$| $$ | $$
263+
02:48:14.150 [main] INFO startup - | $$ \ $$| $$_____/| $$ | $$| $$ \____ $$ | $$ $$| $$ | $$| $$ | $$| $$ | $$| $$_____/| $$ | $$ /$$
264+
02:48:14.150 [main] INFO startup - | $$ | $$| $$$$$$$| $$$$$$$| $$ /$$$$$$$/ | $$$$$$/| $$$$$$/| $$ | $$| $$ | $$| $$$$$$$| $$$$$$$ | $$$$/
265+
02:48:14.150 [main] INFO startup - |__/ |__/ \_______/ \_______/|__/|_______/ \______/ \______/ |__/ |__/|__/ |__/ \_______/ \_______/ \___/
266+
02:48:14.150 [main] INFO startup -
267+
02:48:14.150 [main] INFO startup - ##################################################################
268+
02:48:14.151 [main] INFO startup -
269+
02:48:14.151 [main] INFO startup - Initializing Redis Connect Instance
270+
02:48:14.151 [main] INFO startup -
271+
02:48:14.151 [main] INFO startup - ##################################################################
272+
....
273+
....
274+
02:48:41.481 [JobManager-1] INFO startup - JobId: {connect}:job:initial_load claim request with ID: 1637117271879-0 has been fully processed and all metadata has been updated
275+
02:48:41.485 [JobManager-1] INFO startup - Instance: 30@virag-cdc published Job Claim Transition Event to Channel: REDIS.CONNECT.JOB.CLAIM.TRANSITION.EVENTS Message: {"jobId":"{connect}:job:initial_load","instanceName":"30@virag-cdc","transitionEvent":"CLAIMED","serviceName":"JobClaimer"}
276+
02:48:41.485 [lettuce-nioEventLoop-4-3] INFO startup - Instance: 30@virag-cdc consumed Job Claim Transition Event on Channel: REDIS.CONNECT.JOB.CLAIM.TRANSITION.EVENTS Message: {"jobId":"{connect}:job:initial_load","instanceName":"30@virag-cdc","transitionEvent":"CLAIMED","serviceName":"JobClaimer"}
277+
02:48:51.532 [EventProducer-1] WARN startup - Instance: 30@virag-cdc did not find entry in its executor threads local cache during stop process for JobId: {connect}:job:initial_load
278+
02:48:51.532 [EventProducer-1] INFO startup - Instance: 30@virag-cdc successfully cancelled heartbeat for JobId: {connect}:job:initial_load
279+
02:48:51.532 [EventProducer-1] INFO startup - Instance: 30@virag-cdc successfully stopped replication pipeline for JobId: {connect}:job:initial_load
280+
02:48:51.532 [EventProducer-1] INFO startup - Instance: 30@virag-cdc now owns 0 job(s) from its 2 max allowable capacity
281+
02:48:51.532 [EventProducer-1] INFO startup - Instance: 30@virag-cdc successfully stopped JobId: {connect}:job:initial_load and added it to {connect}:jobs:stopped
282+
02:49:11.019 [JobManager-2] INFO startup - Getting instance of EventHandler for : REDIS_HASH_WRITER
283+
02:49:11.054 [JobManager-2] INFO startup - Instance: 30@virag-cdc successfully established Redis connection for RedisConnectorEventHandler service
284+
02:49:11.057 [JobManager-2] INFO startup - Getting instance of EventHandler for : REDIS_HASH_CHECKPOINT_WRITER
285+
02:49:11.057 [JobManager-2] WARN startup - metricsKey not set - Metrics collection will be disabled
286+
02:49:11.086 [JobManager-2] INFO startup - Instance: 30@virag-cdc successfully established Redis connection for RedisCheckpointReader service
287+
02:49:11.090 [JobManager-2] INFO redisconnect - Instance: 30@virag-cdc recovered JobId: {connect}:task:partition:initial_load:1 and will set StartRecord: 2
288+
02:49:11.092 [JobManager-2] INFO redisconnect - Reading Mapper Config from : /opt/redislabs/redis-connect-mysql/config/samples/loader/mappers
289+
02:49:11.108 [JobManager-2] INFO redisconnect - Loaded Config for : RedisConnect.emp
290+
02:49:11.147 [JobManager-2] INFO startup - Instance: 30@virag-cdc successfully started job execution for JobId: {connect}:task:partition:initial_load:1
291+
....
292+
....
252293
```
253294
254295
</p>

‎connectors/mysql/demo/config/samples/loader/TaskCreator.yml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,4 +7,4 @@ producerConfig:
77
- table: RedisConnect.emp # schema.table
88
numJobs: 5
99
config: JobConfig.yml
10-
loadQuery: "SELECT * FROM (SELECT e.*, ROW_NUMBER() OVER (ORDER BY e.empno) RowIndex FROM RedisConnect.emp e) emps WHERE emps.RowIndex BETWEEN ${start} and ${end}"
10+
loadQuery: "SELECT * FROM (SELECT e.*, ROW_NUMBER() OVER (ORDER BY e.empno) RowIndex FROM RedisConnect.emp e) emps WHERE emps.RowIndex >= ${start} and emps.RowIndex <= ${end}"

‎connectors/mysql/demo/config/samples/loader/env.yml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ connections:
1212
type: RDB
1313
name: RedisConnect #database pool name
1414
database: RedisConnect #database
15-
url: "jdbc:mysql://127.0.0.1:3306/RedisConnect?useInformationSchema=true"
15+
url: "jdbc:mysql://127.0.0.1:3306/RedisConnect"
1616
host: 127.0.0.1
1717
port: 3306
1818
username: ${REDISCONNECT_SOURCE_USERNAME}

0 commit comments

Comments
 (0)