Sports Stats demo failing

Four Stars

Sports Stats demo failing

Still having problems, this time with the Sports Stats demo ...

 

I run step 1 without issue

 

but then step 2, I get warnings ...

Starting job Step_2_SportStats_Read_Dataset at 23:45 27/06/2018.

[statistics] connecting to socket on port 3814
[statistics] connected
[WARN ]: org.apache.kafka.clients.producer.ProducerConfig - The configuration security.protocol = null was supplied but isn't a known config.
[WARN ]: org.apache.kafka.clients.producer.ProducerConfig - The configuration value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer was supplied but isn't a known config.
[WARN ]: org.apache.kafka.clients.producer.ProducerConfig - The configuration key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer was supplied but isn't a known config.
[WARN ]: org.apache.kafka.clients.producer.ProducerConfig - The configuration security.protocol = null was supplied but isn't a known config.
[WARN ]: org.apache.kafka.clients.producer.ProducerConfig - The configuration value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer was supplied but isn't a known config.
[WARN ]: org.apache.kafka.clients.producer.ProducerConfig - The configuration key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer was supplied but isn't a known config.
[statistics] disconnected
Job Step_2_SportStats_Read_Dataset ended at 23:46 27/06/2018. [exit code=0]

And step 3 fails ...

Starting job Step_3_SportStats_LiveStream at 23:46 27/06/2018.

[statistics] connecting to socket on port 4065
[statistics] connected
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/home/talend/workspace/.Java/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/home/talend/workspace/.Java/lib/talend-spark-assembly-1.6.0-cdh5.8.1-hadoop2.6.0-cdh5.8.1-with-hive.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
[WARN ]: org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
[WARN ]: org.apache.spark.SparkConf - In Spark 1.0 and later spark.local.dir will be overridden by the value set by the cluster manager (via SPARK_LOCAL_DIRS in mesos/standalone and LOCAL_DIRS in YARN).
[WARN ]: org.apache.spark.util.Utils - Your hostname, talend resolves to a loopback address: 127.0.1.1; using 192.XXX.XXX.XXX instead (on interface ens32)
[WARN ]: org.apache.spark.util.Utils - Set SPARK_LOCAL_IP if you need to bind to another address
[WARN ]: org.apache.hadoop.hdfs.shortcircuit.DomainSocketFactory - The short-circuit local reads feature cannot be used because libhadoop cannot be loaded.
[WARN ]: kafka.utils.VerifiableProperties - Property serializer.encoding is not valid
com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException: Could not create connection to database server.
	at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
	at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
	at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
	at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
	at com.mysql.jdbc.Util.handleNewInstance(Util.java:409)
	at com.mysql.jdbc.Util.getInstance(Util.java:384)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1013)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:987)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:973)
	at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:918)
	at com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2588)
	at com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2321)
	at com.mysql.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:832)
	at com.mysql.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:46)
	at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
	at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
	at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
	at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
	at com.mysql.jdbc.Util.handleNewInstance(Util.java:409)
	at com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:417)
	at com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:344)
	at java.sql.DriverManager.getConnection(DriverManager.java:664)
	at java.sql.DriverManager.getConnection(DriverManager.java:208)
	at bigdata_cloudera.step_3_sportstats_livestream_0_1.Step_3_SportStats_LiveStream.tKafkaInput_1Process(Step_3_SportStats_LiveStream.java:1993)
	at bigdata_cloudera.step_3_sportstats_livestream_0_1.Step_3_SportStats_LiveStream.run(Step_3_SportStats_LiveStream.java:2326)
	at bigdata_cloudera.step_3_sportstats_livestream_0_1.Step_3_SportStats_LiveStream.runJobInTOS(Step_3_SportStats_LiveStream.java:2279)
	at bigdata_cloudera.step_3_sportstats_livestream_0_1.Step_3_SportStats_LiveStream.main(Step_3_SportStats_LiveStream.java:2158)
Caused by: java.lang.NullPointerException
	at com.mysql.jdbc.ConnectionImpl.getServerCharacterEncoding(ConnectionImpl.java:3307)
	at com.mysql.jdbc.MysqlIO.sendConnectionAttributes(MysqlIO.java:1985)
	at com.mysql.jdbc.MysqlIO.proceedHandshakeWithPluggableAuthentication(MysqlIO.java:1911)
	at com.mysql.jdbc.MysqlIO.doHandshake(MysqlIO.java:1288)
	at com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2506)
	at com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2539)
	... 16 more
[WARN ]: org.apache.spark.streaming.StreamingContext - StreamingContext has not been started yet
Exception in thread "main" java.lang.RuntimeException: TalendJob: 'Step_3_SportStats_LiveStream' - Failed with exit code: 1.
	at bigdata_cloudera.step_3_sportstats_livestream_0_1.Step_3_SportStats_LiveStream.main(Step_3_SportStats_LiveStream.java:2169)
[statistics] disconnected
[ERROR]: bigdata_cloudera.step_3_sportstats_livestream_0_1.Step_3_SportStats_LiveStream - TalendJob: 'Step_3_SportStats_LiveStream' - Failed with exit code: 1.
[WARN ]: org.apache.spark.rpc.netty.Dispatcher - Message RemoteProcessDisconnected(172.xx.x.x:xxxxx) dropped. RpcEnv already stopped.
[WARN ]: org.apache.spark.rpc.netty.Dispatcher - Message RemoteProcessDisconnected(172.xx.x.x:xxxxx) dropped. RpcEnv already stopped.
Job Step_3_SportStats_LiveStream ended at 23:47 27/06/2018. [exit code=1]

[Note: IP addresses masked]

 

Please help

K

Tutorial

Introduction to Talend Open Studio for Data Integration.

Definitive Guide to Data Integration

Practical steps to developing your data integration strategy.

Definitive Guide to Data Quality

Create systems and workflow to manage clean data ingestion and data transformation.