Skip to content

Commit

Permalink
[FLINK-22864][table] Remove the flink-table-planner and flink-table-u…
Browse files Browse the repository at this point in the history
…ber module

In order to avoid user confusion, reduce duplicate code, and improve maintainability
and testing times of the Flink project as a whole this removes the legacy planner
module.

It means that both the BatchTableEnvironment and DataSet API interop with
Table API are reaching end of life. Use the unified TableEnvironment for
batch and stream processing with the new planner or the DataStream API
in batch execution mode.

Users are encouraged to update their pipelines. Flink 1.13 is the last
version that offers the old functionality.

This closes apache#16080.
  • Loading branch information
twalthr committed Jun 4, 2021
1 parent bc8c739 commit 074e29d
Show file tree
Hide file tree
Showing 785 changed files with 1 addition and 160,082 deletions.
7 changes: 0 additions & 7 deletions flink-dist/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -331,13 +331,6 @@ under the License.
<scope>provided</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-uber_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-uber-blink_${scala.binary.version}</artifactId>
Expand Down
7 changes: 0 additions & 7 deletions flink-dist/src/main/assemblies/bin.xml
Original file line number Diff line number Diff line change
Expand Up @@ -70,13 +70,6 @@ under the License.
</file>

<!-- Table/SQL Uber JAR -->
<file>
<source>../flink-table/flink-table-uber/target/flink-table-uber_${scala.binary.version}-${project.version}.jar</source>
<outputDirectory>lib/</outputDirectory>
<destName>flink-table_${scala.binary.version}-${project.version}.jar</destName>
<fileMode>0644</fileMode>
</file>

<file>
<source>../flink-table/flink-table-uber-blink/target/flink-table-uber-blink_${scala.binary.version}-${project.version}.jar</source>
<outputDirectory>lib/</outputDirectory>
Expand Down
2 changes: 1 addition & 1 deletion flink-end-to-end-tests/flink-python-test/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-uber_${scala.binary.version}</artifactId>
<artifactId>flink-table-api-java-bridge_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,6 @@ checkCodeDependencies "${END_TO_END_DIR}/../flink-table/flink-table-api-scala-br
checkCodeDependencies "${END_TO_END_DIR}/../flink-table/flink-table-planner-blink/target/flink-table-planner-blink_${FLINK_SCALA_VERSION}.jar"
checkCodeDependencies "${END_TO_END_DIR}/../flink-table/flink-table-runtime-blink/target/flink-table-runtime-blink_${FLINK_SCALA_VERSION}.jar"
checkCodeDependencies "${FLINK_DIR}/lib/flink-table-blink_${FLINK_SCALA_VERSION}.jar"
checkCodeDependencies "${FLINK_DIR}/lib/flink-table_${FLINK_SCALA_VERSION}.jar"

checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-api-java/target/flink-table-api-java-${FLINK_VERSION}.jar"
checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-api-scala/target/flink-table-api-scala_${FLINK_SCALA_VERSION}.jar"
Expand All @@ -116,4 +115,3 @@ checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-api-scala-bri
checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-planner-blink/target/flink-table-planner-blink_${FLINK_SCALA_VERSION}.jar"
checkAllowedPackages "${END_TO_END_DIR}/../flink-table/flink-table-runtime-blink/target/flink-table-runtime-blink_${FLINK_SCALA_VERSION}.jar"
checkAllowedPackages "${FLINK_DIR}/lib/flink-table-blink_${FLINK_SCALA_VERSION}.jar"
checkAllowedPackages "${FLINK_DIR}/lib/flink-table_${FLINK_SCALA_VERSION}.jar"
Loading

0 comments on commit 074e29d

Please sign in to comment.