diff --git a/FlowPlugins/CommunityFlowPlugins/ffmpegCommand/ffmpegCommandExecute/1.0.0/index.js b/FlowPlugins/CommunityFlowPlugins/ffmpegCommand/ffmpegCommandExecute/1.0.0/index.js
index 57d6fb29b..73d3ebb6f 100644
--- a/FlowPlugins/CommunityFlowPlugins/ffmpegCommand/ffmpegCommandExecute/1.0.0/index.js
+++ b/FlowPlugins/CommunityFlowPlugins/ffmpegCommand/ffmpegCommandExecute/1.0.0/index.js
@@ -118,6 +118,10 @@ var plugin = function (args) { return __awaiter(void 0, void 0, void 0, function
                     }
                     return !stream.removed;
                 });
+                if (streams.length === 0) {
+                    args.jobLog('No streams mapped for new file');
+                    throw new Error('No streams mapped for new file');
+                }
                 _loop_1 = function (i) {
                     var stream = streams[i];
                     stream.outputArgs = stream.outputArgs.map(function (arg) {
diff --git a/FlowPluginsTs/CommunityFlowPlugins/ffmpegCommand/ffmpegCommandExecute/1.0.0/index.ts b/FlowPluginsTs/CommunityFlowPlugins/ffmpegCommand/ffmpegCommandExecute/1.0.0/index.ts
index d2bf22ff3..2791d89a2 100644
--- a/FlowPluginsTs/CommunityFlowPlugins/ffmpegCommand/ffmpegCommandExecute/1.0.0/index.ts
+++ b/FlowPluginsTs/CommunityFlowPlugins/ffmpegCommand/ffmpegCommandExecute/1.0.0/index.ts
@@ -91,6 +91,11 @@ const plugin = async (args: IpluginInputArgs): Promise<IpluginOutputArgs> => {
     return !stream.removed;
   });
 
+  if (streams.length === 0) {
+    args.jobLog('No streams mapped for new file');
+    throw new Error('No streams mapped for new file');
+  }
+
   for (let i = 0; i < streams.length; i += 1) {
     const stream = streams[i];