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 2018/07/19 06:51:38 UTC
[1/2] flink git commit: [hotfix] [docs] Update docs about streaming
joins
Repository: flink
Updated Branches:
refs/heads/master fefe866ba -> 3d1f67bda
[hotfix] [docs] Update docs about streaming joins
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3d1f67bd
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3d1f67bd
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3d1f67bd
Branch: refs/heads/master
Commit: 3d1f67bdab7da9b46dcfb47ffdca3e739d0fc312
Parents: 85a6828
Author: Timo Walther <tw...@apache.org>
Authored: Thu Jul 19 08:50:09 2018 +0200
Committer: Timo Walther <tw...@apache.org>
Committed: Thu Jul 19 08:51:04 2018 +0200
----------------------------------------------------------------------
docs/dev/table/tableApi.md | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/3d1f67bd/docs/dev/table/tableApi.md
----------------------------------------------------------------------
diff --git a/docs/dev/table/tableApi.md b/docs/dev/table/tableApi.md
index 44436c4..2f65145 100644
--- a/docs/dev/table/tableApi.md
+++ b/docs/dev/table/tableApi.md
@@ -506,7 +506,7 @@ Table result = left.join(right).where("a = d").select("a, b, e");
<tr>
<td>
- <strong>Outer Joins</strong><br>
+ <strong>Outer Join</strong><br>
<span class="label label-primary">Batch</span>
<span class="label label-primary">Streaming</span>
<span class="label label-info">Result Updating</span>
@@ -521,6 +521,7 @@ Table leftOuterResult = left.leftOuterJoin(right, "a = d").select("a, b, e");
Table rightOuterResult = left.rightOuterJoin(right, "a = d").select("a, b, e");
Table fullOuterResult = left.fullOuterJoin(right, "a = d").select("a, b, e");
{% endhighlight %}
+<p><b>Note:</b> For streaming queries the required state to compute the query result might grow infinitely depending on the number of distinct input rows. Please provide a query configuration with valid retention interval to prevent excessive state size. See <a href="streaming.html">Streaming Concepts</a> for details.</p>
</td>
</tr>
<tr>
@@ -612,6 +613,7 @@ Table result = orders
<td>
<strong>Inner Join</strong><br>
<span class="label label-primary">Batch</span>
+ <span class="label label-primary">Streaming</span>
</td>
<td>
<p>Similar to a SQL JOIN clause. Joins two tables. Both tables must have distinct field names and at least one equality join predicate must be defined through join operator or using a where or filter operator.</p>
@@ -620,12 +622,15 @@ val left = ds1.toTable(tableEnv, 'a, 'b, 'c)
val right = ds2.toTable(tableEnv, 'd, 'e, 'f)
val result = left.join(right).where('a === 'd).select('a, 'b, 'e)
{% endhighlight %}
+<p><b>Note:</b> For streaming queries the required state to compute the query result might grow infinitely depending on the number of distinct input rows. Please provide a query configuration with valid retention interval to prevent excessive state size. See <a href="streaming.html">Streaming Concepts</a> for details.</p>
</td>
</tr>
<tr>
<td>
- <strong>Outer Joins</strong><br>
+ <strong>Outer Join</strong><br>
<span class="label label-primary">Batch</span>
+ <span class="label label-primary">Streaming</span>
+ <span class="label label-info">Result Updating</span>
</td>
<td>
<p>Similar to SQL LEFT/RIGHT/FULL OUTER JOIN clauses. Joins two tables. Both tables must have distinct field names and at least one equality join predicate must be defined.</p>
@@ -637,6 +642,7 @@ val leftOuterResult = left.leftOuterJoin(right, 'a === 'd).select('a, 'b, 'e)
val rightOuterResult = left.rightOuterJoin(right, 'a === 'd).select('a, 'b, 'e)
val fullOuterResult = left.fullOuterJoin(right, 'a === 'd).select('a, 'b, 'e)
{% endhighlight %}
+<p><b>Note:</b> For streaming queries the required state to compute the query result might grow infinitely depending on the number of distinct input rows. Please provide a query configuration with valid retention interval to prevent excessive state size. See <a href="streaming.html">Streaming Concepts</a> for details.</p>
</td>
</tr>
<tr>
[2/2] flink git commit: [hotfix] [sql-client] Fix typo in
SqlExecutionException
Posted by tw...@apache.org.
[hotfix] [sql-client] Fix typo in SqlExecutionException
This closes #6364.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/85a68286
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/85a68286
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/85a68286
Branch: refs/heads/master
Commit: 85a68286840ff5684b344bf807c206cc81feb968
Parents: fefe866
Author: xueyu <27...@qq.com>
Authored: Wed Jul 18 21:39:57 2018 +0800
Committer: Timo Walther <tw...@apache.org>
Committed: Thu Jul 19 08:51:04 2018 +0200
----------------------------------------------------------------------
.../apache/flink/table/client/gateway/local/ExecutionContext.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/85a68286/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java b/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
index 926bdb0..9152908 100644
--- a/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
+++ b/flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java
@@ -236,7 +236,7 @@ public class ExecutionContext<T> {
TableFactoryService.find(BatchTableSinkFactory.class, sinkProperties, classLoader);
return factory.createBatchTableSink(sinkProperties);
}
- throw new SqlExecutionException("Unsupported execution type for sources.");
+ throw new SqlExecutionException("Unsupported execution type for sinks.");
}
// --------------------------------------------------------------------------------------------