Murtadha Hubail has submitted this change and it was merged.

Change subject: [ASTERIXDB-2490][BAD] Coordinated Change For Encrypted IPC
......................................................................


[ASTERIXDB-2490][BAD] Coordinated Change For Encrypted IPC

Change-Id: I3792fc7937aec09a263b365b50f281c9aca9b883
---
M 
asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java
1 file changed, 5 insertions(+), 5 deletions(-)

Approvals:
  Jenkins: Verified
  Michael Blow: Looks good to me, approved
  Murtadha Hubail: Looks good to me, but someone else must approve



diff --git 
a/asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java
 
b/asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java
index d2a6613..3fab8ba 100644
--- 
a/asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java
+++ 
b/asterix-bad/src/main/java/org/apache/asterix/bad/recovery/BADGlobalRecoveryManager.java
@@ -145,12 +145,12 @@
             listener.suspend();
             activeEventHandler.registerListener(listener);
             BADJobService.redeployJobSpec(entityId, procedure.getBody(), 
metadataProvider, badStatementExecutor, hcc,
-                    new RequestParameters(
-                            new ResultSet(hcc, 
appCtx.getCompilerProperties().getFrameSize(),
-                                    ResultReader.NUM_READERS),
+                    new RequestParameters(new ResultSet(hcc,
+                            
appCtx.getServiceContext().getControllerService().getNetworkSecurityManager()
+                                    .getSocketChannelFactory(), 
appCtx.getCompilerProperties().getFrameSize(),
+                            ResultReader.NUM_READERS),
                             new 
ResultProperties(IStatementExecutor.ResultDelivery.IMMEDIATE),
-                            new IStatementExecutor.Stats(), null, null, null, 
null, true),
-                    true);
+                            new IStatementExecutor.Stats(), null, null, null, 
null, true), true);
             metadataProvider.getLocks().unlock();
             //Log that the procedure stopped by cluster restart. Procedure is 
available again now.
             LOGGER.log(Level.SEVERE, entityId.getExtensionName() + " " + 
entityId.getDataverse() + "."

-- 
To view, visit https://asterix-gerrit.ics.uci.edu/3060
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings

Gerrit-MessageType: merged
Gerrit-Change-Id: I3792fc7937aec09a263b365b50f281c9aca9b883
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb-bad
Gerrit-Branch: master
Gerrit-Owner: Murtadha Hubail <[email protected]>
Gerrit-Reviewer: Jenkins <[email protected]>
Gerrit-Reviewer: Michael Blow <[email protected]>
Gerrit-Reviewer: Murtadha Hubail <[email protected]>

Reply via email to