From 501ae44dc5ced98c0defb4225c953d23f9e4afaf Mon Sep 17 00:00:00 2001
From: Sergii Mikhtoniuk <mikhtoniuk@gmail.com>
Date: Thu, 25 Jun 2020 19:15:30 -0700
Subject: [PATCH] Upgrade Flink version

---
 CHANGELOG.md                                                  | 4 ++++
 .../src/main/scala/dev/kamu/cli/external/DockerImages.scala   | 2 +-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index a269f44a55..c72f32dd5d 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -4,6 +4,10 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.18.1] - 2020-06-25
+### Changed
+- Upgraded Flink engine to `0.3.0`
+
 ## [0.18.0] - 2020-06-23
 ### Added
 - Watermarking support
diff --git a/core.coordinator/src/main/scala/dev/kamu/cli/external/DockerImages.scala b/core.coordinator/src/main/scala/dev/kamu/cli/external/DockerImages.scala
index 869deb79b4..2eda917a4c 100644
--- a/core.coordinator/src/main/scala/dev/kamu/cli/external/DockerImages.scala
+++ b/core.coordinator/src/main/scala/dev/kamu/cli/external/DockerImages.scala
@@ -10,7 +10,7 @@ package dev.kamu.cli.external
 
 object DockerImages {
   val SPARK = "kamudata/engine-spark:0.5.0"
-  val FLINK = "kamudata/engine-flink:0.2.0"
+  val FLINK = "kamudata/engine-flink:0.3.0"
 
   val LIVY = SPARK
   val JUPYTER = "kamudata/jupyter-uber:0.0.1"