From 3df00623dce88d5d04f76142daa69e81caceafd7 Mon Sep 17 00:00:00 2001 From: Ivan Mushketyk Date: Fri, 16 Dec 2016 07:56:46 +0000 Subject: [PATCH] [FLINK-5349] Fix typos in Twitter connector code sample --- docs/dev/connectors/twitter.md | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/docs/dev/connectors/twitter.md b/docs/dev/connectors/twitter.md index 0ccbbff6142d6..9b6a01912ba12 100644 --- a/docs/dev/connectors/twitter.md +++ b/docs/dev/connectors/twitter.md @@ -58,20 +58,20 @@ In contrast to other connectors, the `TwitterSource` depends on no additional se
{% highlight java %} Properties props = new Properties(); -p.setProperty(TwitterSource.CONSUMER_KEY, ""); -p.setProperty(TwitterSource.CONSUMER_SECRET, ""); -p.setProperty(TwitterSource.TOKEN, ""); -p.setProperty(TwitterSource.TOKEN_SECRET, ""); +props.setProperty(TwitterSource.CONSUMER_KEY, ""); +props.setProperty(TwitterSource.CONSUMER_SECRET, ""); +props.setProperty(TwitterSource.TOKEN, ""); +props.setProperty(TwitterSource.TOKEN_SECRET, ""); DataStream streamSource = env.addSource(new TwitterSource(props)); {% endhighlight %}
{% highlight scala %} val props = new Properties(); -p.setProperty(TwitterSource.CONSUMER_KEY, ""); -p.setProperty(TwitterSource.CONSUMER_SECRET, ""); -p.setProperty(TwitterSource.TOKEN, ""); -p.setProperty(TwitterSource.TOKEN_SECRET, ""); +props.setProperty(TwitterSource.CONSUMER_KEY, ""); +props.setProperty(TwitterSource.CONSUMER_SECRET, ""); +props.setProperty(TwitterSource.TOKEN, ""); +props.setProperty(TwitterSource.TOKEN_SECRET, ""); DataStream streamSource = env.addSource(new TwitterSource(props)); {% endhighlight %}