azagrebin commented on a change in pull request #12690:
URL: https://github.com/apache/flink/pull/12690#discussion_r447536097



##########
File path: docs/ops/deployment/kubernetes.md
##########
@@ -89,6 +93,7 @@ and use `kubectl` to terminate the common components:
     kubectl delete -f flink-configuration-configmap.yaml
     # if created then also the rest service
     kubectl delete -f jobmanager-rest-service.yaml
+    kubectl delete -f taskmanager-query-state-service.yaml

Review comment:
       ```suggestion
       # if created then also the queryable state service
       kubectl delete -f taskmanager-query-state-service.yaml
   ```

##########
File path: docs/ops/deployment/kubernetes.md
##########
@@ -81,6 +81,10 @@ You can then access the Flink UI via different ways:
 
         {% highlight bash %}./bin/flink run -m <public-node-ip>:<node-port> 
./examples/streaming/WordCount.jar{% endhighlight %}
 
+* Create a `NodePort` service on the query state service of taskmanager:

Review comment:
       by using `* ` you continue the list related to:
   `You can then access the Flink UI via different ways:`

##########
File path: docs/ops/deployment/kubernetes.md
##########
@@ -81,6 +81,10 @@ You can then access the Flink UI via different ways:
 
         {% highlight bash %}./bin/flink run -m <public-node-ip>:<node-port> 
./examples/streaming/WordCount.jar{% endhighlight %}
 
+* Create a `NodePort` service on the query state service of taskmanager:

Review comment:
       ```suggestion
   You can also access the queryable state of TaskManager if you create a 
`NodePort` service for it:
   ```

##########
File path: docs/ops/deployment/kubernetes.md
##########
@@ -81,6 +81,10 @@ You can then access the Flink UI via different ways:
 
         {% highlight bash %}./bin/flink run -m <public-node-ip>:<node-port> 
./examples/streaming/WordCount.jar{% endhighlight %}
 
+* Create a `NodePort` service on the query state service of taskmanager:
+    1. Run `kubectl create -f taskmanager-query-state-service.yaml` to create 
the `NodePort` service on taskmanager. The example of 
`taskmanager-query-state-service.yaml` can be found in 
[appendix](#common-cluster-resource-definitions).
+    2. Run `kubectl get svc flink-taskmanager-query-state` to know the 
`node-port` of this service. Then `QueryableStateClient(<public-node-ip>, 
<node-port>)` could be used to submit the user queries.

Review comment:
       ```suggestion
       2. Run `kubectl get svc flink-taskmanager-query-state` to know the 
`node-port` of this service. Then you can create the 
[QueryableStateClient(<public-node-ip>, <node-port>)]({{ site.baseurl 
}}/dev/stream/state/queryable_state.html#querying-state) to submit the state 
queries.
   ```




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to