��ស់រូបភាពខាងក្រោម',
		bgFixed : 'ទំព័រក្រោមមិនប្តូរ',
		txtColor : 'ពណ៌អក្សរ',
		margin : 'ស៊ុមទំព័រ',
		marginTop : 'លើ',
		marginLeft : 'ឆ្វេង',
		marginRight : 'ស្ដាំ',
		marginBottom : 'ក្រោម',
		metaKeywords : 'ពាក្យនៅក្នុងឯកសារ (ផ្តាច់ពីគ្នាដោយក្បៀស)',
		metaDescription : 'សេចក្តីអត្ថាធិប្បាយអំពីឯកសារ',
		metaAuthor : 'អ្នកនិពន្ធ',
		metaCopyright : 'រក្សាសិទ្ធិ៏',
		previewHtml : '<p>This is some <strong>sample text</strong>. You are using <a href="javascript:void(0)">CKEditor</a>.</p>' // MISSING
	}
};


package io.ray.streaming.runtime.demo;

import io.ray.api.Ray;
import io.ray.streaming.api.context.StreamingContext;
import io.ray.streaming.api.function.impl.SinkFunction;
import io.ray.streaming.api.stream.DataStreamSource;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;
import java.util.Arrays;
import java.util.concurrent.TimeUnit;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testng.Assert;
import org.testng.annotations.Test;

public class UnionStreamTest {

  private static final Logger LOG = LoggerFactory.getLogger(UnionStreamTest.class);

  @Test(timeOut = 60000)
  public void testUnionStream() throws Exception {
    Ray.shutdown();
    String sinkFileName = "/tmp/testUnionStream.txt";
    Files.deleteIfExists(Paths.get(sinkFileName));

    StreamingContext context = StreamingContext.buildContext();
    DataStreamSource<Integer> streamSource1 =
        DataStreamSource.fromCollection(context, Arrays.asList(1, 1));
    DataStreamSource<Integer> streamSource2 =
        DataStreamSource.fromCollection(context, Arrays.asList(1, 1));
    DataStreamSource<In