File tree Expand file tree Collapse file tree 2 files changed +16
-9
lines changed Expand file tree Collapse file tree 2 files changed +16
-9
lines changed Original file line number Diff line number Diff line change 1
- # flink-scala-2.13
1
+ # flink-scala
2
2
3
- For now Flink does not support Scala 2.13. For more refer to < https://issues.apache.org/jira/browse/FLINK-13414 > .
3
+ This module is a replacement for the ` org.apache.flink:flink-scala ` lib shipped with flink distribution,
4
+ and allows using flink with higher scala versions than 2.12.8.
4
5
5
- Our solution to deploy Scala 2.13 code to Flink, until it's officially supported (or Flink becomes really scala-free):
6
+ For more refer to < https://issues.apache.org/jira/browse/FLINK-13414 > .
6
7
8
+ ## Replacing flink-scala in flink distribution
7
9
``` bash
8
10
rm $FLINK_HOME /lib/flink-scala* .jar
9
- wget https://repo1.maven.org/maven2/pl/touk/flink-scala-2-13_2.13/1.1.2/flink-scala-2-13_2.13-1.1.2-assembly.jar -O $FLINK_HOME /lib/flink-scala-2-13_2.13-1.1.1-assembly.jar
11
+
12
+ wget https://central.sonatype.com/repository/maven-snapshots/pl/touk/flink-scala_2.13/1.1.3-SNAPSHOT/flink-scala_2.13-1.1.3-SNAPSHOT-assembly.jar -O $FLINK_HOME /lib/flink-scala_2.13-1.1.3-SNAPSHOT-assembly.jar
10
13
```
11
14
15
+ ## Using as a lib (probably only sufficient when child-first classloading is enabled on flink)
12
16
``` scala
13
- libraryDependencies += " pl.touk" %% " flink-scala-2-13 " % " 1.1.2 "
17
+ libraryDependencies += " pl.touk" %% " flink-scala" % " 1.1.3-SNAPSHOT "
14
18
```
15
19
20
+ ## Prebuild flink images
21
+ * we provide prebuild flink docker images for scala 2.12 and 2.13 on [ Docker Hub] ( https://hub.docker.com/r/touk/flink )
22
+
16
23
## Publishing
17
24
```
18
25
sbt publishSigned sonatypeBundleRelease
Original file line number Diff line number Diff line change @@ -41,9 +41,9 @@ lazy val publishSettings = Seq(
41
41
// we'll end up with two scm sections and invalid pom...
42
42
pomExtra in Global := {
43
43
<scm >
44
- <connection >scm: git: github.com/ TouK / flink- scala- 2.13 .git</connection >
45
- <developerConnection >scm: git: git@ github.com: TouK / flink- scala- 2.13 .git</developerConnection >
46
- <url >github.com/ TouK / flink- scala- 2.13 </url >
44
+ <connection >scm: git: github.com/ TouK / flink- scala.git</connection >
45
+ <developerConnection >scm: git: git@ github.com: TouK / flink- scala.git</developerConnection >
46
+ <url >github.com/ TouK / flink- scala</url >
47
47
</scm >
48
48
<developers >
49
49
<developer >
@@ -61,7 +61,7 @@ lazy val root = (project in file("."))
61
61
name := " flink-scala" ,
62
62
organization := " pl.touk" ,
63
63
licenses := Seq (" Apache 2" -> url(" http://www.apache.org/licenses/LICENSE-2.0.txt" )),
64
- homepage := Some (url(" https://github.com/TouK/flink-scala-2.13 " )),
64
+ homepage := Some (url(" https://github.com/TouK/flink-scala" )),
65
65
libraryDependencies ++= (forScalaVersion(scalaVersion.value) {
66
66
case (2 , 12 ) =>
67
67
Seq (
You can’t perform that action at this time.
0 commit comments