src/test/java/org/embulk/output/td/TestRecordWriter.java in embulk-output-td-0.3.1 vs src/test/java/org/embulk/output/td/TestRecordWriter.java in embulk-output-td-0.3.2
- old
+ new
@@ -55,11 +55,11 @@
schema = schema("time", Types.LONG, "_c0", Types.LONG, "_c1", Types.STRING,
"_c2", Types.BOOLEAN, "_c3", Types.DOUBLE, "_c4", Types.TIMESTAMP);
plugin = plugin();
- task = pluginTask(config().set("session_name", "my_session"));
+ task = pluginTask(config().set("session_name", "my_session").set("tmpdir", plugin.getEnvironmentTempDirectory()));
}
@Test
public void checkOpenAndClose()
throws Exception
@@ -190,10 +190,14 @@
public void checkGeneratedTimeValueByOption()
throws Exception
{
schema = schema("_c0", Types.LONG, "_c1", Types.STRING,
"_c2", Types.BOOLEAN, "_c3", Types.DOUBLE, "_c4", Types.TIMESTAMP);
- task = pluginTask(config().set("session_name", "my_session").set("time_value", ImmutableMap.of("from", 0L, "to", 0L)));
+ task = pluginTask(config()
+ .set("session_name", "my_session")
+ .set("time_value", ImmutableMap.of("from", 0L, "to", 0L))
+ .set("tmpdir", plugin.getEnvironmentTempDirectory())
+ );
recordWriter = recordWriter(task, tdClient(plugin, task), fieldWriters(log, task, schema));
try {
recordWriter.open(schema);