You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2019/05/15 07:16:25 UTC
[spark] branch branch-2.3 updated: [MINOR][SS] Remove duplicate
'add' in comment of `StructuredSessionization`.
This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a commit to branch branch-2.3
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-2.3 by this push:
new 306ebb2 [MINOR][SS] Remove duplicate 'add' in comment of `StructuredSessionization`.
306ebb2 is described below
commit 306ebb2975b0346a557a0e0f23e6f897d3912eef
Author: gengjiaan <ge...@360.cn>
AuthorDate: Wed May 15 16:01:43 2019 +0900
[MINOR][SS] Remove duplicate 'add' in comment of `StructuredSessionization`.
## What changes were proposed in this pull request?
`StructuredSessionization` comment contains duplicate 'add', I think it should be changed.
## How was this patch tested?
Exists UT.
Closes #24589 from beliefer/remove-duplicate-add-in-comment.
Lead-authored-by: gengjiaan <ge...@360.cn>
Co-authored-by: Jiaan Geng <be...@163.com>
Signed-off-by: HyukjinKwon <gu...@apache.org>
(cherry picked from commit 7dd2dd5dc5d4210bef88b75b7f5b06266dc4ce1c)
Signed-off-by: HyukjinKwon <gu...@apache.org>
---
.../apache/spark/examples/sql/streaming/StructuredSessionization.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/examples/src/main/scala/org/apache/spark/examples/sql/streaming/StructuredSessionization.scala b/examples/src/main/scala/org/apache/spark/examples/sql/streaming/StructuredSessionization.scala
index ed63fb6..29dbb0d 100644
--- a/examples/src/main/scala/org/apache/spark/examples/sql/streaming/StructuredSessionization.scala
+++ b/examples/src/main/scala/org/apache/spark/examples/sql/streaming/StructuredSessionization.scala
@@ -70,7 +70,7 @@ object StructuredSessionization {
line.split(" ").map(word => Event(sessionId = word, timestamp))
}
- // Sessionize the events. Track number of events, start and end timestamps of session, and
+ // Sessionize the events. Track number of events, start and end timestamps of session,
// and report session updates.
val sessionUpdates = events
.groupByKey(event => event.sessionId)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org