Updated on 2025-04-15 GMT+08:00

Flink SQL Redis Development Rules

Job Parameters

The following table describes the parameter settings for Flink Redis jobs.

Table 1 Flink Redis job parameter specifications

Parameter

Mandatory (Yes/No)

Type

Description

zSetScoreColumn

No

String

Column name of the score field in the ZSet format when Redis functions as a dimension table.

hashKeyColumn

No

String

Column name of the Hash field, in hash format.

host

Yes

String

IP address for connecting to the Redis cluster, which is the instance IP address (service plane) of the Redis cluster.

port

Yes

String

Port number of the Redis instance.

The port number of a Redis instance is calculated as follows: 22400 + Instance ID – 1.

To obtain the instance ID, log in to FusionInsight Manager and choose Cluster > Services > Redis. On the page that is displayed, click Redis Manager then click the target Redis cluster name.

For example, in the Redis cluster, the port number of the Redis instance that corresponds to the role R1 port is 22400 (22400 + 1 – 1 = 22400).

separator

No

String

Separator for the fields in a value when Redis functions as a dimension table, for example, (,) and (\u200b).

key-ttl-mode

No

String

Redis data expiration policy. The options include:

  • no-ttl: indicates data does not expire.
  • expire-msec: specifies the period after which data expires, measured in milliseconds.
  • expire-at-date: indicates data expires at the specified time, accurate to seconds.
  • expire-at-timestamp: indicates data expires at the specified time, accurate to milliseconds.

key-ttl

No

String

This parameter is mandatory when key-ttl-mode is set to a value other than no-ttl. The value does not contain a unit.

isSSLMode

No

String

Whether to enable the SSL mode.

  • true: enables the SSL mode.
  • false: disables the SSL mode.

keyPrefix

No

String

Prefix of the Redis key.