Skip to content

Latest commit

 

History

History
43 lines (37 loc) · 839 Bytes

README.md

File metadata and controls

43 lines (37 loc) · 839 Bytes

Requirements

  • A Kafka cluster
  • A mariaDB instance

Setup

Database

Create user:

CREATE DATABASE telematics;
CREATE USER 'telematics'@'localhost' IDENTIFIED BY 'XXXX';
GRANT ALL PRIVILEGES ON telematics.* TO 'telematics'@'localhost';
FLUSH PRIVILEGES;

Run DDL in sql/trips_ddl.sql`

Scala

# SDKMan is cool
sdk install scala 2.12.16
sdk use scala 2.12.16
sdk install sbt

Run

export RUN_LOCALLY=1
 JDBC_USER=telematics JDBC_PW=$PASSWORD sbt run

Submit

Create a src/main/resources/production.conf first.

# Edit this
cp src/main/resources/application.conf src/main/resources/production.conf
# Build, run
sbt clean assembly
flink run \
      --detached \
      --jobmanager bigiron.lan:8082 \
      ./target/scala-2.12/TinyTelematics-assembly-0.1.jar