<NME> TestFanOutSink.java
<BEF> ADDFILE
<MSG> FLUME-411: Events sent down each branch of a FanOutSink should be independent

<DFF> @@ -0,0 +1,42 @@
+/**
+ * Licensed to Cloudera, Inc. under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  Cloudera, Inc. licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.cloudera.flume.core;
+
+import java.io.IOException;
+
+import org.junit.Test;
+
+import com.cloudera.flume.conf.Context;
+import com.cloudera.flume.conf.FlumeBuilder;
+import com.cloudera.flume.conf.FlumeSpecException;
+
+public class TestFanOutSink {
+
+  /**
+   * Verify that events are independent down each fanout path
+   */
+  @Test
+  public void testIndependentEvents() throws FlumeSpecException, IOException {
+
+    String spec = "[ { value(\"foo\",\"bar\") => null}, { value(\"foo\",\"bar\" ) => null } ] ";
+    EventSink snk = FlumeBuilder.buildSink(new Context(), spec);
+    snk.open();
+    snk.append(new EventImpl("event body".getBytes()));
+
+  }
+}

{'addition_count': 42, 'commit_subject': 'FLUME-411: Events sent down each branch of a FanOutSink should be independent', 'deletion_count': 0, 'file_extension': '.java', 'lang': 'java', 'license': 'apache-2.0', 'repo_name': 'cloudera/flume'}