Add Cpu & Ulimits to handle container start up failed in integration tests

Author: SravanThotakura05

src/main/java/com/solacecoe/connectors/spark/streaming/partitions/SolaceInputPartitionReader.java

@@ -339,7 +339,6 @@ private void registerTaskListener() {
                 logShutdownMessage(context);
             } else if (context.isCompleted()) {
                 String processedMessageIDs = SolaceMessageTracker.getProcessedMessagesIDs(this.solaceInputPartition.getId());
-                System.out.println(this.solaceInputPartition.getId() + " - " + processedMessageIDs);
                 if(processedMessageIDs != null && !processedMessageIDs.isEmpty()) {
                     try {
                         Path path = Paths.get(this.checkpointLocation + "/" + this.solaceInputPartition.getId() + ".txt");

src/test/java/com/solacecoe/connectors/spark/oauth/SolaceOAuthContainer.java

@@ -1,6 +1,7 @@
 package com.solacecoe.connectors.spark.oauth;
 
 import com.github.dockerjava.api.command.InspectContainerResponse;
+import com.github.dockerjava.api.model.Ulimit;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.wait.strategy.Wait;
 import org.testcontainers.images.builder.Transferable;
@@ -59,12 +60,15 @@ public SolaceOAuthContainer(String dockerImageName) {
     public SolaceOAuthContainer(DockerImageName dockerImageName) {
         super(dockerImageName);
         dockerImageName.assertCompatibleWith(DEFAULT_IMAGE_NAME);
+        Ulimit ulimit = new Ulimit("nofile", 2448, 1048576);
+        List<Ulimit> ulimitList = new ArrayList<>();
+        ulimitList.add(ulimit);
         withCreateContainerCmdModifier(cmd -> {
             cmd.withUser("1000");
             cmd.getHostConfig()
                     .withShmSize(SHM_SIZE)
-                    .withMemorySwap(-1L)
-                    .withMemoryReservation(0L);
+                    .withUlimits(ulimitList)
+                    .withCpuCount(1l);
         });
         this.waitStrategy = Wait.forLogMessage(SOLACE_READY_MESSAGE, 1).withStartupTimeout(Duration.ofSeconds(60));
         withExposedPorts(8080);