You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Xin Chen (Jira)" <ji...@apache.org> on 2025/05/30 03:14:00 UTC
[jira] [Comment Edited] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful
[ https://issues.apache.org/jira/browse/FLINK-37873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955083#comment-17955083 ]
Xin Chen edited comment on FLINK-37873 at 5/30/25 3:13 AM:
-----------------------------------------------------------
I am using Flink-sql-connector-hbase-1.4.
{code:java}
flink-sql-connector-hbase-1.4_1.12.2.jar {code}
There are two main issues here:
# Why does Flink's HBase connector not verify the existence of the table to be operated on? And we just prepare to flush the data directly into it?
# When this table does not exist, it seems that the task will not have any error messages that affect the execution status. There is an error stack that only triggers the hbase client to print this stack when the connector is closed, but it does not affect the task status.
The task status displayed as successful is fatal and can mislead users into thinking that the data has been successfully inserted into HBase！
was (Author: JIRAUSER298666):
I am using Flink-sql-connector-hbase-1.4.
There are two main issues here:
# Why does Flink's HBase connector not verify the existence of the table to be operated on? And we just prepare to flush the data directly into it?
# When this table does not exist, it seems that the task will not have any error messages that affect the execution status. There is an error stack that only triggers the hbase client to print this stack when the connector is closed, but it does not affect the task status.
The task status displayed as successful is fatal and can mislead users into thinking that the data has been successfully inserted into HBase！
> 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful
> ---------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-37873
> URL: https://issues.apache.org/jira/browse/FLINK-37873
> Project: Flink
> Issue Type: Bug
> Reporter: Xin Chen
> Priority: Major
> Fix For: 1.16.2
>
> Attachments: image-2025-05-30-11-02-54-974.png
>
>
> If I have enabled the buffer flush, such as setting ''sink.buffer-flush.max-rows'='1000', but when I specify a table that definitely does not exist, that is, the ‘table-name‘ field is a completely non-existent table, why does the flink task not report an error? It shows successful execution, and there is no error log in the task. Only when closed, there is a stack print.
>
> The Flink SQL:
>
> {code:java}
> tbEnv.executeSql("CREATE TABLE IF NOT EXISTS hTable (\n"
> + "rowkey STRING,\n"
> + "family1 ROW<q1 STRING,q2 STRING>,\n"
> + "family2 ROW<q3 STRING,q4 STRING>,\n"
> + "PRIMARY KEY (rowkey) NOT ENFORCED\n"
> + ") WITH (\n"
> + "'connector' = 'hbase-1.4',\n"
> + "'table-name' = 'mytable3',\n" // mytable3 does not exist in Hbase!!!
> + "'sink.buffer-flush.max-rows' = '1000',\n"
> + "'hbase.regionserver.kerberos.principal' = 'hbase/_HOST@DAHUA.COM',\n"
> + "'hbase.master.kerberos.principal' = 'hbase/_HOST@DAHUA.COM',\n"
> + "'hbase.security.authentication' = 'kerberos',\n"
> + "'hbase.ipc.client.fallback-to-simple-auth-allowed' = 'true',\n"
> + "'zookeeper.quorum' = 'hdp-zookeeper-hdp-zookeeper-0.hdp-zookeeper-hdp-zookeeper.cx-test.svc.cluster.local:2181'\n"
> + " )");
> String sql3 = "insert into hTable values ('200', ROW('300','AAA'), ROW('400','BBB'))";
> tbEnv.executeSql(sql3);{code}
> Flink task state：
>
> !image-2025-05-30-11-02-54-974.png!
> Taskmanager.log:
> {code:java}
> 2025-05-30 09:11:53,825 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Establish JobManager connection for job ffffffffb9bf812e0000000000000000.
> 2025-05-30 09:11:53,828 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Offer reserved slots to the leader of job ffffffffb9bf812e0000000000000000.
> 2025-05-30 09:11:53,850 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 4e07d1d05b97f8882c94c3372b11e540.
> 2025-05-30 09:11:53,855 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 4e07d1d05b97f8882c94c3372b11e540.
> 2025-05-30 09:11:53,885 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task Source: Values(tuples=[[{ 0 }]]) -> Calc(select=[_UTF-16LE'100' AS EXPR$0, (_UTF-16LE'300' ROW _UTF-16LE'AAA') AS EXPR$1, (_UTF-16LE'400' ROW _UTF-16LE'BBB') AS EXPR$2]) -> Sink: Sink(table=[default_catalog.default_database.hTable], fields=[EXPR$0, EXPR$1, EXPR$2]) (1/1)#0 (5675710f80e829cc299d53501cd9765f), deploy into slot with allocation id 4e07d1d05b97f8882c94c3372b11e540.
> 2025-05-30 09:11:53,895 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: Values(tuples=[[{ 0 }]]) -> Calc(select=[_UTF-16LE'100' AS EXPR$0, (_UTF-16LE'300' ROW _UTF-16LE'AAA') AS EXPR$1, (_UTF-16LE'400' ROW _UTF-16LE'BBB') AS EXPR$2]) -> Sink: Sink(table=[default_catalog.default_database.hTable], fields=[EXPR$0, EXPR$1, EXPR$2]) (1/1)#0 (5675710f80e829cc299d53501cd9765f) switched from CREATED to DEPLOYING.
> 2025-05-30 09:11:53,898 INFO org.apache.flink.runtime.taskmanager.Task [] - Loading JAR files for task Source: Values(tuples=[[{ 0 }]]) -> Calc(select=[_UTF-16LE'100' AS EXPR$0, (_UTF-16LE'300' ROW _UTF-16LE'AAA') AS EXPR$1, (_UTF-16LE'400' ROW _UTF-16LE'BBB') AS EXPR$2]) -> Sink: Sink(table=[default_catalog.default_database.hTable], fields=[EXPR$0, EXPR$1, EXPR$2]) (1/1)#0 (5675710f80e829cc299d53501cd9765f) [DEPLOYING].
> 2025-05-30 09:11:54,060 INFO org.apache.flink.runtime.taskmanager.Task [] - Registering task at network: Source: Values(tuples=[[{ 0 }]]) -> Calc(select=[_UTF-16LE'100' AS EXPR$0, (_UTF-16LE'300' ROW _UTF-16LE'AAA') AS EXPR$1, (_UTF-16LE'400' ROW _UTF-16LE'BBB') AS EXPR$2]) -> Sink: Sink(table=[default_catalog.default_database.hTable], fields=[EXPR$0, EXPR$1, EXPR$2]) (1/1)#0 (5675710f80e829cc299d53501cd9765f) [DEPLOYING].
> 2025-05-30 09:11:54,084 INFO org.apache.flink.streaming.runtime.tasks.StreamTask [] - No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
> 2025-05-30 09:11:54,092 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: Values(tuples=[[{ 0 }]]) -> Calc(select=[_UTF-16LE'100' AS EXPR$0, (_UTF-16LE'300' ROW _UTF-16LE'AAA') AS EXPR$1, (_UTF-16LE'400' ROW _UTF-16LE'BBB') AS EXPR$2]) -> Sink: Sink(table=[default_catalog.default_database.hTable], fields=[EXPR$0, EXPR$1, EXPR$2]) (1/1)#0 (5675710f80e829cc299d53501cd9765f) switched from DEPLOYING to RUNNING.
> 2025-05-30 09:11:54,178 WARN org.apache.flink.metrics.MetricGroup [] - The operator name Sink: Sink(table=[default_catalog.default_database.hTable], fields=[EXPR$0, EXPR$1, EXPR$2]) exceeded the 80 characters length limit and was truncated.
> 2025-05-30 09:11:54,461 WARN org.apache.flink.metrics.MetricGroup [] - The operator name Calc(select=[_UTF-16LE'100' AS EXPR$0, (_UTF-16LE'300' ROW _UTF-16LE'AAA') AS EXPR$1, (_UTF-16LE'400' ROW _UTF-16LE'BBB') AS EXPR$2]) exceeded the 80 characters length limit and was truncated.
> =============================================================================================================================================================
> 2025-05-30 09:11:54,494 INFO org.apache.flink.connector.hbase.sink.HBaseSinkFunction [] - start open ...
> 2025-05-30 09:11:54,525 WARN org.apache.flink.connector.hbase.util.HBaseConfigurationUtil [] - Could not find HBase configuration via any of the supported methods (Flink configuration, environment variables).
> 2025-05-30 09:11:54,678 INFO org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper [] - Process identifier=hconnection-0x1a4ac2a8 connecting to ZooKeeper ensemble=hdp-zookeeper-hdp-zookeeper-0.hdp-zookeeper-hdp-zookeeper.cx-test.svc.cluster.local:2181
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:zookeeper.version=3.4.14-HDP-22.10.2-efc83fdf3946366b6cd1191a5af00dd26735cde9, built on 09/06/2022 11:01 GMT
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:host.name=192.168.234.96
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:java.version=1.8.0_342
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:java.vendor=Bisheng
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:java.home=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.342.b07-0.oe2203.x86_64/jre
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:java.class.path=:xxxx
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:java.io.tmpdir=/tmp
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:java.compiler=<NA>
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:os.name=Linux
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:os.arch=amd64
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:os.version=5.10.0-60.66.0.91.oe2203.x86_64
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:user.name=root
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:user.home=/root
> 2025-05-30 09:11:54,684 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Client environment:user.dir=/cloud/data/hadoop/yarn/nodemanager/local/usercache/hadoop/appcache/application_1747795725599_0302/container_1747795725599_0302_01_000002
> 2025-05-30 09:11:54,685 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Initiating client connection, connectString=hdp-zookeeper-hdp-zookeeper-0.hdp-zookeeper-hdp-zookeeper.cx-test.svc.cluster.local:2181 sessionTimeout=90000 watcher=org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.zookeeper.PendingWatcher@4e2b3acc
> 2025-05-30 09:11:54,702 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.Login [] - Client successfully logged in.
> 2025-05-30 09:11:54,703 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.Login [] - TGT refresh thread started.
> 2025-05-30 09:11:54,703 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.Login [] - TGT valid starting at: Fri May 30 09:11:54 CST 2025
> 2025-05-30 09:11:54,703 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.Login [] - TGT expires: Sat May 31 09:11:54 CST 2025
> 2025-05-30 09:11:54,704 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.Login [] - TGT refresh sleeping until: Sat May 31 05:19:36 CST 2025
> 2025-05-30 09:11:54,705 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.client.ZooKeeperSaslClient [] - Client will use GSSAPI as SASL mechanism.
> 2025-05-30 09:11:54,706 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ClientCnxn [] - Opening socket connection to server hdp-zookeeper-hdp-zookeeper-0.hdp-zookeeper-hdp-zookeeper.cx-test.svc.cluster.local/192.168.123.164:2181. Will attempt to SASL-authenticate using Login Context section 'Client'
> 2025-05-30 09:11:54,707 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ClientCnxn [] - Socket connection established to hdp-zookeeper-hdp-zookeeper-0.hdp-zookeeper-hdp-zookeeper.cx-test.svc.cluster.local/192.168.123.164:2181, initiating session
> 2025-05-30 09:11:54,710 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ClientCnxn [] - Session establishment complete on server hdp-zookeeper-hdp-zookeeper-0.hdp-zookeeper-hdp-zookeeper.cx-test.svc.cluster.local/192.168.123.164:2181, sessionid = 0x1008fd670fd20a8, negotiated timeout = 90000
> 2025-05-30 09:11:54,922 INFO org.apache.flink.connector.hbase.sink.HBaseSinkFunction [] - end open.
> =====================================================================================================================================================
> 2025-05-30 09:11:55,211 ERROR org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.AsyncProcess [] - Failed to get region location
> org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.TableNotFoundException: Table 'mytable3' was not found, got: mytable2.
> at org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.locateRegionInMeta(ConnectionManager.java:1345) ~[flink-sql-connector-hbase-1.4_1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.locateRegion(ConnectionManager.java:1221) ~[flink-sql-connector-hbase-1.4_1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.AsyncProcess.submit(AsyncProcess.java:496) ~[flink-sql-connector-hbase-1.4_1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.AsyncProcess.submit(AsyncProcess.java:436) ~[flink-sql-connector-hbase-1.4_1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.BufferedMutatorImpl.backgroundFlushCommits(BufferedMutatorImpl.java:246) ~[flink-sql-connector-hbase-1.4_1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.BufferedMutatorImpl.close(BufferedMutatorImpl.java:186) ~[flink-sql-connector-hbase-1.4_1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.connector.hbase.sink.HBaseSinkFunction.close(HBaseSinkFunction.java:216) ~[flink-sql-connector-hbase-1.4_1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) ~[flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:109) ~[flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.lambda$closeOperator$5(StreamOperatorWrapper.java:213) ~[flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93) ~[flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.closeOperator(StreamOperatorWrapper.java:210) ~[flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.lambda$deferCloseOperatorToMailbox$3(StreamOperatorWrapper.java:185) ~[flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:93) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.tryYield(MailboxExecutorImpl.java:97) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.quiesceTimeServiceAndCloseOperator(StreamOperatorWrapper.java:162) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:131) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:135) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:135) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.OperatorChain.closeOperators(OperatorChain.java:439) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:627) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:589) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:755) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:570) [flink-dist_2.11-1.12.2-HDP-25.04.3.jar:1.12.2-HDP-25.04.3]
> at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342]
> 2025-05-30 09:11:55,220 INFO org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation [] - Closing zookeeper sessionid=0x1008fd670fd20a8
> 2025-05-30 09:11:55,221 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ZooKeeper [] - Session: 0x1008fd670fd20a8 closed
> 2025-05-30 09:11:55,221 INFO org.apache.flink.hbase.shaded.org.apache.zookeeper.ClientCnxn [] - EventThread shut down for session: 0x1008fd670fd20a8
> 2025-05-30 09:11:55,227 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: Values(tuples=[[{ 0 }]]) -> Calc(select=[_UTF-16LE'100' AS EXPR$0, (_UTF-16LE'300' ROW _UTF-16LE'AAA') AS EXPR$1, (_UTF-16LE'400' ROW _UTF-16LE'BBB') AS EXPR$2]) -> Sink: Sink(table=[default_catalog.default_database.hTable], fields=[EXPR$0, EXPR$1, EXPR$2]) (1/1)#0 (5675710f80e829cc299d53501cd9765f) switched from RUNNING to FINISHED.
> 2025-05-30 09:11:55,227 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Source: Values(tuples=[[{ 0 }]]) -> Calc(select=[_UTF-16LE'100' AS EXPR$0, (_UTF-16LE'300' ROW _UTF-16LE'AAA') AS EXPR$1, (_UTF-16LE'400' ROW _UTF-16LE'BBB') AS EXPR$2]) -> Sink: Sink(table=[default_catalog.default_database.hTable], fields=[EXPR$0, EXPR$1, EXPR$2]) (1/1)#0 (5675710f80e829cc299d53501cd9765f).
> 2025-05-30 09:11:55,228 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state FINISHED to JobManager for task Source: Values(tuples=[[{ 0 }]]) -> Calc(select=[_UTF-16LE'100' AS EXPR$0, (_UTF-16LE'300' ROW _UTF-16LE'AAA') AS EXPR$1, (_UTF-16LE'400' ROW _UTF-16LE'BBB') AS EXPR$2]) -> Sink: Sink(table=[default_catalog.default_database.hTable], fields=[EXPR$0, EXPR$1, EXPR$2]) (1/1)#0 5675710f80e829cc299d53501cd9765f.
> 2025-05-30 09:11:55,267 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot TaskSlot(index:0, state:ACTIVE, resource profile: ResourceProfile{cpuCores=1.0000000000000000, taskHeapMemory=25.600mb (26843542 bytes), taskOffHeapMemory=0 bytes, managedMemory=230.400mb (241591914 bytes), networkMemory=64.000mb (67108864 bytes)}, allocationId: 4e07d1d05b97f8882c94c3372b11e540, jobId: ffffffffb9bf812e0000000000000000).
> 2025-05-30 09:11:55,271 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Remove job ffffffffb9bf812e0000000000000000 from job leader monitoring. {code}
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)