[
https://issues.apache.org/jira/browse/FLINK-28174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Emile updated FLINK-28174:
--------------------------
Description:
I'm trying to use the StatsD metrics reporter with the Flink Kubernetes
Operator. These are the default configurations that I'm using:
{code:yaml}
// Some comments here
defaultConfiguration:
create: true
append: true
flink-conf.yaml: |+
kubernetes.operator.metrics.reporter.stsd.factory.class:
org.apache.flink.metrics.statsd.StatsDReporterFactory
kubernetes.operator.metrics.reporter.stsd.host: localhost
kubernetes.operator.metrics.reporter.stsd.port: 8125
{code}
However, instead of using localhost, I want to dynamically resolve the host.
Instead of _localhost_ as the host, I want to use the value from the field path
_status.hostIP_.
Is this currently possible? If so can you provide assistance, please?
was:
I'm trying to use the StatsD metrics reporter with the Flink Kubernetes
Operator. These are the default configurations that I'm using:
{code:java}
// Some comments here
public String getFoo()
{
return foo;
}
{code}
```
defaultConfiguration:
create: true
append: true
flink-conf.yaml: |+
kubernetes.operator.metrics.reporter.stsd.factory.class:
org.apache.flink.metrics.statsd.StatsDReporterFactory
kubernetes.operator.metrics.reporter.stsd.host: localhost
kubernetes.operator.metrics.reporter.stsd.port: 8125
```
However, instead of using localhost, I want to dynamically resolve the host.
Instead of `localhost` as the host, I want to use the value from the field path
`status.hostIP`.
Is this currently possible? If so can you provide assistance, please?
> Dynamically resolve StatsD Reporter Host
> ----------------------------------------
>
> Key: FLINK-28174
> URL: https://issues.apache.org/jira/browse/FLINK-28174
> Project: Flink
> Issue Type: Bug
> Components: Kubernetes Operator
> Reporter: Emile
> Priority: Blocker
> Labels: question
>
> I'm trying to use the StatsD metrics reporter with the Flink Kubernetes
> Operator. These are the default configurations that I'm using:
> {code:yaml}
> // Some comments here
> defaultConfiguration:
> create: true
> append: true
> flink-conf.yaml: |+
> kubernetes.operator.metrics.reporter.stsd.factory.class:
> org.apache.flink.metrics.statsd.StatsDReporterFactory
> kubernetes.operator.metrics.reporter.stsd.host: localhost
> kubernetes.operator.metrics.reporter.stsd.port: 8125
> {code}
> However, instead of using localhost, I want to dynamically resolve the host.
> Instead of _localhost_ as the host, I want to use the value from the field
> path _status.hostIP_.
> Is this currently possible? If so can you provide assistance, please?
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
