You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by jo...@apache.org on 2022/09/27 00:51:12 UTC

[druid] branch master updated (e839660b6a -> 1f1fced6d4)

This is an automated email from the ASF dual-hosted git repository.

jonwei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git


    from e839660b6a Grab the thread name in a poisoned pool (#13143)
     add 1f1fced6d4 Add JsonInputFormat option to assume newline delimited JSON, improve parse exception handling for multiline JSON (#13089)

No new revisions were added by this update.

Summary of changes:
 .../druid/data/input/impl/JsonInputFormat.java     |  75 +++++++++++--
 .../impl/{JsonReader.java => JsonNodeReader.java}  | 125 +++++++++++++--------
 .../input/impl/CloudObjectInputSourceTest.java     |   8 +-
 .../druid/data/input/impl/JsonInputFormatTest.java |  12 +-
 .../druid/data/input/impl/JsonLineReaderTest.java  |  16 ++-
 ...JsonReaderTest.java => JsonNodeReaderTest.java} |  73 +++++++-----
 .../druid/data/input/impl/JsonReaderTest.java      |  28 +++--
 docs/ingestion/data-formats.md                     |   7 ++
 .../data/input/aliyun/OssInputSourceTest.java      |  10 +-
 .../google/GoogleCloudStorageInputSourceTest.java  |   8 +-
 .../input/kafkainput/KafkaInputFormatTest.java     |  15 ++-
 .../druid/indexing/kafka/KafkaSamplerSpecTest.java |   4 +-
 .../kafka/supervisor/KafkaSupervisorTest.java      |   2 +
 .../indexing/kinesis/KinesisSamplerSpecTest.java   |   2 +-
 .../kinesis/supervisor/KinesisSupervisorTest.java  |   3 +
 .../apache/druid/msq/querykit/DataSourcePlan.java  |   2 +-
 .../org/apache/druid/msq/exec/MSQSelectTest.java   |   2 +-
 .../druid/msq/indexing/error/MSQWarningsTest.java  |   2 +-
 .../external/ExternalInputSpecSlicerTest.java      |   2 +-
 .../druid/data/input/s3/S3InputSourceTest.java     |  18 +--
 .../druid/indexing/common/task/IndexTaskTest.java  |   2 +-
 ...ltiPhaseParallelIndexingWithNullColumnTest.java |   6 +-
 .../parallel/ParallelIndexSupervisorTaskTest.java  |   2 +-
 .../parallel/ParallelIndexTestingFactory.java      |   2 +-
 .../PartialHashSegmentGenerateTaskTest.java        |   4 +-
 .../parallel/SinglePhaseParallelIndexingTest.java  |   2 +
 .../batch/parallel/SinglePhaseSubTaskSpecTest.java |   2 +-
 .../overlord/sampler/InputSourceSamplerTest.java   |   2 +-
 .../SeekableStreamIndexTaskTestBase.java           |   2 +
 .../SeekableStreamSupervisorSpecTest.java          |   6 +-
 .../seekablestream/StreamChunkParserTest.java      |   6 +-
 .../SeekableStreamSupervisorStateTest.java         |   4 +-
 website/.spelling                                  |   2 +
 33 files changed, 311 insertions(+), 145 deletions(-)
 copy core/src/main/java/org/apache/druid/data/input/impl/{JsonReader.java => JsonNodeReader.java} (56%)
 copy core/src/test/java/org/apache/druid/data/input/impl/{JsonReaderTest.java => JsonNodeReaderTest.java} (88%)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org