Define different set of advanced parameters for redeploy.

Author: gskrobisz

designer/client/src/components/modals/DeployWithParametersDialog.tsx

@@ -21,6 +21,8 @@ import { NodeTable } from "../graph/node-modal/NodeDetailsContent/NodeTable";
 import { ToggleProcessActionModalData } from "./DeployProcessDialog";
 import LoaderSpinner from "../spinner/Spinner";
 import { useErrorBoundary } from "react-error-boundary";
+import { RootState } from "../../reducers";
+import { getProcessState } from "../../reducers/selectors/scenarioState";
 
 function initialNodesData(params: ActionNodeParameters[]): NodesDeploymentData {
     return params.reduce(
@@ -44,11 +46,16 @@ export function DeployWithParametersDialog(props: WindowContentProps<WindowKind,
     const [parametersDefinition, setParametersDefinition] = useState<ActionNodeParameters[]>([]);
     const [parametersValues, setParametersValues] = useState<NodesDeploymentData>({});
 
+    const scenarioState = useSelector((state: RootState) => getProcessState(state));
+    const scenarioStatusesToActiveDeploy = ["RUNNING", "SCHEDULED"];
+    const isDeploymentActive = scenarioStatusesToActiveDeploy.includes(scenarioState.status.name);
+
     const getActionParameters = useCallback(async () => {
         setIsLoading(true);
         await HttpService.getActionParameters(processName)
             .then((response) => {
-                const definition = response.data.actionNameToParameters["DEPLOY"] || ([] as ActionNodeParameters[]);
+                const actionName = response.data.actionNameToParameters["REDEPLOY"] && isDeploymentActive ? "REDEPLOY" : "DEPLOY";
+                const definition = response.data.actionNameToParameters[actionName] || ([] as ActionNodeParameters[]);
                 const initialValues = initialNodesData(definition);
                 setParametersDefinition(definition);
                 setParametersValues(initialValues);
@@ -59,7 +66,7 @@ export function DeployWithParametersDialog(props: WindowContentProps<WindowKind,
             .finally(() => {
                 setIsLoading(false);
             });
-    }, [processName, showBoundary]);
+    }, [processName, showBoundary, isDeploymentActive]);
 
     useEffect(() => {
         getActionParameters();

designer/client/src/components/toolbars/scenarioDetails/ScenarioLabels.tsx

@@ -32,7 +32,6 @@ interface AddLabelProps {
 const isValidWidthsArray = (widths: number[]): boolean => widths.every((w) => w >= 0 && w !== undefined);
 
 const findThresholdIndex = (numbers: number[], threshold: number): number => {
-    console.log(threshold);
     let sum = 0;
     for (let i = 0; i < numbers.length; i++) {
         sum += numbers[i];

engine/flink/kafka-components-utils/src/main/scala/pl/touk/nussknacker/engine/kafka/source/flink/FlinkKafkaSource.scala

@@ -106,7 +106,25 @@ class FlinkKafkaSource[T](
           label = Some("Offset reset strategy"),
           hintText = None
         ),
-      )
+      ),
+      ScenarioActionName("REDEPLOY") -> Map(
+        OFFSET_RESET_STRATEGY_PARAM_NAME -> ParameterConfig(
+          defaultValue = Some(OffsetResetStrategy.None.toString),
+          editor = Some(
+            FixedValuesWithRadioParameterEditor(
+              List(
+                FixedExpressionValue(
+                  OffsetResetStrategy.None.toString,
+                  s"Resume reading where it previously stopped"
+                ),
+              )
+            )
+          ),
+          validators = None,
+          label = Some("Offset reset strategy"),
+          hintText = None
+        ),
+      ),
     )
   }