flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Keith Wiggins <keith.wigg...@genband.com>
Subject Need help with Hive Sink
Date Mon, 02 Nov 2015 19:54:02 GMT
Greetings,

  We are encountering the following exception when attempting to use the hive sink.

2015-11-02 13:57:47,177 (SinkRunner-PollingRunner-DefaultSinkProcessor) [ERROR - org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:160)]
Unable to deliver event. Exception follows.
org.apache.flume.EventDeliveryException: java.lang.ArrayIndexOutOfBoundsException: 157
        at org.apache.flume.sink.hive.HiveSink.process(HiveSink.java:268)
        at org.apache.flume.sink.DefaultSinkProcessor.process(DefaultSinkProcessor.java:68)
        at org.apache.flume.SinkRunner$PollingRunner.run(SinkRunner.java:147)
        at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ArrayIndexOutOfBoundsException: 157
        at org.apache.hive.hcatalog.streaming.DelimitedInputWriter.reorderFields(DelimitedInputWriter.java:180)
        at org.apache.hive.hcatalog.streaming.DelimitedInputWriter.write(DelimitedInputWriter.java:213)
        at org.apache.hive.hcatalog.streaming.HiveEndPoint$TransactionBatchImpl.write(HiveEndPoint.java:632)
        at org.apache.flume.sink.hive.HiveDelimitedTextSerializer.write(HiveDelimitedTextSerializer.java:51)
        at org.apache.flume.sink.hive.HiveWriter$1.call(HiveWriter.java:153)
        at org.apache.flume.sink.hive.HiveWriter$1.call(HiveWriter.java:147)
        at org.apache.flume.sink.hive.HiveWriter$9.call(HiveWriter.java:366)
        at java.util.concurrent.FutureTask.run(FutureTask.java:262)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
        ... 1 more

Here is the background as to what we are sending.  I have created a log file of 100 records
that contains 187 fields ( A mock billing record ).  We have examined all the records to ensure
that they all have the same number of fields.

Example record;
2015-10-01 11:43:33,1443714213,000:00:12,10.11.1.3,39894,10.11.3.3,,,131,131,IV,01,N,0,,,,16,AD,322738,315960,484991414,,14437103751613112,49,Canada_3,0,France_3,0,16,131,0,,ac
k-rx,16,12,,h323,end1,1,,442,,,0,,12.156,EDT,msx_Canada,,3,,Canada,France,routename,destcustid,callzone,3,,16,600,6,0,10,G711,10,94,600,6,0,10,G711,10,92,,sip,10.0.0.1,10.0.0.2
,,,diversioninfo,,,,,source,,,,,,,,49206,49206,74.106.168.197,27516,10.128.249.58,53610,,,,,,,01/10/2015
10:39:35,01/10/2015 10:39:47,,1,1111,3333,2222,4444,None,1869138903,189
6645364,,Unauthorized,Unauthorized,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,48,,,,,,,,,,,,,,,,,,,,,,,,,,,,,,

These records are being delivered to an Avro sink (I removed the IPs)

agent.sources = CDRS
agent.channels = memoryChannel_1
agent.sinks = k2 k3
agent.sinkgroups = load-balance

agent.sinkgroups.load-balance.sinks = k2 k3
agent.sinkgroups.load-balance.processor.type = load_balance
agent.sinkgroups.load-balance.processor.selector = round_robin

agent.sources.CDRS.type = spooldir
agent.sources.CDRS.channels = memoryChannel_1
agent.sources.CDRS.spoolDir = /var/log/cdrs/
agent.sources.CDRS.fileHeader = true
agent.sources.CDRS.interceptors = itime
agent.sources.CDRS.interceptors.itime.type = timestamp

agent.sinks.k2.type = avro
agent.sinks.k2.channel = memoryChannel_1
agent.sinks.k2.hostname =
agent.sinks.k2.port = 4775

agent.sinks.k3.type = avro
agent.sinks.k3.channel = memoryChannel_1
agent.sinks.k3.hostname =
agent.sinks.k3.port = 4775

# Each channel's type is defined.
agent.channels.memoryChannel_1.type = memory

# Other config values specific to each type of channel(sink or source)
# can be defined as well
# In this case, it specifies the capacity of the memory channel
agent.channels.memoryChannel_1.capacity = 100

