water.DException$DistributedException: from /172.16.2.222:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Operation not allowed on string vector.

JIRA | Kevin Normoyle | 2 years ago
  1. 0

    cd h2o-dev/py2/testdir_single_jvm python test_w2v_basic.py summary parameters: {'len': 100, 'offset': 0} JSON call returned non-200 status with http://172.16.2.222:54321/3/Frames.json/syn_enums_500000x1.hex/columns/C1/summary?len=100&offset=0 r.status_code: 500 r.headers: {'date': 'Thu, 18 Dec 2014 00:36:32 GMT', 'content-type': 'application/json'} r.text: {"__meta":{"schema_version":1,"schema_name":"HttpErrorV1","schema_type":"Iced"},"status_header":"500 Internal Server Error","errmsg":"DistributedException: from /172.16.2.222:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Operation not allowed on string vector.","errurl":null,"stacktrace":["water.fvec.CStrChunk.atd_impl(CStrChunk.java:39)","water.fvec.Chunk.at0(Chunk.java:261)","water.fvec.RollupStats$Histo.map(RollupStats.java:227)","water.MRTask.compute2(MRTask.java:408)","water.H2O$H2OCountedCompleter.compute(H2O.java:577)","jsr166y.CountedCompleter.exec(CountedCompleter.java:429)","jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263)","jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974)","jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1477)","jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)"]} ERROR 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: water.DException$DistributedException: from /172.16.2.222:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Operation not allowed on string vector. 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at water.fvec.CStrChunk.atd_impl(CStrChunk.java:39) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at water.fvec.Chunk.at0(Chunk.java:261) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at water.fvec.RollupStats$Histo.map(RollupStats.java:227) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at water.MRTask.compute2(MRTask.java:408) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at water.H2O$H2OCountedCompleter.compute(H2O.java:577) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at jsr166y.CountedCompleter.exec(CountedCompleter.java:429) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1477) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104) ERROR

    JIRA | 2 years ago | Kevin Normoyle
    water.DException$DistributedException: from /172.16.2.222:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Operation not allowed on string vector.
  2. 0

    cd h2o-dev/py2/testdir_single_jvm python test_w2v_basic.py summary parameters: {'len': 100, 'offset': 0} JSON call returned non-200 status with http://172.16.2.222:54321/3/Frames.json/syn_enums_500000x1.hex/columns/C1/summary?len=100&offset=0 r.status_code: 500 r.headers: {'date': 'Thu, 18 Dec 2014 00:36:32 GMT', 'content-type': 'application/json'} r.text: {"__meta":{"schema_version":1,"schema_name":"HttpErrorV1","schema_type":"Iced"},"status_header":"500 Internal Server Error","errmsg":"DistributedException: from /172.16.2.222:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Operation not allowed on string vector.","errurl":null,"stacktrace":["water.fvec.CStrChunk.atd_impl(CStrChunk.java:39)","water.fvec.Chunk.at0(Chunk.java:261)","water.fvec.RollupStats$Histo.map(RollupStats.java:227)","water.MRTask.compute2(MRTask.java:408)","water.H2O$H2OCountedCompleter.compute(H2O.java:577)","jsr166y.CountedCompleter.exec(CountedCompleter.java:429)","jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263)","jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974)","jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1477)","jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)"]} ERROR 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: water.DException$DistributedException: from /172.16.2.222:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Operation not allowed on string vector. 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at water.fvec.CStrChunk.atd_impl(CStrChunk.java:39) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at water.fvec.Chunk.at0(Chunk.java:261) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at water.fvec.RollupStats$Histo.map(RollupStats.java:227) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at water.MRTask.compute2(MRTask.java:408) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at water.H2O$H2OCountedCompleter.compute(H2O.java:577) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at jsr166y.CountedCompleter.exec(CountedCompleter.java:429) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1477) 12-17 16:36:32.902 172.16.2.222:54321 27306 # Session WARN: at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104) ERROR

    JIRA | 2 years ago | Kevin Normoyle
    water.DException$DistributedException: from /172.16.2.222:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Operation not allowed on string vector.
  3. 0

    Workflow: - load bestbuy dataset from HDFS: hdfs://mr-0xd6/datasets/bestbuy_test.csv - parse dataset - go to inspect - click on summary of the 1st column (called 'USER') The exception is thrown: 0-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: water.DException$DistributedException: from /172.16.2.223:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Only Strings allowed 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.fvec.CStrChunk.atd_impl(CStrChunk.java:39) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.fvec.Chunk.at0(Chunk.java:251) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.fvec.RollupStats$Histo.map(RollupStats.java:227) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:408) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.H2O$H2OCountedCompleter.compute(H2O.java:200) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at jsr166y.CountedCompleter.exec(CountedCompleter.java:429) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1477) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)

    JIRA | 2 years ago | Michal Malohlava
    water.DException$DistributedException: from /172.16.2.223:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Only Strings allowed
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Workflow: - load bestbuy dataset from HDFS: hdfs://mr-0xd6/datasets/bestbuy_test.csv - parse dataset - go to inspect - click on summary of the 1st column (called 'USER') The exception is thrown: 0-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: water.DException$DistributedException: from /172.16.2.223:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Only Strings allowed 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.fvec.CStrChunk.atd_impl(CStrChunk.java:39) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.fvec.Chunk.at0(Chunk.java:251) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.fvec.RollupStats$Histo.map(RollupStats.java:227) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:408) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.MRTask.compute2(MRTask.java:370) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at water.H2O$H2OCountedCompleter.compute(H2O.java:200) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at jsr166y.CountedCompleter.exec(CountedCompleter.java:429) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1477) 10-23 13:33:45.068 172.16.2.223:54321 49438 # Session WARN: at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)

    JIRA | 2 years ago | Michal Malohlava
    water.DException$DistributedException: from /172.16.2.223:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Only Strings allowed
  6. 0

    Steps to reproduce: {code} val data = sc.parallelize((1 to 100000).map(_=>java.util.UUID.randomUUID().toString+" "+java.util.UUID.randomUUID().toString)) val schema = StructType(Seq(StructField("c1", StringType, true))) val rowRDD = data.map(Row(_)) val stringColumnTable = sqlContext.applySchema(rowRDD, schema) val h2oFrame = toDataFrame(stringColumnTable) scala> h2oFrame.vecs.map(_.get_type_str) res2: Array[String] = Array(string) scala> org.apache.spark.examples.h2o.DemoUtils.splitFrame(h2oFrame, Array("1","2","3"), Array(0.6,0.2,0.2)) onExCompletion for hex.splitframe.ShuffleSplitFrame$1@5d9445ed onExCompletion for hex.splitframe.ShuffleSplitFrame$1@5d9445ed water.DException$DistributedException: from /192.168.1.4:54321; by class hex.splitframe.ShuffleSplitFrame$1; class java.lang.IllegalArgumentException: Operation not allowed on string vector. at water.fvec.CStrChunk.atd_impl(CStrChunk.java:39) at water.fvec.Chunk.atd(Chunk.java:252) at hex.splitframe.ShuffleSplitFrame$1.map(ShuffleSplitFrame.java:40) at water.MRTask.compute2(MRTask.java:430) at water.H2O$H2OCountedCompleter.compute(H2O.java:582) at jsr166y.CountedCompleter.exec(CountedCompleter.java:429) at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974) at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1477) at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104) water.DException$DistributedException: from /192.168.1.4:54323; by class hex.splitframe.ShuffleSplitFrame$1; class java.lang.IllegalArgumentException: Operation not allowed on string vector. at water.fvec.CStrChunk.atd_impl(CStrChunk.java:39) at water.fvec.Chunk.atd(Chunk.java:252) at hex.splitframe.ShuffleSplitFrame$1.map(ShuffleSplitFrame.java:40) at water.MRTask.compute2(MRTask.java:430) at water.MRTask.compute2(MRTask.java:374) at water.MRTask.compute2(MRTask.java:374) at water.MRTask.compute2(MRTask.java:374) at water.H2O$H2OCountedCompleter.compute(H2O.java:582) at jsr166y.CountedCompleter.exec(CountedCompleter.java:429) at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974) at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1477) at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104) java.lang.RuntimeException: water.DException$DistributedException: from /192.168.1.4:54327; by class hex.splitframe.ShuffleSplitFrame$1; class water.DException$DistributedException: from /192.168.1.4:54321; by class hex.splitframe.ShuffleSplitFrame$1; class java.lang.IllegalArgumentException: Operation not allowed on string vector. at water.MRTask.getResult(MRTask.java:265) at water.MRTask.doAll(MRTask.java:220) at water.MRTask.doAll(MRTask.java:217) at hex.splitframe.ShuffleSplitFrame.shuffleSplitFrame(ShuffleSplitFrame.java:29) at org.apache.spark.examples.h2o.DemoUtils$.splitFrame(DemoUtils.scala:110) at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:35) at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:40) at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:42) at $iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:44) at $iwC$$iwC$$iwC$$iwC.<init>(<console>:46) at $iwC$$iwC$$iwC.<init>(<console>:48) at $iwC$$iwC.<init>(<console>:50) at $iwC.<init>(<console>:52) at <init>(<console>:54) at .<init>(<console>:58) at .<clinit>(<console>) at .<init>(<console>:7) at .<clinit>(<console>) at $print(<console>) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:483) at org.apache.spark.repl.SparkIMain$ReadEvalPrint.call(SparkIMain.scala:852) at org.apache.spark.repl.SparkIMain$Request.loadAndRun(SparkIMain.scala:1125) at org.apache.spark.repl.SparkIMain.loadAndRunReq$1(SparkIMain.scala:674) at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:705) at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:669) at org.apache.spark.repl.SparkILoop.reallyInterpret$1(SparkILoop.scala:828) at org.apache.spark.repl.SparkILoop.interpretStartingWith(SparkILoop.scala:873) at org.apache.spark.repl.SparkILoop.command(SparkILoop.scala:785) at org.apache.spark.repl.SparkILoop.processLine$1(SparkILoop.scala:628) at org.apache.spark.repl.SparkILoop.innerLoop$1(SparkILoop.scala:636) at org.apache.spark.repl.SparkILoop.loop(SparkILoop.scala:641) at org.apache.spark.repl.SparkILoop$$anonfun$process$1.apply$mcZ$sp(SparkILoop.scala:968) at org.apache.spark.repl.SparkILoop$$anonfun$process$1.apply(SparkILoop.scala:916) at org.apache.spark.repl.SparkILoop$$anonfun$process$1.apply(SparkILoop.scala:916) at scala.tools.nsc.util.ScalaClassLoader$.savingContextLoader(ScalaClassLoader.scala:135) at org.apache.spark.repl.SparkILoop.process(SparkILoop.scala:916) at org.apache.spark.repl.SparkILoop.process(SparkILoop.scala:1011) at org.apache.spark.repl.Main$.main(Main.scala:31) at org.apache.spark.repl.Main.main(Main.scala) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:483) at org.apache.spark.deploy.SparkSubmit$.launch(SparkSubmit.scala:358) at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:75) at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala) Caused by: water.DException$DistributedException: from /192.168.1.4:54327; by class hex.splitframe.ShuffleSplitFrame$1; class water.DException$DistributedException: from /192.168.1.4:54321; by class hex.splitframe.ShuffleSplitFrame$1; class java.lang.IllegalArgumentException: Operation not allowed on string vector. at water.fvec.CStrChunk.atd_impl(CStrChunk.java:39) at water.fvec.Chunk.atd(Chunk.java:252) at hex.splitframe.ShuffleSplitFrame$1.map(ShuffleSplitFrame.java:40) at water.MRTask.compute2(MRTask.java:430) at water.H2O$H2OCountedCompleter.compute(H2O.java:582) at jsr166y.CountedCompleter.exec(CountedCompleter.java:429) at jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263) at jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974) at jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1477) at jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104) {code} Reproduced on this build: http://h2o-release.s3.amazonaws.com/sparkling-water/master/86/index.html

    JIRA | 2 years ago | Peter Rudenko
    water.DException$DistributedException: from /192.168.1.4:54321; by class hex.splitframe.ShuffleSplitFrame$1; class java.lang.IllegalArgumentException: Operation not allowed on string vector.

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. water.DException$DistributedException

      from /172.16.2.222:54321; by class water.fvec.RollupStats$ComputeRollupsTask; class java.lang.IllegalArgumentException: Operation not allowed on string vector.

      at water.fvec.CStrChunk.atd_impl()
    2. water.fvec
      RollupStats$Histo.map
      1. water.fvec.CStrChunk.atd_impl(CStrChunk.java:39)
      2. water.fvec.Chunk.at0(Chunk.java:261)
      3. water.fvec.RollupStats$Histo.map(RollupStats.java:227)
      3 frames
    3. water
      H2O$H2OCountedCompleter.compute
      1. water.MRTask.compute2(MRTask.java:408)
      2. water.H2O$H2OCountedCompleter.compute(H2O.java:577)
      2 frames
    4. jsr166y
      ForkJoinWorkerThread.run
      1. jsr166y.CountedCompleter.exec(CountedCompleter.java:429)
      2. jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:263)
      3. jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974)
      4. jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1477)
      5. jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
      5 frames