This is an automated email from the ASF dual-hosted git repository.
ppkarwasz pushed a change to branch feat/protect-branches
in repository https://gitbox.apache.org/repos/asf/logging-flume.git
from 89956e59f Add branch protection rulesets
add 7e8a3aa99 fix: change required reviews to 0
add 99de0cde9 FLUME-3466: Remove morphline-solr-sink module (moved to its
own repo) (#426)
add 416ddb2de Update version to 2.0.0-SNAPSHOT. disable hadoop builds
(#429)
add 547226f83 Disable Windows build
add 36f8ac120 Move Avro & Thrift. Switch to java.time from joda (#431)
add 8b67f6c2c Merge remote-tracking branch 'apache/trunk' into
feat/protect-branches
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 2 +-
.github/workflows/build.yml | 47 +-
.github/workflows/codeql-analysis.yml | 3 +
.../workflows/develocity-publish-build-scans.yaml | 40 -
bin/flume-ng | 2 +-
build-support/pom.xml | 2 +-
flume-bom/pom.xml | 58 +-
flume-ng-auth/pom.xml | 2 +-
flume-ng-channels/flume-file-channel/pom.xml | 2 +-
.../org/apache/flume/channel/file/FileChannel.java | 4 +-
.../apache/flume/channel/file/TestFileChannel.java | 2 +-
.../channel/file/TestFileChannelErrorMetrics.java | 2 +-
.../org/apache/flume/channel/file/TestUtils.java | 2 +-
.../file/encryption/TestFileChannelEncryption.java | 2 +-
.../flume-spillable-memory-channel/pom.xml | 2 +-
.../flume/channel/SpillableMemoryChannel.java | 4 +-
.../flume/channel/TestSpillableMemoryChannel.java | 4 +-
flume-ng-channels/pom.xml | 2 +-
flume-ng-clients/flume-ng-log4jappender/pom.xml | 2 +-
.../TestLoadBalancingLog4jAppender.java | 1 -
.../clients/log4jappender/TestLog4jAppender.java | 1 -
.../log4jappender/TestLog4jAppenderWithAvro.java | 1 -
flume-ng-clients/pom.xml | 2 +-
.../flume-ng-config-filter-api/pom.xml | 2 +-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
flume-ng-configfilters/pom.xml | 2 +-
flume-ng-configuration/pom.xml | 2 +-
.../java/org/apache/flume/conf/sink/SinkType.java | 21 +-
.../org/apache/flume/conf/source/SourceType.java | 6 +-
flume-ng-core/pom.xml | 115 +-
.../src/main/java/org/apache/flume/Channel.java | 1 +
.../flume/channel/BasicChannelSemantics.java | 2 +-
.../flume/channel/BasicTransactionSemantics.java | 2 +-
.../org/apache/flume/channel/ChannelProcessor.java | 2 +-
.../org/apache/flume/channel/ChannelUtils.java | 2 +-
.../org/apache/flume/channel/MemoryChannel.java | 4 +-
.../flume/channel/PseudoTxnMemoryChannel.java | 2 +-
.../formatter/output/RollTimePathManager.java | 9 +-
.../RegexExtractorInterceptorMillisSerializer.java | 13 +-
.../flume/serialization/EventDeserializerType.java | 20 +-
.../flume/serialization/EventSerializerType.java | 20 +-
.../serialization/TransientPositionTracker.java | 0
.../org/apache/flume/sink/AbstractRpcSink.java | 4 +-
.../java/org/apache/flume/source/NetcatSource.java | 2 +-
.../org/apache/flume/source/NetcatUdpSource.java | 2 +-
.../flume/source/SequenceGeneratorSource.java | 2 +-
.../java/org/apache/flume/source/StressSource.java | 2 +-
.../java/org/apache/flume/source/SyslogParser.java | 79 +-
.../org/apache/flume/source/SyslogTcpSource.java | 2 +-
.../org/apache/flume/source/SyslogUDPSource.java | 2 +-
.../org/apache/flume/source/http/HTTPSource.java | 2 +-
.../channel/AbstractBasicChannelSemanticsTest.java | 2 +-
.../java/org/apache/flume/channel/MockChannel.java | 2 +-
.../apache/flume/channel/TestChannelProcessor.java | 2 +-
.../org/apache/flume/channel/TestChannelUtils.java | 2 +-
.../apache/flume/channel/TestMemoryChannel.java | 2 +-
.../channel/TestMemoryChannelConcurrency.java | 2 +-
.../flume/formatter/output/TestBucketPath.java | 12 +-
.../interceptor/TestRegexExtractorInterceptor.java | 16 +-
...tRegexExtractorInterceptorMillisSerializer.java | 14 +-
.../apache/flume/sink/TestDefaultSinkFactory.java | 24 +-
.../flume/sink/TestLoadBalancingSinkProcessor.java | 2 +-
.../org/apache/flume/sink/TestRollingFileSink.java | 2 +-
.../org/apache/flume/source/TestAvroSource.java | 610 -------
.../flume/source/TestDefaultSourceFactory.java | 29 +-
.../flume/source/TestMultiportSyslogTCPSource.java | 13 +-
.../org/apache/flume/source/TestNetcatSource.java | 2 +-
.../flume/source/TestSequenceGeneratorSource.java | 2 +-
.../org/apache/flume/source/TestStressSource.java | 2 +-
.../org/apache/flume/source/TestSyslogParser.java | 125 +-
.../apache/flume/source/TestSyslogTcpSource.java | 6 +-
.../apache/flume/source/TestSyslogUdpSource.java | 6 +-
.../org/apache/flume/source/TestThriftSource.java | 383 ----
flume-ng-dist/pom.xml | 36 +-
flume-ng-embedded-agent/pom.xml | 8 +-
.../apache/flume/agent/embedded/EmbeddedAgent.java | 2 +-
.../flume/agent/embedded/EmbeddedSource.java | 2 +-
flume-ng-node/pom.xml | 6 +-
.../node/TestAbstractConfigurationProvider.java | 52 +-
flume-ng-sdk/pom.xml | 175 +-
.../src/main/java/org/apache/flume/Context.java | 0
.../org/apache/flume/annotations/Disposable.java | 0
.../flume/annotations/InterfaceAudience.java | 0
.../flume/annotations/InterfaceStability.java | 0
.../org/apache/flume/annotations/Recyclable.java | 0
.../org/apache/flume/api/FailoverRpcClient.java | 2 +-
.../org/apache/flume/api/RpcClientFactory.java | 79 +-
.../java/org/apache/flume/event}/EventReader.java | 2 +-
.../apache/flume/event}/ReliableEventReader.java | 2 +-
.../flume/event}/SimpleTextLineEventReader.java | 3 +-
.../apache/flume/exception}/ChannelException.java | 2 +-
.../flume/exception}/ChannelFullException.java | 2 +-
.../flume/instrumentation/ChannelCounter.java | 0
.../flume/instrumentation/ChannelCounterMBean.java | 0
.../instrumentation/MonitoredCounterGroup.java | 0
.../apache/flume/instrumentation/SinkCounter.java | 2 +-
.../flume/instrumentation/SinkCounterMBean.java | 0
.../flume/instrumentation/SourceCounter.java | 2 +-
.../flume/instrumentation/SourceCounterMBean.java | 0
.../flume/serialization/DecodeErrorPolicy.java | 0
.../flume/serialization/EventDeserializer.java | 0
.../flume/serialization/LengthMeasurable.java | 0
.../flume/serialization/LineDeserializer.java | 0
.../flume/serialization/PositionTracker.java | 0
.../apache/flume/serialization/RemoteMarkable.java | 0
.../org/apache/flume/serialization/Resettable.java | 0
.../serialization/ResettableFileInputStream.java | 0
.../flume/serialization/ResettableInputStream.java | 0
.../org/apache/flume/serialization/Seekable.java | 0
...SpoolDirectorySourceConfigurationConstants.java | 0
.../org/apache/flume/tools/PlatformDetect.java | 0
.../org/apache/flume/api/ThriftTestingSource.java | 282 ---
.../flume/event}/TestBufferedLineReader.java | 18 +-
flume-ng-sinks/flume-http-sink/pom.xml | 2 +-
flume-ng-sinks/flume-irc-sink/pom.xml | 2 +-
.../java/org/apache/flume/sink/irc/IRCSink.java | 2 +-
.../flume-ng-morphline-solr-sink/README.md | 20 -
.../flume-ng-morphline-solr-sink/pom.xml | 186 --
.../sink/solr/morphline/BlobDeserializer.java | 161 --
.../flume/sink/solr/morphline/BlobHandler.java | 129 --
.../sink/solr/morphline/MorphlineHandler.java | 62 -
.../sink/solr/morphline/MorphlineHandlerImpl.java | 163 --
.../sink/solr/morphline/MorphlineInterceptor.java | 239 ---
.../flume/sink/solr/morphline/MorphlineSink.java | 211 ---
.../sink/solr/morphline/MorphlineSolrSink.java | 48 -
.../flume/sink/solr/morphline/UUIDInterceptor.java | 114 --
.../src/test/appended-resources/META-INF/LICENSE | 42 -
.../flume/sink/solr/morphline/EmbeddedSource.java | 45 -
.../morphline/FlumeHttpServletRequestWrapper.java | 424 -----
.../morphline/ResettableTestStringInputStream.java | 89 -
.../sink/solr/morphline/TestBlobDeserializer.java | 122 --
.../flume/sink/solr/morphline/TestBlobHandler.java | 60 -
.../flume/sink/solr/morphline/TestEnvironment.java | 33 -
.../solr/morphline/TestMorphlineInterceptor.java | 167 --
.../sink/solr/morphline/TestMorphlineSolrSink.java | 450 -----
.../sink/solr/morphline/TestUUIDInterceptor.java | 63 -
.../src/test/resources/custom-mimetypes.xml | 38 -
.../src/test/resources/log4j2.xml | 38 -
.../resources/solr/collection1/conf/currency.xml | 67 -
.../resources/solr/collection1/conf/elevate.xml | 38 -
.../solr/collection1/conf/lang/contractions_ca.txt | 8 -
.../solr/collection1/conf/lang/contractions_fr.txt | 9 -
.../solr/collection1/conf/lang/contractions_ga.txt | 5 -
.../solr/collection1/conf/lang/contractions_it.txt | 23 -
.../solr/collection1/conf/lang/hyphenations_ga.txt | 5 -
.../solr/collection1/conf/lang/stemdict_nl.txt | 6 -
.../solr/collection1/conf/lang/stoptags_ja.txt | 420 -----
.../solr/collection1/conf/lang/stopwords_ar.txt | 125 --
.../solr/collection1/conf/lang/stopwords_bg.txt | 193 ---
.../solr/collection1/conf/lang/stopwords_ca.txt | 220 ---
.../solr/collection1/conf/lang/stopwords_cz.txt | 172 --
.../solr/collection1/conf/lang/stopwords_da.txt | 108 --
.../solr/collection1/conf/lang/stopwords_de.txt | 292 ----
.../solr/collection1/conf/lang/stopwords_el.txt | 78 -
.../solr/collection1/conf/lang/stopwords_en.txt | 54 -
.../solr/collection1/conf/lang/stopwords_es.txt | 354 ----
.../solr/collection1/conf/lang/stopwords_eu.txt | 99 --
.../solr/collection1/conf/lang/stopwords_fa.txt | 313 ----
.../solr/collection1/conf/lang/stopwords_fi.txt | 95 -
.../solr/collection1/conf/lang/stopwords_fr.txt | 183 --
.../solr/collection1/conf/lang/stopwords_ga.txt | 110 --
.../solr/collection1/conf/lang/stopwords_gl.txt | 161 --
.../solr/collection1/conf/lang/stopwords_hi.txt | 235 ---
.../solr/collection1/conf/lang/stopwords_hu.txt | 209 ---
.../solr/collection1/conf/lang/stopwords_hy.txt | 46 -
.../solr/collection1/conf/lang/stopwords_id.txt | 359 ----
.../solr/collection1/conf/lang/stopwords_it.txt | 301 ----
.../solr/collection1/conf/lang/stopwords_ja.txt | 127 --
.../solr/collection1/conf/lang/stopwords_lv.txt | 172 --
.../solr/collection1/conf/lang/stopwords_nl.txt | 117 --
.../solr/collection1/conf/lang/stopwords_no.txt | 192 --
.../solr/collection1/conf/lang/stopwords_pt.txt | 251 ---
.../solr/collection1/conf/lang/stopwords_ro.txt | 233 ---
.../solr/collection1/conf/lang/stopwords_ru.txt | 241 ---
.../solr/collection1/conf/lang/stopwords_sv.txt | 131 --
.../solr/collection1/conf/lang/stopwords_th.txt | 119 --
.../solr/collection1/conf/lang/stopwords_tr.txt | 212 ---
.../solr/collection1/conf/lang/userdict_ja.txt | 29 -
.../resources/solr/collection1/conf/protwords.txt | 21 -
.../resources/solr/collection1/conf/schema.xml | 947 ----------
.../resources/solr/collection1/conf/solrconfig.xml | 1828 --------------------
.../resources/solr/collection1/conf/stopwords.txt | 14 -
.../resources/solr/collection1/conf/synonyms.txt | 29 -
.../test/resources/test-documents/NullHeader.docx | Bin 4355 -> 0 bytes
.../test/resources/test-documents/boilerplate.html | 41 -
.../src/test/resources/test-documents/cars.csv | 6 -
.../src/test/resources/test-documents/cars.csv.gz | Bin 167 -> 0 bytes
.../src/test/resources/test-documents/cars.ssv | 6 -
.../src/test/resources/test-documents/cars.tar.gz | Bin 10240 -> 0 bytes
.../src/test/resources/test-documents/cars.tsv | 6 -
.../src/test/resources/test-documents/complex.mbox | 291 ----
.../test-documents/multiline-sessions.log | 9 -
.../multiline-stacktrace-expected-long-event.log | 25 -
.../test-documents/multiline-stacktrace.log | 30 -
...length-delimited-20130430-234145-tweets.json.gz | Bin 955 -> 0 bytes
.../src/test/resources/test-documents/rsstest.rss | 36 -
.../test-documents/sample-statuses-20120906-141433 | 4 -
.../sample-statuses-20120906-141433-medium.avro | Bin 249540 -> 0 bytes
.../sample-statuses-20120906-141433-subschema.avsc | 12 -
.../sample-statuses-20120906-141433.avro | Bin 1208 -> 0 bytes
.../sample-statuses-20120906-141433.avsc | 57 -
.../sample-statuses-20120906-141433.bz2 | Bin 1054 -> 0 bytes
.../sample-statuses-20120906-141433.gz | Bin 907 -> 0 bytes
.../resources/test-documents/test-documents.7z | Bin 71931 -> 0 bytes
.../resources/test-documents/test-documents.cpio | Bin 116224 -> 0 bytes
.../resources/test-documents/test-documents.tar | Bin 133120 -> 0 bytes
.../resources/test-documents/test-documents.tbz2 | Bin 71127 -> 0 bytes
.../resources/test-documents/test-documents.tgz | Bin 69060 -> 0 bytes
.../resources/test-documents/test-documents.zip | Bin 68403 -> 0 bytes
.../test/resources/test-documents/test-outlook.msg | Bin 19968 -> 0 bytes
.../resources/test-documents/test-zip-of-zip.zip | Bin 299 -> 0 bytes
.../src/test/resources/test-documents/testAIFF.aif | Bin 3894 -> 0 bytes
.../src/test/resources/test-documents/testBMP.bmp | Bin 22554 -> 0 bytes
.../test/resources/test-documents/testBMPfp.txt | 3 -
.../test/resources/test-documents/testDITA.dita | 34 -
.../test/resources/test-documents/testEMLX.emlx | 55 -
.../test/resources/test-documents/testEXCEL.xls | Bin 13824 -> 0 bytes
.../test/resources/test-documents/testEXCEL.xlsx | Bin 9453 -> 0 bytes
.../test/resources/test-documents/testFLAC.flac | Bin 10604 -> 0 bytes
.../src/test/resources/test-documents/testFLAC.oga | Bin 10820 -> 0 bytes
.../src/test/resources/test-documents/testFLV.flv | Bin 90580 -> 0 bytes
.../src/test/resources/test-documents/testGIF.gif | Bin 8495 -> 0 bytes
.../src/test/resources/test-documents/testJAR.jar | Bin 441 -> 0 bytes
.../resources/test-documents/testJPEG_EXIF.jpg | Bin 16357 -> 0 bytes
.../resources/test-documents/testJPEG_EXIF.jpg.gz | Bin 8595 -> 0 bytes
.../test-documents/testJPEG_EXIF.jpg.tar.gz | Bin 8722 -> 0 bytes
.../src/test/resources/test-documents/testKML.kml | 917 ----------
.../test/resources/test-documents/testKeynote.key | Bin 221745 -> 0 bytes
.../test/resources/test-documents/testMP3i18n.mp3 | Bin 40832 -> 0 bytes
.../src/test/resources/test-documents/testMP4.m4a | Bin 4770 -> 0 bytes
.../resources/test-documents/testNumbers.numbers | Bin 134571 -> 0 bytes
.../src/test/resources/test-documents/testPDF.pdf | Bin 34824 -> 0 bytes
.../src/test/resources/test-documents/testPNG.png | Bin 17041 -> 0 bytes
.../src/test/resources/test-documents/testPPM.ppm | 4 -
.../resources/test-documents/testPPT_various.ppt | Bin 164352 -> 0 bytes
.../resources/test-documents/testPPT_various.pptx | Bin 56659 -> 0 bytes
.../src/test/resources/test-documents/testPSD.psd | Bin 69410 -> 0 bytes
.../test/resources/test-documents/testPages.pages | Bin 134152 -> 0 bytes
.../src/test/resources/test-documents/testRDF.rdf | 23 -
.../src/test/resources/test-documents/testRFC822 | 41 -
.../resources/test-documents/testRTFVarious.rtf | 329 ----
.../src/test/resources/test-documents/testSVG.svg | 7 -
.../src/test/resources/test-documents/testTIFF.tif | Bin 25584 -> 0 bytes
.../test/resources/test-documents/testTrueType.ttf | Bin 98724 -> 0 bytes
.../test/resources/test-documents/testVISIO.vsd | Bin 45568 -> 0 bytes
.../test/resources/test-documents/testVORBIS.ogg | Bin 4241 -> 0 bytes
.../src/test/resources/test-documents/testWAR.war | Bin 1003 -> 0 bytes
.../src/test/resources/test-documents/testWAV.wav | Bin 3884 -> 0 bytes
.../test/resources/test-documents/testWINMAIL.dat | Bin 66276 -> 0 bytes
.../src/test/resources/test-documents/testWMA.wma | Bin 27747 -> 0 bytes
.../src/test/resources/test-documents/testWMF.wmf | Bin 51590 -> 0 bytes
.../src/test/resources/test-documents/testWMV.wmv | Bin 113878 -> 0 bytes
.../resources/test-documents/testWORD_various.doc | Bin 35328 -> 0 bytes
.../test-documents/testWindows-x86-32.exe | Bin 11723 -> 0 bytes
.../src/test/resources/test-documents/testXML.xml | 48 -
.../test-morphlines/grokIfNotMatchDropRecord.conf | 75 -
.../test-morphlines/ifDetectMimeType.conf | 74 -
.../resources/test-morphlines/noOperation.conf | 27 -
.../test/resources/test-morphlines/readClob.conf | 32 -
.../test-morphlines/solrCellDocumentTypes.conf | 260 ---
flume-ng-sinks/pom.xml | 3 +-
flume-ng-sources/flume-jms-source/pom.xml | 2 +-
.../org/apache/flume/source/jms/JMSSource.java | 2 +-
.../org/apache/flume/source/jms/TestJMSSource.java | 2 +-
flume-ng-sources/flume-scribe-source/pom.xml | 2 +-
flume-ng-sources/flume-taildir-source/pom.xml | 2 +-
.../source/taildir/ReliableTaildirEventReader.java | 2 +-
.../apache/flume/source/taildir/TaildirSource.java | 2 +-
.../flume/source/taildir/TestTaildirSource.java | 2 +-
flume-ng-sources/pom.xml | 3 +-
flume-ng-tests/pom.xml | 6 +-
.../org/apache/flume/test/agent/TestConfig.java | 2 +
flume-ng-tests/src/test/resources/log4j2.xml | 2 +-
flume-parent/pom.xml | 154 +-
flume-rpc/flume-rpc-avro/pom.xml | 222 +++
.../src/main/avro/TransferStateFileMeta.avsc | 0
.../flume-rpc-avro}/src/main/avro/flume.avdl | 0
.../flume/rpc/avro/client}/AvroCLIClient.java | 6 +-
.../flume/rpc/avro/client}/NettyAvroRpcClient.java | 15 +-
.../serialization/AbstractAvroEventSerializer.java | 8 +-
.../avro}/serialization/AvroEventDeserializer.java | 6 +-
.../AvroEventSerializerConfigurationConstants.java | 2 +-
.../serialization/DurablePositionTracker.java | 4 +-
.../FlumeEventAvroEventSerializer.java | 3 +-
.../ReliableSpoolingFileEventReader.java | 4 +-
.../org/apache/flume/rpc/avro}/sink/AvroSink.java | 9 +-
.../apache/flume/rpc/avro}/source/AvroSource.java | 25 +-
.../rpc/avro}/source/SpoolDirectorySource.java | 9 +-
.../flume/rpc}/api/TestFailoverRpcClient.java | 7 +-
.../org/apache/flume/rpc/avro}/RpcTestUtils.java | 6 +-
.../rpc/avro}/TestLoadBalancingRpcClient.java | 9 +-
.../flume/rpc/avro}/TestRpcClientFactory.java | 6 +-
.../rpc/avro/client}/TestNettyAvroRpcClient.java | 12 +-
.../serialization/SyslogAvroEventSerializer.java | 32 +-
.../serialization/TestAvroEventDeserializer.java | 6 +-
.../serialization/TestDurablePositionTracker.java | 3 +-
.../TestFlumeEventAvroEventSerializer.java | 3 +-
.../TestReliableSpoolingFileEventReader.java | 33 +-
.../TestResettableFileInputStream.java | 6 +-
.../serialization}/TestSpoolingFileLineReader.java | 2 +-
.../TestSyslogAvroEventSerializer.java | 4 +-
.../apache/flume/rpc/avro}/sink/TestAvroSink.java | 6 +-
.../rpc/avro}/sink/TestDefaultSinkFactory.java | 6 +-
.../apache/flume/rpc/avro}/source/MockSource.java | 2 +-
.../rpc/avro}/source/TestDefaultSourceFactory.java | 11 +-
.../rpc/avro}/source/TestSpoolDirectorySource.java | 9 +-
.../node/TestAbstractConfigurationProvider.java | 6 +-
.../resources/TestResettableFileInputStream_1.avro | Bin
.../TestResettableFileInputStream_1.truncated.avro | Bin
.../src/test/resources/certs/gencerts.sh | 0
.../src/test/resources/certs/rootca.conf | 0
.../src/test/resources/certs/server.conf | 0
.../src/test/resources/jettykeystore | Bin
.../src/test/resources/keystorefile.jks | Bin
.../flume-rpc-avro}/src/test/resources/log4j2.xml | 1 +
.../src/test/resources/server.flume-crt.pem | 0
.../src/test/resources/server.flume-keystore.p12 | Bin
.../src/test/resources/server.flume.pem | 0
.../flume-rpc-avro}/src/test/resources/server.p12 | Bin
.../src/test/resources/syslog_event.avsc | 0
.../src/test/resources/truststore.jks | Bin
.../src/test/resources/truststorefile.jks | Bin
flume-rpc/flume-rpc-thrift/pom.xml | 216 +++
.../java/org/apache/flume/rpc}/thrift/Status.java | 4 +-
.../apache/flume/rpc}/thrift/ThriftFlumeEvent.java | 5 +-
.../flume/rpc}/thrift/ThriftSourceProtocol.java | 16 +-
.../rpc/thrift}/api/SecureRpcClientFactory.java | 5 +-
.../rpc/thrift}/api/SecureThriftRpcClient.java | 5 +-
.../flume/rpc/thrift/client}/ThriftRpcClient.java | 20 +-
.../apache/flume/rpc/thrift}/sink/ThriftSink.java | 9 +-
.../flume/rpc/thrift}/source/ThriftSource.java | 21 +-
.../flume-rpc-thrift}/src/main/thrift/aslv2 | 0
.../flume-rpc-thrift}/src/main/thrift/flume.thrift | 0
.../flume/rpc/thrift}/TestThriftRpcClient.java | 6 +-
.../flume/rpc/thrift/ThriftTestingSource.java | 636 +++++++
.../flume/rpc/thrift}/sink/TestThriftSink.java | 6 +-
.../flume/rpc/thrift}/source/MockSource.java | 2 +-
.../thrift}/source/TestDefaultSourceFactory.java | 35 +-
.../src/test/resources/certs/gencerts.sh | 0
.../src/test/resources/certs/rootca.conf | 0
.../src/test/resources/certs/server.conf | 0
.../src/test/resources/keystorefile.jks | Bin
.../src/test/resources/log4j2.xml | 1 +
.../src/test/resources/truststore.jks | Bin
.../src/test/resources/truststorefile.jks | Bin
flume-rpc/pom.xml | 162 ++
flume-tools/pom.xml | 2 +-
pom.xml | 9 +-
349 files changed, 2013 insertions(+), 16581 deletions(-)
delete mode 100644 .github/workflows/develocity-publish-build-scans.yaml
rename flume-ng-core/src/{test =>
main}/java/org/apache/flume/serialization/TransientPositionTracker.java (100%)
delete mode 100644
flume-ng-core/src/test/java/org/apache/flume/source/TestAvroSource.java
delete mode 100644
flume-ng-core/src/test/java/org/apache/flume/source/TestThriftSource.java
rename {flume-ng-configuration =>
flume-ng-sdk}/src/main/java/org/apache/flume/Context.java (100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/annotations/Disposable.java (100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/annotations/InterfaceAudience.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/annotations/InterfaceStability.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/annotations/Recyclable.java (100%)
rename {flume-ng-core/src/main/java/org/apache/flume/client/avro =>
flume-ng-sdk/src/main/java/org/apache/flume/event}/EventReader.java (98%)
rename {flume-ng-core/src/main/java/org/apache/flume/client/avro =>
flume-ng-sdk/src/main/java/org/apache/flume/event}/ReliableEventReader.java
(97%)
rename {flume-ng-core/src/main/java/org/apache/flume/client/avro =>
flume-ng-sdk/src/main/java/org/apache/flume/event}/SimpleTextLineEventReader.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-ng-sdk/src/main/java/org/apache/flume/exception}/ChannelException.java
(97%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-ng-sdk/src/main/java/org/apache/flume/exception}/ChannelFullException.java
(97%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/ChannelCounter.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/ChannelCounterMBean.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/MonitoredCounterGroup.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/SinkCounter.java
(98%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/SinkCounterMBean.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/SourceCounter.java
(98%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/SourceCounterMBean.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/DecodeErrorPolicy.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/EventDeserializer.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/LengthMeasurable.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/LineDeserializer.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/PositionTracker.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/RemoteMarkable.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/Resettable.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/ResettableInputStream.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/Seekable.java (100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/source/SpoolDirectorySourceConfigurationConstants.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/tools/PlatformDetect.java (100%)
delete mode 100644
flume-ng-sdk/src/test/java/org/apache/flume/api/ThriftTestingSource.java
rename {flume-ng-core/src/test/java/org/apache/flume/client/avro =>
flume-ng-sdk/src/test/java/org/apache/flume/event}/TestBufferedLineReader.java
(89%)
delete mode 100644 flume-ng-sinks/flume-ng-morphline-solr-sink/README.md
delete mode 100644 flume-ng-sinks/flume-ng-morphline-solr-sink/pom.xml
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobDeserializer.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobHandler.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandler.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandlerImpl.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineInterceptor.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSolrSink.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/UUIDInterceptor.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/appended-resources/META-INF/LICENSE
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/EmbeddedSource.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/FlumeHttpServletRequestWrapper.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/ResettableTestStringInputStream.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestBlobDeserializer.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestBlobHandler.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestEnvironment.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestMorphlineInterceptor.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestMorphlineSolrSink.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestUUIDInterceptor.java
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/custom-mimetypes.xml
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/log4j2.xml
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/currency.xml
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/elevate.xml
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_ca.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_fr.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_ga.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_it.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/hyphenations_ga.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stemdict_nl.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stoptags_ja.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ar.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_bg.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ca.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_cz.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_da.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_de.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_el.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_en.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_es.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_eu.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_fa.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_fi.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_fr.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ga.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_gl.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_hi.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_hu.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_hy.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_id.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_it.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ja.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_lv.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_nl.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_no.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_pt.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ro.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ru.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_sv.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_th.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_tr.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/userdict_ja.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/protwords.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/schema.xml
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/solrconfig.xml
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/stopwords.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/synonyms.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/NullHeader.docx
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/boilerplate.html
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.csv
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.csv.gz
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.ssv
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.tar.gz
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.tsv
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/complex.mbox
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/multiline-sessions.log
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/multiline-stacktrace-expected-long-event.log
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/multiline-stacktrace.log
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/non-length-delimited-20130430-234145-tweets.json.gz
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/rsstest.rss
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433-medium.avro
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433-subschema.avsc
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.avro
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.avsc
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.bz2
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.gz
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.7z
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.cpio
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.tar
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.tbz2
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.tgz
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.zip
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-outlook.msg
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-zip-of-zip.zip
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testAIFF.aif
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testBMP.bmp
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testBMPfp.txt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testDITA.dita
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testEMLX.emlx
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testEXCEL.xls
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testEXCEL.xlsx
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testFLAC.flac
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testFLAC.oga
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testFLV.flv
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testGIF.gif
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJAR.jar
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJPEG_EXIF.jpg
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJPEG_EXIF.jpg.gz
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJPEG_EXIF.jpg.tar.gz
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testKML.kml
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testKeynote.key
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testMP3i18n.mp3
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testMP4.m4a
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testNumbers.numbers
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPDF.pdf
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPNG.png
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPPM.ppm
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPPT_various.ppt
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPPT_various.pptx
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPSD.psd
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPages.pages
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testRDF.rdf
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testRFC822
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testRTFVarious.rtf
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testSVG.svg
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testTIFF.tif
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testTrueType.ttf
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testVISIO.vsd
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testVORBIS.ogg
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWAR.war
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWAV.wav
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWINMAIL.dat
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWMA.wma
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWMF.wmf
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWMV.wmv
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWORD_various.doc
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWindows-x86-32.exe
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testXML.xml
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/grokIfNotMatchDropRecord.conf
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/ifDetectMimeType.conf
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/noOperation.conf
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/readClob.conf
delete mode 100644
flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/solrCellDocumentTypes.conf
create mode 100644 flume-rpc/flume-rpc-avro/pom.xml
rename {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/main/avro/TransferStateFileMeta.avsc (100%)
rename {flume-ng-sdk => flume-rpc/flume-rpc-avro}/src/main/avro/flume.avdl
(100%)
rename {flume-ng-core/src/main/java/org/apache/flume/client/avro =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro/client}/AvroCLIClient.java
(96%)
rename {flume-ng-sdk/src/main/java/org/apache/flume/api =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro/client}/NettyAvroRpcClient.java
(97%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/serialization/AbstractAvroEventSerializer.java
(86%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/serialization/AvroEventDeserializer.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/serialization/AvroEventSerializerConfigurationConstants.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/serialization/DurablePositionTracker.java
(97%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/serialization/FlumeEventAvroEventSerializer.java
(95%)
rename {flume-ng-core/src/main/java/org/apache/flume/client/avro =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro/serialization}/ReliableSpoolingFileEventReader.java
(99%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/sink/AvroSink.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/source/AvroSource.java
(98%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/source/SpoolDirectorySource.java
(97%)
rename {flume-ng-sdk/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc}/api/TestFailoverRpcClient.java
(96%)
rename {flume-ng-sdk/src/test/java/org/apache/flume/api =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/RpcTestUtils.java
(98%)
rename {flume-ng-sdk/src/test/java/org/apache/flume/api =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/TestLoadBalancingRpcClient.java
(98%)
rename {flume-ng-sdk/src/test/java/org/apache/flume/api =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/TestRpcClientFactory.java
(96%)
rename {flume-ng-sdk/src/test/java/org/apache/flume/api =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro/client}/TestNettyAvroRpcClient.java
(97%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/SyslogAvroEventSerializer.java
(91%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/TestAvroEventDeserializer.java
(95%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/TestDurablePositionTracker.java
(96%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/TestFlumeEventAvroEventSerializer.java
(97%)
rename {flume-ng-core/src/test/java/org/apache/flume/client/avro =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro/serialization}/TestReliableSpoolingFileEventReader.java
(95%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/TestResettableFileInputStream.java
(98%)
rename {flume-ng-core/src/test/java/org/apache/flume/client/avro =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro/serialization}/TestSpoolingFileLineReader.java
(99%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/TestSyslogAvroEventSerializer.java
(96%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/sink/TestAvroSink.java
(99%)
copy {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/sink/TestDefaultSinkFactory.java
(91%)
copy {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/source/MockSource.java
(97%)
copy {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/source/TestDefaultSourceFactory.java
(87%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/source/TestSpoolDirectorySource.java
(98%)
copy {flume-ng-node/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc}/node/TestAbstractConfigurationProvider.java
(98%)
rename {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/TestResettableFileInputStream_1.avro
(100%)
rename {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/TestResettableFileInputStream_1.truncated.avro
(100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/certs/gencerts.sh (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/certs/rootca.conf (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/certs/server.conf (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/jettykeystore (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/keystorefile.jks (100%)
copy {flume-ng-channels/flume-file-channel =>
flume-rpc/flume-rpc-avro}/src/test/resources/log4j2.xml (94%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/server.flume-crt.pem (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/server.flume-keystore.p12 (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/server.flume.pem (100%)
copy {flume-ng-core => flume-rpc/flume-rpc-avro}/src/test/resources/server.p12
(100%)
rename {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/syslog_event.avsc (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/truststore.jks (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/truststorefile.jks (100%)
create mode 100644 flume-rpc/flume-rpc-thrift/pom.xml
rename {flume-ng-sdk/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc}/thrift/Status.java
(95%)
rename {flume-ng-sdk/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc}/thrift/ThriftFlumeEvent.java
(99%)
rename {flume-ng-sdk/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc}/thrift/ThriftSourceProtocol.java
(99%)
rename {flume-ng-auth/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc/thrift}/api/SecureRpcClientFactory.java
(90%)
rename {flume-ng-auth/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc/thrift}/api/SecureThriftRpcClient.java
(96%)
rename {flume-ng-sdk/src/main/java/org/apache/flume/api =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc/thrift/client}/ThriftRpcClient.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc/thrift}/sink/ThriftSink.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc/thrift}/source/ThriftSource.java
(97%)
rename {flume-ng-sdk => flume-rpc/flume-rpc-thrift}/src/main/thrift/aslv2
(100%)
rename {flume-ng-sdk =>
flume-rpc/flume-rpc-thrift}/src/main/thrift/flume.thrift (100%)
rename {flume-ng-sdk/src/test/java/org/apache/flume/api =>
flume-rpc/flume-rpc-thrift/src/test/java/org/apache/flume/rpc/thrift}/TestThriftRpcClient.java
(96%)
create mode 100644
flume-rpc/flume-rpc-thrift/src/test/java/org/apache/flume/rpc/thrift/ThriftTestingSource.java
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/test/java/org/apache/flume/rpc/thrift}/sink/TestThriftSink.java
(98%)
copy {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/test/java/org/apache/flume/rpc/thrift}/source/MockSource.java
(97%)
copy {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/test/java/org/apache/flume/rpc/thrift}/source/TestDefaultSourceFactory.java
(68%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/certs/gencerts.sh (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/certs/rootca.conf (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/certs/server.conf (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/keystorefile.jks (100%)
copy {flume-ng-channels/flume-file-channel =>
flume-rpc/flume-rpc-thrift}/src/test/resources/log4j2.xml (94%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/truststore.jks (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/truststorefile.jks (100%)
create mode 100644 flume-rpc/pom.xml