The flume agent on the hadoop server has the configuration; (Note that we have played with
a small channel to match the data coming in).  We did have things working when we were using
the hdfs sink.

agent.sources = LSMetrics
agent.channels = memoryChannel
agent.sinks = k1

# For each one of the sources, the type is defined
agent.sources.LSMetrics.type = avro
agent.sources.LSMetrics.batchSize = 1
agent.sources.LSMetrics.channels = memoryChannel
agent.sources.LSMetrics.bind =
agent.sources.LSMetrics.port = 4775
agent.sources.LSMetrics.interceptors = dateI
agent.sources.LSMetrics.interceptors.dateI.type = regex_extractor
agent.sources.LSMetrics.interceptors.dateI.regex = ^(\\d+)-.*
agent.sources.LSMetrics.interceptors.dateI.serializers = y
agent.sources.LSMetrics.interceptors.dateI.serializers.y.name = ddate

agent.sinks.k1.type = hive
agent.sinks.k1.channel = memoryChannel
agent.sinks.k1.hive.metastore = thrift://:9083
agent.sinks.k1.hive.database = default
agent.sinks.k1.hive.table = acs_cdr_orc_v7
agent.sinks.k1.hive.partition = %{ddate}
agent.sinks.k1.callTimeout = 100000
agent.sinks.k1.serializer = DELIMITED
agent.sinks.k1.serializer.delimeter = ,
agent.sinks.k1.serializer.fieldnames = starttime,datetimeint,callduration,origip,sourceq931port,termip,unspecified1,userid,calle164,calldtmf,calltypeinfo,unspecified2,disccode,erroridleg1,errordescleg1,unspecified3,unspecified4,ani,mediatype,bytesforwardedfromsrc,bytesforwardedfromdst,seqnum,transcoder_id,callid,holdtime,origgw,origport,termgw,termport,isdncode,lastcallnumber,erroridleg2,errordescleg2,lastevent,newani,duration,incomingcallid,protocol,cdrtype,huntattempts,origtg,pdd,h323raserror,h323h225error,sipfinalresponsecode,termtg,durationmsec,tz,mswname,numberaftertransit,termnumbertype,orignumbertype,origrealm,termrealm,callroute,calldstcustid,callzonedata,calldstnumtype,callsrcnumtype,origisdncausecode,srcpacketsreceived,srcpacketslost,srcpacketsdiscarded,srcpdv,srccodec,srclatency,srcrfactor,dstpacketsreceived,dstpacketslost,dstpacketsdiscarded,dstpdv,dstcodec,dstlatency,dstrfactor,srcsiprespcode,peerprotocol,srcprivateip,dstprivateip,srcigrpname,dstigrpname,diversioninfo,customcontacttag,e911call,unspecified5,unspecified6,callreleasesource,huntattemptsincludinglcf,callgappingerror,errorcodeinreasonheader,oclobjecttype,oclobjectiddtnregidrealmname,oclobjectiddtnrealmuport,oclpolicyname,srcprivateport,destprivateport,srcrealmmediaip,srcrealmmediaport,dstrealmmediaip,dstrealmmediaport,origtgc,termtgc,srcpcv,destpcv,srcpani,destpani,callconnecttimemsec,endtimemsec,routingnumber,mlines,fromuriuserpart,newfromuriuserpart,paiduriuserpart,newpaiduriuserpart,privacy,requesturiuserpart,newrequesturiuserpart,localrefertransferstatus,sipfinalresponsereason,srcsiprespreason,chargenumber,chargenumbernoa,chargenumbernpi,segmentstarttimems,segmentdurationfractional,srcxrlossrate,srcxrdiscardrate,srcxrburstdensity,srcxrgapdensity,srcxrburstduration,srcxrgapduration,srcxrroundtripdelay,srcxrendsystemdelay,srcxrgmin,srcxrjitterbufferadaptive,srcxrjitterbufferrate,srcxrrfactor,srcxrmos_cq,srcxrjitterbuffernominaldelay,srcxrjitterbuffermaximumdelay,srcxrjitterbufferabsolutemaximumdelay,dstxrlossrate,dstxrdiscardrate,dstxrburstdensity,dstxrgapdensity,dstxrburstduration,dstxrgapduration,dstxrroundtripdelay,dstxrendsystemdelay,dstxrgmin,dstxrjitterbufferadaptive,dstxrjitterbufferrate,dstxrrfactor,dstxrmos_cq,dstxrjitterbuffernominaldelay,dstxrjitterbuffermaximumdelay,dstxrjitterbufferabsolutemaximumdelay,unspecified7,unspecified8,srcciphersuite,destciphersuite,srcpacketoutsidereplaywindow,srcpacketauthfailure,srcpacketcipherfailure,destpacketoutsidereplaywindow,destpacketauthfailure,destpacketcipherfailure,fmmcallleginfo1,fmmcallleginfo2,fmmcallleginfo3,fmmcallleginfo4,fmmcallleginfo5,fmmcallinfo1,fmmcallinfo2,fmmcallinfo3,fmmcallinfo4,fmmcallinfo5,embeddeddspinsertion,outgoingtouri,incomingrequesturi,incomingrsaipaddress,sbciserverversion,outgoingrequesturi,outgoingfromuri,privacyingressrequested,privacymethodegress,privacyegressrequested,srcpolicedpackets,ddate

