- Fix for [1393]

Author: pmalves

plugins/river/twitter/build.gradle

@@ -33,8 +33,10 @@ configurations {
 dependencies {
     compile project(':elasticsearch')
 
-    compile('org.twitter4j:twitter4j-core:2.1.10') { transitive = false }
-    distLib('org.twitter4j:twitter4j-core:2.1.10') { transitive = false }
+    compile('org.twitter4j:twitter4j-core:2.2.4') { transitive = false }
+    compile('org.twitter4j:twitter4j-stream:2.2.4') { transitive = false }
+    compile('org.twitter4j:twitter4j-core:2.2.4') { transitive = false }
+    compile('org.twitter4j:twitter4j-stream:2.2.4') { transitive = false }
 }
 
 task explodedDist(dependsOn: [jar], description: 'Builds the plugin zip file') << {
@@ -129,4 +131,4 @@ uploadArchives {
 
 eclipseClasspath {
     defaultOutputDir = file('build/eclipse-build')
-}
+}

plugins/river/twitter/src/main/java/org/elasticsearch/river/twitter/TwitterRiver.java

@@ -138,7 +138,7 @@ public class TwitterRiver extends AbstractRiverComponent implements River {
                 if (follow != null) {
                     if (follow instanceof List) {
                         List lFollow = (List) follow;
-                        int[] followIds = new int[lFollow.size()];
+                        long[] followIds = new long[lFollow.size()];
                         for (int i = 0; i < lFollow.size(); i++) {
                             Object o = lFollow.get(i);
                             if (o instanceof Number) {
@@ -150,7 +150,7 @@ public class TwitterRiver extends AbstractRiverComponent implements River {
                         filterQuery.follow(followIds);
                     } else {
                         String[] ids = Strings.commaDelimitedListToStringArray(follow.toString());
-                        int[] followIds = new int[ids.length];
+                        long[] followIds = new long[ids.length];
                         for (int i = 0; i < ids.length; i++) {
                             followIds[i] = Integer.parseInt(ids[i]);
                         }
@@ -265,11 +265,9 @@ public class TwitterRiver extends AbstractRiverComponent implements River {
         }
         currentRequest = client.prepareBulk();
         if (streamType.equals("filter") || filterQuery != null) {
-            try {
+   
                 stream.filter(filterQuery);
-            } catch (TwitterException e) {
-                logger.warn("failed to create filter stream based on query, disabling river....");
-            }
+
         } else if (streamType.equals("firehose")) {
             stream.firehose(0);
         } else {
@@ -309,11 +307,8 @@ private void reconnect() {
             stream.addListener(new StatusHandler());
 
             if (streamType.equals("filter") || filterQuery != null) {
-                try {
-                    stream.filter(filterQuery);
-                } catch (TwitterException e) {
-                    logger.warn("failed to create filter stream based on query, disabling river....");
-                }
+                stream.filter(filterQuery);
+
             } else if (streamType.equals("firehose")) {
                 stream.firehose(0);
             } else {