We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents de03f66 + 35e21dc commit b7c7598Copy full SHA for b7c7598
scripts/run_pipeline_local.sh
@@ -75,7 +75,7 @@ if [ -f "$BACKBONE_PACKAGED_FILE" ]; then
75
$FLINK_DIR/start-cluster.sh
76
echo "Flink Cluster Started - Job Progress Can be Seen via Configured WebUI Port (Default: localhost:8081)"
77
echo "Submitting Job..."
78
- $FLINK_DIR/flink run -c org.ohnlp.backbone.core.BackboneRunner bin/Backbone-Core-Flink-Packaged.jar --runner=FlinkRunner --config=$BACKBONE_CONFIG
+ $FLINK_DIR/flink run -c org.ohnlp.backbone.core.BackboneRunner bin/Backbone-Core-Flink-Packaged.jar --runner=FlinkRunner --config=$BACKBONE_CONFIG --reIterableGroupByKeyResult
79
read -p "Job Complete, Press [ENTER] to Shut Down Embedded Flink Cluster"
80
$FLINK_DIR/stop-cluster.sh
81
else
0 commit comments