You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@geode.apache.org by "Lynn Gallinat (JIRA)" <ji...@apache.org> on 2018/03/14 22:18:00 UTC

[jira] [Commented] (GEODE-4844) JdbcWriter and JdbcAsyncWriter will write rows loaded by the JdbcLoader

    [ https://issues.apache.org/jira/browse/GEODE-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16399536#comment-16399536 ] 

Lynn Gallinat commented on GEODE-4844:
--------------------------------------

Here is a stack showing the JdbcWriter being invoked on a get.

{noformat}
system.log: [info 2018/03/14 14:54:41.634 PDT bridgegemfire1_lgallinat-mbpro_60865 <ServerConnection on port 28828 Thread 0> tid=0x55] xxx in JdbcWriter beforeUpdate with event EntryEventImpl[op=LOCAL_LOAD_UPDATE;region=/DefaultRegion;key=15;oldValue=null;newValue=PreferBytesCachedDeserializable@671997068;callbackArg=null;originRemote=true;originMember=10.118.19.43(bridgegemfire1_lgallinat-mbpro_60865:60865)<ec><v1>:1025;context=identity(10.118.19.43(edgegemfire1_lgallinat-mbpro_60867:60867:loner):49318:46de8126:edgegemfire1_lgallinat-mbpro_60867,connection=1;id=EventIDid=54bytes;threadID=2;sequenceID=4]]
  java.lang.Exception: Exception to get stack trace
        at org.apache.geode.connectors.jdbc.JdbcWriter.getStackTrace(JdbcWriter.java:121)
        at org.apache.geode.connectors.jdbc.JdbcWriter.beforeUpdate(JdbcWriter.java:58)
        at org.apache.geode.internal.cache.SearchLoadAndWriteProcessor.doLocalWrite(SearchLoadAndWriteProcessor.java:878)
        at org.apache.geode.internal.cache.SearchLoadAndWriteProcessor.doNetWrite(SearchLoadAndWriteProcessor.java:209)
        at org.apache.geode.internal.cache.PartitionedRegion.cacheWriteBeforePut(PartitionedRegion.java:7714)
        at org.apache.geode.internal.cache.BucketRegion.cacheWriteBeforePut(BucketRegion.java:1973)
        at org.apache.geode.internal.cache.AbstractRegionMap.invokeCacheWriter(AbstractRegionMap.java:2563)
        at org.apache.geode.internal.cache.AbstractRegionMap.basicPut(AbstractRegionMap.java:2322)
        at org.apache.geode.internal.cache.LocalRegion.basicPutEntry(LocalRegion.java:5733)
        at org.apache.geode.internal.cache.DistributedRegion.basicPutEntry(DistributedRegion.java:441)
        at org.apache.geode.internal.cache.BucketRegion.basicPutEntry(BucketRegion.java:1306)
        at org.apache.geode.internal.cache.DistributedRegion.putNewValueInRegion(DistributedRegion.java:2247)
        at org.apache.geode.internal.cache.DistributedRegion.findObjectInSystem(DistributedRegion.java:2207)
        at org.apache.geode.internal.cache.LocalRegion.nonTxnFindObject(LocalRegion.java:1490)
        at org.apache.geode.internal.cache.LocalRegionDataView.findObject(LocalRegionDataView.java:176)
        at org.apache.geode.internal.cache.LocalRegion.get(LocalRegion.java:1379)
        at org.apache.geode.internal.cache.PartitionedRegionDataStore.getLocally(PartitionedRegionDataStore.java:1996)
        at org.apache.geode.internal.cache.PartitionedRegion.getFromBucket(PartitionedRegion.java:3904)
        at org.apache.geode.internal.cache.PartitionedRegion.findObjectInSystem(PartitionedRegion.java:3313)
        at org.apache.geode.internal.cache.PartitionedRegionDataView.findObject(PartitionedRegionDataView.java:72)
        at org.apache.geode.internal.cache.LocalRegion.get(LocalRegion.java:1379)
        at org.apache.geode.internal.cache.LocalRegion.getRetained(LocalRegion.java:1340)
        at org.apache.geode.internal.cache.LocalRegion.getRetained(LocalRegion.java:1325)
        at org.apache.geode.internal.cache.tier.sockets.command.Get70.getEntryRetained(Get70.java:342)
        at org.apache.geode.internal.cache.tier.sockets.command.Get70.getEntry(Get70.java:236)
        at org.apache.geode.internal.cache.tier.sockets.command.Get70.cmdExecute(Get70.java:154)
        at org.apache.geode.internal.cache.tier.sockets.BaseCommand.execute(BaseCommand.java:163)
        at org.apache.geode.internal.cache.tier.sockets.ServerConnection.doNormalMsg(ServerConnection.java:868)
        at org.apache.geode.internal.cache.tier.sockets.OriginalServerConnection.doOneMessage(OriginalServerConnection.java:85)
        at org.apache.geode.internal.cache.tier.sockets.ServerConnection.run(ServerConnection.java:1248)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at org.apache.geode.internal.cache.tier.sockets.AcceptorImpl$4$1.run(AcceptorImpl.java:644)
        at java.lang.Thread.run(Thread.java:748)

{noformat}

> JdbcWriter and JdbcAsyncWriter will write rows loaded by the JdbcLoader
> -----------------------------------------------------------------------
>
>                 Key: GEODE-4844
>                 URL: https://issues.apache.org/jira/browse/GEODE-4844
>             Project: Geode
>          Issue Type: Bug
>          Components: extensions, regions
>    Affects Versions: 1.4.0
>            Reporter: Darrel Schneider
>            Priority: Major
>
> If a region has both the JdbcLoader and JdbcWriter on it then every time the JdbcLoader loads something from jdbc, it is also rewritten to jdbc by the JdbcWriter.
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)