Hi Gabor: In order to fix security issues, some modifications have been made to the real-time function of Kylin 3.1.3n.
You need to set “kylin.server.mode=stream_coordinator" in kylin.properties of the coordinator node, which can no longer be set to “kylin.server.mode=all” for coordinator node. Thank you for your test and report, we will update the document later to remind kylin users of the changes here. > 在 2022年1月6日，上午4:57，Árki Gábor <[email protected]> 写道： > > Hi All, > > I wanted to try out Kylin 3.1.3 with a clean installation but ran into an > issue. The stream receiver is unable to start due to the following error: > > 2021-12-30 18:20:07,474 ERROR [main] server.StreamingReceiver:53 : streaming > receiver start fail > org.apache.kylin.stream.coordinator.exception.StoreException: > com.fasterxml.jackson.core.JsonParseException: Unexpected character ('.' > (code 46)): Expected space separating root-level values > at [Source: (byte[])"24.0.1.128"; line: 1, column: 6] > at > org.apache.kylin.stream.coordinator.ZookeeperStreamMetadataStore.getCoordinatorNode(ZookeeperStreamMetadataStore.java:276) > at > org.apache.kylin.stream.coordinator.client.HttpCoordinatorClient.<init>(HttpCoordinatorClient.java:53) > at > org.apache.kylin.stream.server.StreamingServer.<init>(StreamingServer.java:126) > at > org.apache.kylin.stream.server.StreamingServer.getInstance(StreamingServer.java:141) > at > org.apache.kylin.stream.server.StreamingReceiver.startStreamingServer(StreamingReceiver.java:67) > at > org.apache.kylin.stream.server.StreamingReceiver.start(StreamingReceiver.java:61) > at > org.apache.kylin.stream.server.StreamingReceiver.main(StreamingReceiver.java:51) > Caused by: com.fasterxml.jackson.core.JsonParseException: Unexpected > character ('.' (code 46)): Expected space separating root-level values > at [Source: (byte[])"24.0.1.128"; line: 1, column: 6] > at > com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1840) > at > com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:712) > at > com.fasterxml.jackson.core.base.ParserMinimalBase._reportUnexpectedChar(ParserMinimalBase.java:637) > at > com.fasterxml.jackson.core.base.ParserMinimalBase._reportMissingRootWS(ParserMinimalBase.java:684) > at > com.fasterxml.jackson.core.json.UTF8StreamJsonParser._verifyRootSpace(UTF8StreamJsonParser.java:1659) > at > com.fasterxml.jackson.core.json.UTF8StreamJsonParser._parseFloat(UTF8StreamJsonParser.java:1626) > at > com.fasterxml.jackson.core.json.UTF8StreamJsonParser._parsePosNumber(UTF8StreamJsonParser.java:1393) > at > com.fasterxml.jackson.core.json.UTF8StreamJsonParser._nextTokenNotInObject(UTF8StreamJsonParser.java:854) > at > com.fasterxml.jackson.core.json.UTF8StreamJsonParser.nextToken(UTF8StreamJsonParser.java:753) > at > com.fasterxml.jackson.databind.ObjectMapper._initForReading(ObjectMapper.java:4340) > at > com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4189) > at > com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3266) > at org.apache.kylin.common.util.JsonUtil.readValue(JsonUtil.java:76) > at > org.apache.kylin.stream.coordinator.ZookeeperStreamMetadataStore.getCoordinatorNode(ZookeeperStreamMetadataStore.java:272) > ... 6 more > > I did check in ZooKeeper and indeed the path is containing the plain string > of the IP address instead of a valid JSON Node object that is present in ZK > in our 3.1.0 installation: > > [hadoop@ip-24-0-1-128 kylin_stream]$ hbase zkcli > Connecting to ip-24-0-1-124.us-west-2.compute.internal:2181 > Welcome to ZooKeeper! > JLine support is disabled > > WATCHER:: > > WatchedEvent state:SyncConnected type:None path:null > get /kylin/kylin_metadata/stream/coordinator > 24.0.1.128 > cZxid = 0x77 > ctime = Thu Dec 30 18:18:27 UTC 2021 > mZxid = 0x77 > mtime = Thu Dec 30 18:18:27 UTC 2021 > pZxid = 0x77 > cversion = 0 > dataVersion = 0 > aclVersion = 0 > ephemeralOwner = 0x0 > dataLength = 10 > numChildren = 0 > > Do you have any idea what could be the issue? > > Regards, > Gabor
