You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by pr...@apache.org on 2015/09/14 19:18:13 UTC
[1/2] incubator-apex-core git commit: APEX-121 #resolve
Repository: incubator-apex-core
Updated Branches:
refs/heads/devel-3 760039e81 -> efaa8f282
APEX-121 #resolve
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/89aefea4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/89aefea4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/89aefea4
Branch: refs/heads/devel-3
Commit: 89aefea4c0b5ac8b40efd2a191b81142a8c302f9
Parents: c349090
Author: Gaurav <ga...@datatorrent.com>
Authored: Sat Sep 12 22:50:11 2015 -0700
Committer: Gaurav <ga...@datatorrent.com>
Committed: Sat Sep 12 22:50:11 2015 -0700
----------------------------------------------------------------------
.../com/datatorrent/stram/stream/BufferServerPublisher.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/89aefea4/engine/src/main/java/com/datatorrent/stram/stream/BufferServerPublisher.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/stream/BufferServerPublisher.java b/engine/src/main/java/com/datatorrent/stram/stream/BufferServerPublisher.java
index d8e09c8..39cf667 100644
--- a/engine/src/main/java/com/datatorrent/stram/stream/BufferServerPublisher.java
+++ b/engine/src/main/java/com/datatorrent/stram/stream/BufferServerPublisher.java
@@ -112,7 +112,14 @@ public class BufferServerPublisher extends Publisher implements ByteCounterStrea
* if there is any state write that for the subscriber before we write the data.
*/
if (dsp.state != null) {
- write(DataTuple.getSerializedTuple(MessageType.CODEC_STATE_VALUE, dsp.state));
+ array = DataTuple.getSerializedTuple(MessageType.CODEC_STATE_VALUE, dsp.state);
+ try {
+ while (!write(array)) {
+ sleep(5);
+ }
+ } catch (InterruptedException ie) {
+ throw new RuntimeException(ie);
+ }
}
/*
* Now that the state if any has been sent, we can proceed with the actual data we want to send.
[2/2] incubator-apex-core git commit: Merge branch 'APEX-121' of
github.com:gauravgopi123/incubator-apex-core into devel-3
Posted by pr...@apache.org.
Merge branch 'APEX-121' of github.com:gauravgopi123/incubator-apex-core into devel-3
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/efaa8f28
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/efaa8f28
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/efaa8f28
Branch: refs/heads/devel-3
Commit: efaa8f282e2404344f95cb0f5ce9d401e28391de
Parents: 760039e 89aefea
Author: Pramod Immaneni <pr...@datatorrent.com>
Authored: Mon Sep 14 10:10:34 2015 -0700
Committer: Pramod Immaneni <pr...@datatorrent.com>
Committed: Mon Sep 14 10:10:34 2015 -0700
----------------------------------------------------------------------
.../com/datatorrent/stram/stream/BufferServerPublisher.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
----------------------------------------------------------------------