H2OFrame.table() fails on multinode with force_col_types #16742
Description
When running latest rel-3.46.0 on 4 nodes, the AstTable throws unimplemented exception when using force_col_types=True.
To reproduce:
def test_multinode_table_issue():
np.random.seed(10)
n_samples = 10511 # 10510 passes
float_var3 = np.random.choice([10.0, 20.0, 30.0, 40.0], n_samples)
data = {
'FloatVar3': float_var3,
}
input_data = pd.DataFrame(data)
input_data.loc[:, "key"] = np.arange(len(input_data))
tf = tempfile.mktemp(".parquet")
try:
input_data.to_parquet(tf)
input_data = h2o.import_file(tf, force_col_types=True, col_types={
'FloatVar3': "float",
})
finally:
os.unlink(tf)
print(input_data["FloatVar3"].table()) The exception with stacktrace:
01-19 15:24:19.193 192.168.0.73:54321 83451 3723302-27 INFO water.default: POST /99/Rapids, parms: {ast=(tmp= py_1_sid_b14e (table (cols_py tmp1sf93k0v_parquet.hex 'FloatVar3') True)), session_id=_sid_b14e}
01-19 15:24:19.198 192.168.0.73:54321 83451 3723302-27 ERROR water.default:
water.util.DistributedException: DistributedException from /192.168.0.73:54321: 'unimplemented'
at water.MRTask.getResult(MRTask.java:660) ~[h2o.jar:?]
at water.MRTask.getResult(MRTask.java:670) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:530) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:412) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:397) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.slow_table(AstTable.java:144) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.apply(AstTable.java:65) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.apply(AstTable.java:27) ~[h2o.jar:?]
at water.rapids.ast.AstExec.exec(AstExec.java:63) ~[h2o.jar:?]
at water.rapids.ast.prims.assign.AstTmpAssign.apply(AstTmpAssign.java:48) ~[h2o.jar:?]
at water.rapids.ast.prims.assign.AstTmpAssign.apply(AstTmpAssign.java:17) ~[h2o.jar:?]
at water.rapids.ast.AstExec.exec(AstExec.java:63) ~[h2o.jar:?]
at water.rapids.Session.exec(Session.java:99) ~[h2o.jar:?]
at water.rapids.Rapids.exec(Rapids.java:94) ~[h2o.jar:?]
at water.api.RapidsHandler.exec(RapidsHandler.java:34) ~[h2o.jar:?]
at sun.reflect.GeneratedMethodAccessor102.invoke(Unknown Source) ~[?:?]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_241]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_241]
at water.api.Handler.handle(Handler.java:60) ~[h2o.jar:?]
at water.api.RequestServer.serve(RequestServer.java:472) ~[h2o.jar:?]
at water.api.RequestServer.doGeneric(RequestServer.java:303) ~[h2o.jar:?]
at water.api.RequestServer.doPost(RequestServer.java:227) ~[h2o.jar:?]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:707) ~[h2o.jar:?]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:554) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1440) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:505) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1355) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[h2o.jar:?]
at water.webserver.jetty9.Jetty9ServerAdapter$LoginHandler.handle(Jetty9ServerAdapter.java:130) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[h2o.jar:?]
at org.eclipse.jetty.server.Server.handle(Server.java:516) ~[h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:487) ~[h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:732) [h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:479) [h2o.jar:?]
at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277) [h2o.jar:?]
at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) [h2o.jar:?]
at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105) [h2o.jar:?]
at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131) [h2o.jar:?]
at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409) [h2o.jar:?]
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) [h2o.jar:?]
at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) [h2o.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_241]
Caused by: water.exceptions.H2OIllegalArgumentException: unimplemented
at water.H2O.unimpl(H2O.java:1377) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable$SlowCnt.reduce(AstTable.java:308) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable$SlowCnt.reduce(AstTable.java:264) ~[h2o.jar:?]
at water.MRTask.reduce4(MRTask.java:937) ~[h2o.jar:?]
at water.MRTask.reduce3(MRTask.java:924) ~[h2o.jar:?]
at water.MRTask.postLocal0(MRTask.java:891) ~[h2o.jar:?]
at water.MRTask.onCompletion(MRTask.java:864) ~[h2o.jar:?]
at jsr166y.CountedCompleter.__tryComplete(CountedCompleter.java:425) ~[h2o.jar:?]
at water.RPC$2.compute2(RPC.java:648) ~[h2o.jar:?]
at water.H2O$H2OCountedCompleter.compute(H2O.java:1704) ~[h2o.jar:?]
at jsr166y.CountedCompleter.exec(CountedCompleter.java:468) ~[h2o.jar:?]
at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) ~[h2o.jar:?]
at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:976) ~[h2o.jar:?]
at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479) ~[h2o.jar:?]
at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104) ~[h2o.jar:?]
01-19 15:24:19.198 192.168.0.73:54321 83451 3723302-27 ERROR water.default:
water.util.DistributedException: DistributedException from /192.168.0.73:54321: 'unimplemented'
at water.MRTask.getResult(MRTask.java:660) ~[h2o.jar:?]
at water.MRTask.getResult(MRTask.java:670) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:530) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:412) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:397) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.slow_table(AstTable.java:144) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.apply(AstTable.java:65) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.apply(AstTable.java:27) ~[h2o.jar:?]
at water.rapids.ast.AstExec.exec(AstExec.java:63) ~[h2o.jar:?]
at water.rapids.ast.prims.assign.AstTmpAssign.apply(AstTmpAssign.java:48) ~[h2o.jar:?]
at water.rapids.ast.prims.assign.AstTmpAssign.apply(AstTmpAssign.java:17) ~[h2o.jar:?]
at water.rapids.ast.AstExec.exec(AstExec.java:63) ~[h2o.jar:?]
at water.rapids.Session.exec(Session.java:99) ~[h2o.jar:?]
at water.rapids.Rapids.exec(Rapids.java:94) ~[h2o.jar:?]
at water.api.RapidsHandler.exec(RapidsHandler.java:34) ~[h2o.jar:?]
at sun.reflect.GeneratedMethodAccessor102.invoke(Unknown Source) ~[?:?]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_241]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_241]
at water.api.Handler.handle(Handler.java:60) ~[h2o.jar:?]
at water.api.RequestServer.serve(RequestServer.java:472) ~[h2o.jar:?]
at water.api.RequestServer.doGeneric(RequestServer.java:303) ~[h2o.jar:?]
at water.api.RequestServer.doPost(RequestServer.java:227) ~[h2o.jar:?]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:707) ~[h2o.jar:?]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:554) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1440) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:505) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1355) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[h2o.jar:?]
at water.webserver.jetty9.Jetty9ServerAdapter$LoginHandler.handle(Jetty9ServerAdapter.java:130) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[h2o.jar:?]
at org.eclipse.jetty.server.Server.handle(Server.java:516) ~[h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:487) ~[h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:732) [h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:479) [h2o.jar:?]
at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277) [h2o.jar:?]
at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) [h2o.jar:?]
at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105) [h2o.jar:?]
at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131) [h2o.jar:?]
at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409) [h2o.jar:?]
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) [h2o.jar:?]
at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) [h2o.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_241]
Caused by: water.exceptions.H2OIllegalArgumentException: unimplemented
at water.H2O.unimpl(H2O.java:1377) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable$SlowCnt.reduce(AstTable.java:308) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable$SlowCnt.reduce(AstTable.java:264) ~[h2o.jar:?]
at water.MRTask.reduce4(MRTask.java:937) ~[h2o.jar:?]
at water.MRTask.reduce3(MRTask.java:924) ~[h2o.jar:?]
at water.MRTask.postLocal0(MRTask.java:891) ~[h2o.jar:?]
at water.MRTask.onCompletion(MRTask.java:864) ~[h2o.jar:?]
at jsr166y.CountedCompleter.__tryComplete(CountedCompleter.java:425) ~[h2o.jar:?]
at water.RPC$2.compute2(RPC.java:648) ~[h2o.jar:?]
at water.H2O$H2OCountedCompleter.compute(H2O.java:1704) ~[h2o.jar:?]
at jsr166y.CountedCompleter.exec(CountedCompleter.java:468) ~[h2o.jar:?]
at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) ~[h2o.jar:?]
at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:976) ~[h2o.jar:?]
at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479) ~[h2o.jar:?]
at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104) ~[h2o.jar:?]
01-19 15:24:19.209 192.168.0.73:54321 83451 3723302-27 ERROR water.default:
water.util.DistributedException: DistributedException from /192.168.0.73:54321: 'unimplemented'
at water.MRTask.getResult(MRTask.java:660) ~[h2o.jar:?]
at water.MRTask.getResult(MRTask.java:670) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:530) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:412) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:397) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.slow_table(AstTable.java:144) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.apply(AstTable.java:65) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.apply(AstTable.java:27) ~[h2o.jar:?]
at water.rapids.ast.AstExec.exec(AstExec.java:63) ~[h2o.jar:?]
at water.rapids.ast.prims.assign.AstTmpAssign.apply(AstTmpAssign.java:48) ~[h2o.jar:?]
at water.rapids.ast.prims.assign.AstTmpAssign.apply(AstTmpAssign.java:17) ~[h2o.jar:?]
at water.rapids.ast.AstExec.exec(AstExec.java:63) ~[h2o.jar:?]
at water.rapids.Session.exec(Session.java:99) ~[h2o.jar:?]
at water.rapids.Rapids.exec(Rapids.java:94) ~[h2o.jar:?]
at water.api.RapidsHandler.exec(RapidsHandler.java:34) ~[h2o.jar:?]
at sun.reflect.GeneratedMethodAccessor102.invoke(Unknown Source) ~[?:?]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_241]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_241]
at water.api.Handler.handle(Handler.java:60) ~[h2o.jar:?]
at water.api.RequestServer.serve(RequestServer.java:472) ~[h2o.jar:?]
at water.api.RequestServer.doGeneric(RequestServer.java:303) ~[h2o.jar:?]
at water.api.RequestServer.doPost(RequestServer.java:227) ~[h2o.jar:?]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:707) ~[h2o.jar:?]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:554) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1440) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:505) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1355) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[h2o.jar:?]
at water.webserver.jetty9.Jetty9ServerAdapter$LoginHandler.handle(Jetty9ServerAdapter.java:130) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[h2o.jar:?]
at org.eclipse.jetty.server.Server.handle(Server.java:516) ~[h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:487) ~[h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:732) [h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:479) [h2o.jar:?]
at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277) [h2o.jar:?]
at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) [h2o.jar:?]
at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105) [h2o.jar:?]
at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131) [h2o.jar:?]
at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409) [h2o.jar:?]
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) [h2o.jar:?]
at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) [h2o.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_241]
Caused by: water.exceptions.H2OIllegalArgumentException: unimplemented
at water.H2O.unimpl(H2O.java:1377) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable$SlowCnt.reduce(AstTable.java:308) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable$SlowCnt.reduce(AstTable.java:264) ~[h2o.jar:?]
at water.MRTask.reduce4(MRTask.java:937) ~[h2o.jar:?]
at water.MRTask.reduce3(MRTask.java:924) ~[h2o.jar:?]
at water.MRTask.postLocal0(MRTask.java:891) ~[h2o.jar:?]
at water.MRTask.onCompletion(MRTask.java:864) ~[h2o.jar:?]
at jsr166y.CountedCompleter.__tryComplete(CountedCompleter.java:425) ~[h2o.jar:?]
at water.RPC$2.compute2(RPC.java:648) ~[h2o.jar:?]
at water.H2O$H2OCountedCompleter.compute(H2O.java:1704) ~[h2o.jar:?]
at jsr166y.CountedCompleter.exec(CountedCompleter.java:468) ~[h2o.jar:?]
at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) ~[h2o.jar:?]
at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:976) ~[h2o.jar:?]
at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479) ~[h2o.jar:?]
at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104) ~[h2o.jar:?]
01-19 15:24:19.209 192.168.0.73:54321 83451 3723302-27 ERROR water.default:
water.util.DistributedException: DistributedException from /192.168.0.73:54321: 'unimplemented'
at water.MRTask.getResult(MRTask.java:660) ~[h2o.jar:?]
at water.MRTask.getResult(MRTask.java:670) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:530) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:412) ~[h2o.jar:?]
at water.MRTask.doAll(MRTask.java:397) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.slow_table(AstTable.java:144) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.apply(AstTable.java:65) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable.apply(AstTable.java:27) ~[h2o.jar:?]
at water.rapids.ast.AstExec.exec(AstExec.java:63) ~[h2o.jar:?]
at water.rapids.ast.prims.assign.AstTmpAssign.apply(AstTmpAssign.java:48) ~[h2o.jar:?]
at water.rapids.ast.prims.assign.AstTmpAssign.apply(AstTmpAssign.java:17) ~[h2o.jar:?]
at water.rapids.ast.AstExec.exec(AstExec.java:63) ~[h2o.jar:?]
at water.rapids.Session.exec(Session.java:99) ~[h2o.jar:?]
at water.rapids.Rapids.exec(Rapids.java:94) ~[h2o.jar:?]
at water.api.RapidsHandler.exec(RapidsHandler.java:34) ~[h2o.jar:?]
at sun.reflect.GeneratedMethodAccessor102.invoke(Unknown Source) ~[?:?]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_241]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_241]
at water.api.Handler.handle(Handler.java:60) ~[h2o.jar:?]
at water.api.RequestServer.serve(RequestServer.java:472) ~[h2o.jar:?]
at water.api.RequestServer.doGeneric(RequestServer.java:303) ~[h2o.jar:?]
at water.api.RequestServer.doPost(RequestServer.java:227) ~[h2o.jar:?]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:707) ~[h2o.jar:?]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:554) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1440) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) ~[h2o.jar:?]
at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:505) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1355) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[h2o.jar:?]
at water.webserver.jetty9.Jetty9ServerAdapter$LoginHandler.handle(Jetty9ServerAdapter.java:130) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) ~[h2o.jar:?]
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) ~[h2o.jar:?]
at org.eclipse.jetty.server.Server.handle(Server.java:516) ~[h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:487) ~[h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:732) [h2o.jar:?]
at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:479) [h2o.jar:?]
at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:277) [h2o.jar:?]
at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) [h2o.jar:?]
at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105) [h2o.jar:?]
at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173) [h2o.jar:?]
at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131) [h2o.jar:?]
at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409) [h2o.jar:?]
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883) [h2o.jar:?]
at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034) [h2o.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_241]
Caused by: water.exceptions.H2OIllegalArgumentException: unimplemented
at water.H2O.unimpl(H2O.java:1377) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable$SlowCnt.reduce(AstTable.java:308) ~[h2o.jar:?]
at water.rapids.ast.prims.advmath.AstTable$SlowCnt.reduce(AstTable.java:264) ~[h2o.jar:?]
at water.MRTask.reduce4(MRTask.java:937) ~[h2o.jar:?]
at water.MRTask.reduce3(MRTask.java:924) ~[h2o.jar:?]
at water.MRTask.postLocal0(MRTask.java:891) ~[h2o.jar:?]
at water.MRTask.onCompletion(MRTask.java:864) ~[h2o.jar:?]
at jsr166y.CountedCompleter.__tryComplete(CountedCompleter.java:425) ~[h2o.jar:?]
at water.RPC$2.compute2(RPC.java:648) ~[h2o.jar:?]
at water.H2O$H2OCountedCompleter.compute(H2O.java:1704) ~[h2o.jar:?]
at jsr166y.CountedCompleter.exec(CountedCompleter.java:468) ~[h2o.jar:?]
at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) ~[h2o.jar:?]
at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:976) ~[h2o.jar:?]
at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1479) ~[h2o.jar:?]
at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104) ~[h2o.jar:?]