You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2017/07/13 21:45:57 UTC
[1/2] flink git commit: [hotfix] [table] Fix typo in DataStreamRel
ScalaDocs.
Repository: flink
Updated Branches:
refs/heads/release-1.3 e8887fe67 -> 1ed2ef438
[hotfix] [table] Fix typo in DataStreamRel ScalaDocs.
This closes #4303.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aa636bf2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/aa636bf2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/aa636bf2
Branch: refs/heads/release-1.3
Commit: aa636bf20950bc025f62f3f8ebde162920f88acd
Parents: e8887fe
Author: Ken Geis <ge...@gmail.com>
Authored: Tue Jul 11 12:22:58 2017 -0700
Committer: Fabian Hueske <fh...@apache.org>
Committed: Thu Jul 13 23:44:10 2017 +0200
----------------------------------------------------------------------
.../apache/flink/table/plan/nodes/datastream/DataStreamRel.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/aa636bf2/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRel.scala
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRel.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRel.scala
index 65d336f..fc5570d 100644
--- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRel.scala
+++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRel.scala
@@ -48,7 +48,7 @@ trait DataStreamRel extends FlinkRelNode {
def producesUpdates: Boolean = false
/**
- * Wheter the [[DataStreamRel]] consumes retraction messages instead of forwarding them.
+ * Whether the [[DataStreamRel]] consumes retraction messages instead of forwarding them.
* The node might or might not produce new retraction messages.
*/
def consumesRetractions: Boolean = false
[2/2] flink git commit: [FLINK-7154] [docs] Missing call to build
CsvTableSource example
Posted by fh...@apache.org.
[FLINK-7154] [docs] Missing call to build CsvTableSource example
The Java and Scala example code for CsvTableSource create a builder but
are missing the final call to build.
This closes #4313.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1ed2ef43
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1ed2ef43
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1ed2ef43
Branch: refs/heads/release-1.3
Commit: 1ed2ef4389d1814b5353df6675295a93b54cc5c7
Parents: aa636bf
Author: Greg Hogan <co...@greghogan.com>
Authored: Tue Jul 11 14:21:50 2017 -0400
Committer: Fabian Hueske <fh...@apache.org>
Committed: Thu Jul 13 23:44:25 2017 +0200
----------------------------------------------------------------------
docs/dev/table/sourceSinks.md | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/1ed2ef43/docs/dev/table/sourceSinks.md
----------------------------------------------------------------------
diff --git a/docs/dev/table/sourceSinks.md b/docs/dev/table/sourceSinks.md
index 58049c8..7af74ca 100644
--- a/docs/dev/table/sourceSinks.md
+++ b/docs/dev/table/sourceSinks.md
@@ -173,7 +173,8 @@ CsvTableSource csvTableSource = CsvTableSource
.lineDelimiter("$")
.ignoreFirstLine()
.ignoreParseErrors()
- .commentPrefix("%");
+ .commentPrefix("%")
+ .build();
{% endhighlight %}
</div>
@@ -191,6 +192,7 @@ val csvTableSource = CsvTableSource
.ignoreFirstLine
.ignoreParseErrors
.commentPrefix("%")
+ .build
{% endhighlight %}
</div>
</div>