You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/02/10 13:09:27 UTC
[flink] branch release-1.10 updated: [hotfix][example] Copy
StreamWindowSQLExample.jar to dist/examples/table
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new ad21321 [hotfix][example] Copy StreamWindowSQLExample.jar to dist/examples/table
ad21321 is described below
commit ad21321cafbae7855c929596b24c16650fb89cfd
Author: Jark Wu <ja...@apache.org>
AuthorDate: Mon Feb 10 20:40:04 2020 +0800
[hotfix][example] Copy StreamWindowSQLExample.jar to dist/examples/table
---
flink-examples/flink-examples-table/pom.xml | 1 +
.../org/apache/flink/table/examples/java/StreamWindowSQLExample.java | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-examples/flink-examples-table/pom.xml b/flink-examples/flink-examples-table/pom.xml
index d097495..c4c40fa 100644
--- a/flink-examples/flink-examples-table/pom.xml
+++ b/flink-examples/flink-examples-table/pom.xml
@@ -236,6 +236,7 @@ under the License.
<configuration>
<target>
<copy file="${project.basedir}/target/flink-examples-table_${scala.binary.version}-${project.version}-StreamSQLExample.jar" tofile="${project.basedir}/target/StreamSQLExample.jar"/>
+ <copy file="${project.basedir}/target/flink-examples-table_${scala.binary.version}-${project.version}-StreamWindowSQLExample.jar" tofile="${project.basedir}/target/StreamWindowSQLExample.jar"/>
<copy file="${project.basedir}/target/flink-examples-table_${scala.binary.version}-${project.version}-WordCountSQL.jar" tofile="${project.basedir}/target/WordCountSQL.jar"/>
<copy file="${project.basedir}/target/flink-examples-table_${scala.binary.version}-${project.version}-WordCountTable.jar" tofile="${project.basedir}/target/WordCountTable.jar"/>
<copy file="${project.basedir}/target/flink-examples-table_${scala.binary.version}-${project.version}-StreamTableExample.jar" tofile="${project.basedir}/target/StreamTableExample.jar"/>
diff --git a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/StreamWindowSQLExample.java b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/StreamWindowSQLExample.java
index a2a7f5f..286d58f 100644
--- a/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/StreamWindowSQLExample.java
+++ b/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/StreamWindowSQLExample.java
@@ -31,7 +31,7 @@ import java.io.IOException;
/**
* Simple example for demonstrating the use of SQL in Java.
*
- * <p>Usage: {@code ./bin/flink run ./examples/table/StreamWindowSQLExample.java}
+ * <p>Usage: {@code ./bin/flink run ./examples/table/StreamWindowSQLExample.jar}
*
* <p>This example shows how to:
* - Register a table via DDL