zuhan
zuhan
获取A股最新更新的板块信息 block_data = TUSHARE_PRO.ths_index().query("type!='R'").query("exchange=='A'") block_data.query("name=='区块链'") ``` ne_block = TUSHARE_PRO.ths_member(ts_code="864005.TI") one_block ``` 但是返回的却是美股的 ts_code | code | name -- | -- | -- 864005.TI | AMD.O | AMD 864005.TI | BTBT.O...
get_realtime_quotes实时接口目前是下线了吗？ 请求实时接口get_realtime_quotes，返回失败，提示如下： raise HTTPError(req.full_url, code, msg, hdrs, fp) urllib.error.HTTPError: HTTP Error 403: Forbidde
Excel file format cannot be determined, you must specify an engine manually. 错误信息，需要选择 QUANTAXIS> save stock_block 2022-06-05 10:56:16,243 - root - WARNING - ##JOB09 Now Saving STOCK_BlOCK ==== QUANTAXIS>> ##JOB09...
通过pip安装，但是安装启动失败，wrong version, should be 3.4/3.5/3.6 version 错误信息： QUANTAXIS>> start QUANTAXIS no display found. Using non-interactive Agg backend if you use ssh, you can use ssh with -X parmas to avoid...
can‘t run,Caused by: java.lang.NoClassDefFoundError: org/apache/spark/sql/catalyst/util/ArrayData$
Caused by: java.lang.NoClassDefFoundError: org/apache/spark/sql/catalyst/util/ArrayData$
Caused by: java.lang.NoSuchMethodError: org.tensorflow.example.BytesList$Builder.addValue(Lorg/tensorflow/spark/shaded/com/google/protobuf/ByteString;)Lorg/tensorflow/example/BytesList$Builder; at org.tensorflow.spark.datasources.tfrecords.serde.BytesListFeatureEncoder$$anonfun$encode$3.apply(FeatureEncoder.scala:68) at org.tensorflow.spark.datasources.tfrecords.serde.BytesListFeatureEncoder$$anonfun$encode$3.apply(FeatureEncoder.scala:67) at scala.collection.immutable.List.foreach(List.scala:381) at org.tensorflow.spark.datasources.tfrecords.serde.BytesListFeatureEncoder$.encode(FeatureEncoder.scala:67) at org.tensorflow.spark.datasources.tfrecords.serde.DefaultTfRecordRowEncoder$.org$tensorflow$spark$datasources$tfrecords$serde$DefaultTfRecordRowEncoder$$encodeFeature(DefaultTfRecordRowEncoder.scala:118) at org.tensorflow.spark.datasources.tfrecords.serde.DefaultTfRecordRowEncoder$$anonfun$encodeExample$1.apply(DefaultTfRecordRowEncoder.scala:64) at org.tensorflow.spark.datasources.tfrecords.serde.DefaultTfRecordRowEncoder$$anonfun$encodeExample$1.apply(DefaultTfRecordRowEncoder.scala:61) at scala.collection.immutable.List.foreach(List.scala:381) at org.tensorflow.spark.datasources.tfrecords.serde.DefaultTfRecordRowEncoder$.encodeExample(DefaultTfRecordRowEncoder.scala:61) at org.tensorflow.spark.datasources.tfrecords.DefaultSource$$anonfun$2.apply(DefaultSource.scala:59) at org.tensorflow.spark.datasources.tfrecords.DefaultSource$$anonfun$2.apply(DefaultSource.scala:56) at scala.collection.Iterator$$anon$11.next(Iterator.scala:409) at scala.collection.Iterator$$anon$13.hasNext(Iterator.scala:462)...
org.spark_project.guava.util.concurrent.ExecutionError: java.lang.NoClassDefFoundError: org/codehaus/janino/ClassBodyEvaluator at org.spark_project.guava.cache.LocalCache$Segment.get(LocalCache.java:2261) at org.spark_project.guava.cache.LocalCache.get(LocalCache.java:4000) at org.spark_project.guava.cache.LocalCache.getOrLoad(LocalCache.java:4004) at org.spark_project.guava.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4874) at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator$.compile(CodeGenerator.scala:905) at org.apache.spark.sql.catalyst.expressions.codegen.GenerateUnsafeProjection$.create(GenerateUnsafeProjection.scala:412) at org.apache.spark.sql.catalyst.expressions.codegen.GenerateUnsafeProjection$.create(GenerateUnsafeProjection.scala:366) at org.apache.spark.sql.catalyst.expressions.codegen.GenerateUnsafeProjection$.create(GenerateUnsafeProjection.scala:32) at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator.generate(CodeGenerator.scala:889) at org.apache.spark.sql.catalyst.expressions.UnsafeProjection$.create(Projection.scala:130) at org.apache.spark.sql.catalyst.expressions.UnsafeProjection$.create(Projection.scala:120) at org.apache.spark.sql.catalyst.expressions.UnsafeProjection$.create(Projection.scala:114) at org.apache.spark.sql.execution.RDDScanExec$$anonfun$doExecute$2.apply(ExistingRDD.scala:194) at...
how to know the data format？can you show me the test data？
it will throw kafka.common.OffsetOutOfRangeException?why
17/07/26 15:20:58 INFO mapreduce.Job main: Task Id : attempt_1496398596009_5376987_m_000005_1, Status : FAILED Error: java.nio.BufferUnderflowException at java.nio.HeapByteBuffer.get(HeapByteBuffer.java:145) at java.nio.ByteBuffer.get(ByteBuffer.java:694) at kafka.api.ApiUtils$.readShortString(ApiUtils.scala:40) at kafka.api.TopicData$.readFrom(FetchResponse.scala:95) at kafka.api.FetchResponse$$anonfun$4.apply(FetchResponse.scala:169) at kafka.api.FetchResponse$$anonfun$4.apply(FetchResponse.scala:168) at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:251) at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:251)...