[GitHub] [geode-kafka-connector] DonalEvans opened a new pull request #2: Added JsonPdxConverter

2020-02-20 Thread GitBox 
DonalEvans opened a new pull request #2: Added JsonPdxConverter
URL: https://github.com/apache/geode-kafka-connector/pull/2
 
 
   - Allows PdxInstance objects to be converted to JSON bytes when sourced
   from a Geode region into a Kafka topic
   - Allows JSON bytes to be converted to PdxInstance objects when sinked
   into a Geode region from a Kafka topic
   - Added unit and DUnit tests for JsonPdxConverter
   - Added functionality to the test framework to specify custom key
   converter, custom value converter and configuration properties for each
   - Added TestObject class to allow validation of
   serialization/deserialization
   
   Authored-by: Donal Evans 


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


With regards,
Apache Git Services

[GitHub] [geode-kafka-connector] DonalEvans merged pull request #2: Added JsonPdxConverter

2020-02-20 Thread GitBox 
DonalEvans merged pull request #2: Added JsonPdxConverter
URL: https://github.com/apache/geode-kafka-connector/pull/2
 
 
   


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


With regards,
Apache Git Services

Re: Failure to push message seen in a dunit test

2020-02-20 Thread Bruce Schuchardt 
Thanks Kirk - I created a JIRA ticket to track this.  GEODE-7807

On 2/19/20, 4:39 PM, "Kirk Lund"  wrote:

Yep, the test method was
testReplaceOfflineMemberAndRestart_WithMultipleDiskStores. I can probably
reproduce with log files if that helps.

On Wed, Feb 19, 2020 at 10:04 AM Bruce Schuchardt 
wrote:

> Kirk, do you recall which of the tests in that class hit this problem?  It
> looks pretty serious.
>
> On 2/19/20, 9:24 AM, "Kirk Lund"  wrote:
>
> While running PersistentColocatedPartitionedRegionDistributedTest a
> thousand times to verify that I've fixed a flaky issue in the test, it
> hit
> an interesting failure trying to send a RequestImageMessage. This
> generated
> a stack trace which caused the test to fail grep for suspect strings.
> I can
> easily suppress this failure, BUT it looks like a bug in message
> distribution which may have been introduced by the recent membership
> changes (modularization).
>
> Here's the stack trace for anyone who wants it (I'm not working on
> this):
>
> [fatal 2020/02/19 02:50:04.862 GMT 
> tid=8410] While pushing message
>  path='/__PR/_B__region2_1'; sender=172.17.0.4(185):41003;
> keysOnly=false; processorId=40462; waitForInit=false;
> checkTombstoneVersions=true;
>
> versionVector=RegionVersionVector[2ab5849689d446bd-a7da0400b0e718f7={rv0
> gc0 localVersion=0 local exceptions=[]} others={}, gc={}]; unfinished
> keys=[])> to recipients: <172.17.0.4(179):41002>
> java.lang.IllegalArgumentException: newPosition > limit: (32768 >
> 90)
> at
> java.base/java.nio.Buffer.createPositionException(Buffer.java:318)
> at java.base/java.nio.Buffer.position(Buffer.java:293)
> at 
java.base/java.nio.ByteBuffer.position(ByteBuffer.java:1086)
> at
> 
java.base/java.nio.MappedByteBuffer.position(MappedByteBuffer.java:226)
> at
> java.base/java.nio.MappedByteBuffer.position(MappedByteBuffer.java:67)
> at
> java.base/sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:116)
> at java.base/sun.nio.ch.IOUtil.write(IOUtil.java:58)
> at java.base/sun.nio.ch.IOUtil.write(IOUtil.java:50)
> at
> java.base/sun.nio.ch
> .SocketChannelImpl.write(SocketChannelImpl.java:463)
> at
>
> org.apache.geode.internal.tcp.Connection.writeFully(Connection.java:2587)
> at
>
> 
org.apache.geode.internal.tcp.Connection.sendPreserialized(Connection.java:1867)
> at
>
> org.apache.geode.internal.tcp.MsgStreamer.realFlush(MsgStreamer.java:324)
> at
>
> 
org.apache.geode.internal.tcp.MsgStreamer.writeMessage(MsgStreamer.java:249)
> at
>
> 
org.apache.geode.distributed.internal.direct.DirectChannel.sendToMany(DirectChannel.java:393)
> at
>
> 
org.apache.geode.distributed.internal.direct.DirectChannel.sendToOne(DirectChannel.java:248)
> at
>
> 
org.apache.geode.distributed.internal.direct.DirectChannel.send(DirectChannel.java:604)
> at
>
> 
org.apache.geode.distributed.internal.DistributionImpl.directChannelSend(DistributionImpl.java:348)
> at
>
> 
org.apache.geode.distributed.internal.DistributionImpl.send(DistributionImpl.java:293)
> at
>
> 
org.apache.geode.distributed.internal.ClusterDistributionManager.sendViaMembershipManager(ClusterDistributionManager.java:2060)
> at
>
> 
org.apache.geode.distributed.internal.ClusterDistributionManager.sendOutgoing(ClusterDistributionManager.java:1987)
> at
>
> 
org.apache.geode.distributed.internal.ClusterDistributionManager.sendMessage(ClusterDistributionManager.java:2024)
> at
>
> 
org.apache.geode.distributed.internal.ClusterDistributionManager.putOutgoing(ClusterDistributionManager.java:1084)
> at
>
> 
org.apache.geode.internal.cache.InitialImageOperation.getFromOne(InitialImageOperation.java:514)
> at
>
> 
org.apache.geode.internal.cache.DistributedRegion.getInitialImageAndRecovery(DistributedRegion.java:1222)
> at
>
> 
org.apache.geode.internal.cache.DistributedRegion.initialize(DistributedRegion.java:1082)
> at
>
> 
org.apache.geode.internal.cache.BucketRegion.initialize(BucketRegion.java:259)
> at
>
> 
org.apache.geode.internal.cache.LocalRegion.createSubregion(LocalRegion.java:983)
> at
>
> 
org.apache.geode.internal.cache.PartitionedRegionDataStore.createBucketRegion(PartitionedRegionDataStore.java:785)
>