Giter VIP home page Giter VIP logo

embulk-output-jubatus_nearest_neighbor's People

Contributors

smdmts avatar

Watchers

 avatar  avatar

embulk-output-jubatus_nearest_neighbor's Issues

msgpack-rpc could not use?

msgpack-rpc could not use with embulk?

2017-12-20 11:35:57.170 +0900: Embulk v0.8.39

********************************** INFORMATION **********************************
  Join us! Embulk-announce mailing list is up for IMPORTANT annoucement such as
    compatibility-breaking changes and key feature updates.
  https://groups.google.com/forum/#!forum/embulk-announce
*********************************************************************************

2017-12-20 11:36:12.031 +0900 [INFO] (0001:transaction): Loaded plugin embulk-output-jubatus_nearest_neighbor (0.1.0)
2017-12-20 11:36:12.143 +0900 [INFO] (0001:transaction): Loaded plugin embulk-filter-column (0.7.1)
2017-12-20 11:36:12.160 +0900 [INFO] (0001:transaction): Listing local files at directory '/Users/masatoshi.shimada/work/embulk/example/try1/csv' filtering filename by prefix 'sample_01'
2017-12-20 11:36:12.162 +0900 [INFO] (0001:transaction): "follow_symlinks" is set false. Note that symbolic links to directories are skipped.
2017-12-20 11:36:12.166 +0900 [INFO] (0001:transaction): Loading files [/Users/masatoshi.shimada/work/embulk/example/try1/csv/sample_01.csv]
2017-12-20 11:36:12.213 +0900 [INFO] (0001:transaction): Using local thread executor with max_threads=16 / output tasks 8 = input tasks 1 * 8
start
Dec 20, 2017 11:36:12 AM org.msgpack.template.builder.BuildContext build
重大: builder:
{
  if (!$3 && $1.trySkipNil()) {
    return null;
  }
  us.jubat.common.Datum$StringValue _$$_t;
  if ($2 == null) {
    _$$_t = new us.jubat.common.Datum$StringValue();
  } else {
    _$$_t = (us.jubat.common.Datum$StringValue) $2;
  }
  $1.readArrayBegin();
  if ($1.trySkipNil()) {  } else {
    _$$_t.key = (java.lang.String) this.templates[0].read($1, _$$_t.key);
  }
  if ($1.trySkipNil()) {  } else {
    _$$_t.value = (java.lang.String) this.templates[1].read($1, _$$_t.value);
  }
  $1.readArrayEnd();
  return _$$_t;
}

org.embulk.exec.PartialExecutionException: org.msgpack.MessageTypeException: org.msgpack.template.builder.TemplateBuildException: Cannot compile:
{
  if (!$3 && $1.trySkipNil()) {
    return null;
  }
  us.jubat.common.Datum$StringValue _$$_t;
  if ($2 == null) {
    _$$_t = new us.jubat.common.Datum$StringValue();
  } else {
    _$$_t = (us.jubat.common.Datum$StringValue) $2;
  }
  $1.readArrayBegin();
  if ($1.trySkipNil()) {  } else {
    _$$_t.key = (java.lang.String) this.templates[0].read($1, _$$_t.key);
  }
  if ($1.trySkipNil()) {  } else {
    _$$_t.value = (java.lang.String) this.templates[1].read($1, _$$_t.value);
  }
  $1.readArrayEnd();
  return _$$_t;
}

	at org.embulk.exec.BulkLoader$LoaderState.buildPartialExecuteException(BulkLoader.java:375)
	at org.embulk.exec.BulkLoader.doRun(BulkLoader.java:607)
	at org.embulk.exec.BulkLoader.access$000(BulkLoader.java:35)
	at org.embulk.exec.BulkLoader$1.run(BulkLoader.java:391)
	at org.embulk.exec.BulkLoader$1.run(BulkLoader.java:387)
	at org.embulk.spi.Exec.doWith(Exec.java:25)
	at org.embulk.exec.BulkLoader.run(BulkLoader.java:387)
	at org.embulk.EmbulkEmbed.run(EmbulkEmbed.java:180)
	at org.embulk.EmbulkRunner.runInternal(EmbulkRunner.java:331)
	at org.embulk.EmbulkRunner.run(EmbulkRunner.java:174)
	at org.embulk.cli.EmbulkRun.runSubcommand(EmbulkRun.java:468)
	at org.embulk.cli.EmbulkRun.run(EmbulkRun.java:100)
	at org.embulk.cli.Main.main(Main.java:28)
	Suppressed: java.lang.NullPointerException
		at org.embulk.exec.BulkLoader.doCleanup(BulkLoader.java:496)
		at org.embulk.exec.BulkLoader$3.run(BulkLoader.java:427)
		at org.embulk.exec.BulkLoader$3.run(BulkLoader.java:423)
		at org.embulk.spi.Exec.doWith(Exec.java:25)
		at org.embulk.exec.BulkLoader.cleanup(BulkLoader.java:423)
		at org.embulk.EmbulkEmbed.run(EmbulkEmbed.java:184)
		... 5 more
