Skip to content

Instantly share code, notes, and snippets.

@leonj1
Created August 4, 2017 12:44
Show Gist options
  • Save leonj1/1610e7b9a9fca600229643c84fadb632 to your computer and use it in GitHub Desktop.
Save leonj1/1610e7b9a9fca600229643c84fadb632 to your computer and use it in GitHub Desktop.
.............................
IN server.handleRequest Beginning. Request Header: &{44 1 2 1 {{0 0} 34439} 0}
goroutine 1 [running]:
runtime/debug.Stack(0x39, 0xc42006dc30, 0x1)
/usr/local/go/src/runtime/debug/stack.go:24 +0x79
runtime/debug.PrintStack()
/usr/local/go/src/runtime/debug/stack.go:16 +0x22
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).handleRequest(0xc4200b6540, 0xc4200d4900, 0xc4200d4900)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:387 +0x17c
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).loop(0xc4200b6540, 0x0)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:378 +0x175
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).Serve(0xc4200b6540)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:326 +0x59
main.main()
/home/jleon43/go/src/ds-webhdfs/webhdfs.go:63 +0x98e
12:40:06.014244 Dispatch 2: LOOKUP, NodeId: 1. names: [tmp] 4 bytes
IN server.handleRequest req.Status is OK
[UTIL] Returning GetCurrentNameNode
GetAttr
Filesystem info for tmp: {0 0 11006 16386 supergroup 0 1501850239935 hdfs 1777 0 0 DIRECTORY}
GetAttr FileStatus: {0 0 11006 16386 supergroup 0 1501850239935 hdfs 1777 0 0 DIRECTORY}
GetAttr: Directory found
fuse.Attr DIRECTORY is: {M040755 SZ=0 L=0 0:0 B0*0 i0:0 A 0.000000000 M 1501850239935.000000000 C 0.000000000}
*** In fsops.Lookup child Ino is 0 Name: tmp ***
*** In fsops.Lookup Returning fuse.OK (leaving) Name: tmp ***
IN server.handleRequest Performing Write. Request Header: &{44 1 2 1 {{0 0} 34439} 0}
12:40:06.044875 Serialize 2: LOOKUP code: OK value: {NodeId: 3 Generation=0 EntryValid=0.000 AttrValid=0.000 Attr={M040755 SZ=0 L=0 0:0 B0*0 i0:3 A 0.000000000 M 1501850239935.000000000 C 0.000000000}}
IN server.handleRequest Leaving: OK
.............................
IN server.handleRequest Beginning. Request Header: &{45 1 3 3 {{0 0} 34439} 0}
goroutine 5 [running]:
runtime/debug.Stack(0x39, 0xc420069e70, 0x1)
/usr/local/go/src/runtime/debug/stack.go:24 +0x79
runtime/debug.PrintStack()
/usr/local/go/src/runtime/debug/stack.go:16 +0x22
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).handleRequest(0xc4200b6540, 0xc420122000, 0xc420122000)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:387 +0x17c
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).loop(0xc4200b6540, 0x64ab01)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:378 +0x175
created by ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).readRequest
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:286 +0x367
12:40:06.045027 Dispatch 3: LOOKUP, NodeId: 3. names: [jose] 5 bytes
IN server.handleRequest req.Status is OK
[UTIL] Returning GetCurrentNameNode
GetAttr
Filesystem info for tmp/jose: {0 0 56 218923433 supergroup 0 1501798004046 dsproxy 755 0 0 DIRECTORY}
GetAttr FileStatus: {0 0 56 218923433 supergroup 0 1501798004046 dsproxy 755 0 0 DIRECTORY}
GetAttr: Directory found
fuse.Attr DIRECTORY is: {M040755 SZ=0 L=0 0:0 B0*0 i0:0 A 0.000000000 M 1501798004046.000000000 C 0.000000000}
*** In fsops.Lookup child Ino is 0 Name: jose ***
*** In fsops.Lookup Returning fuse.OK (leaving) Name: jose ***
IN server.handleRequest Performing Write. Request Header: &{45 1 3 3 {{0 0} 34439} 0}
12:40:06.051934 Serialize 3: LOOKUP code: OK value: {NodeId: 4 Generation=0 EntryValid=0.000 AttrValid=0.000 Attr={M040755 SZ=0 L=0 0:0 B0*0 i0:4 A 0.000000000 M 1501798004046.000000000 C 0.000000000}}
IN server.handleRequest Leaving: OK
.............................
IN server.handleRequest Beginning. Request Header: &{53 1 4 4 {{0 0} 34439} 0}
goroutine 5 [running]:
runtime/debug.Stack(0x39, 0xc420069e70, 0x1)
/usr/local/go/src/runtime/debug/stack.go:24 +0x79
runtime/debug.PrintStack()
/usr/local/go/src/runtime/debug/stack.go:16 +0x22
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).handleRequest(0xc4200b6540, 0xc420122000, 0xc420122000)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:387 +0x17c
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).loop(0xc4200b6540, 0x64ab01)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:378 +0x175
created by ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).readRequest
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:286 +0x367
12:40:06.052019 Dispatch 4: LOOKUP, NodeId: 4. names: [09909ccc.txt] 13 bytes
IN server.handleRequest req.Status is OK
[UTIL] Returning GetCurrentNameNode
GetAttr
Filesystem info for tmp/jose/09909ccc.txt: {0 0 0 0 0 0 0 0 }
GetAttr FileStatus: {0 0 0 0 0 0 0 0 }
Does not exist (leaving): tmp/jose/09909ccc.txt
*** In fsops.Lookup code Not OK (leaving) Name: 09909ccc.txt ***
IN server.handleRequest Performing Write. Request Header: &{53 1 4 4 {{0 0} 34439} 0}
12:40:06.059701 Serialize 4: LOOKUP code: 2=no such file or directory value: {NodeId: 0 Generation=0 EntryValid=0.000 AttrValid=0.000 Attr={M00 SZ=0 L=0 0:0 B0*0 i0:0 A 0.000000000 M 0.000000000 C 0.000000000}}
IN server.handleRequest Leaving: OK
.............................
IN server.handleRequest Beginning. Request Header: &{69 35 5 4 {{0 0} 34439} 0}
goroutine 1 [running]:
runtime/debug.Stack(0x39, 0xc42006dc30, 0x1)
/usr/local/go/src/runtime/debug/stack.go:24 +0x79
runtime/debug.PrintStack()
/usr/local/go/src/runtime/debug/stack.go:16 +0x22
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).handleRequest(0xc4200b6540, 0xc4200d4900, 0xc4200d4900)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:387 +0x17c
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).loop(0xc4200b6540, 0x0)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:378 +0x175
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).Serve(0xc4200b6540)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:326 +0x59
main.main()
/home/jleon43/go/src/ds-webhdfs/webhdfs.go:63 +0x98e
12:40:06.059801 Dispatch 5: CREATE, NodeId: 4. data: {0105040 [CREAT,WRONLY,0x8000] (022)} names: [09909ccc.txt] 13 bytes
IN server.handleRequest req.Status is OK
================================
In Create. Name: tmp/jose/09909ccc.txt, Flags: 32833, Mode: 35360. Context: &{{0 0} 34439}
[UTIL] Returning GetCurrentNameNode
Attempting to Create tmp/jose/09909ccc.txt
================================
In WebPutHandleRedirect. Path: http://api.example.com:50070/webhdfs/v1/tmp/jose/09909ccc.txt?user.name=dsproxy&op=CREATE
Created (WebPutHandleRedirect)
In Create: Opening file
In Create: Bad things happened. File:<nil>, Code: 38=function not implemented. Exiting
IN server.handleRequest Performing Write. Request Header: &{69 35 5 4 {{0 0} 34439} 0}
12:40:06.099748 Serialize 5: CREATE code: 38=function not implemented value: {NodeId: 0 Generation=0 {M00 SZ=0 L=0 0:0 B0*0 i0:0 A 0.000000000 M 0.000000000 C 0.000000000} &{0 0 0}}
IN server.handleRequest Leaving: OK
.............................
IN server.handleRequest Beginning. Request Header: &{69 8 6 4 {{0 0} 34439} 0}
goroutine 5 [running]:
runtime/debug.Stack(0x39, 0xc420069e70, 0x1)
/usr/local/go/src/runtime/debug/stack.go:24 +0x79
runtime/debug.PrintStack()
/usr/local/go/src/runtime/debug/stack.go:16 +0x22
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).handleRequest(0xc4200b6540, 0xc4201b6000, 0xc4201b6000)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:387 +0x17c
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).loop(0xc4200b6540, 0x64ab01)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:378 +0x175
created by ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).readRequest
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:286 +0x367
12:40:06.099933 Dispatch 6: MKNOD, NodeId: 4. data: {0105040 (022), 0} names: [09909ccc.txt] 13 bytes
IN server.handleRequest req.Status is OK
================================
In Mknod: Name: tmp/jose/09909ccc.txt, Mode: 35360, Dev:0, Context: &{{0 0} 34439}
Mknod, returning OK
[UTIL] Returning GetCurrentNameNode
GetAttr
Filesystem info for tmp/jose/09909ccc.txt: {1501850406090 134217728 0 294604970 supergroup 0 1501850406094 dsproxy 755 3 0 FILE}
GetAttr FileStatus: {1501850406090 134217728 0 294604970 supergroup 0 1501850406094 dsproxy 755 3 0 FILE}
GetAttr: File found
fuse.Attr FILE is: {M0100644 SZ=0 L=0 0:0 B0*0 i0:0 A 1501850406090.000000000 M 1501850406094.000000000 C 0.000000000}
[UTIL] Returning GetCurrentNameNode
GetAttr
Filesystem info for tmp/jose/09909ccc.txt: {1501850406090 134217728 0 294604970 supergroup 0 1501850406094 dsproxy 755 3 0 FILE}
GetAttr FileStatus: {1501850406090 134217728 0 294604970 supergroup 0 1501850406094 dsproxy 755 3 0 FILE}
GetAttr: File found
fuse.Attr FILE is: {M0100644 SZ=0 L=0 0:0 B0*0 i0:0 A 1501850406090.000000000 M 1501850406094.000000000 C 0.000000000}
IN server.handleRequest Performing Write. Request Header: &{69 8 6 4 {{0 0} 34439} 0}
12:40:06.113974 Serialize 6: MKNOD code: OK value:
IN server.handleRequest Leaving: OK
.............................
IN server.handleRequest Beginning. Request Header: &{48 14 7 5 {{0 0} 34439} 0}
goroutine 5 [running]:
runtime/debug.Stack(0x39, 0xc420069e70, 0x1)
/usr/local/go/src/runtime/debug/stack.go:24 +0x79
runtime/debug.PrintStack()
/usr/local/go/src/runtime/debug/stack.go:16 +0x22
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).handleRequest(0xc4200b6540, 0xc420122000, 0xc420122000)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:387 +0x17c
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).loop(0xc4200b6540, 0x64ab01)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:378 +0x175
created by ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).readRequest
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:286 +0x367
12:40:06.114148 Dispatch 7: OPEN, NodeId: 5. data: {WRONLY,0x8000}
IN server.handleRequest req.Status is OK
In Open
[UTIL] Returning GetCurrentNameNode
Attempting to open
Returning contents:
Setting webHdfFile to have webHdfs path as http://api.example.com/webhdfs/v1/tmp/jose/09909ccc.txt?user.name=dsproxy
In file.SetInode
IN server.handleRequest Performing Write. Request Header: &{48 14 7 5 {{0 0} 34439} 0}
12:40:06.147434 Serialize 7: OPEN code: OK value: {Fh 2 }
IN server.handleRequest Leaving: OK
.............................
IN server.handleRequest Beginning. Request Header: &{68 22 8 5 {{0 0} 34439} 0}
goroutine 1 [running]:
runtime/debug.Stack(0x39, 0xc42006dc30, 0x1)
/usr/local/go/src/runtime/debug/stack.go:24 +0x79
runtime/debug.PrintStack()
/usr/local/go/src/runtime/debug/stack.go:16 +0x22
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).handleRequest(0xc4200b6540, 0xc4200d4900, 0xc4200d4900)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:387 +0x17c
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).loop(0xc4200b6540, 0x0)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:378 +0x175
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).Serve(0xc4200b6540)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:326 +0x59
main.main()
/home/jleon43/go/src/ds-webhdfs/webhdfs.go:63 +0x98e
12:40:07.885521 Dispatch 8: GETXATTR, NodeId: 5. data: {sz 0} names: [security.capability] 20 bytes
IN server.handleRequest req.Status is OK
GetXAttr
Input. name: tmp/jose/09909ccc.txt, attribute: security.capability. context: &{{0 0} 34439}
IN server.handleRequest Performing Write. Request Header: &{68 22 8 5 {{0 0} 34439} 0}
12:40:07.885625 Serialize 8: GETXATTR code: OK value:
IN server.handleRequest Leaving: OK
.............................
IN server.handleRequest Beginning. Request Header: &{87 16 9 5 {{0 0} 34439} 0}
goroutine 12 [running]:
runtime/debug.Stack(0x39, 0xc4201bbe70, 0x1)
/usr/local/go/src/runtime/debug/stack.go:24 +0x79
runtime/debug.PrintStack()
/usr/local/go/src/runtime/debug/stack.go:16 +0x22
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).handleRequest(0xc4200b6540, 0xc420122240, 0xc420122240)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:387 +0x17c
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).loop(0xc4200b6540, 0x64ab01)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:378 +0x175
created by ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).readRequest
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:286 +0x367
12:40:07.885767 Dispatch 9: WRITE, NodeId: 5. 7 bytes
IN server.handleRequest req.Status is OK
================================
In webHdfsFile.Write
--------------------------------
In WebWriteHandleRedirect. Path: http://api.example.com/webhdfs/v1/tmp/jose/09909ccc.txt?user.name=dsproxy
Writing to WebHdfs path: http://api.example.com/webhdfs/v1/tmp/jose/09909ccc.txt?user.name=dsproxy&overwrite=true&op=CREATE
Writing to location path: http://api.example.com/webhdfs/v1/tmp/jose/09909ccc.txt?op=CREATE&delegation=JwAHZHNwcm94eQdkc3Byb3h5AIoBXa1Ck9KKAV3RTxfSjfYczY4C4hRHLk0yf5bt1QaPZwuqIX1PD8lykBJXRUJIREZTIGRlbGVnYXRpb24RMTAwLjgwLjE2LjgzOjgwMjA&namenoderpcaddress=CLUSTER&createflag=&createparent=true&overwrite=true
Created (by WebWriteHandleRedirect)
IN server.handleRequest Performing Write. Request Header: &{87 16 9 5 {{0 0} 34439} 0}
12:40:08.029318 Serialize 9: WRITE code: OK value:
IN server.handleRequest Leaving: OK
.............................
IN server.handleRequest Beginning. Request Header: &{64 25 10 5 {{0 0} 34439} 0}
goroutine 5 [running]:
runtime/debug.Stack(0x39, 0xc420069e70, 0x1)
/usr/local/go/src/runtime/debug/stack.go:24 +0x79
runtime/debug.PrintStack()
/usr/local/go/src/runtime/debug/stack.go:16 +0x22
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).handleRequest(0xc4200b6540, 0xc420122000, 0xc420122000)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:387 +0x17c
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).loop(0xc4200b6540, 0x64ab01)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:378 +0x175
created by ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).readRequest
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:286 +0x367
12:40:08.029433 Dispatch 10: FLUSH, NodeId: 5. data: {Fh 2}
IN server.handleRequest req.Status is OK
In file.Flush
IN server.handleRequest Performing Write. Request Header: &{64 25 10 5 {{0 0} 34439} 0}
12:40:08.029452 Serialize 10: FLUSH code: OK value:
IN server.handleRequest Leaving: OK
.............................
IN server.handleRequest Beginning. Request Header: &{64 18 11 5 {{0 0} 0} 0}
goroutine 1 [running]:
runtime/debug.Stack(0x39, 0xc42006dc30, 0x1)
/usr/local/go/src/runtime/debug/stack.go:24 +0x79
runtime/debug.PrintStack()
/usr/local/go/src/runtime/debug/stack.go:16 +0x22
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).handleRequest(0xc4200b6540, 0xc4200d4900, 0xc4200d4900)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:387 +0x17c
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).loop(0xc4200b6540, 0x0)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:378 +0x175
ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse.(*Server).Serve(0xc4200b6540)
/home/jleon43/go/src/ds-webhdfs/vendor/github.com/hanwen/go-fuse/fuse/server.go:326 +0x59
main.main()
/home/jleon43/go/src/ds-webhdfs/webhdfs.go:63 +0x98e
12:40:08.029728 Dispatch 11: RELEASE, NodeId: 5. data: {Fh 2 WRONLY,0x8000 0x2 L12697921921949515127}
IN server.handleRequest req.Status is OK
In file.Release
IN server.handleRequest Performing Write. Request Header: &{64 18 11 5 {{0 0} 0} 0}
12:40:08.029822 Serialize 11: RELEASE code: OK value:
IN server.handleRequest Leaving: OK
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment