diff --git a/splitter/splitter.go b/splitter/splitter.go
index 9b811a4..ed50863 100644
--- a/splitter/splitter.go
+++ b/splitter/splitter.go
@@ -65,9 +65,11 @@ func unpack(input []byte) (LogEventBatch, error) {
 // RFC3339Micro is the RFC3339 format in microseconds
 const RFC3339Micro = "2006-01-02T15:04:05.999999-07:00"
 
+// http://docs.aws.amazon.com/batch/latest/userguide/job_states.html
+// "log stream name format is jobDefinitionName/default/ecs_task_id (this format may change in the future)."
 const taskMeta = `([a-z0-9-]+)--([a-z0-9-]+)\/` + // env--app
-	`([0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12})\/` + // task-id
-	`([0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12})` // container-id
+	`default\/` +
+	`([0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12})` // task-id
 
 var taskRegex = regexp.MustCompile(taskMeta)
 
diff --git a/splitter/splitter_test.go b/splitter/splitter_test.go
index 2a90c03..20d23c5 100644
--- a/splitter/splitter_test.go
+++ b/splitter/splitter_test.go
@@ -64,7 +64,7 @@ func TestFullLoop(t *testing.T) {
   "messageType": "DATA_MESSAGE",
   "owner": "123456789012",
   "logGroup": "/aws/batch/job",
-  "logStream": "environment--app/11111111-2222-3333-4444-555566667777/88889999-0000-aaa-bbbb-ccccddddeeee",
+  "logStream": "environment--app/default/11111111-2222-3333-4444-555566667777",
   "subscriptionFilters": [
     "MySubscriptionFilter"
   ],
@@ -103,7 +103,7 @@ func TestSplit(t *testing.T) {
 		MessageType:         "DATA_MESSAGE",
 		Owner:               "123456789012",
 		LogGroup:            "/aws/batch/job",
-		LogStream:           "env--app/12345678-1234-1234-1234-555566667777/88889999-0000-aaaa-bbbb-ccccddddeeee",
+		LogStream:           "env--app/default/12345678-1234-1234-1234-555566667777",
 		SubscriptionFilters: []string{"MySubscriptionFilter"},
 		LogEvents: []LogEvent{
 			{