Caused by: org.msgpack.MessageTypeException: org.msgpack.template.builder.TemplateBuildException: Cannot compile:
{
  if (!$3 && $1.trySkipNil()) {
    return null;
  }
  us.jubat.common.Datum$StringValue _$$_t;
  if ($2 == null) {
    _$$_t = new us.jubat.common.Datum$StringValue();
  } else {
    _$$_t = (us.jubat.common.Datum$StringValue) $2;
  }
  $1.readArrayBegin();
  if ($1.trySkipNil()) {  } else {
    _$$_t.key = (java.lang.String) this.templates[0].read($1, _$$_t.key);
  }
  if ($1.trySkipNil()) {  } else {
    _$$_t.value = (java.lang.String) this.templates[1].read($1, _$$_t.value);
  }
  $1.readArrayEnd();
  return _$$_t;
}

	at org.msgpack.template.TemplateRegistry.buildAndRegister(TemplateRegistry.java:516)
	at org.msgpack.template.TemplateRegistry.lookupAfterBuilding(TemplateRegistry.java:413)
	at org.msgpack.template.TemplateRegistry.lookup(TemplateRegistry.java:246)
	at org.msgpack.template.TemplateRegistry.lookupGenericTypeImpl(TemplateRegistry.java:302)
	at org.msgpack.template.TemplateRegistry.lookupGenericType(TemplateRegistry.java:275)
	at org.msgpack.template.TemplateRegistry.lookup(TemplateRegistry.java:201)
	at org.msgpack.template.builder.JavassistTemplateBuilder.toTemplate(JavassistTemplateBuilder.java:128)
	at org.msgpack.template.builder.JavassistTemplateBuilder.buildTemplate(JavassistTemplateBuilder.java:116)
	at org.msgpack.template.builder.AbstractTemplateBuilder.buildTemplate(AbstractTemplateBuilder.java:61)
	at org.msgpack.template.TemplateRegistry.buildAndRegister(TemplateRegistry.java:503)
	at org.msgpack.template.TemplateRegistry.lookupAfterBuilding(TemplateRegistry.java:413)
	at org.msgpack.template.TemplateRegistry.lookup(TemplateRegistry.java:246)
	at org.msgpack.MessagePack.lookup(MessagePack.java:620)
	at org.msgpack.packer.AbstractPacker.write(AbstractPacker.java:202)
	at org.msgpack.rpc.message.RequestMessage.writeTo(RequestMessage.java:57)
	at org.msgpack.template.MessagePackableTemplate.write(MessagePackableTemplate.java:42)
	at org.msgpack.template.MessagePackableTemplate.write(MessagePackableTemplate.java:26)
	at org.msgpack.template.AbstractTemplate.write(AbstractTemplate.java:27)
	at org.msgpack.MessagePack.write(MessagePack.java:234)
	at org.msgpack.rpc.transport.PooledStreamClientTransport.sendMessage(PooledStreamClientTransport.java:73)
	at org.msgpack.rpc.Session.sendRequest(Session.java:121)
	at org.msgpack.rpc.Session.callAsyncApply(Session.java:106)
	at us.jubat.common.ClientBase.call(ClientBase.java:35)
	at org.embulk.output.jubatus_nearest_neighbor.jubatus.JubatusJava.setRow(JubatusJava.java:23)
	at org.embulk.output.jubatus_nearest_neighbor.JubatusNearestNeighborSetOutputPlugin.transaction(JubatusNearestNeighborSetOutputPlugin.scala:18)
	at org.embulk.exec.BulkLoader$4$1$1.transaction(BulkLoader.java:560)
	at org.embulk.exec.LocalExecutorPlugin.transaction(LocalExecutorPlugin.java:54)
	at org.embulk.exec.BulkLoader$4$1.run(BulkLoader.java:555)
	at org.embulk.spi.util.Filters$RecursiveControl.transaction(Filters.java:96)
	at org.embulk.spi.util.Filters$RecursiveControl$1.run(Filters.java:92)
	at org.embulk.filter.column.ColumnFilterPlugin.transaction(ColumnFilterPlugin.java:81)
	at org.embulk.spi.util.Filters$RecursiveControl.transaction(Filters.java:87)
	at org.embulk.spi.util.Filters.transaction(Filters.java:49)
	at org.embulk.exec.BulkLoader$4.run(BulkLoader.java:549)
	at org.embulk.spi.FileInputRunner$RunnerControl$1$1.run(FileInputRunner.java:126)
	at org.embulk.standards.CsvParserPlugin.transaction(CsvParserPlugin.java:247)
	at org.embulk.spi.FileInputRunner$RunnerControl$1.run(FileInputRunner.java:120)
	at org.embulk.spi.util.Decoders$RecursiveControl.transaction(Decoders.java:77)
	at org.embulk.spi.util.Decoders.transaction(Decoders.java:33)
	at org.embulk.spi.FileInputRunner$RunnerControl.run(FileInputRunner.java:117)
	at org.embulk.standards.LocalFileInputPlugin.resume(LocalFileInputPlugin.java:87)
	at org.embulk.standards.LocalFileInputPlugin.transaction(LocalFileInputPlugin.java:77)
	at org.embulk.spi.FileInputRunner.transaction(FileInputRunner.java:67)
	at org.embulk.exec.BulkLoader.doRun(BulkLoader.java:544)
	... 11 more
