GoogleCloudPlatform/flink-on-k8s-operator issues and pull requests

#99 - Removed unused base kustomization.

Pull Request - State: closed - Opened by hongyegong about 5 years ago

#98 - Improve the doc for GCS integration

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#97 - Add scripts for testing with Kafka

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#96 - Fix resource keys in tests

Pull Request - State: closed - Opened by elanv about 5 years ago - 2 comments

#95 - Calculate Flink JVM heap size

Pull Request - State: closed - Opened by elanv about 5 years ago - 3 comments

#94 - Add liveness probe for JM/TM containers

Pull Request - State: closed - Opened by functicons about 5 years ago - 2 comments

#93 - Job submission failed for akka.pattern.AskTimeoutException

Issue - State: closed - Opened by functicons about 5 years ago - 2 comments
Labels: bug

#92 - Add doc on setting up test env for streaming applications

Pull Request - State: closed - Opened by functicons about 5 years ago - 4 comments

#91 - Support restore from last savepoint recorded in job status

Pull Request - State: closed - Opened by functicons about 5 years ago - 3 comments

#90 - Added custom docker image with GCS connector

Pull Request - State: closed - Opened by hongyegong about 5 years ago - 2 comments

#89 - Supported checkpoint and savepoint to GCS thru customized flink docke…

Pull Request - State: closed - Opened by hongyegong about 5 years ago

#88 - More than one job were found

Issue - State: closed - Opened by functicons about 5 years ago - 6 comments
Labels: bug

#87 - Make status a subresource which could be updated independently

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#86 - Declarative CRD validation

Issue - State: open - Opened by functicons about 5 years ago
Labels: feature

#85 - Reject unknown fields in the CR

Issue - State: open - Opened by functicons about 5 years ago - 4 comments
Labels: feature

#84 - Support start job from a savepoints dir without specifying savepoint ID

Issue - State: open - Opened by functicons about 5 years ago
Labels: feature

#83 - Support remote job jar

Issue - State: closed - Opened by functicons about 5 years ago - 3 comments
Labels: feature

#82 - Support cancel job with savepoint

Pull Request - State: closed - Opened by functicons about 5 years ago - 3 comments

#81 - Generate a random ID suffix for child resources

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: feature

#80 - Failed to update status

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: bug

#79 - Support cancel job with savepoint

Issue - State: closed - Opened by functicons about 5 years ago
Labels: feature

#78 - Support cluster cleanup policy after job finishes

Pull Request - State: closed - Opened by functicons about 5 years ago - 4 comments

#77 - Add integration tests for the controller

Issue - State: open - Opened by functicons about 5 years ago
Labels: test

#76 - Add configMap for cluster configuration

Pull Request - State: closed - Opened by elanv about 5 years ago - 7 comments

#75 - Add validation for create FlinkCluster requests

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#74 - Add unit test for TimeConverter

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: test

#73 - Add savepoint location in job status

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#72 - Support checkpoint and savepoint to GCS

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: feature

#71 - Fix to parse time format of last savepoint that includes time zone offset

Pull Request - State: closed - Opened by elanv about 5 years ago - 1 comment

#70 - Support taking savepoints periodically

Pull Request - State: closed - Opened by functicons about 5 years ago - 4 comments

#69 - Wait until cluster status is stable before taking reconciliation action

Issue - State: closed - Opened by functicons about 5 years ago
Labels: bug

#68 - Add NotSubmitted as the initial state of job

Issue - State: closed - Opened by functicons about 5 years ago
Labels: good first issue, feature

#67 - Minor refactor

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#66 - Options to handle cluster when job is finished.

Issue - State: closed - Opened by elanv about 5 years ago - 2 comments
Labels: feature

#65 - Upgrade streaming job cluster or session cluster

Issue - State: closed - Opened by elanv about 5 years ago - 5 comments
Labels: feature

#64 - Support for various job submission types and job resource types

Issue - State: open - Opened by elanv about 5 years ago - 6 comments
Labels: feature

#63 - Delay deleting cluster resources by 5 mins after the job finishes

Pull Request - State: closed - Opened by functicons about 5 years ago - 3 comments

#62 - Delay deleting job cluster resources after the job finishes

Issue - State: closed - Opened by functicons about 5 years ago
Labels: feature

#61 - Cancel jobs and take savepoints when deleting a cluster

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: feature

#60 - Provide a source of infinite text stream for test purposes

Issue - State: open - Opened by functicons about 5 years ago - 2 comments
Labels: test

#59 - Add liveness probe for JM/TM containers

Issue - State: closed - Opened by functicons about 5 years ago
Labels: good first issue, feature

#58 - Use ConfigMap for Flink config

Issue - State: closed - Opened by functicons about 5 years ago
Labels: good first issue, feature

#57 - Added flink streaming example to developer guide. Resolves #17

Pull Request - State: closed - Opened by hongyegong about 5 years ago - 3 comments

#56 - Fix JM/TM deployment status

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#55 - Resource leak after deleting JM service on GKE

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: bug

#54 - Fix jobmanager service assert in converter test

Pull Request - State: closed - Opened by elanv about 5 years ago - 1 comment

#53 - Submit job after Flink API is ready

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#52 - Add doc on submitting jobs with port forwarding

Pull Request - State: closed - Opened by functicons about 5 years ago - 2 comments
Labels: documentation

#51 - Add doc on how to submit jobs to a session cluster

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#50 - Add unit test for computing desired state from CR

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#49 - Define a new CRD to submit job to session cluster

Issue - State: open - Opened by functicons about 5 years ago - 5 comments
Labels: feature

#48 - Add unit tests for controller

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: good first issue, test

#47 - JM service status not accurate

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: bug

