controllers/flinkcluster/flinkcluster_reconciler.go (4 lines): - line 451: // TODO: Record event or introduce Condition in CRD status to notify update state pended. - line 646: // TODO: Not to delete the job submitter immediately, and retain the latest ones for inspection. - line 758: // TODO: spec.job.cancelRequested will be deprecated - line 765: // TODO: spec.job.savepointGeneration will be deprecated controllers/flinkcluster/flinkcluster_updater.go (3 lines): - line 739: // TODO: It would be ideal to set the times with the timestamp retrieved from the Flink API like /jobs/{job-id}. - line 793: // TODO: SavepointTime should be set with the timestamp generated in job manager. - line 1026: // TODO: Record event or introduce Condition in CRD status to notify update state pended. controllers/flinkcluster/flinkcluster_converter.go (2 lines): - line 1065: // TODO: Validating webhook should verify hostFormat - line 1404: // TODO: Wouldn't it be better to create a file, put it in an operator image, and read from them?. controllers/flinkcluster/flinkcluster_observer.go (1 line): - line 726: // TODO: default limit apis/flinkcluster/v1beta1/flinkcluster_types.go (1 line): - line 420: // TODO: Memory calculation would be change. Let's watch the issue FLINK-13980.