[
https://issues.apache.org/jira/browse/BEAM-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henning Rohde resolved BEAM-4034.
---------------------------------
Resolution: Fixed
Fix Version/s: 2.5.0
> Hooks panic on flink
> --------------------
>
> Key: BEAM-4034
> URL: https://issues.apache.org/jira/browse/BEAM-4034
> Project: Beam
> Issue Type: Bug
> Components: sdk-go
> Reporter: Henning Rohde
> Assignee: Henning Rohde
> Priority: Major
> Fix For: 2.5.0
>
> Time Spent: 50m
> Remaining Estimate: 0h
>
> It seems the serialized hooks are set only for Dataflow. It should probably
> not panic if nothing is set. I see the below on Flink.
> $ docker logs 0f5
> 2018/04/09 21:03:48 Initializing Go harness: /opt/apache/beam/boot --id=-123
> --logging_endpoint=docker.for.mac.host.internal:61723
> --artifact_endpoint=docker.for.mac.host.internal:61724
> --provision_endpoint=docker.for.mac.host.internal:61725
> --control_endpoint=docker.for.mac.host.internal:61721
> --semi_persist_dir=/tmp/semi_persistent_dir2198305397089608348
> Worker panic: DeserializeHooks failed on input "": unexpected end of JSON
> inputgoroutine 1 [running]:
> runtime/debug.Stack(0x4f, 0x0, 0x0)
> /usr/local/go/src/runtime/debug/stack.go:24 +0xa7
> runtime/debug.PrintStack()
> /usr/local/go/src/runtime/debug/stack.go:16 +0x22
> github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/init.hook.func1()
>
> /Users/herohde/go/src/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/init/init.go:76
> +0xb6
> panic(0xc65060, 0xc4200402a0)
> /usr/local/go/src/runtime/panic.go:491 +0x283
> github.com/apache/beam/sdks/go/pkg/beam/core/util/hooks.DeserializeHooksFromOptions()
>
> /Users/herohde/go/src/github.com/apache/beam/sdks/go/pkg/beam/core/util/hooks/hooks.go:135
> +0x402
> github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness.Main(0x136dd00,
> 0xc420060010, 0x7ffdcfb0dda8, 0x22, 0x7ffdcfb0ddde, 0x22, 0x0, 0x0)
>
> /Users/herohde/go/src/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/harness.go:41
> +0x4f
> github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/init.hook()
>
> /Users/herohde/go/src/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/init/init.go:84
> +0xc1
> github.com/apache/beam/sdks/go/pkg/beam/core/runtime.Init()
>
> /Users/herohde/go/src/github.com/apache/beam/sdks/go/pkg/beam/core/runtime/init.go:42
> +0x4c
> github.com/apache/beam/sdks/go/pkg/beam.Init()
>
> /Users/herohde/go/src/github.com/apache/beam/sdks/go/pkg/beam/forward.go:63
> +0x20
> main.main()
>
> /Users/herohde/go/src/github.com/apache/beam/sdks/go/examples/wordcount/wordcount.go:156
> +0x39
> 2018/04/09 21:03:49 User program exited: exit status 2
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
