Fix Fhir IO Search IT (#30158)

* [BEAM-12550] Implement Parallelizable Skew and Kurtosis
(Skew implementation)

R: @TheNeuralBit

* fix fhirio search tests

* spotless

* reduce query count and size

* postcommit

* remove clear

---------

Co-authored-by: svetakvsundhar <svetak.sundhar@gmail.com>

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIOSearchIT.java

@@ -43,7 +43,6 @@
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableMap;
 import org.junit.After;
 import org.junit.Before;
-import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -66,7 +65,7 @@ public static Collection<String> versions() {
   private static final String BASE_STORE_ID =
       "FHIR_store_search_it_" + System.currentTimeMillis() + "_" + new SecureRandom().nextInt(32);
   private String fhirStoreId;
-  private static final int MAX_NUM_OF_SEARCHES = 50;
+  private static final int MAX_NUM_OF_SEARCHES = 20;
   private List<FhirSearchParameter<String>> input = new ArrayList<>();
   private List<FhirSearchParameter<List<Integer>>> genericParametersInput = new ArrayList<>();
   private static final String KEY = "key";
@@ -96,9 +95,9 @@ public void setup() throws Exception {
 
     JsonArray fhirResources =
         JsonParser.parseString(bundles.get(0)).getAsJsonObject().getAsJsonArray("entry");
-    Map<String, String> searchParameters = ImmutableMap.of("_count", "50");
+    Map<String, String> searchParameters = ImmutableMap.of("_count", "20");
     Map<String, List<Integer>> genericSearchParameters =
-        ImmutableMap.of("_count", Arrays.asList(50));
+        ImmutableMap.of("_count", Arrays.asList(20));
 
     // Include a non-resource type search.
     input.add(FhirSearchParameter.of("", KEY, searchParameters));
@@ -127,7 +126,6 @@ public void teardown() throws IOException {
     }
   }
 
-  @Ignore("https://github.com/apache/beam/issues/28505")
   @Test
   public void testFhirIOSearch() {
     pipeline.getOptions().as(DirectOptions.class).setBlockOnRun(false);
@@ -157,7 +155,6 @@ public void testFhirIOSearch() {
     pipeline.run().waitUntilFinish();
   }
 
-  @Ignore("https://github.com/apache/beam/issues/28505")
   @Test
   public void testFhirIOSearchWithGenericParameters() {
     pipeline.getOptions().as(DirectOptions.class).setBlockOnRun(false);