You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by go...@apache.org on 2022/02/03 20:17:51 UTC
[phoenix] branch 4.x updated: Addendum PHOENIX-6622
This is an automated email from the ASF dual-hosted git repository.
gokcen pushed a commit to branch 4.x
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/4.x by this push:
new 7127713 Addendum PHOENIX-6622
7127713 is described below
commit 712771371156622668078d93483fd18855dc97aa
Author: Gokcen Iskender <go...@gmail.com>
AuthorDate: Thu Feb 3 11:58:22 2022 -0800
Addendum PHOENIX-6622
Signed-off-by: Gokcen Iskender <go...@gmail.com>
---
.../apache/phoenix/end2end/transform/TransformMonitorExtendedIT.java | 5 +++--
.../org/apache/phoenix/end2end/transform/TransformMonitorIT.java | 2 +-
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/transform/TransformMonitorExtendedIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/transform/TransformMonitorExtendedIT.java
index b4dd5a6..0251f56 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/transform/TransformMonitorExtendedIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/transform/TransformMonitorExtendedIT.java
@@ -64,8 +64,9 @@ public class TransformMonitorExtendedIT extends BaseTest {
@BeforeClass
public static synchronized void doSetup() throws Exception {
- Map<String, String> serverProps = com.google.common.collect.Maps.newHashMapWithExpectedSize(2);
- serverProps.put(ScanInfoUtil.PHOENIX_MAX_LOOKBACK_AGE_CONF_KEY, Integer.toString(60*60)); // An hour
+ Map<String, String> serverProps = Maps.newHashMapWithExpectedSize(2);
+ serverProps.put(ScanInfoUtil.PHOENIX_MAX_LOOKBACK_AGE_CONF_KEY,
+ Integer.toString(60*60)); // An hour
serverProps.put(QueryServices.IS_NAMESPACE_MAPPING_ENABLED, Boolean.TRUE.toString());
Map<String, String> clientProps = Maps.newHashMapWithExpectedSize(1);
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/transform/TransformMonitorIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/transform/TransformMonitorIT.java
index f78f905..97c10e9 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/transform/TransformMonitorIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/transform/TransformMonitorIT.java
@@ -654,7 +654,7 @@ public class TransformMonitorIT extends ParallelStatsDisabledIT {
}
public static void waitForTransformToGetToState(PhoenixConnection conn, SystemTransformRecord record, PTable.TransformStatus status) throws InterruptedException, SQLException {
- int maxTries = 200, nTries = 0;
+ int maxTries = 250, nTries = 0;
String lastStatus = "";
do {
if (status.name().equals(record.getTransformStatus())) {