#46 - Add Cloud Build CI

Pull Request - State: closed - Opened by functicons about 5 years ago

#45 - Add ingress resource

Pull Request - State: closed - Opened by elanv about 5 years ago - 20 comments
Labels: feature

#44 - Add builder image with dependencies installed

Pull Request - State: closed - Opened by functicons about 5 years ago - 1 comment

#43 - Uploaded a Dockerfile for development

Pull Request - State: closed - Opened by hongyegong about 5 years ago - 1 comment

#42 - Getting Flink job ID always fails when job is running and succeeds when job is finished

Issue - State: closed - Opened by functicons about 5 years ago
Labels: bug

#41 - Separate cluster status and job status

Pull Request - State: closed - Opened by functicons about 5 years ago

#40 - Kubernete cluster created by minikube cannot pull image from Google Container Registry

Issue - State: closed - Opened by hongyegong about 5 years ago - 1 comment
Labels: documentation

#39 - Avoid fetching Flink job ID again when it is already recorded

Pull Request - State: closed - Opened by functicons about 5 years ago

#38 - Strange TaskManager deployment status update behavior

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: bug

#37 - Update check_build_deps.sh

Pull Request - State: closed - Opened by hongyegong about 5 years ago

#36 - Add status update events for FlinkCluster CR

Pull Request - State: closed - Opened by functicons about 5 years ago

#35 - Cluster status is still CREATING when the job has finished

Issue - State: closed - Opened by functicons about 5 years ago
Labels: bug

#34 - Support scaling up/down TaskManagers.

Issue - State: open - Opened by functicons about 5 years ago - 2 comments
Labels: feature

#33 - Re-queue the reconcile after reconciliation failed.

Pull Request - State: closed - Opened by hongyegong about 5 years ago

#32 - Check job pod status in addition to job status to update CR status

Pull Request - State: closed - Opened by functicons about 5 years ago

#31 - Support node selector for JobManager and TaskManager pods

Pull Request - State: closed - Opened by functicons about 5 years ago

#30 - Job status is marked as Running in CR when the job pod is still Pending

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: bug

#29 - Test and document Pub/Sub integration with Flink 1.9 image

Issue - State: open - Opened by functicons about 5 years ago
Labels: documentation

#28 - Update CRD doc for TaskManager sidecars

Pull Request - State: closed - Opened by functicons about 5 years ago

#27 - Add sidecars to CRD doc

Issue - State: closed - Opened by functicons about 5 years ago
Labels: bug, documentation

#26 - Support non-default namespace for JM/TM/Job

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment

#25 - Rename EXTRA_FLINK_PROPERTIES to FLINK_PROPERTIES

Pull Request - State: closed - Opened by functicons about 5 years ago

#24 - Rename EXTRA_FLINK_PROPERTIES to FLINK_PROPERTIES

Issue - State: closed - Opened by functicons about 5 years ago

#23 - Add a Dockerfile for build environment

Issue - State: closed - Opened by functicons about 5 years ago
Labels: feature

#22 - Create savepoints periodically

Issue - State: closed - Opened by functicons about 5 years ago
Labels: feature

#21 - Fix Go version check problem

Pull Request - State: closed - Opened by functicons about 5 years ago

#20 - Trigger reconcile periodically

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: feature

#19 - Disallow updating FlinkCluster spec

Pull Request - State: closed - Opened by functicons about 5 years ago

#18 - Set default values for FlinkCluster custom resource

Pull Request - State: closed - Opened by functicons about 5 years ago

#17 - Add an example for streaming job

Issue - State: closed - Opened by functicons about 5 years ago - 2 comments
Labels: documentation

#16 - Improve getting Flink Job ID

Issue - State: closed - Opened by functicons about 5 years ago
Labels: feature

#15 - Separate job client Docker image and Flink JobManager/TaskManager image

Issue - State: closed - Opened by functicons about 5 years ago - 1 comment
Labels: feature

#14 - Support HA mode for JobManager

Issue - State: open - Opened by functicons about 5 years ago - 16 comments
Labels: feature

#13 - Add user guide

Issue - State: closed - Opened by functicons about 5 years ago - 2 comments
Labels: documentation

#12 - Create a Helm chart for the operator

Issue - State: closed - Opened by functicons about 5 years ago
Labels: feature

#11 - Add events to the FlinkCluster CR

Issue - State: closed - Opened by functicons about 5 years ago
Labels: feature

#10 - Support node selector for JobManager and TaskManager pods

Issue - State: closed - Opened by functicons about 5 years ago
Labels: feature

#9 - Fix untyped nil error

Pull Request - State: closed - Opened by functicons about 5 years ago

#8 - Add presubmit check with Cloud Build

Issue - State: closed - Opened by functicons about 5 years ago
Labels: feature

#7 - Add mutating and validating webooks

Issue - State: closed - Opened by functicons about 5 years ago - 4 comments
Labels: feature

#6 - Add boilerplate code for supporting mutating and validating webhooks

Pull Request - State: closed - Opened by functicons about 5 years ago

#5 - Make samples more Minikube friendly

Pull Request - State: closed - Opened by functicons about 5 years ago

#4 - Fix nil pointer error

Pull Request - State: closed - Opened by functicons about 5 years ago

#3 - Add build dependency check in Makefile

Pull Request - State: closed - Opened by functicons about 5 years ago

#2 - Support sidecar containers in TaskManager pod

Pull Request - State: closed - Opened by functicons about 5 years ago

#1 - Pass resource limits to JM/TM containers through Downward API

Pull Request - State: closed - Opened by functicons about 5 years ago

GitHub / GoogleCloudPlatform/flink-on-k8s-operator issues and pull requests