You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2019/02/06 09:43:31 UTC
[flink] branch master updated (85a655a -> ca4ff37)
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 85a655a [hotfix][tests] Move field definitions before method definitions
new 96e5a20 [hotfix][table] Annotate QueryConfig classes
new ca4ff37 [FLINK-11535][table] Include table-api-java in SQL Client jar
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-table/flink-sql-client/pom.xml | 14 ++++++++++++++
.../java/org/apache/flink/table/api/BatchQueryConfig.java | 3 +++
.../java/org/apache/flink/table/api/StreamQueryConfig.java | 2 ++
3 files changed, 19 insertions(+)
[flink] 02/02: [FLINK-11535][table] Include table-api-java in SQL
Client jar
Posted by tw...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit ca4ff379c5187836643dac011b7a986d608b0dee
Author: Timo Walther <tw...@apache.org>
AuthorDate: Tue Feb 5 15:40:28 2019 +0100
[FLINK-11535][table] Include table-api-java in SQL Client jar
This closes #7652.
---
flink-table/flink-sql-client/pom.xml | 14 ++++++++++++++
1 file changed, 14 insertions(+)
diff --git a/flink-table/flink-sql-client/pom.xml b/flink-table/flink-sql-client/pom.xml
index 28acd69..39a5439 100644
--- a/flink-table/flink-sql-client/pom.xml
+++ b/flink-table/flink-sql-client/pom.xml
@@ -68,9 +68,22 @@ under the License.
<!-- Table ecosystem -->
<dependency>
<groupId>org.apache.flink</groupId>
+ <artifactId>flink-table-common</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-table-api-java</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.flink</groupId>
<artifactId>flink-table-api-java-bridge_${scala.binary.version}</artifactId>
<version>${project.version}</version>
</dependency>
+
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-planner_${scala.binary.version}</artifactId>
@@ -162,6 +175,7 @@ under the License.
<artifactSet>
<includes combine.children="append">
<include>org.apache.flink:flink-table-common</include>
+ <include>org.apache.flink:flink-table-api-java</include>
<include>org.apache.flink:flink-table-api-java-bridge_${scala.binary.version}</include>
<include>org.apache.flink:flink-table-planner_${scala.binary.version}</include>
<include>org.apache.flink:flink-cep_${scala.binary.version}</include>
[flink] 01/02: [hotfix][table] Annotate QueryConfig classes
Posted by tw...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 96e5a20e0438e158ca98265906a6494838b002bb
Author: Timo Walther <tw...@apache.org>
AuthorDate: Tue Feb 5 15:39:04 2019 +0100
[hotfix][table] Annotate QueryConfig classes
---
.../src/main/java/org/apache/flink/table/api/BatchQueryConfig.java | 3 +++
.../src/main/java/org/apache/flink/table/api/StreamQueryConfig.java | 2 ++
2 files changed, 5 insertions(+)
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/BatchQueryConfig.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/BatchQueryConfig.java
index 5ad2d7a..a7cac52 100644
--- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/BatchQueryConfig.java
+++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/BatchQueryConfig.java
@@ -18,9 +18,12 @@
package org.apache.flink.table.api;
+import org.apache.flink.annotation.PublicEvolving;
+
/**
* The {@link BatchQueryConfig} holds parameters to configure the behavior of batch queries.
*/
+@PublicEvolving
public class BatchQueryConfig implements QueryConfig {
}
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/StreamQueryConfig.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/StreamQueryConfig.java
index 5190634..86c0c75 100644
--- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/StreamQueryConfig.java
+++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/StreamQueryConfig.java
@@ -18,11 +18,13 @@
package org.apache.flink.table.api;
+import org.apache.flink.annotation.PublicEvolving;
import org.apache.flink.api.common.time.Time;
/**
* The {@link StreamQueryConfig} holds parameters to configure the behavior of streaming queries.
*/
+@PublicEvolving
public class StreamQueryConfig implements QueryConfig {
/**