Skip to content

Commit db3e7a6

Browse files
committed
handle null in actions job
1 parent 19f6c5b commit db3e7a6

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

offline-jobs/spark/src/main/java/io/seldon/spark/actions/GroupActionsJob.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,12 @@ public int compare(ClientDetail o1, ClientDetail o2) {
172172
return 0;
173173
}
174174
});
175-
for (String client : clientList) {
175+
System.out.println("Client list "+clientList.toString());
176+
for (String client : clientList)
177+
{
178+
if (client != null)
179+
{
180+
System.out.println("looking at client "+client);
176181
final String currentClient = client;
177182

178183
JavaPairRDD<String, ActionData> filtered_by_client = pairs.filter(new Function<Tuple2<String, ActionData>, Boolean>() {
@@ -247,6 +252,9 @@ public Boolean call(String v1) throws Exception {
247252
long json_only_count = json_only.count();
248253
clientDetailZeroQueue.add(new ClientDetail(currentClient, json_only_with_zeros.count() - json_only_count));
249254
clientDetailQueue.add(new ClientDetail(currentClient, json_only_count));
255+
}
256+
else
257+
System.out.println("Found null client!");
250258
}
251259

252260
System.out.println("- Client Action (Zero Userid) Count -");

0 commit comments

Comments
 (0)