Luis Fernandez
04/07/2022, 8:25 PMMayank
quickStart
program, which internally starts all pinot components within the same jvm. You can run Pinot and debug it in IDE as you do any application.Luis Fernandez
04/07/2022, 8:48 PMLuis Fernandez
04/07/2022, 8:48 PMInstance 0.0.26.108_9000 is not leader of cluster QuickStartCluster due to exception happen when session check
org.I0Itec.zkclient.exception.ZkInterruptedException: java.lang.InterruptedException
Luis Fernandez
04/07/2022, 8:48 PMMayank
Kenny Bastani
04/07/2022, 9:38 PMLuis Fernandez
04/07/2022, 9:40 PMKenny Bastani
04/07/2022, 9:41 PMLuis Fernandez
04/07/2022, 9:42 PMLuis Fernandez
04/07/2022, 9:42 PMKenny Bastani
04/07/2022, 9:43 PMKenny Bastani
04/07/2022, 9:43 PMKenny Bastani
04/07/2022, 9:50 PMKenny Bastani
04/07/2022, 9:51 PMnetstat -vanp tcp | grep '*.2123\|9000\|8000\|7000'
Kenny Bastani
04/07/2022, 9:51 PMKenny Bastani
04/07/2022, 9:52 PMls /usr/local/var/lib/pinot/data/rawdata
Kenny Bastani
04/08/2022, 12:04 AMLuis Fernandez
04/08/2022, 1:49 PMLuis Fernandez
04/08/2022, 1:58 PMpinot/build
don’t know if that has anything to doLuis Fernandez
04/08/2022, 2:16 PMLuis Fernandez
04/08/2022, 2:16 PMtcp6 0 0 *.7000 *.* LISTEN 131072 131072 1905 0 0x0100 0x00000006
tcp4 0 0 *.7000 *.* LISTEN 131072 131072 1905 0 0x0100 0x00000006
Luis Fernandez
04/08/2022, 2:27 PMLuis Fernandez
04/08/2022, 2:29 PMMayank
Luis Fernandez
04/08/2022, 7:54 PMLuis Fernandez
04/08/2022, 7:54 PM2022/04/08 15:53:37.705 INFO [PostQueryCommand] [main] Executing command: PostQuery -brokerProtocol http -brokerHost 0.0.26.108 -brokerPort 8000 -queryType sql -query select count(*) from baseballStats limit 1
java.net.NoRouteToHostException: No route to host (Host unreachable)
Luis Fernandez
04/08/2022, 9:20 PM2022/04/08 15:53:37.705 INFO [PostQueryCommand] [main] Executing command: PostQuery -brokerProtocol http -brokerHost 0.0.26.108 -brokerPort 8000 -queryType sql -query select count(*) from baseballStats limit 1
java.net.NoRouteToHostException: No route to host (Host unreachable)
Mayank
Mayank
Luis Fernandez
04/09/2022, 12:00 AMLuis Fernandez
04/09/2022, 12:01 AM2022/04/08 20:00:59.462 INFO [StartBrokerCommand] [main] Executing command: StartBroker -brokerHost null -brokerPort 8000 -zkAddress localhost:2123
Luis Fernandez
04/09/2022, 12:02 AM2022/04/08 20:01:00.457 INFO [StartServiceManagerCommand] [Start a Pinot [BROKER]] Started Pinot [BROKER] instance [Broker_0.0.26.108_8000] at 9.464s since launch
Kenny Bastani
04/09/2022, 4:45 PMLuis Fernandez
04/09/2022, 4:53 PMMayank
Luis Fernandez
04/11/2022, 2:12 PMLuis Fernandez
04/11/2022, 2:24 PMLuis Fernandez
04/11/2022, 2:24 PMMayank
Luis Fernandez
04/11/2022, 2:26 PMLuis Fernandez
04/11/2022, 2:27 PMLuis Fernandez
04/11/2022, 2:28 PMMayank
Mayank
Luis Fernandez
04/11/2022, 2:29 PMLuis Fernandez
04/11/2022, 2:29 PMjava.net.NoRouteToHostException: No route to host (Host unreachable)
at java.base/java.net.PlainSocketImpl.socketConnect(Native Method)
at java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:399)
at java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:242)
at java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:224)
at java.base/java.net.Socket.connect(Socket.java:609)
at java.base/java.net.Socket.connect(Socket.java:558)
at java.base/sun.net.NetworkClient.doConnect(NetworkClient.java:182)
at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:474)
at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:569)
at java.base/sun.net.www.http.HttpClient.<init>(HttpClient.java:242)
at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:341)
at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:362)
at java.base/sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1248)
at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1187)
at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1081)
at java.base/sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1015)
at java.base/sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(HttpURLConnection.java:1362)
at java.base/sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1337)
at org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand.sendRequest(AbstractBaseAdminCommand.java:91)
at org.apache.pinot.tools.admin.command.PostQueryCommand.run(PostQueryCommand.java:145)
at org.apache.pinot.tools.admin.command.QuickstartRunner.runQuery(QuickstartRunner.java:280)
at org.apache.pinot.tools.Quickstart.runSampleQueries(Quickstart.java:192)
at org.apache.pinot.tools.Quickstart.execute(Quickstart.java:130)
at org.apache.pinot.tools.admin.command.QuickStartCommand.execute(QuickStartCommand.java:157)
at org.apache.pinot.tools.Command.call(Command.java:33)
at org.apache.pinot.tools.Command.call(Command.java:29)
at picocli.CommandLine.executeUserObject(CommandLine.java:1953)
at picocli.CommandLine.access$1300(CommandLine.java:145)
at picocli.CommandLine$RunLast.executeUserObjectOfLastSubcommandWithSameParent(CommandLine.java:2352)
at picocli.CommandLine$RunLast.handle(CommandLine.java:2346)
at picocli.CommandLine$RunLast.handle(CommandLine.java:2311)
at picocli.CommandLine$AbstractParseResultHandler.execute(CommandLine.java:2179)
at picocli.CommandLine.execute(CommandLine.java:2078)
at org.apache.pinot.tools.admin.PinotAdministrator.execute(PinotAdministrator.java:161)
at org.apache.pinot.tools.admin.PinotAdministrator.main(PinotAdministrator.java:192)
at org.apache.pinot.tools.Quickstart.main(Quickstart.java:229)
Luis Fernandez
04/11/2022, 2:30 PMLuis Fernandez
04/11/2022, 2:30 PM2022/04/11 10:29:11.620 ERROR [BaseTableDataManager] [HelixTaskExecutor-message_handle_thread] Attempts exceeded when downloading segment: baseballStats_OFFLINE_0 for table: baseballStats_OFFLINE from: <http://0.0.26.108:9000/segments/baseballStats/baseballStats_OFFLINE_0> to: /Users/luisfernandez/development/pinot/usr/local/var/lib/pinot/data/1649687329197/baseballStats/rawdata/PinotServerDataDir0/baseballStats_OFFLINE/tmp/tmp-baseballStats_OFFLINE_0-edf388f0-9451-4948-8730-a6cf9987103e/baseballStats_OFFLINE_0.tar.gz
2022/04/11 10:29:11.624 ERROR [SegmentOnlineOfflineStateModelFactory$SegmentOnlineOfflineStateModel] [HelixTaskExecutor-message_handle_thread] Caught exception in state transition from OFFLINE -> ONLINE for resource: baseballStats_OFFLINE, partition: baseballStats_OFFLINE_0
Mayank
Luis Fernandez
04/11/2022, 4:46 PMLuis Fernandez
04/11/2022, 4:47 PMpinot.set.instance.id.to.hostname
Luis Fernandez
04/11/2022, 4:47 PMLuis Fernandez
04/11/2022, 4:47 PMMayank
Luis Fernandez
04/11/2022, 6:34 PMMayank
Luis Fernandez
04/11/2022, 6:39 PMLuis Fernandez
04/11/2022, 6:39 PM2022/04/11 14:39:03.485 INFO [PostQueryCommand] [main] Executing command: PostQuery -brokerProtocol http -brokerHost 0.0.26.108 -brokerPort 8000 -queryType sql -query select count(*) from baseballStats limit 1
Luis Fernandez
04/11/2022, 6:39 PMMayank
Navina
04/11/2022, 7:08 PMifconfig
on your machine return?
2. Are you passing any explicit brokerHost
in your quickstart command line args? If not, you can try to debug with a breakpoint in class NetUtils.getHostAddress
Luis Fernandez
04/11/2022, 7:09 PMNavina
04/11/2022, 7:10 PMLuis Fernandez
04/11/2022, 7:10 PMLuis Fernandez
04/11/2022, 7:10 PMlo0: flags=8049<UP,LOOPBACK,RUNNING,MULTICAST> mtu 16384
options=1203<RXCSUM,TXCSUM,TXSTATUS,SW_TIMESTAMP>
inet 127.0.0.1 netmask 0xff000000
inet6 ::1 prefixlen 128
inet6 fe80::1%lo0 prefixlen 64 scopeid 0x1
nd6 options=201<PERFORMNUD,DAD>
gif0: flags=8010<POINTOPOINT,MULTICAST> mtu 1280
stf0: flags=0<> mtu 1280
en3: flags=8863<UP,BROADCAST,SMART,RUNNING,SIMPLEX,MULTICAST> mtu 1500
ether ac:de:48:00:11:22
inet6 fe80::aede:48ff:fe00:1122%en3 prefixlen 64 scopeid 0x4
nd6 options=201<PERFORMNUD,DAD>
media: autoselect (100baseTX <full-duplex>)
status: active
ap1: flags=8802<BROADCAST,SIMPLEX,MULTICAST> mtu 1500
options=400<CHANNEL_IO>
ether a6:83:e7:83:1b:87
media: autoselect
status: inactive
en0: flags=8863<UP,BROADCAST,SMART,RUNNING,SIMPLEX,MULTICAST> mtu 1500
options=6463<RXCSUM,TXCSUM,TSO4,TSO6,CHANNEL_IO,PARTIAL_CSUM,ZEROINVERT_CSUM>
ether a4:83:e7:83:1b:87
inet6 fe80::cf0:694d:2fc1:10da%en0 prefixlen 64 secured scopeid 0x6
inet 192.168.1.239 netmask 0xffffff00 broadcast 192.168.1.255
nd6 options=201<PERFORMNUD,DAD>
media: autoselect
status: active
en2: flags=8963<UP,BROADCAST,SMART,RUNNING,PROMISC,SIMPLEX,MULTICAST> mtu 1500
options=460<TSO4,TSO6,CHANNEL_IO>
ether 82:c7:97:27:dc:00
media: autoselect <full-duplex>
status: inactive
en1: flags=8963<UP,BROADCAST,SMART,RUNNING,PROMISC,SIMPLEX,MULTICAST> mtu 1500
options=460<TSO4,TSO6,CHANNEL_IO>
ether 82:c7:97:27:dc:01
media: autoselect <full-duplex>
status: inactive
bridge0: flags=8863<UP,BROADCAST,SMART,RUNNING,SIMPLEX,MULTICAST> mtu 1500
options=63<RXCSUM,TXCSUM,TSO4,TSO6>
ether 82:c7:97:27:dc:01
Configuration:
id 0:0:0:0:0:0 priority 0 hellotime 0 fwddelay 0
maxage 0 holdcnt 0 proto stp maxaddr 100 timeout 1200
root id 0:0:0:0:0:0 priority 0 ifcost 0 port 0
ipfilter disabled flags 0x0
member: en1 flags=3<LEARNING,DISCOVER>
ifmaxaddr 0 port 8 priority 0 path cost 0
member: en2 flags=3<LEARNING,DISCOVER>
ifmaxaddr 0 port 7 priority 0 path cost 0
nd6 options=201<PERFORMNUD,DAD>
media: <unknown type>
status: inactive
awdl0: flags=8943<UP,BROADCAST,RUNNING,PROMISC,SIMPLEX,MULTICAST> mtu 1500
options=400<CHANNEL_IO>
ether d2:cc:1b:7e:45:87
inet6 fe80::d0cc:1bff:fe7e:4587%awdl0 prefixlen 64 scopeid 0xa
nd6 options=201<PERFORMNUD,DAD>
media: autoselect
status: active
llw0: flags=8863<UP,BROADCAST,SMART,RUNNING,SIMPLEX,MULTICAST> mtu 1500
options=400<CHANNEL_IO>
ether d2:cc:1b:7e:45:87
inet6 fe80::d0cc:1bff:fe7e:4587%llw0 prefixlen 64 scopeid 0xb
nd6 options=201<PERFORMNUD,DAD>
media: autoselect
status: active
utun0: flags=8051<UP,POINTOPOINT,RUNNING,MULTICAST> mtu 1380
inet6 fe80::1436:ab02:fa43:f0eb%utun0 prefixlen 64 scopeid 0xc
nd6 options=201<PERFORMNUD,DAD>
utun1: flags=8051<UP,POINTOPOINT,RUNNING,MULTICAST> mtu 2000
inet6 fe80::301f:7bae:f0a2:3cab%utun1 prefixlen 64 scopeid 0xd
nd6 options=201<PERFORMNUD,DAD>
utun2: flags=8051<UP,POINTOPOINT,RUNNING,MULTICAST> mtu 1000
inet6 fe80::ce81:b1c:bd2c:69e%utun2 prefixlen 64 scopeid 0xe
nd6 options=201<PERFORMNUD,DAD>
en5: flags=8863<UP,BROADCAST,SMART,RUNNING,SIMPLEX,MULTICAST> mtu 1500
options=6467<RXCSUM,TXCSUM,VLAN_MTU,TSO4,TSO6,CHANNEL_IO,PARTIAL_CSUM,ZEROINVERT_CSUM>
ether 00:e0:4c:00:16:7e
nd6 options=201<PERFORMNUD,DAD>
media: autoselect (none)
status: inactive
Luis Fernandez
04/11/2022, 7:10 PMLuis Fernandez
04/11/2022, 7:11 PMNavina
04/11/2022, 7:18 PMNavina
04/11/2022, 7:23 PMhostname
and see what it returns.
another option is to maybe try providing input arguments for brokerHost
and brokerPort
.Navina
04/11/2022, 7:43 PMhostname
or host 0.0.26.108
to see what is going on because java uses whatever is configured in your systemNavina
04/11/2022, 7:45 PMcat /etc/hosts
for any custom overridesLuis Fernandez
04/11/2022, 7:56 PM$ host 0.0.26.108
Host 108.26.0.0.in-addr.arpa. not found: 3(NXDOMAIN)
do i run that while running the code?Luis Fernandez
04/11/2022, 7:56 PM127.0.0.1 localhost
::1 localhost
# To allow the same kube context to work on the host and the container:
127.0.0.1 kubernetes.docker.internal
Luis Fernandez
04/11/2022, 8:20 PM$ hostname
6764
Navina
04/11/2022, 8:50 PMLuis Fernandez
04/11/2022, 8:51 PMNavina
04/11/2022, 8:53 PMhost 6764
does it resolve correctly?Navina
04/11/2022, 8:53 PMLuis Fernandez
04/11/2022, 9:02 PMNavina
04/11/2022, 9:11 PMdig localhost
?Luis Fernandez
04/11/2022, 9:12 PM;; OPT PSEUDOSECTION:
; EDNS: version: 0, flags:; udp: 1232
;; QUESTION SECTION:
;localhost. IN A
;; ANSWER SECTION:
localhost. 10800 IN A 127.0.0.1
Navina
04/11/2022, 9:18 PMInetAddress#getLocalHost
to return 6764
. I do see the output resolution that you see, which is 0.0.26.108
Unless the hostname returned in localhost
, it doesn't look at the loopback address 127.0.0.1
in your case.Navina
04/11/2022, 9:21 PM-brokerHost
program argument with value as 127.0.01
, while we try to figure out this network resolution behaviorLuis Fernandez
04/11/2022, 9:31 PMLuis Fernandez
04/11/2022, 9:32 PMLuis Fernandez
04/11/2022, 9:32 PM-dataDir "usr/local/var/lib/pinot/data" -brokerHost "127.0.01"
Luis Fernandez
04/11/2022, 9:32 PMNavina
04/11/2022, 9:32 PMLuis Fernandez
04/11/2022, 9:33 PMpicocli.CommandLine$UnmatchedArgumentException: Unknown options: '-brokerHost', '127.0.0.1'
at picocli.CommandLine$Interpreter.validateConstraints(CommandLine.java:13143) ~[picocli-4.6.1.jar:task ':jar' property 'archiveVersion']
at picocli.CommandLine$Interpreter.parse(CommandLine.java:13095) ~[picocli-4.6.1.jar:task ':jar' property 'archiveVersion']
at picocli.CommandLine$Interpreter.processSubcommand(CommandLine.java:13343) ~[picocli-4.6.1.jar:task ':jar' property 'archiveVersion']
at picocli.CommandLine$Interpreter.processArguments(CommandLine.java:13260) ~[picocli-4.6.1.jar:task ':jar' property 'archiveVersion']
at picocli.CommandLine$Interpreter.parse(CommandLine.java:13072) ~[picocli-4.6.1.jar:task ':jar' property 'archiveVersion']
at picocli.CommandLine$Interpreter.parse(CommandLine.java:13041) ~[picocli-4.6.1.jar:task ':jar' property 'archiveVersion']
at picocli.CommandLine$Interpreter.parse(CommandLine.java:12942) ~[picocli-4.6.1.jar:task ':jar' property 'archiveVersion']
at picocli.CommandLine.parseArgs(CommandLine.java:1478) ~[picocli-4.6.1.jar:task ':jar' property 'archiveVersion']
at org.apache.pinot.tools.admin.PinotAdministrator.execute(PinotAdministrator.java:149) [classes/:?]
at org.apache.pinot.tools.admin.PinotAdministrator.main(PinotAdministrator.java:192) [classes/:?]
at org.apache.pinot.tools.Quickstart.main(Quickstart.java:229) [classes/:?]
Luis Fernandez
04/11/2022, 9:35 PMNavina
04/11/2022, 9:38 PMNavina
04/11/2022, 9:40 PMPostQueryCommand
, correct ?Luis Fernandez
04/11/2022, 9:42 PMQuickStart.java
Luis Fernandez
04/11/2022, 9:42 PMLuis Fernandez
04/11/2022, 9:42 PMLuis Fernandez
04/11/2022, 9:44 PMNavina
04/12/2022, 4:25 AMInetAddress.getLocalhost
is probably not returning the ip that is accessible externally. Going by this - https://stackoverflow.com/questions/9481865/getting-the-ip-address-of-the-current-machine-using-java
Perhaps we just need a way to give you a way to override the brokerHost for that command?
Also, have you tried other quick start commands in your IDE? Do they all have the same problem?Luis Fernandez
04/12/2022, 2:08 PMLuis Fernandez
04/12/2022, 2:10 PMLuis Fernandez
04/12/2022, 2:10 PMLuis Fernandez
04/12/2022, 2:11 PMNetUtils.getHostAddress
just to do my thing in my local envMayank
Luis Fernandez
04/12/2022, 2:15 PMMayank