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);