Details

    • Type: New Feature
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.3.1
    • Fix Version/s: 1.4.0
    • Component/s: Sinks+Sources
    • Labels:
      None

      Description

      Add a Flume Morphline Solr Sink that extracts search documents from Flume events, transforms them with a morphline and loads them in Near Real Time into Apache Solr, typically a SolrCloud.

      The sink is intended to be used alongside the HdfsSink. It is designed to extract, transform and load any data in flexible ways, not just structured data, but also arbitrary raw data, including data from many heterogeneous data sources.

      1. FLUME-2070-v1.patch
        532 kB
        wolfgang hoschek
      2. FLUME-2070-v2.patch
        2.39 MB
        wolfgang hoschek
      3. FLUME-2070-v3.patch
        2.39 MB
        wolfgang hoschek
      4. FLUME-2070-v4.patch
        2.39 MB
        wolfgang hoschek
      5. FLUME-2070-v5.patch
        2.39 MB
        wolfgang hoschek
      6. FLUME-2070-v6.patch
        2.39 MB
        wolfgang hoschek
      7. FLUME-2070-v7.patch
        2.39 MB
        wolfgang hoschek
      8. FLUME-2070-v8.patch
        2.39 MB
        wolfgang hoschek

        Issue Links

          Activity

          Hide
          whoschek wolfgang hoschek added a comment -

          Here is a patch that implements this (against master).

          Show
          whoschek wolfgang hoschek added a comment - Here is a patch that implements this (against master).
          Hide
          whoschek wolfgang hoschek added a comment -

          Here is a patch that implements this (against master).

          Show
          whoschek wolfgang hoschek added a comment - Here is a patch that implements this (against master).
          Hide
          hshreedharan Hari Shreedharan added a comment -

          Wolfgang,

          We typically use trunk (not master). So please generate the patch against trunk. Also, I get this error when doing git apply --binary:
          error: pom.xml: patch does not apply
          error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/.DS_Store' without full index line
          error: flume-ng-morphline-solr-sink/src/test/.DS_Store: patch does not apply
          error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/.DS_Store' without full index line
          error: flume-ng-morphline-solr-sink/src/test/resources/.DS_Store: patch does not apply
          error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/.DS_Store' without full index line
          error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/.DS_Store: patch does not apply
          error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.tar.gz' without full index line
          error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.tar.gz: patch does not apply
          error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/non-length-delimited-20130430-234145-tweets.json.gz' without full index line
          error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/non-length-delimited-20130430-234145-tweets.json.gz: patch does not apply
          error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433-medium.avro' without full index line
          error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433-medium.avro: patch does not apply
          error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.avro' without full index line
          error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.avro: patch does not apply
          error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.bz2' without full index line
          error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.bz2: patch does not apply

          (I think you should ignore the .DS_Store files (unless they are required)). I think you need to generate the diff with index or is there another way of applying the patch?

          Show
          hshreedharan Hari Shreedharan added a comment - Wolfgang, We typically use trunk (not master). So please generate the patch against trunk. Also, I get this error when doing git apply --binary: error: pom.xml: patch does not apply error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/.DS_Store' without full index line error: flume-ng-morphline-solr-sink/src/test/.DS_Store: patch does not apply error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/.DS_Store' without full index line error: flume-ng-morphline-solr-sink/src/test/resources/.DS_Store: patch does not apply error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/.DS_Store' without full index line error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/.DS_Store: patch does not apply error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.tar.gz' without full index line error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.tar.gz: patch does not apply error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/non-length-delimited-20130430-234145-tweets.json.gz' without full index line error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/non-length-delimited-20130430-234145-tweets.json.gz: patch does not apply error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433-medium.avro' without full index line error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433-medium.avro: patch does not apply error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.avro' without full index line error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.avro: patch does not apply error: cannot apply binary patch to 'flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.bz2' without full index line error: flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.bz2: patch does not apply (I think you should ignore the .DS_Store files (unless they are required)). I think you need to generate the diff with index or is there another way of applying the patch?
          Hide
          rvs Roman Shaposhnik added a comment -

          wolfgang hoschek a few points:

          1. perhaps the easiest way to generate a patch that applies cleanly would be git format-patch (just a thought)
          2. why not un-comment the dependency in flume-ng-dist/pom.xml ?
          3. it would be cleaner to remove repositories section from flume-ng-sinks/flume-ng-morphline-solr-sink/pom.xml
          4. I am a little bit concerned about the version of the jcl-over-slf4j dependency (is there any reason not to use flume's?)
          Show
          rvs Roman Shaposhnik added a comment - wolfgang hoschek a few points: perhaps the easiest way to generate a patch that applies cleanly would be git format-patch (just a thought) why not un-comment the dependency in flume-ng-dist/pom.xml ? it would be cleaner to remove repositories section from flume-ng-sinks/flume-ng-morphline-solr-sink/pom.xml I am a little bit concerned about the version of the jcl-over-slf4j dependency (is there any reason not to use flume's?)
          Hide
          whoschek wolfgang hoschek added a comment -

          Here is a patch against trunk.

          Show
          whoschek wolfgang hoschek added a comment - Here is a patch against trunk.
          Hide
          whoschek wolfgang hoschek added a comment -

          "why not un-comment the dependency in flume-ng-dist/pom.xml ?"

          It tried to uncomment it, but for some reason it doesn't build like that

          "I am a little bit concerned about the version of the jcl-over-slf4j dependency (is there any reason not to use flume's?)"

          I believe it actually uses the same version that flume currently uses (1.6.1), but flume currently doesn't define a version variable for slf4j in the parent pom.

          Show
          whoschek wolfgang hoschek added a comment - "why not un-comment the dependency in flume-ng-dist/pom.xml ?" It tried to uncomment it, but for some reason it doesn't build like that "I am a little bit concerned about the version of the jcl-over-slf4j dependency (is there any reason not to use flume's?)" I believe it actually uses the same version that flume currently uses (1.6.1), but flume currently doesn't define a version variable for slf4j in the parent pom.
          Hide
          hshreedharan Hari Shreedharan added a comment -

          Hi Wolfgang,

          Great patch, thanks! Here are some relatively minor comments I have:

          • This need not be synchronized, since only one thread - the sink runner will call process on a particular sink:
            /org/apache/flume/sink/solr/morphline/MorphlineSolrSink.java:119
              public synchronized Status process() throws EventDeliveryException {
            
          • This counter should be incremented every time indexer.process() is called (though not all sinks even try to update this counter}
            /org/apache/flume/sink/solr/morphline/MorphlineSolrSink.java:155
                  sinkCounter.addToEventDrainAttemptCount(numEventsTaken);
            
          • We should log the exceptions if the rollbacks (for the indexer or the channel failed}:
            /org/apache/flume/sink/solr/morphline/MorphlineSolrSink.java:166
                  try {
                    if (!isSolrTransactionCommitted) {
                      indexer.rollbackTransaction();
                    }
                  } catch (Throwable t2) {
                    ; // ignore
                  } finally {
                    try {
                      txn.rollback();
                    } catch (Throwable t4) {
                      ; // ignore
                    }
                  }
            
          • Why not use a LinkedBlockingDeque or something like that here:
            org.apache.flume.sink.solr.morphline.MorphlineInterceptor.LocalMorphlineInterceptor
            private final List<LocalMorphlineInterceptor> pool = new ArrayList();
            

          Also we might want to make sure we only spawn a maximum number of the LocalMorphlineInterceptors?

          • This array can be pre-allocated and reused no?
            /org/apache/flume/sink/solr/morphline/BlobDeserializer.java:77
            byte[] buf = new byte[Math.min(maxBlobLength, DEFAULT_BUFFER_SIZE)];
            
          • This code seems to be repeated in BlobHandler and BlobDeserializer, maybe move it to a util class or something?:
                  ByteArrayOutputStream blob = null;
                  byte[] buf = new byte[Math.min(maxBlobLength, DEFAULT_BUFFER_SIZE)];
                  int blobLength = 0;
                  int n = 0;
                  while ((n = in.read(buf, 0, Math.min(buf.length, maxBlobLength - blobLength))) != -1) {
                    if (blob == null) {
                      blob = new ByteArrayOutputStream(n);
                    }
                    blob.write(buf, 0, n);
                    blobLength += n;
                    if (blobLength >= maxBlobLength) {
                      LOGGER.warn("Request length exceeds maxBlobLength ({}), truncating BLOB event!", maxBlobLength);
                      break;
                    }
                  }
            

          Also, we should see if we can fix the build issue. Also, could you please rebase on trunk?

          Show
          hshreedharan Hari Shreedharan added a comment - Hi Wolfgang, Great patch, thanks! Here are some relatively minor comments I have: This need not be synchronized, since only one thread - the sink runner will call process on a particular sink: /org/apache/flume/sink/solr/morphline/MorphlineSolrSink.java:119 public synchronized Status process() throws EventDeliveryException { This counter should be incremented every time indexer.process() is called (though not all sinks even try to update this counter} /org/apache/flume/sink/solr/morphline/MorphlineSolrSink.java:155 sinkCounter.addToEventDrainAttemptCount(numEventsTaken); We should log the exceptions if the rollbacks (for the indexer or the channel failed}: /org/apache/flume/sink/solr/morphline/MorphlineSolrSink.java:166 try { if (!isSolrTransactionCommitted) { indexer.rollbackTransaction(); } } catch (Throwable t2) { ; // ignore } finally { try { txn.rollback(); } catch (Throwable t4) { ; // ignore } } Why not use a LinkedBlockingDeque or something like that here: org.apache.flume.sink.solr.morphline.MorphlineInterceptor.LocalMorphlineInterceptor private final List<LocalMorphlineInterceptor> pool = new ArrayList(); Also we might want to make sure we only spawn a maximum number of the LocalMorphlineInterceptors? This array can be pre-allocated and reused no? /org/apache/flume/sink/solr/morphline/BlobDeserializer.java:77 byte [] buf = new byte [ Math .min(maxBlobLength, DEFAULT_BUFFER_SIZE)]; This code seems to be repeated in BlobHandler and BlobDeserializer, maybe move it to a util class or something?: ByteArrayOutputStream blob = null ; byte [] buf = new byte [ Math .min(maxBlobLength, DEFAULT_BUFFER_SIZE)]; int blobLength = 0; int n = 0; while ((n = in.read(buf, 0, Math .min(buf.length, maxBlobLength - blobLength))) != -1) { if (blob == null ) { blob = new ByteArrayOutputStream(n); } blob.write(buf, 0, n); blobLength += n; if (blobLength >= maxBlobLength) { LOGGER.warn( "Request length exceeds maxBlobLength ({}), truncating BLOB event!" , maxBlobLength); break ; } } Also, we should see if we can fix the build issue. Also, could you please rebase on trunk?
          Hide
          whoschek wolfgang hoschek added a comment -

          This need not be synchronized, since only one thread - the sink runner will call process on a particular sink

          thanks - this is now fixed

          This counter should be incremented every time indexer.process() is called (though not all sinks even try to update this counter}

          I looked at HDFSEventSink and it behaves exactly like the MorphlineSink in this regard

          We should log the exceptions if the rollbacks (for the indexer or the channel failed})

          thanks - this is now fixed

          Why not use a LinkedBlockingDeque or something like that here

          thanks - this is now fixed

          Also we might want to make sure we only spawn a maximum number of the LocalMorphlineInterceptors?

          The maximum number of the LocalMorphlineInterceptors won't get bigger than the number of concurrent threads, so this seems fine to me without an explicit limit

          This array can be pre-allocated and reused no?

          I'm not sure it can be reused in a thread safe way and if thread safety is required here.

          This code seems to be repeated in BlobHandler and BlobDeserializer, maybe move it to a util class or something?

          I'd rather keep it separate for the time being. For examnple, at some point you guys might decide to pull one of the two classes up into a higher package and in this case it's easier to not have the code entangled.

          Also, could you please rebase on trunk?

          yep, i've attached a new patch

          Also, we should see if we can fix the build issue.

          I don't know how to fix this one. I tried un-commenting the dependency in flume-ng-dist/pom.xml but for some reason it doesn't build like that:

          [/cloud/repos/flume (trunk *+)] mvn clean test
          [INFO] Scanning for projects...
          [ERROR] The build could not read 1 project -> [Help 1]
          [ERROR]
          [ERROR] The project org.apache.flume:flume-ng-dist:1.4.0-SNAPSHOT (/Users/hoschek/unix/cloud/repos/flume/flume-ng-dist/pom.xml) has 1 error
          [ERROR] 'dependencies.dependency.version' for org.apache.flume.flume-ng-sinks:flume-ng-morphline-solr-sink:jar is missing. @ line 115, column 17
          [ERROR]
          [ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
          [ERROR] Re-run Maven using the -X switch to enable full debug logging.
          [ERROR]
          [ERROR] For more information about the errors and possible solutions, please read the following articles:
          [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/ProjectBuildingException

          When I comment out the dependency in flume-ng-dist/pom.xml it builds fine. But then the dist is incomplete, of course. I believe it might work if you run it once commented out and produce maven artefacts this way, then un-comment the dependency and rerun and now it might work.

          Show
          whoschek wolfgang hoschek added a comment - This need not be synchronized, since only one thread - the sink runner will call process on a particular sink thanks - this is now fixed This counter should be incremented every time indexer.process() is called (though not all sinks even try to update this counter} I looked at HDFSEventSink and it behaves exactly like the MorphlineSink in this regard We should log the exceptions if the rollbacks (for the indexer or the channel failed}) thanks - this is now fixed Why not use a LinkedBlockingDeque or something like that here thanks - this is now fixed Also we might want to make sure we only spawn a maximum number of the LocalMorphlineInterceptors? The maximum number of the LocalMorphlineInterceptors won't get bigger than the number of concurrent threads, so this seems fine to me without an explicit limit This array can be pre-allocated and reused no? I'm not sure it can be reused in a thread safe way and if thread safety is required here. This code seems to be repeated in BlobHandler and BlobDeserializer, maybe move it to a util class or something? I'd rather keep it separate for the time being. For examnple, at some point you guys might decide to pull one of the two classes up into a higher package and in this case it's easier to not have the code entangled. Also, could you please rebase on trunk? yep, i've attached a new patch Also, we should see if we can fix the build issue. I don't know how to fix this one. I tried un-commenting the dependency in flume-ng-dist/pom.xml but for some reason it doesn't build like that: [/cloud/repos/flume (trunk *+)] mvn clean test [INFO] Scanning for projects... [ERROR] The build could not read 1 project -> [Help 1] [ERROR] [ERROR] The project org.apache.flume:flume-ng-dist:1.4.0-SNAPSHOT (/Users/hoschek/unix/cloud/repos/flume/flume-ng-dist/pom.xml) has 1 error [ERROR] 'dependencies.dependency.version' for org.apache.flume.flume-ng-sinks:flume-ng-morphline-solr-sink:jar is missing. @ line 115, column 17 [ERROR] [ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch. [ERROR] Re-run Maven using the -X switch to enable full debug logging. [ERROR] [ERROR] For more information about the errors and possible solutions, please read the following articles: [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/ProjectBuildingException When I comment out the dependency in flume-ng-dist/pom.xml it builds fine. But then the dist is incomplete, of course. I believe it might work if you run it once commented out and produce maven artefacts this way, then un-comment the dependency and rerun and now it might work.
          Hide
          whoschek wolfgang hoschek added a comment -

          I'm attaching v4. diff is that split cdk-morphlines-tika has been split into cdk-morphlines-tika-mime and cdk-morphlines-tika-decompress

          Show
          whoschek wolfgang hoschek added a comment - I'm attaching v4. diff is that split cdk-morphlines-tika has been split into cdk-morphlines-tika-mime and cdk-morphlines-tika-decompress
          Hide
          whoschek wolfgang hoschek added a comment -

          Here is a patch where morphline variables can now also be passed from flume.conf to the morphline, e.g.:
          agent.sinks.solrSink.morphlineVariable.zkHost=127.0.0.1:2181/solr

          Show
          whoschek wolfgang hoschek added a comment - Here is a patch where morphline variables can now also be passed from flume.conf to the morphline, e.g.: agent.sinks.solrSink.morphlineVariable.zkHost=127.0.0.1:2181/solr
          Hide
          whoschek wolfgang hoschek added a comment -

          Here is a patch (v6) that updates the ifDetectMimeType.conf test file with a more comprehensive test.

          Show
          whoschek wolfgang hoschek added a comment - Here is a patch (v6) that updates the ifDetectMimeType.conf test file with a more comprehensive test.
          Hide
          whoschek wolfgang hoschek added a comment -

          I've now updated the pom.xml to point to the updated maven modules.

          Show
          whoschek wolfgang hoschek added a comment - I've now updated the pom.xml to point to the updated maven modules.
          Hide
          hshreedharan Hari Shreedharan added a comment -

          Wolfgang,

          Thanks for the patch. I was able to get the build working after uncommenting the flume-ng-dist/pom.xml by adding the morphline sink as a dependency in the top level pom (you can see how the other sub-modules are listed) - and the jar for the sink seems to be successfully generated. I am still reviewing the rest of the patch, but thought it might be useful to let you know now itself.

          Show
          hshreedharan Hari Shreedharan added a comment - Wolfgang, Thanks for the patch. I was able to get the build working after uncommenting the flume-ng-dist/pom.xml by adding the morphline sink as a dependency in the top level pom (you can see how the other sub-modules are listed) - and the jar for the sink seems to be successfully generated. I am still reviewing the rest of the patch, but thought it might be useful to let you know now itself.
          Hide
          hshreedharan Hari Shreedharan added a comment -

          One other thing is that the test files are causing rat check to fail. Could you please add a rat exclude for that directory?

          Show
          hshreedharan Hari Shreedharan added a comment - One other thing is that the test files are causing rat check to fail. Could you please add a rat exclude for that directory?
          Hide
          whoschek wolfgang hoschek added a comment -

          Ok, here is a version with 1) an added rat exclude and 2) added submodule decl in top level pom.

          Show
          whoschek wolfgang hoschek added a comment - Ok, here is a version with 1) an added rat exclude and 2) added submodule decl in top level pom.
          Hide
          hshreedharan Hari Shreedharan added a comment -

          +1. This looks good. I am running a full build now. Will commit this after that. The README.md file was missing the ASF license header, which I am adding.

          Show
          hshreedharan Hari Shreedharan added a comment - +1. This looks good. I am running a full build now. Will commit this after that. The README.md file was missing the ASF license header, which I am adding.
          Hide
          hshreedharan Hari Shreedharan added a comment -

          Patch committed, rev: cf6298415caca606d44fb8a1833337a23d6088d4. Thanks Wolfgang!

          Show
          hshreedharan Hari Shreedharan added a comment - Patch committed, rev: cf6298415caca606d44fb8a1833337a23d6088d4. Thanks Wolfgang!
          Hide
          hudson Hudson added a comment -

          Integrated in flume-trunk #427 (See https://builds.apache.org/job/flume-trunk/427/)
          FLUME-2070. Add a Flume Morphline Solr Sink. (Revision cf6298415caca606d44fb8a1833337a23d6088d4)

          Result = SUCCESS
          hshreedharan : http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=cf6298415caca606d44fb8a1833337a23d6088d4
          Files :

          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testVORBIS.ogg
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSolrSink.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/complex.mbox
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testSVG.svg
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPDF.pdf
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testXML.xml
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWMV.wmv
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/ResettableTestStringInputStream.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.tar
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testKeynote.key
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_hi.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/log4j.properties
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWINMAIL.dat
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_fr.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_id.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/boilerplate.html
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testVISIO.vsd
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_hu.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPPM.ppm
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJPEG_EXIF.jpg.tar.gz
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPPT_various.ppt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/multiline-stacktrace-expected-long-event.log
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_fi.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandler.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/grokIfNotMatchDropRecord.conf
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestBlobHandler.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/protwords.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.7z
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/readClob.conf
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ja.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineInterceptor.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_cz.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testTrueType.ttf
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.gz
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testNumbers.numbers
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_nl.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobDeserializer.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testDITA.dita
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_no.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testFLAC.flac
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_eu.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testMP3i18n.mp3
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestBlobDeserializer.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/multiline-sessions.log
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWindows-x86-32.exe
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testEMLX.emlx
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.csv.gz
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testBMP.bmp
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/hyphenations_ga.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_it.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/README.md
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.csv
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWAR.war
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/synonyms.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-zip-of-zip.zip
          • flume-ng-sinks/pom.xml
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/currency.xml
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_it.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_hy.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ga.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/custom-mimetypes.xml
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_da.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_gl.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/pom.xml
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testRFC822
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/solrCellDocumentTypes.conf
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_th.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.avro
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ro.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testTIFF.tif
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_es.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPNG.png
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ca.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_sv.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_ca.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testRDF.rdf
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stoptags_ja.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWMA.wma
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/stopwords.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/schema.xml
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.bz2
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ar.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_fr.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandlerImpl.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/solrconfig.xml
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_fa.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_bg.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/elevate.xml
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestMorphlineSolrSink.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.tgz
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_el.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433-subschema.avsc
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/FlumeHttpServletRequestWrapper.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWMF.wmf
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/NullHeader.docx
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testEXCEL.xls
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJPEG_EXIF.jpg.gz
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/ifDetectMimeType.conf
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/EmbeddedSource.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testAIFF.aif
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433-medium.avro
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ru.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWAV.wav
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_pt.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWORD_various.doc
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stemdict_nl.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestEnvironment.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.zip
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJPEG_EXIF.jpg
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_de.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testKML.kml
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJAR.jar
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_en.txt
          • flume-ng-dist/pom.xml
          • pom.xml
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testEXCEL.xlsx
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-outlook.msg
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testRTFVarious.rtf
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_lv.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/userdict_ja.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPages.pages
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testBMPfp.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/UUIDInterceptor.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/non-length-delimited-20130430-234145-tweets.json.gz
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_ga.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.ssv
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestUUIDInterceptor.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestMorphlineInterceptor.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/multiline-stacktrace.log
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPPT_various.pptx
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testFLAC.oga
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.tar.gz
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_tr.txt
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.tsv
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.avsc
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/noOperation.conf
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPSD.psd
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/rsstest.rss
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.tbz2
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobHandler.java
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.cpio
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testGIF.gif
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testMP4.m4a
          • flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testFLV.flv
          Show
          hudson Hudson added a comment - Integrated in flume-trunk #427 (See https://builds.apache.org/job/flume-trunk/427/ ) FLUME-2070 . Add a Flume Morphline Solr Sink. (Revision cf6298415caca606d44fb8a1833337a23d6088d4) Result = SUCCESS hshreedharan : http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=cf6298415caca606d44fb8a1833337a23d6088d4 Files : flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testVORBIS.ogg flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSolrSink.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/complex.mbox flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testSVG.svg flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPDF.pdf flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testXML.xml flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWMV.wmv flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/ResettableTestStringInputStream.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.tar flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testKeynote.key flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_hi.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/log4j.properties flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWINMAIL.dat flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_fr.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_id.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/boilerplate.html flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testVISIO.vsd flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_hu.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPPM.ppm flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJPEG_EXIF.jpg.tar.gz flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPPT_various.ppt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/multiline-stacktrace-expected-long-event.log flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_fi.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandler.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/grokIfNotMatchDropRecord.conf flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestBlobHandler.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/protwords.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.7z flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/readClob.conf flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ja.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineInterceptor.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_cz.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testTrueType.ttf flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.gz flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testNumbers.numbers flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_nl.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobDeserializer.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testDITA.dita flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_no.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testFLAC.flac flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_eu.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433 flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testMP3i18n.mp3 flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestBlobDeserializer.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/multiline-sessions.log flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWindows-x86-32.exe flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testEMLX.emlx flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.csv.gz flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testBMP.bmp flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/hyphenations_ga.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_it.txt flume-ng-sinks/flume-ng-morphline-solr-sink/README.md flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.csv flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWAR.war flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/synonyms.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-zip-of-zip.zip flume-ng-sinks/pom.xml flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/currency.xml flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_it.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_hy.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ga.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/custom-mimetypes.xml flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_da.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_gl.txt flume-ng-sinks/flume-ng-morphline-solr-sink/pom.xml flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testRFC822 flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/solrCellDocumentTypes.conf flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_th.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.avro flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ro.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testTIFF.tif flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_es.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPNG.png flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ca.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_sv.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_ca.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testRDF.rdf flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stoptags_ja.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWMA.wma flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/stopwords.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/schema.xml flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.bz2 flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ar.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_fr.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandlerImpl.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/solrconfig.xml flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_fa.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_bg.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/elevate.xml flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestMorphlineSolrSink.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.tgz flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_el.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433-subschema.avsc flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/FlumeHttpServletRequestWrapper.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWMF.wmf flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/NullHeader.docx flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testEXCEL.xls flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJPEG_EXIF.jpg.gz flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/ifDetectMimeType.conf flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/EmbeddedSource.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testAIFF.aif flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433-medium.avro flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_ru.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWAV.wav flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_pt.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testWORD_various.doc flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stemdict_nl.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestEnvironment.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.zip flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJPEG_EXIF.jpg flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_de.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testKML.kml flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testJAR.jar flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_en.txt flume-ng-dist/pom.xml pom.xml flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testEXCEL.xlsx flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-outlook.msg flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testRTFVarious.rtf flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_lv.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/userdict_ja.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPages.pages flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testBMPfp.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/UUIDInterceptor.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/non-length-delimited-20130430-234145-tweets.json.gz flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/contractions_ga.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.ssv flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestUUIDInterceptor.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/java/org/apache/flume/sink/solr/morphline/TestMorphlineInterceptor.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/multiline-stacktrace.log flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPPT_various.pptx flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testFLAC.oga flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.tar.gz flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/solr/collection1/conf/lang/stopwords_tr.txt flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/cars.tsv flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/sample-statuses-20120906-141433.avsc flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-morphlines/noOperation.conf flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testPSD.psd flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/rsstest.rss flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.tbz2 flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobHandler.java flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/test-documents.cpio flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testGIF.gif flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testMP4.m4a flume-ng-sinks/flume-ng-morphline-solr-sink/src/test/resources/test-documents/testFLV.flv

            People

            • Assignee:
              whoschek wolfgang hoschek
              Reporter:
              whoschek wolfgang hoschek
            • Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development