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