[hotfix] Declare env and insertStatement transient in DbStateBackend

flink-contrib/flink-streaming-contrib/src/main/java/org/apache/flink/contrib/streaming/state/DbStateBackend.java

@@ -65,7 +65,7 @@ public class DbStateBackend extends StateBackend<DbStateBackend> {
 
 	// ------------------------------------------------------
 
-	private Environment env;
+	private transient Environment env;
 
 	// ------------------------------------------------------
 
@@ -77,7 +77,7 @@ public class DbStateBackend extends StateBackend<DbStateBackend> {
 	private final int numSqlRetries;
 	private final int sqlRetrySleep;
 
-	private PreparedStatement insertStatement;
+	private transient PreparedStatement insertStatement;
 
 	// ------------------------------------------------------
 

flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java

@@ -47,7 +47,7 @@ public abstract class StateBackend<Backend extends StateBackend<Backend>> implem
 	 * This method is called by the task upon deployment to initialize the state backend for
 	 * data for a specific job.
 	 *
-	 * @param The {@link Environment} of the task that instantiated the state backend					
+	 * @param env The {@link Environment} of the task that instantiated the state backend
 	 * @throws Exception Overwritten versions of this method may throw exceptions, in which
 	 *                   case the job that uses the state backend is considered failed during
 	 *                   deployment.

flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java

@@ -525,7 +525,7 @@ public abstract class StreamTask<OUT, Operator extends StreamOperator<OUT>>
 
 				case "filesystem":
 					FsStateBackend backend = new FsStateBackendFactory().createFromConfig(flinkConfig);
-					LOG.info("State backend is set to heap memory (checkpoints to filesystem \""
+					LOG.info("State backend is set to filesystem (checkpoints to filesystem \""
 						+ backend.getBasePath() + "\")");
 					return backend;