[jira] [Created] (GEODE-8741) Filter out CQ Update notifications
Mario Ivanac created GEODE-8741: --- Summary: Filter out CQ Update notifications Key: GEODE-8741 URL: https://issues.apache.org/jira/browse/GEODE-8741 Project: Geode Issue Type: Wish Components: cq Reporter: Mario Ivanac We want possibility to block/suppress CQ Update notifications -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (GEODE-8741) Filter out CQ Update notifications
[ https://issues.apache.org/jira/browse/GEODE-8741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mario Ivanac reassigned GEODE-8741: --- Assignee: Mario Ivanac > Filter out CQ Update notifications > -- > > Key: GEODE-8741 > URL: https://issues.apache.org/jira/browse/GEODE-8741 > Project: Geode > Issue Type: Wish > Components: cq >Reporter: Mario Ivanac >Assignee: Mario Ivanac >Priority: Major > > We want possibility to block/suppress CQ Update notifications -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (GEODE-8496) bump dependencies for 1.14
[ https://issues.apache.org/jira/browse/GEODE-8496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238642#comment-17238642 ] ASF GitHub Bot commented on GEODE-8496: --- onichols-pivotal opened a new pull request #5772: URL: https://github.com/apache/geode/pull/5772 it's been a month, and still no 1.14 in sight, so updating again to be sure we have the latest This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > bump dependencies for 1.14 > -- > > Key: GEODE-8496 > URL: https://issues.apache.org/jira/browse/GEODE-8496 > Project: Geode > Issue Type: Improvement > Components: build >Reporter: Owen Nichols >Priority: Major > Labels: pull-request-available > Fix For: 1.14.0 > > > now is a good time in the lull between 1.13 and 1.14 to roll 3rd party > libraries to latest versions wherever possible. Doing this proactively helps > us stay ahead of CVEs and keep up with bugfixes. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (GEODE-8741) Filter out CQ Update notifications
[ https://issues.apache.org/jira/browse/GEODE-8741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mario Ivanac updated GEODE-8741: Priority: Minor (was: Major) > Filter out CQ Update notifications > -- > > Key: GEODE-8741 > URL: https://issues.apache.org/jira/browse/GEODE-8741 > Project: Geode > Issue Type: Wish > Components: cq >Reporter: Mario Ivanac >Assignee: Mario Ivanac >Priority: Minor > > We want possibility to block/suppress CQ Update notifications -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (GEODE-8687) Durable client is continuously re-registering CQs on all servers when event de-serialization fails causing resource exhaustion on servers
[
https://issues.apache.org/jira/browse/GEODE-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238681#comment-17238681
]
ASF GitHub Bot commented on GEODE-8687:
---
mkevo commented on a change in pull request #5730:
URL: https://github.com/apache/geode/pull/5730#discussion_r530290653
##
File path:
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DurableClientCQAutoSerializer.java
##
@@ -0,0 +1,289 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license
+ * agreements. See the NOTICE file distributed with this work for additional
information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache
License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the
License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express
+ * or implied. See the License for the specific language governing permissions
and limitations under
+ * the License.
+ */
+package org.apache.geode.internal.cache.tier.sockets;
+
+import static org.apache.geode.cache.Region.SEPARATOR;
+import static org.apache.geode.test.awaitility.GeodeAwaitility.await;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+
+import java.io.Serializable;
+import java.util.Map;
+import java.util.Objects;
+
+import com.google.common.collect.ImmutableMap;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.client.ClientCache;
+import org.apache.geode.cache.client.ClientRegionFactory;
+import org.apache.geode.cache.client.ClientRegionShortcut;
+import org.apache.geode.cache.client.internal.PoolImpl;
+import org.apache.geode.cache.query.CqAttributesFactory;
+import org.apache.geode.cache.query.CqQuery;
+import org.apache.geode.cache.query.QueryService;
+import org.apache.geode.internal.cache.CacheServerImpl;
+import org.apache.geode.pdx.ReflectionBasedAutoSerializer;
+import org.apache.geode.pdx.internal.AutoSerializableManager;
+import org.apache.geode.test.dunit.Invoke;
+import org.apache.geode.test.dunit.rules.ClientVM;
+import org.apache.geode.test.dunit.rules.ClusterStartupRule;
+import org.apache.geode.test.dunit.rules.MemberVM;
+import org.apache.geode.test.junit.categories.ClientSubscriptionTest;
+import org.apache.geode.test.junit.categories.SerializationTest;
+import org.apache.geode.test.junit.rules.GfshCommandRule;
+
+@Category({ClientSubscriptionTest.class, SerializationTest.class})
+public class DurableClientCQAutoSerializer implements Serializable {
+ private static final String REPLICATE_REGION_NAME = "ReplicateRegion";
+ private static final String PARTITION_REGION_NAME = "PartitionRegion";
+
+ private MemberVM server;
+ private MemberVM server2;
+ private MemberVM locator;
+ private ClientVM client;
+ private ClientVM client2;
+
+ private static TestAutoSerializerCqListener cqListener = null;
+
+ private static final String TEST_OBJECT1_CLASS_PATH =
+ "org.apache.geode.internal.cache.tier.sockets.TestAutoSerializerObject1";
+ private static final String TEST_OBJECT2_CLASS_PATH =
+ "org.apache.geode.internal.cache.tier.sockets.TestAutoSerializerObject2";
+ private static final String TEST_FAULTY_CLASS_PATH =
+
"org.apache.geode.internal.cache.tier.sockets.TestAutoSerializerObject2Faulty";
+ private static final String DURABLE_CLIENT_ID = "durableClient";
+
+ // Traffic data
+ static final Map LIST_TEST_OBJECT1 =
ImmutableMap.of(
+ "key1", new TestAutoSerializerObject1("aa", "bb", 300),
+ "key2", new TestAutoSerializerObject1("aa", "bb", 600),
+ "key3", new TestAutoSerializerObject1("aaa", "bbb", 500));
+
+ static final Map LIST_TEST_OBJECT2 =
ImmutableMap.of(
+ "key1", new TestAutoSerializerObject2("cc", "ddd", 300),
+ "key2", new TestAutoSerializerObject2("cc", "", 400));
+
+ @Rule
+ public GfshCommandRule gfsh = new GfshCommandRule();
+
+ @Rule
+ public ClusterStartupRule cluster = new ClusterStartupRule(5);
+
+ @Before
+ public void setUp() throws Exception {
+Invoke.invokeInEveryVM(
+() ->
System.setProperty(AutoSerializableManager.NO_HARDCODED_EXCLUDES_PARAM,
"true"));
+
+locator =
+cluster.startLocatorVM(0);
+int locatorPort = locator.getPort();
+server = cluster.startServerVM(1,
+s -> s.withConnectionToLocator(locatorPort));
+
+server2 = cluster.startServerVM(2,
+s -> s.withConnectio
[jira] [Commented] (GEODE-8741) Filter out CQ Update notifications
[ https://issues.apache.org/jira/browse/GEODE-8741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238689#comment-17238689 ] ASF GitHub Bot commented on GEODE-8741: --- mivanac opened a new pull request #5773: URL: https://github.com/apache/geode/pull/5773 DO NOT REVIEW: WORK IN PROGRESS Thank you for submitting a contribution to Apache Geode. In order to streamline the review of the contribution we ask you to ensure the following steps have been taken: ### For all changes: - [*] Is there a JIRA ticket associated with this PR? Is it referenced in the commit message? - [*] Has your PR been rebased against the latest commit within the target branch (typically `develop`)? - [*] Is your initial contribution a single, squashed commit? - [*] Does `gradlew build` run cleanly? - [*] Have you written or updated unit tests to verify your changes? - [ ] If adding new dependencies to the code, are these dependencies licensed in a way that is compatible for inclusion under [ASF 2.0](http://www.apache.org/legal/resolved.html#category-a)? ### Note: Please ensure that once the PR is submitted, check Concourse for build issues and submit an update to your PR as soon as possible. If you need help, please send an email to d...@geode.apache.org. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Filter out CQ Update notifications > -- > > Key: GEODE-8741 > URL: https://issues.apache.org/jira/browse/GEODE-8741 > Project: Geode > Issue Type: Wish > Components: cq >Reporter: Mario Ivanac >Assignee: Mario Ivanac >Priority: Minor > > We want possibility to block/suppress CQ Update notifications -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (GEODE-8741) Filter out CQ Update notifications
[ https://issues.apache.org/jira/browse/GEODE-8741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated GEODE-8741: -- Labels: pull-request-available (was: ) > Filter out CQ Update notifications > -- > > Key: GEODE-8741 > URL: https://issues.apache.org/jira/browse/GEODE-8741 > Project: Geode > Issue Type: Wish > Components: cq >Reporter: Mario Ivanac >Assignee: Mario Ivanac >Priority: Minor > Labels: pull-request-available > > We want possibility to block/suppress CQ Update notifications -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (GEODE-8741) Filter out CQ Update notifications
[ https://issues.apache.org/jira/browse/GEODE-8741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238705#comment-17238705 ] ASF GitHub Bot commented on GEODE-8741: --- lgtm-com[bot] commented on pull request #5773: URL: https://github.com/apache/geode/pull/5773#issuecomment-733665150 This pull request **introduces 1 alert** when merging 6203395d2a7aca2604b3dcf81391d2e142d8f605 into 6a29ffbef5f8daca5267ddfdba638fcfd3898735 - [view on LGTM.com](https://lgtm.com/projects/g/apache/geode/rev/pr-51a723a8cb113926be8ad5134d332e640a6385c2) **new alerts:** * 1 for Reference equality test of boxed types This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Filter out CQ Update notifications > -- > > Key: GEODE-8741 > URL: https://issues.apache.org/jira/browse/GEODE-8741 > Project: Geode > Issue Type: Wish > Components: cq >Reporter: Mario Ivanac >Assignee: Mario Ivanac >Priority: Minor > Labels: pull-request-available > > We want possibility to block/suppress CQ Update notifications -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (GEODE-6953) CI failure: RedundancyLevelPart1DUnitTest testRedundancySpecifiedNonPrimaryEPFailsDetectionByPut failed with ComparisonFailure
[
https://issues.apache.org/jira/browse/GEODE-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238831#comment-17238831
]
Geode Integration commented on GEODE-6953:
--
Seen on support/1.12 in [DistributedTestOpenJDK8
#102|https://concourse.apachegeode-ci.info/teams/main/pipelines/apache-support-1-12-main/jobs/DistributedTestOpenJDK8/builds/102]
... see [test
results|http://files.apachegeode-ci.info/builds/apache-support-1-12-main/1.12.1-build.0122/test-results/distributedTest/1604457631/]
or download
[artifacts|http://files.apachegeode-ci.info/builds/apache-support-1-12-main/1.12.1-build.0122/test-artifacts/1604457631/distributedtestfiles-OpenJDK8-1.12.1-build.0122.tgz].
> CI failure: RedundancyLevelPart1DUnitTest
> testRedundancySpecifiedNonPrimaryEPFailsDetectionByPut failed with
> ComparisonFailure
> --
>
> Key: GEODE-6953
> URL: https://issues.apache.org/jira/browse/GEODE-6953
> Project: Geode
> Issue Type: Bug
> Components: client/server
>Reporter: Barrett Oglesby
>Priority: Major
>
> RedundancyLevelPart1DUnitTest.testRedundancySpecifiedNonPrimaryEPFailsDetectionByPut
> failed in DistributedTestOpenJDK11 build 762:
> https://concourse.gemfire-ci.info/teams/main/pipelines/gemfire-develop-main/jobs/DistributedTestOpenJDK11/builds/762
> {noformat}
> org.junit.ComparisonFailure: expected:<[1]> but was:<[0]>
> at
> jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
> at
> jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
> at
> jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
> at
> org.apache.geode.internal.cache.tier.sockets.RedundancyLevelPart1DUnitTest.testRedundancySpecifiedNonPrimaryEPFailsDetectionByPut(RedundancyLevelPart1DUnitTest.java:304)
> at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:566)
> at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
> at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
> at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
> at
> org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
> at
> org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62)
> at
> org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
> at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method
[jira] [Commented] (GEODE-7472) DistributedAckOverflowRegionCCEOffHeapDUnitTest.testConcurrentEventsOnEmptyRegion failed in DistributedTestOpenJDK8
[
https://issues.apache.org/jira/browse/GEODE-7472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238838#comment-17238838
]
Geode Integration commented on GEODE-7472:
--
Seen on support/1.12 in [DistributedTestOpenJDK8
#104|https://concourse.apachegeode-ci.info/teams/main/pipelines/apache-support-1-12-main/jobs/DistributedTestOpenJDK8/builds/104]
... see [test
results|http://files.apachegeode-ci.info/builds/apache-support-1-12-main/1.12.1-build.0123/test-results/distributedTest/1604618952/]
or download
[artifacts|http://files.apachegeode-ci.info/builds/apache-support-1-12-main/1.12.1-build.0123/test-artifacts/1604618952/distributedtestfiles-OpenJDK8-1.12.1-build.0123.tgz].
> DistributedAckOverflowRegionCCEOffHeapDUnitTest.testConcurrentEventsOnEmptyRegion
> failed in DistributedTestOpenJDK8
> ---
>
> Key: GEODE-7472
> URL: https://issues.apache.org/jira/browse/GEODE-7472
> Project: Geode
> Issue Type: Bug
> Components: tests
>Affects Versions: 1.12.0
>Reporter: Mark Hanson
>Priority: Major
> Labels: flaky
> Fix For: 1.12.0
>
>
> testConcurrentEvents is failing in testing.
>
> [https://concourse.apachegeode-ci.info/teams/main/pipelines/mhansonp-mhanson-mass-test-ru-main/jobs/DistributedTestOpenJDK8/builds/1680]
> {noformat}
> org.apache.geode.cache30.DistributedAckOverflowRegionCCEOffHeapDUnitTest >
> testConcurrentEventsOnEmptyRegion FAILED
> org.awaitility.core.ConditionTimeoutException: Condition with alias 'Wait
> for the members to eventually be consistent' didn't complete within 300
> seconds because assertion condition defined as a lambda expression in
> org.apache.geode.cache30.MultiVMRegionTestCase that uses
> org.apache.geode.test.dunit.VM,
> org.apache.geode.test.dunit.VMorg.apache.geode.test.dunit.VM,
> org.apache.geode.test.dunit.VMorg.apache.geode.test.dunit.VM [r2 contents are
> not consistent with r1 for cckey7] expected:<"ccvalue1212233561"> but
> was:.
> Caused by:
> org.junit.ComparisonFailure: [r2 contents are not consistent with r1
> for cckey7] expected:<"ccvalue1212233561"> but was:
> {noformat}
>
> {noformat}
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-= Test Results URI
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
> http://files.apachegeode-ci.info/builds/mhansonp-mhanson-mass-test-ru-main/1.10.0-SNAPSHOT.0007/test-results/distributedTest/1574073134/
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
> Test report artifacts from this job are available at:
> http://files.apachegeode-ci.info/builds/mhansonp-mhanson-mass-test-ru-main/1.10.0-SNAPSHOT.0007/test-artifacts/1574073134/distributedtestfiles-OpenJDK8-1.10.0-SNAPSHOT.0007.tgz{noformat}
> [https://concourse.apachegeode-ci.info/teams/main/pipelines/mhansonp-mhanson-mass-test-ru-main/jobs/DistributedTestOpenJDK8/builds/1613]
> {noformat}
> org.apache.geode.cache30.DistributedAckOverflowRegionCCEOffHeapDUnitTest >
> testConcurrentEventsOnEmptyRegion FAILED
> 22:20:16org.awaitility.core.ConditionTimeoutException: Condition with
> alias 'Wait for the members to eventually be consistent' didn't complete
> within 300 seconds because assertion condition defined as a lambda expression
> in org.apache.geode.cache30.MultiVMRegionTestCase that uses
> org.apache.geode.test.dunit.VM,
> org.apache.geode.test.dunit.VMorg.apache.geode.test.dunit.VM,
> org.apache.geode.test.dunit.VMorg.apache.geode.test.dunit.VM [r2 contents are
> not consistent with r1 for subkey cckey3-1] expected:<"ccvalue[-1702102599]">
> but was:<"ccvalue[2145556138]">.
> 22:20:16
> 22:20:16Caused by:
> 22:20:16org.junit.ComparisonFailure: [r2 contents are not consistent
> with r1 for subkey cckey3-1] expected:<"ccvalue[-1702102599]"> but
> was:<"ccvalue[2145556138]">
> 23:12:55 {noformat}
>
> {noformat}
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-= Test Results URI
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
> http://files.apachegeode-ci.info/builds/mhansonp-mhanson-mass-test-ru-main/1.10.0-SNAPSHOT.0007/test-results/distributedTest/1573975176/
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
> Test report artifacts from this job are available at:
> http://files.apachegeode-ci.info/builds/mhansonp-mhanson-mass-test-ru-main/1.10.0-SNAPSHOT.0007/test-artifacts/1573975176/distributedtestfiles-OpenJDK8-1.10.0-SNAPSHOT.0007.tgz{noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (GEODE-6462) [CI Failure] LocatorConnectionDUnitTest > testGetAvailableServersWithStats failed on validateStats
[
https://issues.apache.org/jira/browse/GEODE-6462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238842#comment-17238842
]
Geode Integration commented on GEODE-6462:
--
Seen on support/1.12 in [DistributedTestOpenJDK8
#109|https://concourse.apachegeode-ci.info/teams/main/pipelines/apache-support-1-12-main/jobs/DistributedTestOpenJDK8/builds/109]
... see [test
results|http://files.apachegeode-ci.info/builds/apache-support-1-12-main/1.12.1-build.0127/test-results/distributedTest/1604688198/]
or download
[artifacts|http://files.apachegeode-ci.info/builds/apache-support-1-12-main/1.12.1-build.0127/test-artifacts/1604688198/distributedtestfiles-OpenJDK8-1.12.1-build.0127.tgz].
> [CI Failure] LocatorConnectionDUnitTest > testGetAvailableServersWithStats
> failed on validateStats
> --
>
> Key: GEODE-6462
> URL: https://issues.apache.org/jira/browse/GEODE-6462
> Project: Geode
> Issue Type: Test
> Components: core
>Reporter: Jens Deppe
>Priority: Major
> Labels: ci
>
> This seems like a flakey test.
> [https://concourse.apachegeode-ci.info/teams/main/pipelines/apache-develop-main/jobs/DistributedTestOpenJDK8/builds/443]
> The test and the protobuf code has not been updated in a while. This is
> probably a flake.
> The following is the error thread
> {code:java}
> org.apache.geode.internal.protocol.protobuf.v1.acceptance.LocatorConnectionDUnitTest
> > testGetAvailableServersWithStats FAILED
> org.apache.geode.test.dunit.RMIException: While invoking
> org.apache.geode.internal.protocol.protobuf.v1.acceptance.LocatorConnectionDUnitTest$$Lambda$37/842046356.run
> in VM 0 running on Host 22c25e73171b with 4 VMs
> at org.apache.geode.test.dunit.VM.executeMethodOnObject(VM.java:579)
> at org.apache.geode.test.dunit.VM.invoke(VM.java:406)
> at
> org.apache.geode.test.junit.rules.VMProvider.invoke(VMProvider.java:85)
> at
> org.apache.geode.internal.protocol.protobuf.v1.acceptance.LocatorConnectionDUnitTest.validateStats(LocatorConnectionDUnitTest.java:234)
> at
> org.apache.geode.internal.protocol.protobuf.v1.acceptance.LocatorConnectionDUnitTest.testSocketWithStats(LocatorConnectionDUnitTest.java:127)
> at
> org.apache.geode.internal.protocol.protobuf.v1.acceptance.LocatorConnectionDUnitTest.testGetAvailableServersWithStats(LocatorConnectionDUnitTest.java:106)
> Caused by:
> org.awaitility.core.ConditionTimeoutException: Assertion condition
> defined as a lambda expression in
> org.apache.geode.internal.protocol.protobuf.v1.acceptance.LocatorConnectionDUnitTest
> that uses long, longlong, longlong, longlong, longint, intint expected:<3>
> but was:<4> within 300 seconds.
> at
> org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:145)
> at
> org.awaitility.core.AssertionCondition.await(AssertionCondition.java:122)
> at
> org.awaitility.core.AssertionCondition.await(AssertionCondition.java:32)
> at
> org.awaitility.core.ConditionFactory.until(ConditionFactory.java:902)
> at
> org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:723)
> at
> org.apache.geode.internal.protocol.protobuf.v1.acceptance.LocatorConnectionDUnitTest.lambda$validateStats$c7642ca0$1(LocatorConnectionDUnitTest.java:235)
> Caused by:
> java.lang.AssertionError: expected:<3> but was:<4>
> at org.junit.Assert.fail(Assert.java:88)
> at org.junit.Assert.failNotEquals(Assert.java:834)
> at org.junit.Assert.assertEquals(Assert.java:118)
> at org.junit.Assert.assertEquals(Assert.java:144)
> at
> org.apache.geode.internal.protocol.protobuf.v1.acceptance.LocatorConnectionDUnitTest.lambda$null$0(LocatorConnectionDUnitTest.java:238)
> {code}
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-= Test Results URI
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
>
> [http://files.apachegeode-ci.info/builds/apache-develop-main/1.9.0-SNAPSHOT.0487/test-results/distributedTest/1551228892/]
>
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
> Test report artifacts from this job are available at:
> [http://files.apachegeode-ci.info/builds/apache-develop-main/1.9.0-SNAPSHOT.0487/test-artifacts/1551228892/distributedtestfiles-OpenJDK8-1.9.0-SNAPSHOT.0487.tgz]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (GEODE-8623) Timing between DNS and Geode startup can result in permanent unknown host exceptions.
[
https://issues.apache.org/jira/browse/GEODE-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238847#comment-17238847
]
ASF GitHub Bot commented on GEODE-8623:
---
Bill commented on a change in pull request #5743:
URL: https://github.com/apache/geode/pull/5743#discussion_r530558020
##
File path: geode-common/src/main/java/org/apache/geode/internal/Retry.java
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license
+ * agreements. See the NOTICE file distributed with this work for additional
information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache
License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the
License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express
+ * or implied. See the License for the specific language governing permissions
and limitations under
+ * the License.
+ */
+package org.apache.geode.internal;
+
+import static java.util.concurrent.TimeUnit.NANOSECONDS;
+
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+import java.util.function.Predicate;
+import java.util.function.Supplier;
+
+import org.apache.geode.annotations.VisibleForTesting;
+
+/**
+ * Utility class for retrying operations.
+ */
+public class Retry {
+
+ interface Timer {
+long nanoTime();
+
+void sleep(long sleepTimeInNano) throws InterruptedException;
+ }
+
+ static class SteadyTimer implements Timer {
+@Override
+public long nanoTime() {
+ return System.nanoTime();
+}
+
+@Override
+public void sleep(long sleepTimeInNano) throws InterruptedException {
+ long millis = NANOSECONDS.toMillis(sleepTimeInNano);
+ // avoid throwing IllegalArgumentException
+ if (millis > 0) {
+Thread.sleep(millis);
+ }
+}
+ }
+
+ private static final SteadyTimer steadyClock = new SteadyTimer();
+
+ /**
+ * Try the supplier function until the predicate is true or timeout occurs.
+ *
+ * @param timeout to retry for
+ * @param timeoutUnit the unit for timeout
+ * @param interval time between each try
+ * @param intervalUnit the unit for interval
+ * @param supplier to execute until predicate is true or times out
+ * @param predicate to test for retry
+ * @param type of return value
+ * @return value from supplier after it passes predicate or times out.
+ */
+ public static T tryFor(long timeout, TimeUnit timeoutUnit,
+ long interval, TimeUnit intervalUnit,
+ Supplier supplier,
+ Predicate predicate) throws TimeoutException, InterruptedException {
+return tryFor(timeout, timeoutUnit, interval, intervalUnit, supplier,
predicate, steadyClock);
+ }
+
+ @VisibleForTesting
+ static T tryFor(long timeout, TimeUnit timeoutUnit,
+ long interval, TimeUnit intervalUnit,
+ Supplier supplier,
+ Predicate predicate,
+ Timer timer) throws TimeoutException, InterruptedException {
+long until = timer.nanoTime() + NANOSECONDS.convert(timeout, timeoutUnit);
+long intervalNano = NANOSECONDS.convert(interval, intervalUnit);
+
+T value;
+for (;;) {
+ value = supplier.get();
+ if (predicate.test(value)) {
+return value;
+ } else {
+// if there is still more time left after we sleep for interval
period, then sleep and retry
+// otherwise break out and throw TimeoutException
+if ((timer.nanoTime() + intervalNano) < until) {
Review comment:
I don't understand (1). In my proposal we never time out at the end of a
sleep. After a sleep we always try the supplier and predicate again. In cases
where the predicate returns `false` forever, we would always sleep and then try
the predicate and then `break` (and throw the exception.)
In cases where the predicate returns `false` forever, our final attempt is
made as close to the timeout as possible (given the limitations of Java thread
scheduling). This is exactly what a user expects.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Timing between DNS and Geode startup can result in permanent unknown host
> exceptions.
> -
>
> Key: GEODE-8623
> URL: https://issues.apache.org/jira/browse/GEODE
[jira] [Commented] (GEODE-2896) CI Failure: ClassCastException in GMSMembershipManagerJUnitTest
[
https://issues.apache.org/jira/browse/GEODE-2896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238860#comment-17238860
]
Geode Integration commented on GEODE-2896:
--
Seen on support/1.13 in [UnitTestOpenJDK8
#41|https://concourse.apachegeode-ci.info/teams/main/pipelines/apache-support-1-13-main/jobs/UnitTestOpenJDK8/builds/41]
... see [test
results|http://files.apachegeode-ci.info/builds/apache-support-1-13-main/1.13.2-build.0406/test-results/test/1605776877/]
or download
[artifacts|http://files.apachegeode-ci.info/builds/apache-support-1-13-main/1.13.2-build.0406/test-artifacts/1605776877/unittestfiles-OpenJDK8-1.13.2-build.0406.tgz].
> CI Failure: ClassCastException in GMSMembershipManagerJUnitTest
>
>
> Key: GEODE-2896
> URL: https://issues.apache.org/jira/browse/GEODE-2896
> Project: Geode
> Issue Type: Bug
> Components: tests
>Reporter: Nabarun Nag
>Priority: Major
> Labels: ci
>
> {noformat}
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest
> > testDirectChannelSendFailureDueToForcedDisconnect FAILED
> java.lang.ClassCastException:
> org.apache.geode.distributed.internal.LonerDistributionManager cannot be cast
> to org.apache.geode.distributed.internal.DistributionManager
> at
> org.apache.geode.distributed.internal.HighPriorityAckedMessage.(HighPriorityAckedMessage.java:68)
> at
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest.testDirectChannelSendFailureDueToForcedDisconnect(GMSMembershipManagerJUnitTest.java:343)
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest
> > testStartupEvents FAILED
> java.lang.ClassCastException:
> org.apache.geode.distributed.internal.LonerDistributionManager cannot be cast
> to org.apache.geode.distributed.internal.DistributionManager
> at
> org.apache.geode.distributed.internal.HighPriorityAckedMessage.(HighPriorityAckedMessage.java:68)
> at
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest.testStartupEvents(GMSMembershipManagerJUnitTest.java:219)
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest
> > testSendToEmptyListIsRejected FAILED
> java.lang.ClassCastException:
> org.apache.geode.distributed.internal.LonerDistributionManager cannot be cast
> to org.apache.geode.distributed.internal.DistributionManager
> at
> org.apache.geode.distributed.internal.HighPriorityAckedMessage.(HighPriorityAckedMessage.java:68)
> at
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest.testSendToEmptyListIsRejected(GMSMembershipManagerJUnitTest.java:177)
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest
> > testDirectChannelSendAllRecipients FAILED
> java.lang.ClassCastException:
> org.apache.geode.distributed.internal.LonerDistributionManager cannot be cast
> to org.apache.geode.distributed.internal.DistributionManager
> at
> org.apache.geode.distributed.internal.HighPriorityAckedMessage.(HighPriorityAckedMessage.java:68)
> at
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest.testDirectChannelSendAllRecipients(GMSMembershipManagerJUnitTest.java:331)
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest
> > testDirectChannelSend FAILED
> java.lang.ClassCastException:
> org.apache.geode.distributed.internal.LonerDistributionManager cannot be cast
> to org.apache.geode.distributed.internal.DistributionManager
> at
> org.apache.geode.distributed.internal.HighPriorityAckedMessage.(HighPriorityAckedMessage.java:68)
> at
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest.testDirectChannelSend(GMSMembershipManagerJUnitTest.java:281)
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest
> > testDirectChannelSendFailureToOneRecipient FAILED
> java.lang.ClassCastException:
> org.apache.geode.distributed.internal.LonerDistributionManager cannot be cast
> to org.apache.geode.distributed.internal.DistributionManager
> at
> org.apache.geode.distributed.internal.HighPriorityAckedMessage.(HighPriorityAckedMessage.java:68)
> at
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest.testDirectChannelSendFailureToOneRecipient(GMSMembershipManagerJUnitTest.java:294)
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManagerJUnitTest
> > testDirectChannelSendFailureToAll FAILED
> java.lang.ClassCastException:
> org.apache.geode
[jira] [Commented] (GEODE-6903) CI Failure: GemFireTransactionDataSourceIntegrationTest.testExceptionHandlingGetConnection failed with Assertion
[
https://issues.apache.org/jira/browse/GEODE-6903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238861#comment-17238861
]
Geode Integration commented on GEODE-6903:
--
Seen on support/1.13 in [IntegrationTestOpenJDK11
#40|https://concourse.apachegeode-ci.info/teams/main/pipelines/apache-support-1-13-main/jobs/IntegrationTestOpenJDK11/builds/40]
... see [test
results|http://files.apachegeode-ci.info/builds/apache-support-1-13-main/1.13.2-build.0413/test-results/integrationTest/1605907306/]
or download
[artifacts|http://files.apachegeode-ci.info/builds/apache-support-1-13-main/1.13.2-build.0413/test-artifacts/1605907306/integrationtestfiles-OpenJDK11-1.13.2-build.0413.tgz].
> CI Failure:
> GemFireTransactionDataSourceIntegrationTest.testExceptionHandlingGetConnection
> failed with Assertion
>
>
> Key: GEODE-6903
> URL: https://issues.apache.org/jira/browse/GEODE-6903
> Project: Geode
> Issue Type: Bug
> Components: transactions
>Affects Versions: 1.14.0
>Reporter: Eric Shu
>Assignee: Eric Shu
>Priority: Major
> Labels: flaky
>
> {noformat}
> org.apache.geode.internal.datasource.GemFireTransactionDataSourceIntegrationTest
> > testExceptionHandlingGetConnection FAILED
> org.junit.ComparisonFailure: expected:<[0]> but was:<[2]>
> at sun.reflect.GeneratedConstructorAccessor26.newInstance(Unknown
> Source)
> at
> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
> at
> org.apache.geode.internal.datasource.GemFireTransactionDataSourceIntegrationTest.testExceptionHandlingGetConnection(GemFireTransactionDataSourceIntegrationTest.java:141)
> {noformat}
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-= Test Results URI
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
> http://files.apachegeode-ci.info/builds/apache-develop-main/1.10.0-SNAPSHOT.0399/test-results/integrationTest/1561170841/
> =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
> Test report artifacts from this job are available at:
> http://files.apachegeode-ci.info/builds/apache-develop-main/1.10.0-SNAPSHOT.0399/test-artifacts/1561170841/integrationtestfiles-OpenJDK8-1.10.0-SNAPSHOT.0399.tgz
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (GEODE-8623) Timing between DNS and Geode startup can result in permanent unknown host exceptions.
[
https://issues.apache.org/jira/browse/GEODE-8623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238865#comment-17238865
]
ASF GitHub Bot commented on GEODE-8623:
---
jinmeiliao commented on a change in pull request #5743:
URL: https://github.com/apache/geode/pull/5743#discussion_r530576020
##
File path: geode-common/src/main/java/org/apache/geode/internal/Retry.java
##
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license
+ * agreements. See the NOTICE file distributed with this work for additional
information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache
License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the
License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express
+ * or implied. See the License for the specific language governing permissions
and limitations under
+ * the License.
+ */
+package org.apache.geode.internal;
+
+import static java.util.concurrent.TimeUnit.NANOSECONDS;
+
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+import java.util.function.Predicate;
+import java.util.function.Supplier;
+
+import org.apache.geode.annotations.VisibleForTesting;
+
+/**
+ * Utility class for retrying operations.
+ */
+public class Retry {
+
+ interface Timer {
+long nanoTime();
+
+void sleep(long sleepTimeInNano) throws InterruptedException;
+ }
+
+ static class SteadyTimer implements Timer {
+@Override
+public long nanoTime() {
+ return System.nanoTime();
+}
+
+@Override
+public void sleep(long sleepTimeInNano) throws InterruptedException {
+ long millis = NANOSECONDS.toMillis(sleepTimeInNano);
+ // avoid throwing IllegalArgumentException
+ if (millis > 0) {
+Thread.sleep(millis);
+ }
+}
+ }
+
+ private static final SteadyTimer steadyClock = new SteadyTimer();
+
+ /**
+ * Try the supplier function until the predicate is true or timeout occurs.
+ *
+ * @param timeout to retry for
+ * @param timeoutUnit the unit for timeout
+ * @param interval time between each try
+ * @param intervalUnit the unit for interval
+ * @param supplier to execute until predicate is true or times out
+ * @param predicate to test for retry
+ * @param type of return value
+ * @return value from supplier after it passes predicate or times out.
+ */
+ public static T tryFor(long timeout, TimeUnit timeoutUnit,
+ long interval, TimeUnit intervalUnit,
+ Supplier supplier,
+ Predicate predicate) throws TimeoutException, InterruptedException {
+return tryFor(timeout, timeoutUnit, interval, intervalUnit, supplier,
predicate, steadyClock);
+ }
+
+ @VisibleForTesting
+ static T tryFor(long timeout, TimeUnit timeoutUnit,
+ long interval, TimeUnit intervalUnit,
+ Supplier supplier,
+ Predicate predicate,
+ Timer timer) throws TimeoutException, InterruptedException {
+long until = timer.nanoTime() + NANOSECONDS.convert(timeout, timeoutUnit);
+long intervalNano = NANOSECONDS.convert(interval, intervalUnit);
+
+T value;
+for (;;) {
+ value = supplier.get();
+ if (predicate.test(value)) {
+return value;
+ } else {
+// if there is still more time left after we sleep for interval
period, then sleep and retry
+// otherwise break out and throw TimeoutException
+if ((timer.nanoTime() + intervalNano) < until) {
Review comment:
> In cases where the predicate returns `false` forever, our final
attempt is made as close to the timeout as possible (given the limitations of
Java thread scheduling). This is exactly what a user expects.
In your proposal, at your final attempt, you calculated what's the time left
till timeout, then you sleep till timeout. Our differences lie at this point
afterwards, I think that since we are already at timeout point we should throw
exception, but you think we should try again. I don't think "trying again" is
"exactly what a user expects", since I certainly didn't expect that.
Let's just list out the choices here and decide what's the "most" reasonable
thing to do. Say our interval is 3 seconds, and there are only 2 seconds left
after our last call to the supplier and the predicate is still false, At this
point, we can do either of the following:
1. throw timeout immediately (my implementation)
2. sleep for 2 seconds till timeout and throw timeout (since 2 is what's
left till timeout)
3. sleep for 3 seconds and throw timeout (since 3 is what user has
[jira] [Commented] (GEODE-8687) Durable client is continuously re-registering CQs on all servers when event de-serialization fails causing resource exhaustion on servers
[
https://issues.apache.org/jira/browse/GEODE-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238915#comment-17238915
]
ASF GitHub Bot commented on GEODE-8687:
---
mkevo commented on a change in pull request #5730:
URL: https://github.com/apache/geode/pull/5730#discussion_r530290678
##
File path:
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DurableClientCQAutoSerializer.java
##
@@ -0,0 +1,289 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license
+ * agreements. See the NOTICE file distributed with this work for additional
information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache
License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the
License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express
+ * or implied. See the License for the specific language governing permissions
and limitations under
+ * the License.
+ */
+package org.apache.geode.internal.cache.tier.sockets;
+
+import static org.apache.geode.cache.Region.SEPARATOR;
+import static org.apache.geode.test.awaitility.GeodeAwaitility.await;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+
+import java.io.Serializable;
+import java.util.Map;
+import java.util.Objects;
+
+import com.google.common.collect.ImmutableMap;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.client.ClientCache;
+import org.apache.geode.cache.client.ClientRegionFactory;
+import org.apache.geode.cache.client.ClientRegionShortcut;
+import org.apache.geode.cache.client.internal.PoolImpl;
+import org.apache.geode.cache.query.CqAttributesFactory;
+import org.apache.geode.cache.query.CqQuery;
+import org.apache.geode.cache.query.QueryService;
+import org.apache.geode.internal.cache.CacheServerImpl;
+import org.apache.geode.pdx.ReflectionBasedAutoSerializer;
+import org.apache.geode.pdx.internal.AutoSerializableManager;
+import org.apache.geode.test.dunit.Invoke;
+import org.apache.geode.test.dunit.rules.ClientVM;
+import org.apache.geode.test.dunit.rules.ClusterStartupRule;
+import org.apache.geode.test.dunit.rules.MemberVM;
+import org.apache.geode.test.junit.categories.ClientSubscriptionTest;
+import org.apache.geode.test.junit.categories.SerializationTest;
+import org.apache.geode.test.junit.rules.GfshCommandRule;
+
+@Category({ClientSubscriptionTest.class, SerializationTest.class})
+public class DurableClientCQAutoSerializer implements Serializable {
+ private static final String REPLICATE_REGION_NAME = "ReplicateRegion";
+ private static final String PARTITION_REGION_NAME = "PartitionRegion";
+
+ private MemberVM server;
+ private MemberVM server2;
+ private MemberVM locator;
+ private ClientVM client;
+ private ClientVM client2;
+
+ private static TestAutoSerializerCqListener cqListener = null;
+
+ private static final String TEST_OBJECT1_CLASS_PATH =
+ "org.apache.geode.internal.cache.tier.sockets.TestAutoSerializerObject1";
+ private static final String TEST_OBJECT2_CLASS_PATH =
+ "org.apache.geode.internal.cache.tier.sockets.TestAutoSerializerObject2";
+ private static final String TEST_FAULTY_CLASS_PATH =
+
"org.apache.geode.internal.cache.tier.sockets.TestAutoSerializerObject2Faulty";
+ private static final String DURABLE_CLIENT_ID = "durableClient";
+
+ // Traffic data
+ static final Map LIST_TEST_OBJECT1 =
ImmutableMap.of(
+ "key1", new TestAutoSerializerObject1("aa", "bb", 300),
+ "key2", new TestAutoSerializerObject1("aa", "bb", 600),
+ "key3", new TestAutoSerializerObject1("aaa", "bbb", 500));
+
+ static final Map LIST_TEST_OBJECT2 =
ImmutableMap.of(
+ "key1", new TestAutoSerializerObject2("cc", "ddd", 300),
+ "key2", new TestAutoSerializerObject2("cc", "", 400));
+
+ @Rule
+ public GfshCommandRule gfsh = new GfshCommandRule();
+
+ @Rule
+ public ClusterStartupRule cluster = new ClusterStartupRule(5);
+
+ @Before
+ public void setUp() throws Exception {
+Invoke.invokeInEveryVM(
+() ->
System.setProperty(AutoSerializableManager.NO_HARDCODED_EXCLUDES_PARAM,
"true"));
+
+locator =
+cluster.startLocatorVM(0);
+int locatorPort = locator.getPort();
+server = cluster.startServerVM(1,
+s -> s.withConnectionToLocator(locatorPort));
+
+server2 = cluster.startServerVM(2,
+s -> s.withConnectio
[jira] [Commented] (GEODE-8687) Durable client is continuously re-registering CQs on all servers when event de-serialization fails causing resource exhaustion on servers
[
https://issues.apache.org/jira/browse/GEODE-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238914#comment-17238914
]
ASF GitHub Bot commented on GEODE-8687:
---
mkevo commented on a change in pull request #5730:
URL: https://github.com/apache/geode/pull/5730#discussion_r530290653
##
File path:
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DurableClientCQAutoSerializer.java
##
@@ -0,0 +1,289 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license
+ * agreements. See the NOTICE file distributed with this work for additional
information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache
License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the
License. You may obtain a
+ * copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
KIND, either express
+ * or implied. See the License for the specific language governing permissions
and limitations under
+ * the License.
+ */
+package org.apache.geode.internal.cache.tier.sockets;
+
+import static org.apache.geode.cache.Region.SEPARATOR;
+import static org.apache.geode.test.awaitility.GeodeAwaitility.await;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+
+import java.io.Serializable;
+import java.util.Map;
+import java.util.Objects;
+
+import com.google.common.collect.ImmutableMap;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.client.ClientCache;
+import org.apache.geode.cache.client.ClientRegionFactory;
+import org.apache.geode.cache.client.ClientRegionShortcut;
+import org.apache.geode.cache.client.internal.PoolImpl;
+import org.apache.geode.cache.query.CqAttributesFactory;
+import org.apache.geode.cache.query.CqQuery;
+import org.apache.geode.cache.query.QueryService;
+import org.apache.geode.internal.cache.CacheServerImpl;
+import org.apache.geode.pdx.ReflectionBasedAutoSerializer;
+import org.apache.geode.pdx.internal.AutoSerializableManager;
+import org.apache.geode.test.dunit.Invoke;
+import org.apache.geode.test.dunit.rules.ClientVM;
+import org.apache.geode.test.dunit.rules.ClusterStartupRule;
+import org.apache.geode.test.dunit.rules.MemberVM;
+import org.apache.geode.test.junit.categories.ClientSubscriptionTest;
+import org.apache.geode.test.junit.categories.SerializationTest;
+import org.apache.geode.test.junit.rules.GfshCommandRule;
+
+@Category({ClientSubscriptionTest.class, SerializationTest.class})
+public class DurableClientCQAutoSerializer implements Serializable {
+ private static final String REPLICATE_REGION_NAME = "ReplicateRegion";
+ private static final String PARTITION_REGION_NAME = "PartitionRegion";
+
+ private MemberVM server;
+ private MemberVM server2;
+ private MemberVM locator;
+ private ClientVM client;
+ private ClientVM client2;
+
+ private static TestAutoSerializerCqListener cqListener = null;
+
+ private static final String TEST_OBJECT1_CLASS_PATH =
+ "org.apache.geode.internal.cache.tier.sockets.TestAutoSerializerObject1";
+ private static final String TEST_OBJECT2_CLASS_PATH =
+ "org.apache.geode.internal.cache.tier.sockets.TestAutoSerializerObject2";
+ private static final String TEST_FAULTY_CLASS_PATH =
+
"org.apache.geode.internal.cache.tier.sockets.TestAutoSerializerObject2Faulty";
+ private static final String DURABLE_CLIENT_ID = "durableClient";
+
+ // Traffic data
+ static final Map LIST_TEST_OBJECT1 =
ImmutableMap.of(
+ "key1", new TestAutoSerializerObject1("aa", "bb", 300),
+ "key2", new TestAutoSerializerObject1("aa", "bb", 600),
+ "key3", new TestAutoSerializerObject1("aaa", "bbb", 500));
+
+ static final Map LIST_TEST_OBJECT2 =
ImmutableMap.of(
+ "key1", new TestAutoSerializerObject2("cc", "ddd", 300),
+ "key2", new TestAutoSerializerObject2("cc", "", 400));
+
+ @Rule
+ public GfshCommandRule gfsh = new GfshCommandRule();
+
+ @Rule
+ public ClusterStartupRule cluster = new ClusterStartupRule(5);
+
+ @Before
+ public void setUp() throws Exception {
+Invoke.invokeInEveryVM(
+() ->
System.setProperty(AutoSerializableManager.NO_HARDCODED_EXCLUDES_PARAM,
"true"));
+
+locator =
+cluster.startLocatorVM(0);
+int locatorPort = locator.getPort();
+server = cluster.startServerVM(1,
+s -> s.withConnectionToLocator(locatorPort));
+
+server2 = cluster.startServerVM(2,
+s -> s.withConnectio
[jira] [Commented] (GEODE-8735) Enable factory lookup logic to look for symbols in the application
[
https://issues.apache.org/jira/browse/GEODE-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238941#comment-17238941
]
ASF GitHub Bot commented on GEODE-8735:
---
gaussianrecurrence commented on pull request #700:
URL: https://github.com/apache/geode-native/pull/700#issuecomment-733945720
There's one thing I am not sure about if it's the right call and that's
having added a modification of GenerateExportHeaders. This is necessary in
order to specify the visibility flags to the factory function added to
cpp-integration-test for testing purposes. Thing is GenerateExportHeaders does
not support executables, so that's the rationale behind
ExecutableExportHeader.cmake
Please let me know what you think about it and if you think there might be a
better alternative.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Enable factory lookup logic to look for symbols in the application
> --
>
> Key: GEODE-8735
> URL: https://issues.apache.org/jira/browse/GEODE-8735
> Project: Geode
> Issue Type: Improvement
> Components: native client
>Affects Versions: 1.13.1
>Reporter: Mario Salazar de Torres
>Priority: Major
> Labels: pull-request-available
>
> *AS A* native client contributor
> *I WANT* to be able to specify factory names within the application space
> *SO THAT* the user does not need to create a separate shared library to load
> several items like partition resolvers, cache loaders, cache writers,
> partition resolvers...
>
> *Additional information*
> The rationale for this change is that if the user wants to declaratively
> specify a partition resolver, right now the only way is by creating the
> shared library.
> So the idea would be to change the current factory implementation, so library
> name is an optional field, and whenever "library-name" is not specified, the
> client will look for symbols within the application instead.
> *For example:*
> Using this region definition:
> {code:xml}
>
>pool-name="partitioned-pool">
>
>
>
> {code}
> And within the application defining this function:
> {code:cpp}
> APPLICATION_EXPORT PartitionResolver* createPartitionResolver()
> {
> return new StringPrefixPartitionResolver{};
> }
> {code}
> You could declaratively create a region which uses the
> StringPrefixPartitionResolver.
> *IMPORTANT.* Take into account that documentation should be updated in order
> to indicate that library-name will become an optional field and what it means
> whenever it's not present.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (GEODE-8735) Enable factory lookup logic to look for symbols in the application
[
https://issues.apache.org/jira/browse/GEODE-8735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238942#comment-17238942
]
ASF GitHub Bot commented on GEODE-8735:
---
gaussianrecurrence commented on pull request #700:
URL: https://github.com/apache/geode-native/pull/700#issuecomment-733946173
> > * Take into account that for OS like Linux, Mac... in addition to
exporting
> > the symbols in the application, you would need to specify `-rdynamic`
> > option while compiling.
>
> This might make great example with corresponding CMake configuration.
I've found out that CMake support exposing executable symbols by setting
ENABLE_EXPORTS=1 property to the executable target. I've used it on IT, so it
could serve as an example. If you think it should be stated more explicitly
somewhere else, please let me know :)
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Enable factory lookup logic to look for symbols in the application
> --
>
> Key: GEODE-8735
> URL: https://issues.apache.org/jira/browse/GEODE-8735
> Project: Geode
> Issue Type: Improvement
> Components: native client
>Affects Versions: 1.13.1
>Reporter: Mario Salazar de Torres
>Priority: Major
> Labels: pull-request-available
>
> *AS A* native client contributor
> *I WANT* to be able to specify factory names within the application space
> *SO THAT* the user does not need to create a separate shared library to load
> several items like partition resolvers, cache loaders, cache writers,
> partition resolvers...
>
> *Additional information*
> The rationale for this change is that if the user wants to declaratively
> specify a partition resolver, right now the only way is by creating the
> shared library.
> So the idea would be to change the current factory implementation, so library
> name is an optional field, and whenever "library-name" is not specified, the
> client will look for symbols within the application instead.
> *For example:*
> Using this region definition:
> {code:xml}
>
>pool-name="partitioned-pool">
>
>
>
> {code}
> And within the application defining this function:
> {code:cpp}
> APPLICATION_EXPORT PartitionResolver* createPartitionResolver()
> {
> return new StringPrefixPartitionResolver{};
> }
> {code}
> You could declaratively create a region which uses the
> StringPrefixPartitionResolver.
> *IMPORTANT.* Take into account that documentation should be updated in order
> to indicate that library-name will become an optional field and what it means
> whenever it's not present.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (GEODE-8737) Create new geode example about rest api
[ https://issues.apache.org/jira/browse/GEODE-8737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238944#comment-17238944 ] ASF GitHub Bot commented on GEODE-8737: --- upthewaterspout commented on pull request #104: URL: https://github.com/apache/geode-examples/pull/104#issuecomment-733948078 > @upthewaterspout i have done the changes as mentioned in point 1 and 2. However pull request checks are failing as i have used HttpClient api of java 11. Is java 11 not supported?. I can reuse HttpURLConnection instead of HttpClient but wanted to confirm if this something do with Travis and LGTM analysis. It does look like we've left the examples using java 8 for Travis. Personally, I think it would be fine if we change the minimum version for the examples to be java 11. We should probably do that with a separate pr and merge that first. I'm on Thanksgiving holiday here right now but I can bring that up next week if you like. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Create new geode example about rest api > --- > > Key: GEODE-8737 > URL: https://issues.apache.org/jira/browse/GEODE-8737 > Project: Geode > Issue Type: New Feature > Components: examples >Reporter: Ashish Choudhary >Assignee: Ashish Choudhary >Priority: Major > Labels: pull-request-available > > Create new example that demonstrate use of geode rest api. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (GEODE-8496) bump dependencies for 1.14
[ https://issues.apache.org/jira/browse/GEODE-8496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238969#comment-17238969 ] ASF GitHub Bot commented on GEODE-8496: --- onichols-pivotal merged pull request #5772: URL: https://github.com/apache/geode/pull/5772 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > bump dependencies for 1.14 > -- > > Key: GEODE-8496 > URL: https://issues.apache.org/jira/browse/GEODE-8496 > Project: Geode > Issue Type: Improvement > Components: build >Reporter: Owen Nichols >Priority: Major > Labels: pull-request-available > Fix For: 1.14.0 > > > now is a good time in the lull between 1.13 and 1.14 to roll 3rd party > libraries to latest versions wherever possible. Doing this proactively helps > us stay ahead of CVEs and keep up with bugfixes. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (GEODE-8496) bump dependencies for 1.14
[ https://issues.apache.org/jira/browse/GEODE-8496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238970#comment-17238970 ] ASF subversion and git services commented on GEODE-8496: Commit 217be41f087072026ea3b411b89107700edfb5f7 in geode's branch refs/heads/develop from Owen Nichols [ https://gitbox.apache.org/repos/asf?p=geode.git;h=217be41 ] GEODE-8496: top up dependency updates (#5772) * Bump jetty from 9.4.34.v20201102 to 9.4.35.v20201120 * Bump netty-all from 4.1.53.Final to 4.1.54.Final * Bump lettuce-core from 5.3.4.RELEASE to 5.3.5.RELEASE * Bump fastutil from 8.4.2 to 8.4.3 * Bump pmd from 6.28.0 to 6.29.0 * Bump tomcat9 from 9.0.39 to 9.0.40 * Bump tomcat8 from 8.5.59 to 8.5.60 * Bump tomcat7 from 7.0.106 to 7.0.107 * Bump bcpkix-jdk15on from 1.66 to 1.67 * Bump spring-boot from 2.3.4.RELEASE to 2.4.0 * Bump spring-hateoas from 1.1.2.RELEASE to 1.2.1 * Bump spring-session-data-redis from 2.3.1.RELEASE to 2.4.1 * Bump spring from 5.2.9.RELEASE to 5.3.1 * Bump junit-quickcheck from 0.9.5 to 1.0 * Bump assertj from 3.17.2 to 3.18.1 * Bump micrometer from 1.5.5 to 1.6.1 * Bump testcontainers from 1.14.3 to 1.15.0 * Bump powermock from 2.0.7 to 2.0.9 * Bump mockito from 3.5.15 to 3.6.28 * Bump log4j from 2.13.3 to 2.14.0 > bump dependencies for 1.14 > -- > > Key: GEODE-8496 > URL: https://issues.apache.org/jira/browse/GEODE-8496 > Project: Geode > Issue Type: Improvement > Components: build >Reporter: Owen Nichols >Priority: Major > Labels: pull-request-available > Fix For: 1.14.0 > > > now is a good time in the lull between 1.13 and 1.14 to roll 3rd party > libraries to latest versions wherever possible. Doing this proactively helps > us stay ahead of CVEs and keep up with bugfixes. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (GEODE-7460) CI failure: DistributedMemberDUnitTest.testGroupsInAllVMs ForcedDisconnectException Failure
[ https://issues.apache.org/jira/browse/GEODE-7460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239027#comment-17239027 ] Geode Integration commented on GEODE-7460: -- Seen in [DistributedTestOpenJDK8 #649|https://concourse.apachegeode-ci.info/teams/main/pipelines/apache-develop-main/jobs/DistributedTestOpenJDK8/builds/649] ... see [test results|http://files.apachegeode-ci.info/builds/apache-develop-main/1.14.0-build.0516/test-results/distributedTest/1606355233/] or download [artifacts|http://files.apachegeode-ci.info/builds/apache-develop-main/1.14.0-build.0516/test-artifacts/1606355233/distributedtestfiles-OpenJDK8-1.14.0-build.0516.tgz]. > CI failure: DistributedMemberDUnitTest.testGroupsInAllVMs > ForcedDisconnectException Failure > --- > > Key: GEODE-7460 > URL: https://issues.apache.org/jira/browse/GEODE-7460 > Project: Geode > Issue Type: Bug > Components: membership >Affects Versions: 1.13.0, 1.14.0 >Reporter: Robert Houghton >Assignee: Bill Burcham >Priority: Major > Time Spent: 20m > Remaining Estimate: 0h > > From the failing job: > =-=-=-=-=-=-=-=-=-=-=-=-=-=-= Test Results URI > =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-= > http://files.apachegeode-ci.info/builds/apache-develop-main/1.12.0-SNAPSHOT.0016/test-results/distributedTest/1573784422/ > =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-= > Test report artifacts from this job are available at: > http://files.apachegeode-ci.info/builds/apache-develop-main/1.12.0-SNAPSHOT.0016/test-artifacts/1573784422/distributedtestfiles-OpenJDK8-1.12.0-SNAPSHOT.0016.tgz > DistributedTest failure due to exception: > org.apache.geode.distributed.DistributedMemberDUnitTest > testGroupsInAllVMs > FAILED > org.apache.geode.test.dunit.RMIException: While invoking > org.apache.geode.distributed.DistributedMemberDUnitTest$6.run in VM 0 running > on Host 3e09f1029b44 with 4 VMs > at org.apache.geode.test.dunit.VM.executeMethodOnObject(VM.java:579) > at org.apache.geode.test.dunit.VM.invoke(VM.java:406) > at > org.apache.geode.distributed.DistributedMemberDUnitTest.testGroupsInAllVMs(DistributedMemberDUnitTest.java:333) > Caused by: > org.apache.geode.SystemConnectException: One or more peers generated > exceptions during connection attempt > at > org.apache.geode.distributed.internal.ClusterDistributionManager.sendStartupMessage(ClusterDistributionManager.java:1625) > at > org.apache.geode.distributed.internal.ClusterDistributionManager.create(ClusterDistributionManager.java:354) > at > org.apache.geode.distributed.internal.InternalDistributedSystem.initialize(InternalDistributedSystem.java:759) > at > org.apache.geode.distributed.internal.InternalDistributedSystem.access$200(InternalDistributedSystem.java:136) > at > org.apache.geode.distributed.internal.InternalDistributedSystem$Builder.build(InternalDistributedSystem.java:3009) > at > org.apache.geode.distributed.internal.InternalDistributedSystem.connectInternal(InternalDistributedSystem.java:269) > at > org.apache.geode.distributed.DistributedSystem.connect(DistributedSystem.java:159) > at > org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase.getSystem(JUnit4DistributedTestCase.java:181) > at > org.apache.geode.distributed.DistributedMemberDUnitTest$6.run(DistributedMemberDUnitTest.java:339) > Caused by: > > org.apache.geode.distributed.DistributedSystemDisconnectedException: > DistributedSystem is shutting down, caused by > org.apache.geode.ForcedDisconnectException: Exiting due to possible network > partition event due to loss of 1 cache processes: > [172.17.0.14(myName:1):41001] > at > org.apache.geode.distributed.internal.membership.adapter.GMSMembershipManager.directChannelSend(GMSMembershipManager.java:1591) > at > org.apache.geode.distributed.internal.membership.adapter.GMSMembershipManager.send(GMSMembershipManager.java:1751) > at > org.apache.geode.distributed.internal.ClusterDistributionManager.sendViaMembershipManager(ClusterDistributionManager.java:2058) > at > org.apache.geode.distributed.internal.ClusterDistributionManager.sendOutgoing(ClusterDistributionManager.java:1985) > at > org.apache.geode.distributed.internal.StartupOperation.sendStartupMessage(StartupOperation.java:74) > at > org.apache.geode.distributed.internal.ClusterDistributionManager.sendStartupMessage(ClusterDistributionManager.java:1622) > ... 8 more > Caused by: >
