Advertisement
Guest User

Untitled

a guest
Sep 24th, 2017
67
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.88 KB | None | 0 0
  1. diff --git a/flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/DriverBaseITCase.java b/flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/DriverBaseITCase.java
  2. index 78b28e0..8c57088 100644
  3. --- a/flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/DriverBaseITCase.java
  4. +++ b/flink-libraries/flink-gelly-examples/src/test/java/org/apache/flink/graph/drivers/DriverBaseITCase.java
  5. @@ -23,7 +23,6 @@ import org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum;
  6. import org.apache.flink.test.util.MultipleProgramsTestBase;
  7. import org.apache.flink.util.FlinkRuntimeException;
  8.  
  9. -import org.apache.commons.lang3.ArrayUtils;
  10. import org.hamcrest.Description;
  11. import org.hamcrest.TypeSafeMatcher;
  12. import org.junit.Assert;
  13. @@ -190,10 +189,6 @@ extends MultipleProgramsTestBase {
  14. switch (mode) {
  15. case CLUSTER:
  16. case COLLECTION:
  17. - case CLUSTER_WITH_CODEGENERATION_ENABLED:
  18. - args = ArrayUtils.add(args, "--__disable_object_reuse");
  19. - break;
  20. -
  21. case CLUSTER_OBJECT_REUSE:
  22. // object reuse is enabled by default when executing drivers
  23. break;
  24. diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MultipleProgramsTestBase.java b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MultipleProgramsTestBase.java
  25. index a2d5899..1855b35 100644
  26. --- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MultipleProgramsTestBase.java
  27. +++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MultipleProgramsTestBase.java
  28. @@ -18,7 +18,6 @@
  29.  
  30. package org.apache.flink.test.util;
  31.  
  32. -import org.apache.flink.runtime.codegeneration.SorterFactory;
  33. import org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster;
  34.  
  35. import org.junit.After;
  36. @@ -67,7 +66,6 @@ public class MultipleProgramsTestBase extends TestBaseUtils {
  37. public enum TestExecutionMode {
  38. CLUSTER,
  39. CLUSTER_OBJECT_REUSE,
  40. - CLUSTER_WITH_CODEGENERATION_ENABLED,
  41. COLLECTION
  42. }
  43.  
  44. @@ -101,10 +99,6 @@ public class MultipleProgramsTestBase extends TestBaseUtils {
  45. case CLUSTER_OBJECT_REUSE:
  46. new TestEnvironment(cluster, 4, true).setAsContext();
  47. break;
  48. - case CLUSTER_WITH_CODEGENERATION_ENABLED:
  49. - new TestEnvironment(cluster, 4, false, true).setAsContext();
  50. - SorterFactory.getInstance().forceCodeGeneration = true; // Fail fast if an error occurs with codegen
  51. - break;
  52. case COLLECTION:
  53. new CollectionTestEnvironment().setAsContext();
  54. break;
  55. @@ -151,7 +145,6 @@ public class MultipleProgramsTestBase extends TestBaseUtils {
  56. public static Collection<Object[]> executionModes() {
  57. return Arrays.asList(
  58. new Object[] { TestExecutionMode.CLUSTER },
  59. - new Object[] { TestExecutionMode.CLUSTER_WITH_CODEGENERATION_ENABLED },
  60. new Object[] { TestExecutionMode.COLLECTION });
  61. }
  62. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement