Flink SQL Jobs

• How Do I Map an OBS Table to a DLI Partitioned Table?

• How Do I Change the Number of Kafka Partitions in a Flink SQL Job Without Stopping It?

• How Do I Fix the DLI.0005 Error When Using EL Expressions to Create a Table in a Flink SQL Job?

• Why Is No Data Queried in the DLI Table Created Using the OBS File Path When Data Is Written to OBS by a Flink Job Output Stream?

• Why Does a Flink SQL Job Fails to Be Executed, and Is "connect to DIS failed java.lang.IllegalArgumentException: Access key cannot be null" Displayed in the Log?

• Data Writing Fails After a Flink SQL Job Consumed Kafka and Sank Data to the Elasticsearch Cluster

• How Do I Configure Connection Retries for Kafka Sink If it is Disconnected?

• How Do I Write Data to Different Elasticsearch Clusters in a Flink Job?

• Why Does DIS Stream Not Exist During Job Semantic Check?

• Why Is Error "Timeout expired while fetching topic metadata" Repeatedly Reported in Flink JobManager Logs?

last updated: 2025-04-11 20:04 UTC - commit: 66e92698cc0b96f51a527ddcef2a7a175958df69