You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by xi...@apache.org on 2020/10/13 21:59:27 UTC

[incubator-pinot] branch fixing_meetup_stream created (now 360912e)

This is an automated email from the ASF dual-hosted git repository.

xiangfu pushed a change to branch fixing_meetup_stream
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.


      at 360912e  Fix meetup stream for quickstart

This branch includes the following new commits:

     new 360912e  Fix meetup stream for quickstart

The 1 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.



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org


[incubator-pinot] 01/01: Fix meetup stream for quickstart

Posted by xi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

xiangfu pushed a commit to branch fixing_meetup_stream
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git

commit 360912e0f3dcfc311bf125349bd6d8cce51415b2
Author: Xiang Fu <fx...@gmail.com>
AuthorDate: Tue Oct 13 14:59:08 2020 -0700

    Fix meetup stream for quickstart
---
 .../src/main/java/org/apache/pinot/tools/streams/MeetupRsvpStream.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/streams/MeetupRsvpStream.java b/pinot-tools/src/main/java/org/apache/pinot/tools/streams/MeetupRsvpStream.java
index 86a89db..8733526 100644
--- a/pinot-tools/src/main/java/org/apache/pinot/tools/streams/MeetupRsvpStream.java
+++ b/pinot-tools/src/main/java/org/apache/pinot/tools/streams/MeetupRsvpStream.java
@@ -113,7 +113,7 @@ public class MeetupRsvpStream {
             LOGGER.error("found an event where data did not have all the fields, don't care about for quickstart", e);
           }
         }
-      }, cec, new URI("ws://stream.meetup.com/2/rsvps"));
+      }, cec, new URI("wss://stream.meetup.com/2/rsvps"));
     } catch (Exception e) {
       LOGGER.error("encountered an error running the meetupRSVPEvents stream", e);
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org