#agent.sinks.k1.hdfs.path = hdfs://:8020/flume
#agent.sinks.k1.hdfs.writeFormat = Text
#agent.sinks.k1.hdfs.fileType = DataStream
#agent.sinks.k1.hdfs.batchSize = 100
#agent.sinks.k1.hdfs.rollInterval = 3600
#agent.sinks.k1.hdfs.rollCount = 1000000
#agent.sinks.k1.hdfs.rollSize = 0
#agent.sinks.k1.hdfs.idleTimeout = 5

# Each channel's type is defined.
agent.channels.memoryChannel.type = memory
agent.channels.memoryChannel.transactionCapacity = 20000

# Other config values specific to each type of channel(sink or source)
# can be defined as well
# In this case, it specifies the capacity of the memory channel
agent.channels.memoryChannel.capacity = 200000

The flume execution output shows the following;

2015-11-02 13:57:27,280 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO - org.apache.hadoop.hive.metastore.HiveMetaStoreClient.open(HiveMetaStoreClient.java:473)]
Connected to metastore.
2015-11-02 13:57:27,458 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG - org.apache.hive.hcatalog.streaming.DelimitedInputWriter.<init>(DelimitedInputWriter.java:121)]
Field reordering needed = true, for endpoint {metaStoreUri='thrift://172.28.172.5:9083', database='default',
table='acs_cdr_orc_v7', partitionVals=[2015] }
2015-11-02 13:57:27,459 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG - org.apache.flume.sink.hive.HiveWriter.nextTxnBatch(HiveWriter.java:326)]
Fetching new Txn Batch for {metaStoreUri='thrift://172.28.172.5:9083', database='default',
table='acs_cdr_orc_v7', partitionVals=[2015] }
2015-11-02 13:57:27,675 (hive-k1-call-runner-0) [DEBUG - org.apache.hive.hcatalog.streaming.AbstractRecordWriter.newBatch(AbstractRecordWriter.java:120)]
Creating Record updater
2015-11-02 13:57:27,678 (hive-k1-call-runner-0) [DEBUG - org.apache.hadoop.hive.metastore.MetaStoreUtils.getDDLFromFieldSchema(MetaStoreUtils.java:843)]
DDL: struct acs_cdr_orc_v7 { string starttime, i32 datetimeint, string callduration, string
origip, i32 sourceq931port, string termip, string unspecified1, string userid, string calle164,
string calldtmf, string calltypeinfo, string unspecified2, string disccode, i32 erroridleg1,
string errordescleg1, string unspecified3, string unspecified4, string ani, string mediatype,
string bytesforwardedfromsrc, string bytesforwardedfromdst, i32 seqnum, string transcoder_id,
string callid, i32 holdtime, string origgw, i32 origport, string termgw, i32 termport, i32
isdncode, string lastcallnumber, i32 erroridleg2, string errordescleg2, string lastevent,
string newani, i32 duration, string incomingcallid, i32 protocol, i32 cdrtype, i32 huntattempts,
string origtg, i32 pdd, i32 h323raserror, i32 h323h225error, i32 sipfinalresponsecode, string
termtg, i32 durationmsec, string tz, string mswname, string numberaftertransit, i32 termnumbertype,
i32 orignumbertype, string origrealm, string termrealm, string callroute, string calldstcustid,
string callzonedata, string calldstnumtype, string callsrcnumtype, string origisdncausecode,
i32 srcpacketsreceived, i32 srcpacketslost, i32 srcpacketsdiscarded, i32 srcpdv, string srccodec,
i32 srclatency, i32 srcrfactor, i32 dstpacketsreceived, i32 dstpacketslost, i32 dstpacketsdiscarded,
i32 dstpdv, string dstcodec, i32 dstlatency, i32 dstrfactor, i32 srcsiprespcode, string peerprotocol,
string srcprivateip, string dstprivateip, string srcigrpname, string dstigrpname, string diversioninfo,
string customcontacttag, string e911call, string unspecified5, string unspecified6, string
callreleasesource, i32 huntattemptsincludinglcf, i32 callgappingerror, i32 errorcodeinreasonheader,
string oclobjecttype, string oclobjectiddtnregidrealmname, string oclobjectiddtnrealmuport,
string oclpolicyname, string srcprivateport, string destprivateport, string srcrealmmediaip,
string srcrealmmediaport, string dstrealmmediaip, string dstrealmmediaport, string origtgc,
string termtgc, string srcpcv, string destpcv, string srcpani, string destpani, string callconnecttimemsec,
string endtimemsec, string routingnumber, i32 mlines, string fromuriuserpart, string newfromuriuserpart,
string paiduriuserpart, string newpaiduriuserpart, string privacy, string requesturiuserpart,
string newrequesturiuserpart, string localrefertransferstatus, string sipfinalresponsereason,
string srcsiprespreason, string chargenumber, i32 chargenumbernoa, i32 chargenumbernpi, string
segmentstarttimems, string segmentdurationfractional, i32 srcxrlossrate, i32 srcxrdiscardrate,
i32 srcxrburstdensity, i32 srcxrgapdensity, i32 srcxrburstduration, i32 srcxrgapduration,
i32 srcxrroundtripdelay, i32 srcxrendsystemdelay, i32 srcxrgmin, i32 srcxrjitterbufferadaptive,
i32 srcxrjitterbufferrate, i32 srcxrrfactor, i32 srcxrmos_cq, i32 srcxrjitterbuffernominaldelay,
i32 srcxrjitterbuffermaximumdelay, i32 srcxrjitterbufferabsolutemaximumdelay, i32 dstxrlossrate,
i32 dstxrdiscardrate, i32 dstxrburstdensity, i32 dstxrgapdensity, i32 dstxrburstduration,
i32 dstxrgapduration, i32 dstxrroundtripdelay, i32 dstxrendsystemdelay, i32 dstxrgmin, i32
dstxrjitterbufferadaptive, i32 dstxrjitterbufferrate, i32 dstxrrfactor, i32 dstxrmos_cq, i32
dstxrjitterbuffernominaldelay, i32 dstxrjitterbuffermaximumdelay, i32 dstxrjitterbufferabsolutemaximumdelay,
string unspecified7, string unspecified8, string srcciphersuite, string destciphersuite, i32
srcpacketoutsidereplaywindow, i32 srcpacketauthfailure, i32 srcpacketcipherfailure, i32 destpacketoutsidereplaywindow,
i32 destpacketauthfailure, i32 destpacketcipherfailure, string fmmcallleginfo1, string fmmcallleginfo2,
string fmmcallleginfo3, string fmmcallleginfo4, string fmmcallleginfo5, string fmmcallinfo1,
string fmmcallinfo2, string fmmcallinfo3, string fmmcallinfo4, string fmmcallinfo5, string
embeddeddspinsertion, string outgoingtouri, string incomingrequesturi, string incomingrsaipaddress,
string sbciserverversion, string outgoingrequesturi, string outgoingfromuri, string privacyingressrequested,
string privacymethodegress, string privacyegressrequested, string srcpolicedpackets}
2015-11-02 13:57:28,062 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO - org.apache.flume.sink.hive.HiveWriter.nextTxnBatch(HiveWriter.java:335)]
Acquired Txn Batch TxnIds=[2101...2200] on endPoint = {metaStoreUri='thrift://172.28.172.5:9083',
database='default', table='acs_cdr_orc_v7', partitionVals=[2015] }. Switching to first txn

