Skip to content

Instantly share code, notes, and snippets.

@asvasyanin
Created February 14, 2024 07:04
Show Gist options
  • Save asvasyanin/13d305881fb033b39e4a231f41d46d23 to your computer and use it in GitHub Desktop.
Save asvasyanin/13d305881fb033b39e4a231f41d46d23 to your computer and use it in GitHub Desktop.
{"level":50,"time":1707872674255,"pid":24,"hostname":"test-67dc5975d7-hlm2c","name":"test","err":"Cannot read properties of undefined (reading 'labels')\nError: Cannot read properties of undefined (reading 'labels')\n at /app/node_modules/scramjet-core/lib/util/mk-transform.js:59:44\n at runNextTicks (node:internal/process/task_queues:60:5)\n at process.processImmediate (node:internal/timers:449:9)\n caused by:\n at DataStream.<anonymous> (/app/parser/registry/parser_registry/drop.js:33:12)\n at runNextTicks (node:internal/process/task_queues:60:5)\n at process.processImmediate (node:internal/timers:449:9)\n at async Promise.all (index 0)\n --- raised in DataStream(15) constructed ---\n at new PromiseTransformStream (/app/node_modules/scramjet-core/lib/util/promise-transform-stream.js:65:27)\n at new DataStream (/app/node_modules/scramjet-core/lib/data-stream.js:43:9)\n at StringStream.map (/app/node_modules/scramjet-core/lib/data-stream.js:197:26)\n at preprocessStream (/app/lib/db/clickhouse.js:832:6)\n at queryFingerprintsScan (/app/lib/db/clickhouse.js:384:22)\n at process.processTicksAndRejections (node:internal/process/task_queues:95:5)\n at async Object.handler (/app/lib/handlers/query_range.js:41:22)","msg":"Cannot read properties of undefined (reading 'labels')"}
node:events:496
throw er; // Unhandled 'error' event
^
StreamError: Cannot read properties of undefined (reading 'labels')
at /app/node_modules/scramjet-core/lib/util/mk-transform.js:59:44
at runNextTicks (node:internal/process/task_queues:60:5)
at process.processImmediate (node:internal/timers:449:9)
caused by:
at DataStream.<anonymous> (/app/parser/registry/parser_registry/drop.js:33:12)
... 2 lines matching cause stack trace ...
at async Promise.all (index 0)
--- raised in DataStream(15) constructed ---
at new PromiseTransformStream (/app/node_modules/scramjet-core/lib/util/promise-transform-stream.js:65:27)
at new DataStream (/app/node_modules/scramjet-core/lib/data-stream.js:43:9)
at StringStream.map (/app/node_modules/scramjet-core/lib/data-stream.js:197:26)
at preprocessStream (/app/lib/db/clickhouse.js:832:6)
at queryFingerprintsScan (/app/lib/db/clickhouse.js:384:22)
at process.processTicksAndRejections (node:internal/process/task_queues:95:5)
at async Object.handler (/app/lib/handlers/query_range.js:41:22) {
chunk: '{"string":"> qryn@3.1.1 start","fingerprint":"10858024703316111882","timestamp_ns":"1707872651030","labels":[["app","test-view"],["container","test"],["filename","\\/var\\/log\\/pods\\/test_test-view-67dc5975d7-hlm2c_432451c5-88bb-4a16-9e56-9783003e1033\\/test\\/1.log"],["job","test\\/test-view"],["namespace","test"],["node_name","infra-spare-0-6xpz7-956bh"],["pod","test-67dc5975d7-hlm2c"],["stream","stdout"]]}',
stream: <ref *1> DataStream {
_events: {
close: [Function: bound onceWrapper] { listener: [Function: onclose] },
error: [ [Function: onerror], [Function (anonymous)] ],
prefinish: [Function: prefinish],
finish: [Function: bound onceWrapper] { listener: [Function: onfinish] },
drain: [Function: pipeOnDrainFunctionResult],
data: [Function: ondata],
end: [Function: bound onceWrapper] { listener: [Function: onend] },
readable: undefined,
unpipe: [Function: onunpipe]
},
_readableState: ReadableState {
highWaterMark: 16,
buffer: [],
bufferIndex: 0,
length: 0,
pipes: [
DataStream {
_events: {
close: [Function],
error: [Function: onerror],
prefinish: [Function: prefinish],
finish: [Function],
drain: undefined,
data: undefined,
end: [Function (anonymous)],
readable: undefined,
unpipe: [Function: onunpipe]
},
_readableState: ReadableState {
highWaterMark: 16,
buffer: [],
bufferIndex: 0,
length: 0,
pipes: [],
awaitDrainWriters: null,
[Symbol(kState)]: 59779341
},
_writableState: WritableState {
highWaterMark: 16,
length: 0,
corked: 0,
onwrite: [Function: bound onwrite],
writelen: 0,
bufferedIndex: 0,
pendingcb: 0,
[Symbol(kState)]: 17580301,
[Symbol(kBufferedValue)]: null
},
allowHalfOpen: true,
_maxListeners: 22,
_eventsCount: 6,
_tapped: false,
_error_handlers: [],
_scramjet_options: {
referrer: [Circular *1],
constructed: 'Error\n' +
' at new PromiseTransformStream (/app/node_modules/scramjet-core/lib/util/promise-transform-stream.js:65:27)\n' +
' at new DataStream (/app/node_modules/scramjet-core/lib/data-stream.js:43:9)\n' +
' at DataStream.into (/app/node_modules/scramjet-core/lib/data-stream.js:421:19)\n' +
' at DataStream.remap (/app/node_modules/scramjet/lib/data-stream.js:383:21)\n' +
' at stream (/app/parser/registry/common.js:279:27)\n' +
' at /app/lib/db/clickhouse.js:855:17\n' +
' at Array.forEach (<anonymous>)\n' +
' at preprocessStream (/app/lib/db/clickhouse.js:854:16)\n' +
' at queryFingerprintsScan (/app/lib/db/clickhouse.js:384:22)\n' +
' at process.processTicksAndRejections (node:internal/process/task_queues:95:5)',
objectMode: true,
promiseRead: null,
promiseWrite: null,
promiseTransform: [AsyncFunction: promiseTransform],
promiseFlush: null,
beforeTransform: null,
afterTransform: null,
writableObjectMode: true,
readableObjectMode: true,
transforms: [Array]
},
seq: 22,
type: 'Transform',
_transform: [Function (anonymous)],
_flush: [Function (anonymous)],
TimeSource: [Function: Date],
setTimeout: [Function: setTimeout] {
[Symbol(nodejs.util.promisify.custom)]: [Getter]
},
clearTimeout: [Function: clearTimeout],
buffer: null,
[Symbol(shapeMode)]: true,
[Symbol(kCapture)]: false,
[Symbol(kCallback)]: null
}
],
awaitDrainWriters: null,
[Symbol(kState)]: 194521357
},
_writableState: WritableState {
highWaterMark: 16,
length: 4,
corked: 0,
onwrite: [Function: bound onwrite],
writelen: 1,
bufferedIndex: 12,
pendingcb: 4,
[Symbol(kState)]: 621332749,
[Symbol(kBufferedValue)]: [
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
null,
{
chunk: '{"string":" [Symbol(kCallback)]: null","fingerprint":"3921707634297781691","timestamp_ns":"1707872650386","labels":[["app","test-vew"],["container","test"],["filename","\\/var\\/log\\/pods\\/test_test-view-67dc5975d7-hlm2c_432451c5-88bb-4a16-9e56-9783003e1033\\/test\\/0.log"],["job","test\\/test-view"],["namespace","test"],["node_name","infra-spare-0-6xpz7-956bh"],["pod","test-view-67dc5975d7-hlm2c"],["stream","stderr"]]}',
encoding: undefined,
callback: [Function: nop]
},
{
chunk: '{"string":" [Symbol(kCapture)]: false,","fingerprint":"3921707634297781691","timestamp_ns":"1707872650386","labels":[["app","test-vew"],["container","test"],["filename","\\/var\\/log\\/pods\\/test_test-view-67dc5975d7-hlm2c_432451c5-88bb-4a16-9e56-9783003e1033\\/test\\/0.log"],["job","test\\/test-view"],["namespace","test"],["node_name","infra-spare-0-6xpz7-956bh"],["pod","test-view-67dc5975d7-hlm2c"],["stream","stderr"]]}',
encoding: undefined,
callback: [Function: nop]
},
{
chunk: '{"string":" [Symbol(shapeMode)]: true,","fingerprint":"3921707634297781691","timestamp_ns":"1707872650386","labels":[["app","test-view"],["container","test"],["filename","\\/var\\/log\\/pods\\/test_test-view-67dc5975d7-hlm2c_432451c5-88bb-4a16-9e56-9783003e1033\\/test\\/0.log"],["job","test\\/test-view"],["namespace","test"],["node_name","infra-spare-0-6xpz7-956bh"],["pod","test-view-67dc5975d7-hlm2c"],["stream","stderr"]]}',
encoding: undefined,
callback: [Function: nop]
}
]
},
allowHalfOpen: true,
_maxListeners: 22,
_eventsCount: 8,
_tapped: true,
_error_handlers: [ [Function (anonymous)], [AsyncFunction (anonymous)] ],
_scramjet_options: {
referrer: StringStream {
_events: {
close: [Function: bound onceWrapper] {
listener: [Function: onclose]
},
error: [ [Function: onerror], [Function (anonymous)] ],
prefinish: [Function: prefinish],
finish: [Function: bound onceWrapper] {
listener: [Function: onfinish]
},
drain: [Function: pipeOnDrainFunctionResult],
data: [Function: ondata],
end: [Function: bound onceWrapper] { listener: [Function: onend] },
readable: undefined,
unpipe: [Function: onunpipe]
},
_readableState: ReadableState {
highWaterMark: 16,
buffer: [
null, null, null, null, null, null, null, null, null, null,
null, null, null, null, null, null, null, null, null, null,
null, null, null, null, null, null, null, null, null, null,
null, null, null, null, null, null, null, null, null, null,
null, null, null, null, null, null, null, null, null, null,
null, null, null, null, null, null, null, null, null, null,
null, null, null, null, null, null, null, null, null, null,
null, null, null, null, null, null, null, null, null, null,
null, null, null, null, null, null, null, null, null, null,
null, null, null, null, null, null, null, null, null, null,
... 39 more items
],
bufferIndex: 112,
length: 27,
pipes: [ [Circular *1] ],
awaitDrainWriters: [Circular *1],
[Symbol(kState)]: 244842765
},
_writableState: WritableState {
highWaterMark: 16,
length: 12,
corked: 0,
onwrite: [Function: bound onwrite],
writelen: 1,
bufferedIndex: 4,
pendingcb: 12,
[Symbol(kState)]: 621332749,
[Symbol(kBufferedValue)]: [
null, null, null,
null, [Object], [Object],
[Object], [Object], [Object],
[Object], [Object], [Object],
[Object], [Object], [Object]
]
},
allowHalfOpen: true,
_maxListeners: 22,
_eventsCount: 8,
_tapped: true,
_error_handlers: [ [AsyncFunction (anonymous)] ],
_scramjet_options: {
referrer: StringStream {
_events: [Object],
_readableState: [ReadableState],
_writableState: [WritableState],
allowHalfOpen: true,
_maxListeners: 22,
_transform: [Function: transform],
_flush: [Function: flush],
_eventsCount: 8,
_tapped: true,
_error_handlers: [Array],
_scramjet_options: [Object],
seq: 13,
type: 'Transform-',
TimeSource: [Function: Date],
setTimeout: [Function],
clearTimeout: [Function: clearTimeout],
buffer: `{"string":" ' at StringStream._selfInstance (\\/app\\/node_modules\\/scramjet-core\\/lib`,
encoding: 'utf8',
[Symbol(shapeMode)]: true,
[Symbol(kCapture)]: false,
[Symbol(kCallback)]: [Function: bound onwrite]
},
constructed: 'Error\n' +
' at new PromiseTransformStream (/app/node_modules/scramjet-core/lib/util/promise-transform-stream.js:65:27)\n' +
' at new DataStream (/app/node_modules/scramjet-core/lib/data-stream.js:43:9)\n' +
' at new StringStream (/app/node_modules/scramjet-core/lib/string-stream.js:34:9)\n' +
' at StringStream._selfInstance (/app/node_modules/scramjet-core/lib/util/promise-transform-stream.js:344:16)\n' +
' at StringStream.endWith (/app/node_modules/scramjet/lib/data-stream.js:245:31)\n' +
' at preprocessStream (/app/lib/db/clickhouse.js:831:59)\n' +
' at queryFingerprintsScan (/app/lib/db/clickhouse.js:384:22)\n' +
' at process.processTicksAndRejections (node:internal/process/task_queues:95:5)\n' +
' at async Object.handler (/app/lib/handlers/query_range.js:41:22)',
objectMode: true,
promiseRead: null,
promiseWrite: null,
promiseTransform: [Function: promiseTransform],
promiseFlush: [Function: flushPromise],
beforeTransform: null,
afterTransform: null,
writableObjectMode: true,
readableObjectMode: true,
transforms: [ [Function] ],
runFlush: [Function: flushPromise]
},
seq: 14,
type: 'Transform',
_transform: [Function (anonymous)],
_flush: [Function (anonymous)],
TimeSource: [Function: Date],
setTimeout: [Function: setTimeout] {
[Symbol(nodejs.util.promisify.custom)]: [Getter]
},
clearTimeout: [Function: clearTimeout],
buffer: '',
encoding: 'utf8',
[Symbol(shapeMode)]: true,
[Symbol(kCapture)]: false,
[Symbol(kCallback)]: [Function: bound onwrite]
},
constructed: 'Error\n' +
' at new PromiseTransformStream (/app/node_modules/scramjet-core/lib/util/promise-transform-stream.js:65:27)\n' +
' at new DataStream (/app/node_modules/scramjet-core/lib/data-stream.js:43:9)\n' +
' at StringStream.map (/app/node_modules/scramjet-core/lib/data-stream.js:197:26)\n' +
' at preprocessStream (/app/lib/db/clickhouse.js:832:6)\n' +
' at queryFingerprintsScan (/app/lib/db/clickhouse.js:384:22)\n' +
' at process.processTicksAndRejections (node:internal/process/task_queues:95:5)\n' +
' at async Object.handler (/app/lib/handlers/query_range.js:41:22)',
objectMode: true,
promiseRead: null,
promiseWrite: null,
promiseTransform: [Function (anonymous)],
promiseFlush: null,
beforeTransform: null,
afterTransform: null,
writableObjectMode: true,
readableObjectMode: true,
transforms: [
[Function: bound ] { ref: [Function (anonymous)] },
[Function: bound ] { ref: [Function (anonymous)] },
[Function: bound ] { ref: [Function (anonymous)] },
[Function: bound ] { ref: [Function (anonymous)] },
[Function: bound ] { ref: [Function (anonymous)] },
[Function: bound ] { ref: [Function (anonymous)] }
]
},
seq: 15,
type: 'Transform',
_transform: [Function (anonymous)],
_flush: [Function (anonymous)],
TimeSource: [Function: Date],
setTimeout: [Function: setTimeout] {
[Symbol(nodejs.util.promisify.custom)]: [Getter]
},
clearTimeout: [Function: clearTimeout],
buffer: null,
[Symbol(shapeMode)]: true,
[Symbol(kCapture)]: false,
[Symbol(kCallback)]: null
},
code: 'ERR_SCRAMJET_EXTERNAL',
cause: TypeError: Cannot read properties of undefined (reading 'labels')
at DataStream.<anonymous> (/app/parser/registry/parser_registry/drop.js:33:12)
at runNextTicks (node:internal/process/task_queues:60:5)
at process.processImmediate (node:internal/timers:449:9)
at async Promise.all (index 0),
constructor: [class StreamError extends Error]
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment