ignite-1.6 Check for empty message buffer in GridContinuousProcessor.addBackupNotification.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e5c8dfe2 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e5c8dfe2 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e5c8dfe2 Branch: refs/heads/master Commit: e5c8dfe243951543bc2a6032efb5f9c087f5b184 Parents: d549daf Author: sboikov <[email protected]> Authored: Tue May 17 11:01:29 2016 +0300 Committer: sboikov <[email protected]> Committed: Tue May 17 11:01:29 2016 +0300 ---------------------------------------------------------------------- .../internal/processors/continuous/GridContinuousProcessor.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e5c8dfe2/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java index fb727cb..0db9b27 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/continuous/GridContinuousProcessor.java @@ -733,7 +733,10 @@ public class GridContinuousProcessor extends GridProcessorAdapter { if (info != null) { final GridContinuousBatch batch = info.addAll(objs); - sendNotification(nodeId, routineId, null, batch.collect(), orderedTopic, true, null); + Collection<Object> toSnd = batch.collect(); + + if (!toSnd.isEmpty()) + sendNotification(nodeId, routineId, null, toSnd, orderedTopic, true, null); } }