It appears as though the records are being read in; (We get 100 of the following events)
2015-11-02 13:57:28,086 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG - org.apache.flume.sink.hive.HiveSink.drainOneBatch(HiveSink.java:299)]
k1 : Writing event to {metaStoreUri='thrift://:9083', database='default', table='acs_cdr_orc_v7',
partitionVals=[2015] }
2015-11-02 13:57:28,087 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG - org.apache.flume.sink.hive.HiveSink.drainOneBatch(HiveSink.java:299)]
k1 : Writing event to {metaStoreUri='thrift://:9083', database='default', table='acs_cdr_orc_v7',
partitionVals=[2015] }
2015-11-02 13:57:28,087 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG - org.apache.flume.sink.hive.HiveSink.drainOneBatch(HiveSink.java:299)]
k1 : Writing event to {metaStoreUri='thrift://:9083', database='default', table='acs_cdr_orc_v7',
partitionVals=[2015] }
.
.

We have verified that the database table that we have created matches the fields identified.
create table acs_cdr_orc_v7 (starttime string, DateTimeInt int,callduration string,origIp
string,sourceQ931Port int,termIp string,unspecified1 string,userId string,callE164 string,callDTMF
string,callTypeInfo string,unspecified2 string,discCode string,errorIDLeg1 int,errorDescLeg1
string,unspecified3 string,unspecified4 string,ani string,mediaType string,bytesForwardedFromSrc
string,bytesForwardedFromDst string,seqNum int,transcoder_id string,callId string,holdTime
int,origGw string,origPort int,termGw string,termPort int,isdnCode int,lastCallNumber string,errorIDLeg2
int,errorDescLeg2 string,lastEvent string,newANI string,duration int,incomingCallId string,protocol
int,cdrType int,huntAttempts int,origTG string,pdd int,h323RASError int,h323H225Error int,sipFinalResponseCode
int,termTG string,durationMsec int,tz string,mswname string,numberAfterTransit string,termNumberType
int,origNumberType int,origRealm string,termRealm string,callRoute string,callDstCustId string,callZoneData
string,callDstNumType string,callSrcNumType string,origISDNCauseCode string,srcPacketsReceived
int,srcPacketsLost int,srcPacketsDiscarded int,srcPDV int,srcCodec string,srcLatency int,srcRFactor
int,dstPacketsReceived int,dstPacketsLost int,dstPacketsDiscarded int,dstPDV int,dstCodec
string,dstLatency int,dstRFactor int,srcSipRespCode int,peerProtocol string,srcPrivateIp string,dstPrivateIp
string,srcIgrpName string,dstIgrpName string,diversioninfo string,customcontacttag  string,
e911call string,unspecified5 string,unspecified6 string,callReleaseSource string,huntAttemptsIncludingLCF
int,callGappingError int,errorCodeInReasonHeader int,oclObjectType string,oclObjectIdDtnRegidRealmname
string,oclObjectIdDtnrealmUport string,oclPolicyName string,srcPrivatePort string,destPrivatePort
string,srcRealmMediaIP string,srcRealmMediaPort string,dstRealmMediaIP string,dstRealmMediaPort
string,origTGC string,termTGC string,srcPCV string,destPCV string,srcPANI string,destPANI
string,callConnectTimeMSec string,endTimeMSec string,routingNumber string,mLines int,fromUriUserPart
string,newFromUriUserPart string,paidUriUserPart string,newPaidUriUserPart string,privacy
string,requestUriUserPart string,newRequestUriUserPart string,localReferTransferStatus string,sipFinalResponseReason
string,srcSipRespReason string,ChargeNumber  string,ChargeNumberNOA int,ChargeNumberNPI  int,segmentstarttimems
string,segmentdurationfractional  string,srcXrLossRate int,srcXrDiscardRate int,srcXrBurstDensity
int,srcXrGapDensity int,srcXrBurstDuration int,srcXrGapDuration  int,srcXrRoundTripDelay int,srcXrEndSystemDelay
 int,srcXrGmin int,srcXrJitterBufferAdaptive int,srcXrJitterBufferRate int,srcXrRfactor int,srcXrMOS_CQ
int,srcXrJitterBufferNominalDelay int,srcXrJitterBufferMaximumDelay int,srcXrJitterBufferAbsoluteMaximumDelay
int,dstXrLossRate int,dstXrDiscardRate int,dstXrBurstDensity int,dstXrGapDensity int,dstXrBurstDuration
int,dstXrGapDuration int,dstXrRoundTripDelay int,dstXrEndSystemDelay int,dstXrGmin int,dstXrJitterBufferAdaptive
int,dstXrJitterBufferRate int,dstXrRfactor int,dstXrMOS_CQ int,dstXrJitterBufferNominalDelay
int,dstXrJitterBufferMaximumDelay int,dstXrJitterBufferAbsoluteMaximumDelay int,unspecified7
string,unspecified8 string,srcCipherSuite string,destCipherSuite string,srcPacketOutsideReplayWindow
int,srcPacketAuthFailure int,srcPacketCipherFailure int,destPacketOutsideReplayWindow int,destPacketAuthFailure
int,destPacketCipherFailure int,fmmCallLegInfo1 string,fmmCallLegInfo2 string,fmmCallLegInfo3
string,fmmCallLegInfo4 string,fmmCallLegInfo5 string,fmmCallInfo1 string,fmmCallInfo2 string,fmmCallInfo3
string,fmmCallInfo4 string,fmmCallInfo5 string,embeddedDspInsertion string,outgoingToURI string,incomingRequestURI
string,incomingRSAIPAddress string,SBCiServerVersion string,outgoingRequestURI string,outgoingFromURI
string,privacyIngressRequested string,privacyMethodEgress string,privacyEgressRequested string,srcPolicedPackets
string) partitioned by (ddate string) clustered by (starttime) into 5 buckets stored as orc
tblproperties("transactional"="true");
Once we received the exception, it appears to try again as the above logs would be repeated
over and over again.
The only thing that I can think of is the ddate as it shows up as another column in the database
but when we tried to add the ddate to the fieldnames we got the error;
Caused by: org.apache.flume.sink.hive.HiveWriter$ConnectException: Failed connecting to EndPoint
{metaStoreUri='thrift://172.28.172.5:9083', database='default', table='acs_cdr_orc_v7', partitionVals=[2015]
}
        at org.apache.flume.sink.hive.HiveWriter.<init>(HiveWriter.java:98)
        at org.apache.flume.sink.hive.HiveSink.getOrCreateWriter(HiveSink.java:343)
        at org.apache.flume.sink.hive.HiveSink.drainOneBatch(HiveSink.java:296)
        at org.apache.flume.sink.hive.HiveSink.process(HiveSink.java:254)
        ... 3 more
