Ask Your Question

read mysql bin log failed?

asked 2017-09-14 00:57:14 -0500

casel.chen gravatar image

I want to setup a pipeline from mysql bin log origin to kafka producer destination. In latest streamset dc 2.7.1 web UI it show the error "Pipeline Status: RUNNING_ERROR: com.streamsets.pipeline.api.StageException: MYSQL_003 - Error connecting to MySql: java.util.concurrent.TimeoutException: BinaryLogClient was unable to connect in 5000ms",

and I noticed the console log as following:

Exception in thread "" java.lang.NumberFormatException: For input string: " b" at java.lang.NumberFormatException.forInputString( at java.lang.Integer.parseInt( at at at at at com.github.shyiko.mysql.binlog.BinaryLogClient.requestBinaryLogStream( at com.github.shyiko.mysql.binlog.BinaryLogClient.connect( at com.github.shyiko.mysql.binlog.BinaryLogClient$ at

The MySQL db read is from Ali Cloud. I also tried the pipeline in my local MySQL db, it works fine. Btw, I can run Maxwell ( to read bin log from Ali MySQL db.

I want to find the root cause and fix it, but I don't know how to debug streamsets DC in local. Anyone can help me? Thanks!

edit retag flag offensive close merge delete


Can you post a stack trace as well?

Jisun gravatar imageJisun ( 2017-09-18 13:01:01 -0500 )edit

1 Answer

Sort by ยป oldest newest most voted

answered 2017-09-18 12:34:20 -0500

junko_urata gravatar image

The NumberFormatException is thrown from the code where it tries to convert uuid to integer. For some reason your uuid contains a character. This is the exact code that throws the exception (byte)Integer.parseInt(uuid.charAt(j) + "" + uuid.charAt(j + 1), 16); I don't know why this happens. Seems like you received a reply for how to debug StreamSets in local environment. I recommend you to debug and compare the UUID when you connect to your local MySQL and the one on Ali Cloud.

edit flag offensive delete link more
Login/Signup to Answer

Question Tools

1 follower


Asked: 2017-09-14 00:57:14 -0500

Seen: 265 times

Last updated: Sep 18 '17