Caused by: org.msgpack.template.builder.TemplateBuildException: Cannot compile:
{
  if (!$3 && $1.trySkipNil()) {
    return null;
  }
  us.jubat.common.Datum$StringValue _$$_t;
  if ($2 == null) {
    _$$_t = new us.jubat.common.Datum$StringValue();
  } else {
    _$$_t = (us.jubat.common.Datum$StringValue) $2;
  }
  $1.readArrayBegin();
  if ($1.trySkipNil()) {  } else {
    _$$_t.key = (java.lang.String) this.templates[0].read($1, _$$_t.key);
  }
  if ($1.trySkipNil()) {  } else {
    _$$_t.value = (java.lang.String) this.templates[1].read($1, _$$_t.value);
  }
  $1.readArrayEnd();
  return _$$_t;
}

	at org.msgpack.template.builder.BuildContext.build(BuildContext.java:73)
	at org.msgpack.template.builder.DefaultBuildContext.buildTemplate(DefaultBuildContext.java:56)
	at org.msgpack.template.builder.JavassistTemplateBuilder.buildTemplate(JavassistTemplateBuilder.java:118)
	at org.msgpack.template.builder.AbstractTemplateBuilder.buildTemplate(AbstractTemplateBuilder.java:61)
	at org.msgpack.template.TemplateRegistry.buildAndRegister(TemplateRegistry.java:503)
	... 54 more
Caused by: java.lang.NullPointerException
	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:498)
	at javassist.ClassPool.toClass2(ClassPool.java:1112)
	at javassist.ClassPool.toClass(ClassPool.java:1093)
	at javassist.CtClass.toClass(CtClass.java:1181)
	at org.msgpack.template.builder.BuildContext.createClass(BuildContext.java:154)
	at org.msgpack.template.builder.BuildContext.build(BuildContext.java:68)
	... 58 more

Error: org.msgpack.MessageTypeException: org.msgpack.template.builder.TemplateBuildException: Cannot compile:
{
  if (!$3 && $1.trySkipNil()) {
    return null;
  }
  us.jubat.common.Datum$StringValue _$$_t;
  if ($2 == null) {
    _$$_t = new us.jubat.common.Datum$StringValue();
  } else {
    _$$_t = (us.jubat.common.Datum$StringValue) $2;
  }
  $1.readArrayBegin();
  if ($1.trySkipNil()) {  } else {
    _$$_t.key = (java.lang.String) this.templates[0].read($1, _$$_t.key);
  }
  if ($1.trySkipNil()) {  } else {
    _$$_t.value = (java.lang.String) this.templates[1].read($1, _$$_t.value);
  }
  $1.readArrayEnd();
  return _$$_t;
}

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google ❤️ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.