Caused by: org.apache.hive.hcatalog.streaming.InvalidColumn: Column 'ddate' not found in table
for input field 1871

Database contents;
hive> describe acs_cdr_orc_v7;
OK
starttime               string
datetimeint             int
callduration            string
origip                  string
sourceq931port          int
termip                  string
unspecified1            string
userid                  string
calle164                string
calldtmf                string
calltypeinfo            string
unspecified2            string
disccode                string
erroridleg1             int
errordescleg1           string
unspecified3            string
unspecified4            string
ani                     string
mediatype               string
bytesforwardedfromsrc   string
bytesforwardedfromdst   string
seqnum                  int
transcoder_id           string
callid                  string
holdtime                int
origgw                  string
origport                int
termgw                  string
termport                int
isdncode                int
lastcallnumber          string
erroridleg2             int
errordescleg2           string
lastevent               string
newani                  string
duration                int
incomingcallid          string
protocol                int
cdrtype                 int
huntattempts            int
origtg                  string
pdd                     int
h323raserror            int
h323h225error           int
sipfinalresponsecode    int
termtg                  string
durationmsec            int
tz                      string
mswname                 string
numberaftertransit      string
termnumbertype          int
orignumbertype          int
origrealm               string
termrealm               string
callroute               string
calldstcustid           string
callzonedata            string
calldstnumtype          string
callsrcnumtype          string
origisdncausecode       string
srcpacketsreceived      int
srcpacketslost          int
srcpacketsdiscarded     int
srcpdv                  int
srccodec                string
srclatency              int
srcrfactor              int
dstpacketsreceived      int
dstpacketslost          int
dstpacketsdiscarded     int
dstpdv                  int
dstcodec                string
dstlatency              int
dstrfactor              int
srcsiprespcode          int
peerprotocol            string
srcprivateip            string
dstprivateip            string
srcigrpname             string
dstigrpname             string
diversioninfo           string
customcontacttag        string
e911call                string
unspecified5            string
unspecified6            string
callreleasesource       string
huntattemptsincludinglcf        int
callgappingerror        int
errorcodeinreasonheader int
oclobjecttype           string
oclobjectiddtnregidrealmname    string
oclobjectiddtnrealmuport        string
oclpolicyname           string
srcprivateport          string
destprivateport         string
srcrealmmediaip         string
srcrealmmediaport       string
dstrealmmediaip         string
dstrealmmediaport       string
origtgc                 string
termtgc                 string
srcpcv                  string
destpcv                 string
srcpani                 string
destpani                string
callconnecttimemsec     string
endtimemsec             string
routingnumber           string
mlines                  int
fromuriuserpart         string
newfromuriuserpart      string
paiduriuserpart         string
newpaiduriuserpart      string
privacy                 string
requesturiuserpart      string
newrequesturiuserpart   string
localrefertransferstatus        string
sipfinalresponsereason  string
srcsiprespreason        string
chargenumber            string
chargenumbernoa         int
chargenumbernpi         int
segmentstarttimems      string
segmentdurationfractional       string
srcxrlossrate           int
srcxrdiscardrate        int
srcxrburstdensity       int
srcxrgapdensity         int
srcxrburstduration      int
srcxrgapduration        int
srcxrroundtripdelay     int
srcxrendsystemdelay     int
srcxrgmin               int
srcxrjitterbufferadaptive       int
srcxrjitterbufferrate   int
srcxrrfactor            int
srcxrmos_cq             int
srcxrjitterbuffernominaldelay   int
srcxrjitterbuffermaximumdelay   int
srcxrjitterbufferabsolutemaximumdelay   int
dstxrlossrate           int
dstxrdiscardrate        int
dstxrburstdensity       int
dstxrgapdensity         int
dstxrburstduration      int
dstxrgapduration        int
dstxrroundtripdelay     int
dstxrendsystemdelay     int
dstxrgmin               int
dstxrjitterbufferadaptive       int
dstxrjitterbufferrate   int
dstxrrfactor            int
dstxrmos_cq             int
dstxrjitterbuffernominaldelay   int
dstxrjitterbuffermaximumdelay   int
dstxrjitterbufferabsolutemaximumdelay   int
unspecified7            string
unspecified8            string
srcciphersuite          string
destciphersuite         string
srcpacketoutsidereplaywindow    int
srcpacketauthfailure    int
srcpacketcipherfailure  int
destpacketoutsidereplaywindow   int
destpacketauthfailure   int
destpacketcipherfailure int
fmmcallleginfo1         string
fmmcallleginfo2         string
fmmcallleginfo3         string
fmmcallleginfo4         string
fmmcallleginfo5         string
fmmcallinfo1            string
fmmcallinfo2            string
fmmcallinfo3            string
fmmcallinfo4            string
fmmcallinfo5            string
embeddeddspinsertion    string
outgoingtouri           string
incomingrequesturi      string
incomingrsaipaddress    string
sbciserverversion       string
outgoingrequesturi      string
outgoingfromuri         string
privacyingressrequested string
privacymethodegress     string
privacyegressrequested  string
srcpolicedpackets       string
ddate                   string

# Partition Information
# col_name              data_type               comment

ddate                   string
Time taken: 0.534 seconds, Fetched: 193 row(s)

Thanks for any support that can be offered.
Keith Wiggins
Software Designer

500 Palladium Drive, Suite 2100
Ottawa ON Canada K2V 1C2
www.genband.com<http://www.genband.com/>
office:+1.343.883.2656

keith.wiggins@genband.com
[Description: http://www.genband.com/extras/email/email_signature_line_below.jpg]<http://www.genband.com/>
Connect with us:[Description: http://www.genband.com/extras/email/facebookBTN.gif]<http://www.facebook.com/genband>[Description:
http://www.genband.com/extras/email/twitterBTN.gif]<https://twitter.com/#!/genband>[Description:
http://www.genband.com/extras/email/linkedBTN.gif]<http://www.linkedin.com/company/genband>[Description:
http://www.genband.com/extras/email/youtubeBTN.gif]<http://www.youtube.com/GenbandClips>[Description:
http://www.genband.com/extras/email/blogBTN.gif]<http://www.genband.com/driving-innovation>


Mime
View raw message