Replies: 1 comment
-
|
2023-09-27 18:56:03.141 [flink-akka.actor.default-dispatcher-14] WARN org.apache.streampark.flink.core.FlinkTableInitializer - [StreamPark] Usage:can't fond config,you can set "--conf $path " in main arguments |
Beta Was this translation helpful? Give feedback.
-
I use my own defined flink base image, the relevant jar package has been copied to the lib and plugins directories, and the pod template is enabled to load pvc, my pod template is as follows:
apiVersion: v1
kind: Pod
metadata:
namespace: kube-system
name: pod-template
spec:
serviceAccount: flink
hostAliases:
- ip: "192.168.0.3"
hostnames:
- "sss.pigsty"
containers:
volumeMounts:
mountPath: /opt/flink/datalake
mountPath: /opt/flink/conf
volumes:
persistentVolumeClaim:
claimName: juicefs-sc-datalake-pvc
configMap:
name: flink-config
items:
- key: flink-conf.yaml
path: flink-conf.yaml
- key: log4j-console.properties
path: log4j-console.properties
imagePullSecrets:
### and I got errors：
sed: couldn't open temporary file /opt/flink/conf/sedNu65YQ: Read-only file system
sed: couldn't open temporary file /opt/flink/conf/sed68j7No: Read-only file system
/docker-entrypoint.sh: line 73: /opt/flink/conf/flink-conf.yaml: Read-only file system
/docker-entrypoint.sh: line 89: /opt/flink/conf/flink-conf.yaml.tmp: Read-only file system
Starting kubernetes-application as a console application on host flink-paimon-datalake-fd7b88d4c-8c2q2.
2023-09-27 18:55:57,751 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - --------------------------------------------------------------------------------
2023-09-27 18:55:57,754 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Preconfiguration:
2023-09-27 18:55:57,811 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] -
RESOURCE_PARAMS extraction logs:
jvm_params: -Xmx469762048 -Xms469762048 -XX:MaxMetaspaceSize=268435456
dynamic_configs: -D jobmanager.memory.off-heap.size=134217728b -D jobmanager.memory.jvm-overhead.min=201326592b -D jobmanager.memory.jvm-metaspace.size=268435456b -D jobmanager.memory.heap.size=469762048b -D jobmanager.memory.jvm-overhead.max=201326592b
logs: WARNING: sun.reflect.Reflection.getCallerClass is not supported. This will impact performance.
INFO [] - Loading configuration property: blob.server.port, 6124
INFO [] - Loading configuration property: state.checkpoints.num-retained, 1
INFO [] - Loading configuration property: jobmanager.execution.failover-strategy, region
INFO [] - Loading configuration property: jobmanager.rpc.address, flink-paimon-datalake.kube-system
INFO [] - Loading configuration property: state.savepoints.dir, file:///opt/flink/savepoints
INFO [] - Loading configuration property: kubernetes.cluster-id, flink-paimon-datalake
INFO [] - Loading configuration property: $internal.application.program-args, --flink.conf;eNrtWmtvG8mV/a5fUZCBUALIpiRPZr3c7AC0LMUaayRDlDPrCRZGsbtIttXd1emHZAb58XvOreoHqddsYOVTPANbIqvuvXUf5z6qXr36vn92Xil1HocmK02kKquqlVHTXIf4Z2YX1Z0ujDq1dRbpKraZ2pvOTvcVfjWFspnhbluo1GJVaLOqiOd1hQ8SR1HpZWFMarKqDJSaGSPkLy6vz45P1CJOZH8Ul24fBLiLqxXWxKW6s8WNWoCUjqKYrHWi4gwfpCIINxZmqYsozpZgna+LeLmqlL3LTFGu4hz8rnmU2WkjTOkIN2xx1rWt/VF6p/bKGKq/gBCPfBQcqD0s4KZd/+3u/n/J7lSvVWYrVZemo67Mt9DkFcSFYGmexDoLZbc/XcsDMn72ROy80liv5SjKLvrLlK52xE78s6qqfDIe393dBVoEDmyxHDdHHJ9DsxezkxGEdns+ZYkpS+jqb3VcQMPztdI5ZAr1HJIm+o72EzOJ+SHDXQF9Z8uhKr39t43UqawREAfvL4DSdKZ2pzN1NttVb6ezs9mQRH49u35/+ela/Tq9uppeXJ+dzNTllTq+vHh3dn12eYHfTtX04rP6cHbxbqgMtAU+5lte8AQQM6YyTRSQVuNMjQh0Ff5e5iaMF3GIo2XLWi+NWtpbU2R0k9wUaVzSqCUEjEAmidO4Eocq7x8LfL53sO3svPrv7/oHZzi2acqA+M6EQZkBZL5V0B6CD3Ho7OB8c2XLioa+W8Whc+qf7fwXnUHjhSpqp2EVwg/mdKDC0FfF/bj2Wpc3frFbqLO1CmFcIIUneaezih4JWMlMWAWQBm5WmorOCYr4xWbJmqEX0W1nFejoBKAEOIqMUGVkzY2iA9CrK5NR5C1hyziihJDM+c6arsI1o5Ec8k/8O9Op+UnlusC/FbHPaWEeZ+Ovdp46UkG5gr5MWFcMLrrpWaZWwCWlb3Wc6HmcxNVaxBuqeOHwpzQtpbLSRTUKk7qsHLEyLGIACY+Cg9c5KHItVLIYp5qrHOIMPWbGScLzVvoGJw0J3ZBTA5EJmqFOknWgPuuC6LnxqVCMl3VhOtvyxGquSxfPzcfyqT98RjXfIUZlF2hueUCws9PTTZGHgfehiUos+JJe42ZXH49Vbouqo9enFpfOgZxat6ly30T9eHj0uqEmB4gz6Gehw3vUnJrijIAXqLdrFZmFrpPKaxH/t+INRfeyASh0C/f0JuiRWxQ2JdCndQZt0juVrSt6laxMIXecmTHTIyCep6nkQHUmoGQzOsplpj5Pry6cBN7JW3vGy8wSu+Eybi8WMDQGrZyDYXMIcV6rDgL3nyP9oZ4jiOG45ZMMHidCvVplMkkaJDF0MjjHjVygNAiBnYzCaqUrtdKI7zD0HwMNGtXAMOQCoZjpGc+NuUC6RvxjY8u/b/GW34YXecNXttI0lRWOqUFhgrCO/97lh85w7lgXtvKpG2KizgH+SNUBxfjtdckswtwd38MOzwnRnCFspRb5+S+/YGely5yuR/exkscIQiujo83TOB6BpxNQ1Ik6/PHgIH3Cl3vo+V2cuU/v39788t4M57h52p2d6Z9NuX3DbeXc7Yzbc1pX+jiv7CfiQJ0tpJr1NRRV+KC7VYiKKF4sgNTI0aj7dGWWsRGlQBtZhSTqXcsf4V6s+ZNlKDtlWyOwmORBkRmWqEbh54VesMDzhrELz6pVeXlPanCcs4fhnr0SlePgQRMM9nty6qS0zuq1K6EJCZt1CxJV5/eu+mR69DEyfPSoYNEmXGZ2lhWVQRom8lALfT5b/vKIqzwPfBsk/0nk6+v0n4O+/lEexr7/OHrjsM+yjwJl8xBdT3Go8sRodmtSR4kSTpM4u9lQQZyhVNIR42jwjAADqdoElhgJhSEUGnQG4jtEiTnO9DwZkbIvidP5A9sWXNQc/uhNB/xZnc59pYldqkxsVTqH3HYRrFlI/J7wCy50aMDwoG8liYFvxLkBK7NlBMflckFyM7KAFI0Ezd64TF2ZTf/AMZeogr0oURz1IGPdM3pvM1j2f/Ow3GPkP3Hdc7mGtVLUviuTOmujVl1Z1O9UosL/XZZzO3JdrUrxU+Bxu7HwkIBcx6a0MAnS2a1phhwSQuxMrN1kPOAvaLHHg0B9avp6gg18rmjyYMOf4rVcpM/xXJxMfaa6h5k9fuyMJe6/abS3gKZVtCjBPl2z1maNPUFl+8MfB+JAi7JR38id8yU6yvdsWaa9luWlmkv2RqN7vVGgPlp06cwENne9OY05uLi8OBlwDjD4u7U3xqCdH7iwukcnqNY54qld13k0gte1GASUSFdalO+aKQl3WHnN8M85/sGnUaB+XdFcv1n7QYgh46G+KH3aKVMi5rJw+aWAqwpFGCe8yS18Q3wEKMXpgknQyuJEPjfQB2WstkEx0YUE9fwrFgNgk/jGdOIoCr1I7B146nxV+pj4BU0jsyi8rC4ki/Z9WmI1booXUa0UehSdLkbWe8Ln/bvT2VDNXg/VsclXQ5UtIEEQBPvqEU1TdCDJu7iYKO+6Y8G08UqPG70j7isiWafDv9W2qFMci5lUxAut5TRPV74J3eYEUtIE+0lA2h64Ic5dHBBOsHKXyfFw4kYKH9EgDvnBUf8DHGpX7TWB3H0xUUeHbw73Hzlu61KBO0EvF0+4T1qR6fH5huu2bTSnd9RQR6U3xItsOC5eB4fBUff9R4e2KeF9VaXJqzL88raOWdSCyUwgoHQpy9d9fmy2G6KegmlwxN8uL78cX51Mr0++TM/Pv2DfPqNo1+Ym819ffjy54BdfPl3Mpqcn+1u4fKuTWqZ8fo+gXssRVVu2dAmy44rq/rcPMFhYE7i519Xb0bN6dZYIdJhMFNm9BMKdyrEqm5iCw1lXN7cRKwOml0G8uQ5vDIGCHt80LLWfvQsK8MwFdYhfGQudWOjmWOtuyNlTbKCOH/mGiJf5yRR8MtigEEj6goXVT8o3RyfNyi1eks1Arh2DoeT4KPUXvlpweGp7MhxLiSuqbQluSHjpI2TR3CBEgOQ48c3Cc+JO1Os0zp5Y2EwuUVlFo+6rEcuBjOsn6q/vTs5PEBaXF1+OpxfHJ+fnUw6ih+rq5Hp6drH9+f8+wS3V30Yo6uHuTPA9flJQPbEvzka5hgdM1MFTy1gHqL+e/M/0+Pr8MwQ7Phmq6fWX85Pp7Fp+fUq4Kk4NSiNIcvC0zlxEwGdGC1hiQ2/l0wLW1PQyM9EEzXBSGrHhrM45nGMX6vzeZ3L00atU5+jzByiab8pojh9dn4JdfwoTXZYjlj8ju4AkIaJh/ZNzCwmKwJPzad6TY4whDRlZvpWE3ZzUV1wuHuqSPs3Bs88dDdrNkckFqHwENrL3BehRDqJe6mtqNtfS8/AuGfYVKXJ6XhVzPcvovtilvjVu6dCnEZ30mXff/z7e3XqyPk20zEMcOIyjuJRyAW1cIVd1QIINvUGg1nqELYrh7ProHldKUKdXNO+7t5ua3A/UA7bsEWt8yIMmfZF1WTNqWKPpDEwwVCtUQeTy1c7lqq12dzlNHVe6IkfaJ9JAu126GRJ6bfzMcbt86ysQXhesoCtgMvxDo1gPq26C0iczbIYw69xP0F0XLLk4sndoOJEIU0+cEJhbQR1ZW+cbX8fifrG0VlEd+hLPtaCoLjIZgLhcmbh+HkBT1ql4xuY4sYvORmejRmcT3pfy5vQF0ukVdKn+oO7MnBoHQHPC9DIJVPwO3tsNwa5OZte+fGsui0oZhp4txMhuviP7ABQgw35VLLw55/ITHCSXrbGqq9WFgEabaRIXjELb3T28OXhzuD20e1RGIe0FxSqQEkoP342wIFUF66t2kCO0ZJILdXtxOVbyM+BWtPbYIt/B6M3Bfx7cE5Ju3xL9Q58kt5ci33NTZXdMP1IuHyHHSOQtmxHQlcGr7c2ZTTtK9WD8uwbNzwxyf8cM13MduQEuncONcJ8c4HqLiYIfNluDsc1YBAlHqnICVVnP/S10v0RzSAXBobOR9AucJtQZUzeqoyxGdgjUp8zNoyQEPHIDAV5hUyB0q8AR7CHoU7KErH6TxKHmd5XGUb4nzXeHnml0S04vgjeXGxMfn6I555ZQNCmCSzNls7J4ZHjOLCdFx6h9mPAzsLy3u0v9e1/xTRDboErzyKUDtALVep+WkTtd5/KnluGEZC+OKj0xZ31yszv0Q0cBmc07XmSqG6QeL1UbV+VAhNk4XzNKY3HEuXWTdGRkrV3aeSXKjzhwMPKMAsukE5dyntcunGb1qA59xSUo68YS7dmZNT2VQu2FFllPDSYDngr48E36VS1woYfKBMtg4t/DjJkqD8fQ2ER+POp+fM0f20n3xA1HO23Dbd2gp+Bo2E1DCKr+nQARdb0xszsbX8qAhusDebjD/tfn/W7633FolcCoKflGwRaRA2tpk2mGdg2oe9qAp6XmyLqZsHp6fu4RlxvjQvRk5pZPJfBh01iDjq2XK5RD6mp69s4Xrs6xWDECrUQ3PhlIuZ1YHbker7QJSiARtTeJkxGAL9+BzEk0WoBQNVB74nCDskkRnB1QkQN0ieyEmmV0+94qJ9MxKSlZsikGPNbeleyMC8Fpjvc7U0Qm50w+C9fjJJ4zjEDr1r3XEkW7eso/dBJwgy75l+VrJZfphR8HgoGaweGZbpZSodLKdlt+qQ1NkrtHXJGZ18slN3SiwDJlbbyy28PwjYJT6UhUOlE97bXpOOX9C1Ofv7ZYWn9pKe8sfEpCvRre0AtM2dwOUEO1RLeEqRQ3qqqZIQNE59e6rHzIpc1jGJQdyFdEHr5PY+/ONyKZ2j1DTcmLNSlSHHleEy5a/vNarhl2FVCR8N+fEKGtpGf++MMvb4cbzRT6Yn5x+Oe3flD5wBWIZxAA1ELXmB8Eh08vBb8JuKXzZ5bpb2h6l/MXmSEJ0B671zpq1ky6jvsw+RJZ6YMpYBpbyrUIewrv4USFW13Eti6lGULFw3JspN7ryNp82A1f3UMAX4JaONGISOTco6kAYhKs2XKZvCTaHgZbr4Sk4FE3xfyPAb9oHlYeBUxct0ybraSAu8h1P+gN/YBSqxuzrvTcQTtOcWM4UeQTzLuxuolRYxBKXgeQzDeTfTJdQ4QoaY7983Q6g1xLeXmJAu5bxXr/h23J25M3yMJ949l0dt6O6QwH7N0uNpoPnoZ46I+LpDBtzrQx2euuHwmNm0d1vV+zTa4npFsskFfinM/uCvYkFcuqdpoa3HhRAjlrAC4jR3UkVCe8hzBPbHDskAXIcFzZcfP92H3zxNZWMtR0MlwgRLeZpO/7XokAApQZzau+hyz0BLdmzQRxRlwaftCLG+1+fomY/u3DvzCQ3244me6uC3oPdN0Yna9RU/m17L8ckFmRF3ejXp3fp0xXb+IyBGSh3JH5fHEbh8Y99gOvjjjIdSP5UpdJ4NfKXO6Bq7WHbC93NKhAYXj3VEOc3ZcS7NTgBrvP2X73viiyYOQXeIFezinexxzMr2fSyL7UXGODibyK4nTKRO7xZ2XzHD/fxloeiq7cYtda86Honqz+B9ftb45BiXA5CxH3Fl2uwtH5uQkJ63dp6KP++qq7sGNecN0ep1K9DsGbclNqPx1xT2zEA1jm9cZTukDxc2uCxebgctyKNqJo4+0phXuZ3U1T2qZ0iz+FNnx3+mpTQexH2z7dd/Eb86TvwaCdtBzt+EfZun3aE7V3lH0dQtVeub6/6tvnHo//h+7OmhsdhFeKTBQjxCynOWRTmAUUsWo6sQfN+xRzv3/U3cMcHuDPzs7/AQP08cg=;--app.name;eNpLy8nMy9YtSMzMzc/TTUksScxJzE4FAFm8CCo=;--parallelism.default;2;--sql;eNqlUUtPhDAQvu+vmFs1AYIHT5s94AaVqGxSSPZIKgxrY2mxrdGfb4GS3c0+LnJo6Mz36syapkmZQpk8vKbQMMt2KOFmAe5rK4Nf3yhrhCwvA1/TTDaqO61UxmooSprlT1PDGkgKEKpmwvIOjWVdP3W2zpG+JfQFHjfU46xxrVvYZuWztye1khJrqzSBFRCfjUwSYQiqt1xJJvyPcbWJp9WPCXvUoUEn0ZAVufcs0nIUjYn2L4s++YiY75eBLr+2Dnl3GYKTWRyfQKYRRR2XZxXmNvu9yh9GHAmUO/sxyMRkGNly4c714RZ7zaWtLHsX+N9NjvVrWxm99jmyvEhpOUhujmIYFI5zkCOYzYIj11a7QH7Tyz+nE8bw
INFO [] - Loading configuration property: parallelism.default, 2
INFO [] - Loading configuration property: kubernetes.namespace, kube-system
INFO [] - Loading configuration property: taskmanager.numberOfTaskSlots, 2
INFO [] - Loading configuration property: kubernetes.rest-service.exposed.type, NodePort
INFO [] - Loading configuration property: state.backend.type, rocksdb
INFO [] - Loading configuration property: kubernetes.container.image.ref, registry.cn-shenzhen.aliyuncs.com/flink-streampark/streamparkflinkjob-kube-system-flink-paimon-datalake
INFO [] - Loading configuration property: $internal.application.main, org.apache.streampark.flink.cli.SqlClient
INFO [] - Loading configuration property: taskmanager.memory.process.size, 1024mb
INFO [] - Loading configuration property: kubernetes.internal.jobmanager.entrypoint.class, org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint
INFO [] - Loading configuration property: pipeline.name, flink-paimon-datalake
INFO [] - Loading configuration property: classloader.resolve-order, child-first
INFO [] - Loading configuration property: kubernetes.pod-template-file.taskmanager, /opt/streampark/workspace/10005/flink-paimon-datalake@kube-system/pod-template.yaml
INFO [] - Loading configuration property: execution.target, kubernetes-application
INFO [] - Loading configuration property: jobmanager.memory.process.size, 1024mb
INFO [] - Loading configuration property: jobmanager.rpc.port, 6123
INFO [] - Loading configuration property: taskmanager.rpc.port, 6122
INFO [] - Loading configuration property: kubernetes.pod-template-file.default, /opt/streampark/workspace/10005/flink-paimon-datalake@kube-system/pod-template.yaml
INFO [] - Loading configuration property: execution.checkpointing.interval, 3min
INFO [] - Loading configuration property: kubernetes.container.image.pull-policy, Always
INFO [] - Loading configuration property: internal.cluster.execution-mode, NORMAL
INFO [] - Loading configuration property: $internal.pipeline.job-id, 727418b2f2814fa198f9cd42b4960af4
INFO [] - Loading configuration property: execution.checkpointing.externalized-checkpoint-retention, [DELETE_ON_CANCELLATION, RETAIN_ON_CANCELLATION]
INFO [] - Loading configuration property: pipeline.jars, local:///opt/flink/usrlib/streampark-flinkjob_flink-paimon-datalake.jar
INFO [] - Loading configuration property: rest.address, localhost
INFO [] - Loading configuration property: kubernetes.pod-template-file.jobmanager, /opt/streampark/workspace/10005/flink-paimon-datalake@kube-system/pod-template.yaml
INFO [] - Loading configuration property: state.checkpoints.dir, file:///opt/flink/checkpoints
INFO [] - The derived from fraction jvm overhead memory (102.400mb (107374184 bytes)) is less than its min value 192.000mb (201326592 bytes), min value will be used instead
INFO [] - Final Master Memory configuration:
INFO [] - Total Process Memory: 1024.000mb (1073741824 bytes)
INFO [] - Total Flink Memory: 576.000mb (603979776 bytes)
INFO [] - JVM Heap: 448.000mb (469762048 bytes)
INFO [] - Off-heap: 128.000mb (134217728 bytes)
INFO [] - JVM Metaspace: 256.000mb (268435456 bytes)
INFO [] - JVM Overhead: 192.000mb (201326592 bytes)
2023-09-27 18:55:57,812 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - --------------------------------------------------------------------------------
2023-09-27 18:55:57,812 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting KubernetesApplicationClusterEntrypoint (Version: 1.17.1, Scala: 2.12, Rev:2750d5c, Date:2023-05-19T10:45:46+02:00)
2023-09-27 18:55:57,812 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - OS current user: flink
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by org.apache.hadoop.security.authentication.util.KerberosUtil (file:/opt/flink/lib/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar) to method sun.security.krb5.Config.getInstance()
WARNING: Please consider reporting this to the maintainers of org.apache.hadoop.security.authentication.util.KerberosUtil
WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations
WARNING: All illegal access operations will be denied in a future release
2023-09-27 18:55:58,240 WARN org.apache.hadoop.util.NativeCodeLoader [] - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2023-09-27 18:55:58,414 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Current Hadoop/Kerberos user: flink
2023-09-27 18:55:58,414 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM: OpenJDK 64-Bit Server VM - Eclipse Adoptium - 11/11.0.19+7
2023-09-27 18:55:58,414 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Arch: amd64
2023-09-27 18:55:58,414 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Maximum heap size: 433 MiBytes
2023-09-27 18:55:58,414 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JAVA_HOME: /opt/java/openjdk
2023-09-27 18:55:58,416 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Hadoop version: 2.8.3
2023-09-27 18:55:58,416 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM Options:
2023-09-27 18:55:58,416 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Xmx469762048
2023-09-27 18:55:58,416 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Xms469762048
2023-09-27 18:55:58,416 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:MaxMetaspaceSize=268435456
2023-09-27 18:55:58,416 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog.file=/opt/flink/log/flink--kubernetes-application-0-flink-paimon-datalake-fd7b88d4c-8c2q2.log
2023-09-27 18:55:58,416 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog4j.configuration=file:/opt/flink/conf/log4j-console.properties
2023-09-27 18:55:58,416 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog4j.configurationFile=file:/opt/flink/conf/log4j-console.properties
2023-09-27 18:55:58,416 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlogback.configurationFile=file:/opt/flink/conf/logback-console.xml
2023-09-27 18:55:58,417 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Program Arguments:
2023-09-27 18:55:58,417 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2023-09-27 18:55:58,417 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.off-heap.size=134217728b
2023-09-27 18:55:58,417 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2023-09-27 18:55:58,418 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-overhead.min=201326592b
2023-09-27 18:55:58,418 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2023-09-27 18:55:58,418 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-metaspace.size=268435456b
2023-09-27 18:55:58,418 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2023-09-27 18:55:58,418 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.heap.size=469762048b
2023-09-27 18:55:58,418 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2023-09-27 18:55:58,418 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-overhead.max=201326592b
2023-09-27 18:55:58,418 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Classpath: /opt/flink/lib/flink-cep-1.17.1.jar:/opt/flink/lib/flink-clients-1.17.1.jar:/opt/flink/lib/flink-connector-files-1.17.1.jar:/opt/flink/lib/flink-csv-1.17.1.jar:/opt/flink/lib/flink-json-1.17.1.jar:/opt/flink/lib/flink-scala_2.12-1.17.1.jar:/opt/flink/lib/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar:/opt/flink/lib/flink-sql-client-1.17.1.jar:/opt/flink/lib/flink-sql-connector-mysql-cdc-2.4.1.jar:/opt/flink/lib/flink-sql-connector-postgres-cdc-2.4.1.jar:/opt/flink/lib/flink-sql-gateway-1.17.1.jar:/opt/flink/lib/flink-table-api-java-uber-1.17.1.jar:/opt/flink/lib/flink-table-planner-loader-1.17.1.jar:/opt/flink/lib/flink-table-runtime-1.17.1.jar:/opt/flink/lib/log4j-1.2-api-2.17.1.jar:/opt/flink/lib/log4j-api-2.17.1.jar:/opt/flink/lib/log4j-core-2.17.1.jar:/opt/flink/lib/log4j-slf4j-impl-2.17.1.jar:/opt/flink/lib/paimon-flink-1.17-0.6-SNAPSHOT.jar:/opt/flink/lib/flink-dist-1.17.1.jar::::
2023-09-27 18:55:58,418 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - --------------------------------------------------------------------------------
2023-09-27 18:55:58,419 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Registered UNIX signal handlers for [TERM, HUP, INT]
2023-09-27 18:55:58,428 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: blob.server.port, 6124
2023-09-27 18:55:58,429 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.num-retained, 1
2023-09-27 18:55:58,429 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.execution.failover-strategy, region
2023-09-27 18:55:58,429 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.address, flink-paimon-datalake.kube-system
2023-09-27 18:55:58,429 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.savepoints.dir, file:///opt/flink/savepoints
2023-09-27 18:55:58,429 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.cluster-id, flink-paimon-datalake
2023-09-27 18:55:58,429 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.application.program-args, --flink.conf;eNrtWmtvG8mV/a5fUZCBUALIpiRPZr3c7AC0LMUaayRDlDPrCRZGsbtIttXd1emHZAb58XvOreoHqddsYOVTPANbIqvuvXUf5z6qXr36vn92Xil1HocmK02kKquqlVHTXIf4Z2YX1Z0ujDq1dRbpKraZ2pvOTvcVfjWFspnhbluo1GJVaLOqiOd1hQ8SR1HpZWFMarKqDJSaGSPkLy6vz45P1CJOZH8Ul24fBLiLqxXWxKW6s8WNWoCUjqKYrHWi4gwfpCIINxZmqYsozpZgna+LeLmqlL3LTFGu4hz8rnmU2WkjTOkIN2xx1rWt/VF6p/bKGKq/gBCPfBQcqD0s4KZd/+3u/n/J7lSvVWYrVZemo67Mt9DkFcSFYGmexDoLZbc/XcsDMn72ROy80liv5SjKLvrLlK52xE78s6qqfDIe393dBVoEDmyxHDdHHJ9DsxezkxGEdns+ZYkpS+jqb3VcQMPztdI5ZAr1HJIm+o72EzOJ+SHDXQF9Z8uhKr39t43UqawREAfvL4DSdKZ2pzN1NttVb6ezs9mQRH49u35/+ela/Tq9uppeXJ+dzNTllTq+vHh3dn12eYHfTtX04rP6cHbxbqgMtAU+5lte8AQQM6YyTRSQVuNMjQh0Ff5e5iaMF3GIo2XLWi+NWtpbU2R0k9wUaVzSqCUEjEAmidO4Eocq7x8LfL53sO3svPrv7/oHZzi2acqA+M6EQZkBZL5V0B6CD3Ho7OB8c2XLioa+W8Whc+qf7fwXnUHjhSpqp2EVwg/mdKDC0FfF/bj2Wpc3frFbqLO1CmFcIIUneaezih4JWMlMWAWQBm5WmorOCYr4xWbJmqEX0W1nFejoBKAEOIqMUGVkzY2iA9CrK5NR5C1hyziihJDM+c6arsI1o5Ec8k/8O9Op+UnlusC/FbHPaWEeZ+Ovdp46UkG5gr5MWFcMLrrpWaZWwCWlb3Wc6HmcxNVaxBuqeOHwpzQtpbLSRTUKk7qsHLEyLGIACY+Cg9c5KHItVLIYp5qrHOIMPWbGScLzVvoGJw0J3ZBTA5EJmqFOknWgPuuC6LnxqVCMl3VhOtvyxGquSxfPzcfyqT98RjXfIUZlF2hueUCws9PTTZGHgfehiUos+JJe42ZXH49Vbouqo9enFpfOgZxat6ly30T9eHj0uqEmB4gz6Gehw3vUnJrijIAXqLdrFZmFrpPKaxH/t+INRfeyASh0C/f0JuiRWxQ2JdCndQZt0juVrSt6laxMIXecmTHTIyCep6nkQHUmoGQzOsplpj5Pry6cBN7JW3vGy8wSu+Eybi8WMDQGrZyDYXMIcV6rDgL3nyP9oZ4jiOG45ZMMHidCvVplMkkaJDF0MjjHjVygNAiBnYzCaqUrtdKI7zD0HwMNGtXAMOQCoZjpGc+NuUC6RvxjY8u/b/GW34YXecNXttI0lRWOqUFhgrCO/97lh85w7lgXtvKpG2KizgH+SNUBxfjtdckswtwd38MOzwnRnCFspRb5+S+/YGely5yuR/exkscIQiujo83TOB6BpxNQ1Ik6/PHgIH3Cl3vo+V2cuU/v39788t4M57h52p2d6Z9NuX3DbeXc7Yzbc1pX+jiv7CfiQJ0tpJr1NRRV+KC7VYiKKF4sgNTI0aj7dGWWsRGlQBtZhSTqXcsf4V6s+ZNlKDtlWyOwmORBkRmWqEbh54VesMDzhrELz6pVeXlPanCcs4fhnr0SlePgQRMM9nty6qS0zuq1K6EJCZt1CxJV5/eu+mR69DEyfPSoYNEmXGZ2lhWVQRom8lALfT5b/vKIqzwPfBsk/0nk6+v0n4O+/lEexr7/OHrjsM+yjwJl8xBdT3Go8sRodmtSR4kSTpM4u9lQQZyhVNIR42jwjAADqdoElhgJhSEUGnQG4jtEiTnO9DwZkbIvidP5A9sWXNQc/uhNB/xZnc59pYldqkxsVTqH3HYRrFlI/J7wCy50aMDwoG8liYFvxLkBK7NlBMflckFyM7KAFI0Ezd64TF2ZTf/AMZeogr0oURz1IGPdM3pvM1j2f/Ow3GPkP3Hdc7mGtVLUviuTOmujVl1Z1O9UosL/XZZzO3JdrUrxU+Bxu7HwkIBcx6a0MAnS2a1phhwSQuxMrN1kPOAvaLHHg0B9avp6gg18rmjyYMOf4rVcpM/xXJxMfaa6h5k9fuyMJe6/abS3gKZVtCjBPl2z1maNPUFl+8MfB+JAi7JR38id8yU6yvdsWaa9luWlmkv2RqN7vVGgPlp06cwENne9OY05uLi8OBlwDjD4u7U3xqCdH7iwukcnqNY54qld13k0gte1GASUSFdalO+aKQl3WHnN8M85/sGnUaB+XdFcv1n7QYgh46G+KH3aKVMi5rJw+aWAqwpFGCe8yS18Q3wEKMXpgknQyuJEPjfQB2WstkEx0YUE9fwrFgNgk/jGdOIoCr1I7B146nxV+pj4BU0jsyi8rC4ki/Z9WmI1booXUa0UehSdLkbWe8Ln/bvT2VDNXg/VsclXQ5UtIEEQBPvqEU1TdCDJu7iYKO+6Y8G08UqPG70j7isiWafDv9W2qFMci5lUxAut5TRPV74J3eYEUtIE+0lA2h64Ic5dHBBOsHKXyfFw4kYKH9EgDvnBUf8DHGpX7TWB3H0xUUeHbw73Hzlu61KBO0EvF0+4T1qR6fH5huu2bTSnd9RQR6U3xItsOC5eB4fBUff9R4e2KeF9VaXJqzL88raOWdSCyUwgoHQpy9d9fmy2G6KegmlwxN8uL78cX51Mr0++TM/Pv2DfPqNo1+Ym819ffjy54BdfPl3Mpqcn+1u4fKuTWqZ8fo+gXssRVVu2dAmy44rq/rcPMFhYE7i519Xb0bN6dZYIdJhMFNm9BMKdyrEqm5iCw1lXN7cRKwOml0G8uQ5vDIGCHt80LLWfvQsK8MwFdYhfGQudWOjmWOtuyNlTbKCOH/mGiJf5yRR8MtigEEj6goXVT8o3RyfNyi1eks1Arh2DoeT4KPUXvlpweGp7MhxLiSuqbQluSHjpI2TR3CBEgOQ48c3Cc+JO1Os0zp5Y2EwuUVlFo+6rEcuBjOsn6q/vTs5PEBaXF1+OpxfHJ+fnUw6ih+rq5Hp6drH9+f8+wS3V30Yo6uHuTPA9flJQPbEvzka5hgdM1MFTy1gHqL+e/M/0+Pr8MwQ7Phmq6fWX85Pp7Fp+fUq4Kk4NSiNIcvC0zlxEwGdGC1hiQ2/l0wLW1PQyM9EEzXBSGrHhrM45nGMX6vzeZ3L00atU5+jzByiab8pojh9dn4JdfwoTXZYjlj8ju4AkIaJh/ZNzCwmKwJPzad6TY4whDRlZvpWE3ZzUV1wuHuqSPs3Bs88dDdrNkckFqHwENrL3BehRDqJe6mtqNtfS8/AuGfYVKXJ6XhVzPcvovtilvjVu6dCnEZ30mXff/z7e3XqyPk20zEMcOIyjuJRyAW1cIVd1QIINvUGg1nqELYrh7ProHldKUKdXNO+7t5ua3A/UA7bsEWt8yIMmfZF1WTNqWKPpDEwwVCtUQeTy1c7lqq12dzlNHVe6IkfaJ9JAu126GRJ6bfzMcbt86ysQXhesoCtgMvxDo1gPq26C0iczbIYw69xP0F0XLLk4sndoOJEIU0+cEJhbQR1ZW+cbX8fifrG0VlEd+hLPtaCoLjIZgLhcmbh+HkBT1ql4xuY4sYvORmejRmcT3pfy5vQF0ukVdKn+oO7MnBoHQHPC9DIJVPwO3tsNwa5OZte+fGsui0oZhp4txMhuviP7ABQgw35VLLw55/ITHCSXrbGqq9WFgEabaRIXjELb3T28OXhzuD20e1RGIe0FxSqQEkoP342wIFUF66t2kCO0ZJILdXtxOVbyM+BWtPbYIt/B6M3Bfx7cE5Ju3xL9Q58kt5ci33NTZXdMP1IuHyHHSOQtmxHQlcGr7c2ZTTtK9WD8uwbNzwxyf8cM13MduQEuncONcJ8c4HqLiYIfNluDsc1YBAlHqnICVVnP/S10v0RzSAXBobOR9AucJtQZUzeqoyxGdgjUp8zNoyQEPHIDAV5hUyB0q8AR7CHoU7KErH6TxKHmd5XGUb4nzXeHnml0S04vgjeXGxMfn6I555ZQNCmCSzNls7J4ZHjOLCdFx6h9mPAzsLy3u0v9e1/xTRDboErzyKUDtALVep+WkTtd5/KnluGEZC+OKj0xZ31yszv0Q0cBmc07XmSqG6QeL1UbV+VAhNk4XzNKY3HEuXWTdGRkrV3aeSXKjzhwMPKMAsukE5dyntcunGb1qA59xSUo68YS7dmZNT2VQu2FFllPDSYDngr48E36VS1woYfKBMtg4t/DjJkqD8fQ2ER+POp+fM0f20n3xA1HO23Dbd2gp+Bo2E1DCKr+nQARdb0xszsbX8qAhusDebjD/tfn/W7633FolcCoKflGwRaRA2tpk2mGdg2oe9qAp6XmyLqZsHp6fu4RlxvjQvRk5pZPJfBh01iDjq2XK5RD6mp69s4Xrs6xWDECrUQ3PhlIuZ1YHbker7QJSiARtTeJkxGAL9+BzEk0WoBQNVB74nCDskkRnB1QkQN0ieyEmmV0+94qJ9MxKSlZsikGPNbeleyMC8Fpjvc7U0Qm50w+C9fjJJ4zjEDr1r3XEkW7eso/dBJwgy75l+VrJZfphR8HgoGaweGZbpZSodLKdlt+qQ1NkrtHXJGZ18slN3SiwDJlbbyy28PwjYJT6UhUOlE97bXpOOX9C1Ofv7ZYWn9pKe8sfEpCvRre0AtM2dwOUEO1RLeEqRQ3qqqZIQNE59e6rHzIpc1jGJQdyFdEHr5PY+/ONyKZ2j1DTcmLNSlSHHleEy5a/vNarhl2FVCR8N+fEKGtpGf++MMvb4cbzRT6Yn5x+Oe3flD5wBWIZxAA1ELXmB8Eh08vBb8JuKXzZ5bpb2h6l/MXmSEJ0B671zpq1ky6jvsw+RJZ6YMpYBpbyrUIewrv4USFW13Eti6lGULFw3JspN7ryNp82A1f3UMAX4JaONGISOTco6kAYhKs2XKZvCTaHgZbr4Sk4FE3xfyPAb9oHlYeBUxct0ybraSAu8h1P+gN/YBSqxuzrvTcQTtOcWM4UeQTzLuxuolRYxBKXgeQzDeTfTJdQ4QoaY7983Q6g1xLeXmJAu5bxXr/h23J25M3yMJ949l0dt6O6QwH7N0uNpoPnoZ46I+LpDBtzrQx2euuHwmNm0d1vV+zTa4npFsskFfinM/uCvYkFcuqdpoa3HhRAjlrAC4jR3UkVCe8hzBPbHDskAXIcFzZcfP92H3zxNZWMtR0MlwgRLeZpO/7XokAApQZzau+hyz0BLdmzQRxRlwaftCLG+1+fomY/u3DvzCQ3244me6uC3oPdN0Yna9RU/m17L8ckFmRF3ejXp3fp0xXb+IyBGSh3JH5fHEbh8Y99gOvjjjIdSP5UpdJ4NfKXO6Bq7WHbC93NKhAYXj3VEOc3ZcS7NTgBrvP2X73viiyYOQXeIFezinexxzMr2fSyL7UXGODibyK4nTKRO7xZ2XzHD/fxloeiq7cYtda86Honqz+B9ftb45BiXA5CxH3Fl2uwtH5uQkJ63dp6KP++qq7sGNecN0ep1K9DsGbclNqPx1xT2zEA1jm9cZTukDxc2uCxebgctyKNqJo4+0phXuZ3U1T2qZ0iz+FNnx3+mpTQexH2z7dd/Eb86TvwaCdtBzt+EfZun3aE7V3lH0dQtVeub6/6tvnHo//h+7OmhsdhFeKTBQjxCynOWRTmAUUsWo6sQfN+xRzv3/U3cMcHuDPzs7/AQP08cg=;--app.name;eNpLy8nMy9YtSMzMzc/TTUksScxJzE4FAFm8CCo=;--parallelism.default;2;--sql;eNqlUUtPhDAQvu+vmFs1AYIHT5s94AaVqGxSSPZIKgxrY2mxrdGfb4GS3c0+LnJo6Mz36syapkmZQpk8vKbQMMt2KOFmAe5rK4Nf3yhrhCwvA1/TTDaqO61UxmooSprlT1PDGkgKEKpmwvIOjWVdP3W2zpG+JfQFHjfU46xxrVvYZuWztye1khJrqzSBFRCfjUwSYQiqt1xJJvyPcbWJp9WPCXvUoUEn0ZAVufcs0nIUjYn2L4s++YiY75eBLr+2Dnl3GYKTWRyfQKYRRR2XZxXmNvu9yh9GHAmUO/sxyMRkGNly4c714RZ7zaWtLHsX+N9NjvVrWxm99jmyvEhpOUhujmIYFI5zkCOYzYIj11a7QH7Tyz+nE8bw
2023-09-27 18:55:58,429 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: parallelism.default, 2
2023-09-27 18:55:58,429 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.namespace, kube-system
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.numberOfTaskSlots, 2
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.rest-service.exposed.type, NodePort
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.type, rocksdb
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.container.image.ref, registry.cn-shenzhen.aliyuncs.com/flink-streampark/streamparkflinkjob-kube-system-flink-paimon-datalake
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.application.main, org.apache.streampark.flink.cli.SqlClient
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.process.size, 1024mb
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.internal.jobmanager.entrypoint.class, org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: pipeline.name, flink-paimon-datalake
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: classloader.resolve-order, child-first
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.taskmanager, /opt/streampark/workspace/10005/flink-paimon-datalake@kube-system/pod-template.yaml
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.target, kubernetes-application
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.memory.process.size, 1024mb
2023-09-27 18:55:58,430 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.port, 6123
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.rpc.port, 6122
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.default, /opt/streampark/workspace/10005/flink-paimon-datalake@kube-system/pod-template.yaml
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.checkpointing.interval, 3min
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.container.image.pull-policy, Always
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: internal.cluster.execution-mode, NORMAL
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.pipeline.job-id, 727418b2f2814fa198f9cd42b4960af4
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.checkpointing.externalized-checkpoint-retention, [DELETE_ON_CANCELLATION, RETAIN_ON_CANCELLATION]
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: pipeline.jars, local:///opt/flink/usrlib/streampark-flinkjob_flink-paimon-datalake.jar
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.address, localhost
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.jobmanager, /opt/streampark/workspace/10005/flink-paimon-datalake@kube-system/pod-template.yaml
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.dir, file:///opt/flink/checkpoints
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading dynamic configuration property: jobmanager.memory.off-heap.size, 134217728b
2023-09-27 18:55:58,431 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading dynamic configuration property: jobmanager.memory.jvm-overhead.min, 201326592b
2023-09-27 18:55:58,432 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading dynamic configuration property: jobmanager.memory.jvm-metaspace.size, 268435456b
2023-09-27 18:55:58,432 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading dynamic configuration property: jobmanager.memory.heap.size, 469762048b
2023-09-27 18:55:58,432 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading dynamic configuration property: jobmanager.memory.jvm-overhead.max, 201326592b
2023-09-27 18:55:58,661 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting KubernetesApplicationClusterEntrypoint.
2023-09-27 18:55:58,721 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install default filesystem.
2023-09-27 18:55:58,737 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-slf4j
2023-09-27 18:55:58,739 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-prometheus
2023-09-27 18:55:58,739 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-statsd
2023-09-27 18:55:58,739 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-graphite
2023-09-27 18:55:58,739 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: external-resource-gpu
2023-09-27 18:55:58,739 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-jmx
2023-09-27 18:55:58,739 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-datadog
2023-09-27 18:55:58,739 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: metrics-influx
2023-09-27 18:55:58,740 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID not found, creating it: s3-fs-hadoop
2023-09-27 18:55:58,869 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install security context.
2023-09-27 18:55:58,920 WARN org.apache.flink.runtime.util.HadoopUtils [] - Could not find Hadoop configuration via any of the supported methods (Flink configuration, environment variables).
2023-09-27 18:55:58,948 INFO org.apache.flink.runtime.security.modules.HadoopModule [] - Hadoop user set to flink (auth:SIMPLE)
2023-09-27 18:55:58,948 INFO org.apache.flink.runtime.security.modules.HadoopModule [] - Kerberos security is disabled.
2023-09-27 18:55:58,951 INFO org.apache.flink.runtime.security.modules.JaasModule [] - Jaas file will be created as /tmp/jaas-2875153330628594427.conf.
2023-09-27 18:55:59,013 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Initializing cluster services.
2023-09-27 18:55:59,017 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Using working directory: WorkingDirectory(/tmp/jm_eb585b8b7db0d71fa88a2268be8d2db9).
2023-09-27 18:55:59,449 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Trying to start actor system, external address flink-paimon-datalake.kube-system:6123, bind address 0.0.0.0:6123.
2023-09-27 18:56:00,625 INFO akka.event.slf4j.Slf4jLogger [] - Slf4jLogger started
2023-09-27 18:56:00,647 INFO akka.remote.RemoteActorRefProvider [] - Akka Cluster not in use - enabling unsafe features anyway because
akka.remote.use-unsafe-remote-features-outside-clusterhas been enabled.2023-09-27 18:56:00,648 INFO akka.remote.Remoting [] - Starting remoting
2023-09-27 18:56:00,845 INFO akka.remote.Remoting [] - Remoting started; listening on addresses :[akka.tcp://[email protected]:6123]
2023-09-27 18:56:01,025 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system started at akka.tcp://[email protected]:6123
2023-09-27 18:56:01,036 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Loading delegation token providers
2023-09-27 18:56:01,038 WARN org.apache.flink.runtime.util.HadoopUtils [] - Could not find Hadoop configuration via any of the supported methods (Flink configuration, environment variables).
2023-09-27 18:56:01,038 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation token provider hadoopfs loaded and initialized
2023-09-27 18:56:01,039 WARN org.apache.flink.runtime.util.HadoopUtils [] - Could not find Hadoop configuration via any of the supported methods (Flink configuration, environment variables).
2023-09-27 18:56:01,039 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation token provider hbase loaded and initialized
2023-09-27 18:56:01,039 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-slf4j
2023-09-27 18:56:01,040 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-prometheus
2023-09-27 18:56:01,040 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-statsd
2023-09-27 18:56:01,040 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-graphite
2023-09-27 18:56:01,040 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: external-resource-gpu
2023-09-27 18:56:01,040 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-jmx
2023-09-27 18:56:01,040 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-datadog
2023-09-27 18:56:01,040 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-influx
2023-09-27 18:56:01,040 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: s3-fs-hadoop
2023-09-27 18:56:01,042 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation token provider s3-hadoop loaded and initialized
2023-09-27 18:56:01,042 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation token providers loaded successfully
2023-09-27 18:56:01,042 INFO org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Loading delegation token receivers
2023-09-27 18:56:01,043 INFO org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Delegation token receiver hadoopfs loaded and initialized
2023-09-27 18:56:01,044 INFO org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Delegation token receiver hbase loaded and initialized
2023-09-27 18:56:01,044 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-slf4j
2023-09-27 18:56:01,044 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-prometheus
2023-09-27 18:56:01,044 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-statsd
2023-09-27 18:56:01,044 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-graphite
2023-09-27 18:56:01,044 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: external-resource-gpu
2023-09-27 18:56:01,044 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-jmx
2023-09-27 18:56:01,044 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-datadog
2023-09-27 18:56:01,044 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: metrics-influx
2023-09-27 18:56:01,045 INFO org.apache.flink.core.plugin.DefaultPluginManager [] - Plugin loader with ID found, reusing it: s3-fs-hadoop
2023-09-27 18:56:01,046 INFO org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Delegation token receiver s3-hadoop loaded and initialized
2023-09-27 18:56:01,046 INFO org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository [] - Delegation token receivers loaded successfully
2023-09-27 18:56:01,046 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Checking provider and receiver instances consistency
2023-09-27 18:56:01,046 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Provider and receiver instances are consistent
2023-09-27 18:56:01,046 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Obtaining delegation tokens
2023-09-27 18:56:01,048 INFO org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Delegation tokens obtained successfully
2023-09-27 18:56:01,048 WARN org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - No tokens obtained so skipping notifications
2023-09-27 18:56:01,061 INFO org.apache.flink.runtime.blob.BlobServer [] - Created BLOB server storage directory /tmp/jm_eb585b8b7db0d71fa88a2268be8d2db9/blobStorage
2023-09-27 18:56:01,064 INFO org.apache.flink.runtime.blob.BlobServer [] - Started BLOB server at 0.0.0.0:6124 - max concurrent requests: 50 - max backlog: 1000
2023-09-27 18:56:01,113 INFO org.apache.flink.runtime.metrics.MetricRegistryImpl [] - No metrics reporter configured, no metrics will be exposed/reported.
2023-09-27 18:56:01,116 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Trying to start actor system, external address flink-paimon-datalake.kube-system:0, bind address 0.0.0.0:0.
2023-09-27 18:56:01,129 INFO akka.event.slf4j.Slf4jLogger [] - Slf4jLogger started
2023-09-27 18:56:01,132 INFO akka.remote.RemoteActorRefProvider [] - Akka Cluster not in use - enabling unsafe features anyway because
akka.remote.use-unsafe-remote-features-outside-clusterhas been enabled.2023-09-27 18:56:01,132 INFO akka.remote.Remoting [] - Starting remoting
2023-09-27 18:56:01,137 INFO akka.remote.Remoting [] - Remoting started; listening on addresses :[akka.tcp://[email protected]:44595]
2023-09-27 18:56:01,143 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system started at akka.tcp://[email protected]:44595
2023-09-27 18:56:01,218 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/rpc/MetricQueryService .
2023-09-27 18:56:01,336 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Upload directory /tmp/flink-web-c69c0686-d98f-4df4-b93a-40958a87338c/flink-web-upload does not exist.
2023-09-27 18:56:01,336 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Created directory /tmp/flink-web-c69c0686-d98f-4df4-b93a-40958a87338c/flink-web-upload for file uploads.
2023-09-27 18:56:01,338 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Starting rest endpoint.
2023-09-27 18:56:01,452 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Determined location of main cluster component log file: /opt/flink/log/flink--kubernetes-application-0-flink-paimon-datalake-fd7b88d4c-8c2q2.log
2023-09-27 18:56:01,452 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Determined location of main cluster component stdout file: /opt/flink/log/flink--kubernetes-application-0-flink-paimon-datalake-fd7b88d4c-8c2q2.out
2023-09-27 18:56:01,617 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Rest endpoint listening at localhost:8081
2023-09-27 18:56:01,619 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - http://localhost:8081 was granted leadership with leaderSessionID=00000000-0000-0000-0000-000000000000
2023-09-27 18:56:01,619 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Web frontend listening at http://localhost:8081.
2023-09-27 18:56:01,629 INFO org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils [] - The derived from fraction jvm overhead memory (102.400mb (107374184 bytes)) is less than its min value 192.000mb (201326592 bytes), min value will be used instead
2023-09-27 18:56:01,630 INFO org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils [] - The derived from fraction network memory (57.600mb (60397978 bytes)) is less than its min value 64.000mb (67108864 bytes), min value will be used instead
2023-09-27 18:56:01,639 INFO org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner [] - DefaultDispatcherRunner was granted leadership with leader id 00000000-0000-0000-0000-000000000000. Creating new DispatcherLeaderProcess.
2023-09-27 18:56:01,643 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Start SessionDispatcherLeaderProcess.
2023-09-27 18:56:01,644 INFO org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Starting resource manager service.
2023-09-27 18:56:01,645 INFO org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Resource manager service is granted leadership with session id 00000000-0000-0000-0000-000000000000.
2023-09-27 18:56:01,646 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Recover all persisted job graphs that are not finished, yet.
2023-09-27 18:56:01,647 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Successfully recovered 0 persisted job graphs.
2023-09-27 18:56:01,720 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/rpc/dispatcher_0 .
2023-09-27 18:56:01,825 INFO org.apache.flink.client.ClientUtils [] - Starting program (detached: true)
2023-09-27 18:56:02,511 ERROR org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler [] - Exception occurred in REST handler: Job 727418b2f2814fa198f9cd42b4960af4 not found
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: blob.server.port, 6124
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.num-retained, 1
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.execution.failover-strategy, region
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.address, flink-paimon-datalake.kube-system
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.savepoints.dir, file:///opt/flink/savepoints
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.cluster-id, flink-paimon-datalake
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.application.program-args, --flink.conf;eNrtWmtvG8mV/a5fUZCBUALIpiRPZr3c7AC0LMUaayRDlDPrCRZGsbtIttXd1emHZAb58XvOreoHqddsYOVTPANbIqvuvXUf5z6qXr36vn92Xil1HocmK02kKquqlVHTXIf4Z2YX1Z0ujDq1dRbpKraZ2pvOTvcVfjWFspnhbluo1GJVaLOqiOd1hQ8SR1HpZWFMarKqDJSaGSPkLy6vz45P1CJOZH8Ul24fBLiLqxXWxKW6s8WNWoCUjqKYrHWi4gwfpCIINxZmqYsozpZgna+LeLmqlL3LTFGu4hz8rnmU2WkjTOkIN2xx1rWt/VF6p/bKGKq/gBCPfBQcqD0s4KZd/+3u/n/J7lSvVWYrVZemo67Mt9DkFcSFYGmexDoLZbc/XcsDMn72ROy80liv5SjKLvrLlK52xE78s6qqfDIe393dBVoEDmyxHDdHHJ9DsxezkxGEdns+ZYkpS+jqb3VcQMPztdI5ZAr1HJIm+o72EzOJ+SHDXQF9Z8uhKr39t43UqawREAfvL4DSdKZ2pzN1NttVb6ezs9mQRH49u35/+ela/Tq9uppeXJ+dzNTllTq+vHh3dn12eYHfTtX04rP6cHbxbqgMtAU+5lte8AQQM6YyTRSQVuNMjQh0Ff5e5iaMF3GIo2XLWi+NWtpbU2R0k9wUaVzSqCUEjEAmidO4Eocq7x8LfL53sO3svPrv7/oHZzi2acqA+M6EQZkBZL5V0B6CD3Ho7OB8c2XLioa+W8Whc+qf7fwXnUHjhSpqp2EVwg/mdKDC0FfF/bj2Wpc3frFbqLO1CmFcIIUneaezih4JWMlMWAWQBm5WmorOCYr4xWbJmqEX0W1nFejoBKAEOIqMUGVkzY2iA9CrK5NR5C1hyziihJDM+c6arsI1o5Ec8k/8O9Op+UnlusC/FbHPaWEeZ+Ovdp46UkG5gr5MWFcMLrrpWaZWwCWlb3Wc6HmcxNVaxBuqeOHwpzQtpbLSRTUKk7qsHLEyLGIACY+Cg9c5KHItVLIYp5qrHOIMPWbGScLzVvoGJw0J3ZBTA5EJmqFOknWgPuuC6LnxqVCMl3VhOtvyxGquSxfPzcfyqT98RjXfIUZlF2hueUCws9PTTZGHgfehiUos+JJe42ZXH49Vbouqo9enFpfOgZxat6ly30T9eHj0uqEmB4gz6Gehw3vUnJrijIAXqLdrFZmFrpPKaxH/t+INRfeyASh0C/f0JuiRWxQ2JdCndQZt0juVrSt6laxMIXecmTHTIyCep6nkQHUmoGQzOsplpj5Pry6cBN7JW3vGy8wSu+Eybi8WMDQGrZyDYXMIcV6rDgL3nyP9oZ4jiOG45ZMMHidCvVplMkkaJDF0MjjHjVygNAiBnYzCaqUrtdKI7zD0HwMNGtXAMOQCoZjpGc+NuUC6RvxjY8u/b/GW34YXecNXttI0lRWOqUFhgrCO/97lh85w7lgXtvKpG2KizgH+SNUBxfjtdckswtwd38MOzwnRnCFspRb5+S+/YGely5yuR/exkscIQiujo83TOB6BpxNQ1Ik6/PHgIH3Cl3vo+V2cuU/v39788t4M57h52p2d6Z9NuX3DbeXc7Yzbc1pX+jiv7CfiQJ0tpJr1NRRV+KC7VYiKKF4sgNTI0aj7dGWWsRGlQBtZhSTqXcsf4V6s+ZNlKDtlWyOwmORBkRmWqEbh54VesMDzhrELz6pVeXlPanCcs4fhnr0SlePgQRMM9nty6qS0zuq1K6EJCZt1CxJV5/eu+mR69DEyfPSoYNEmXGZ2lhWVQRom8lALfT5b/vKIqzwPfBsk/0nk6+v0n4O+/lEexr7/OHrjsM+yjwJl8xBdT3Go8sRodmtSR4kSTpM4u9lQQZyhVNIR42jwjAADqdoElhgJhSEUGnQG4jtEiTnO9DwZkbIvidP5A9sWXNQc/uhNB/xZnc59pYldqkxsVTqH3HYRrFlI/J7wCy50aMDwoG8liYFvxLkBK7NlBMflckFyM7KAFI0Ezd64TF2ZTf/AMZeogr0oURz1IGPdM3pvM1j2f/Ow3GPkP3Hdc7mGtVLUviuTOmujVl1Z1O9UosL/XZZzO3JdrUrxU+Bxu7HwkIBcx6a0MAnS2a1phhwSQuxMrN1kPOAvaLHHg0B9avp6gg18rmjyYMOf4rVcpM/xXJxMfaa6h5k9fuyMJe6/abS3gKZVtCjBPl2z1maNPUFl+8MfB+JAi7JR38id8yU6yvdsWaa9luWlmkv2RqN7vVGgPlp06cwENne9OY05uLi8OBlwDjD4u7U3xqCdH7iwukcnqNY54qld13k0gte1GASUSFdalO+aKQl3WHnN8M85/sGnUaB+XdFcv1n7QYgh46G+KH3aKVMi5rJw+aWAqwpFGCe8yS18Q3wEKMXpgknQyuJEPjfQB2WstkEx0YUE9fwrFgNgk/jGdOIoCr1I7B146nxV+pj4BU0jsyi8rC4ki/Z9WmI1booXUa0UehSdLkbWe8Ln/bvT2VDNXg/VsclXQ5UtIEEQBPvqEU1TdCDJu7iYKO+6Y8G08UqPG70j7isiWafDv9W2qFMci5lUxAut5TRPV74J3eYEUtIE+0lA2h64Ic5dHBBOsHKXyfFw4kYKH9EgDvnBUf8DHGpX7TWB3H0xUUeHbw73Hzlu61KBO0EvF0+4T1qR6fH5huu2bTSnd9RQR6U3xItsOC5eB4fBUff9R4e2KeF9VaXJqzL88raOWdSCyUwgoHQpy9d9fmy2G6KegmlwxN8uL78cX51Mr0++TM/Pv2DfPqNo1+Ym819ffjy54BdfPl3Mpqcn+1u4fKuTWqZ8fo+gXssRVVu2dAmy44rq/rcPMFhYE7i519Xb0bN6dZYIdJhMFNm9BMKdyrEqm5iCw1lXN7cRKwOml0G8uQ5vDIGCHt80LLWfvQsK8MwFdYhfGQudWOjmWOtuyNlTbKCOH/mGiJf5yRR8MtigEEj6goXVT8o3RyfNyi1eks1Arh2DoeT4KPUXvlpweGp7MhxLiSuqbQluSHjpI2TR3CBEgOQ48c3Cc+JO1Os0zp5Y2EwuUVlFo+6rEcuBjOsn6q/vTs5PEBaXF1+OpxfHJ+fnUw6ih+rq5Hp6drH9+f8+wS3V30Yo6uHuTPA9flJQPbEvzka5hgdM1MFTy1gHqL+e/M/0+Pr8MwQ7Phmq6fWX85Pp7Fp+fUq4Kk4NSiNIcvC0zlxEwGdGC1hiQ2/l0wLW1PQyM9EEzXBSGrHhrM45nGMX6vzeZ3L00atU5+jzByiab8pojh9dn4JdfwoTXZYjlj8ju4AkIaJh/ZNzCwmKwJPzad6TY4whDRlZvpWE3ZzUV1wuHuqSPs3Bs88dDdrNkckFqHwENrL3BehRDqJe6mtqNtfS8/AuGfYVKXJ6XhVzPcvovtilvjVu6dCnEZ30mXff/z7e3XqyPk20zEMcOIyjuJRyAW1cIVd1QIINvUGg1nqELYrh7ProHldKUKdXNO+7t5ua3A/UA7bsEWt8yIMmfZF1WTNqWKPpDEwwVCtUQeTy1c7lqq12dzlNHVe6IkfaJ9JAu126GRJ6bfzMcbt86ysQXhesoCtgMvxDo1gPq26C0iczbIYw69xP0F0XLLk4sndoOJEIU0+cEJhbQR1ZW+cbX8fifrG0VlEd+hLPtaCoLjIZgLhcmbh+HkBT1ql4xuY4sYvORmejRmcT3pfy5vQF0ukVdKn+oO7MnBoHQHPC9DIJVPwO3tsNwa5OZte+fGsui0oZhp4txMhuviP7ABQgw35VLLw55/ITHCSXrbGqq9WFgEabaRIXjELb3T28OXhzuD20e1RGIe0FxSqQEkoP342wIFUF66t2kCO0ZJILdXtxOVbyM+BWtPbYIt/B6M3Bfx7cE5Ju3xL9Q58kt5ci33NTZXdMP1IuHyHHSOQtmxHQlcGr7c2ZTTtK9WD8uwbNzwxyf8cM13MduQEuncONcJ8c4HqLiYIfNluDsc1YBAlHqnICVVnP/S10v0RzSAXBobOR9AucJtQZUzeqoyxGdgjUp8zNoyQEPHIDAV5hUyB0q8AR7CHoU7KErH6TxKHmd5XGUb4nzXeHnml0S04vgjeXGxMfn6I555ZQNCmCSzNls7J4ZHjOLCdFx6h9mPAzsLy3u0v9e1/xTRDboErzyKUDtALVep+WkTtd5/KnluGEZC+OKj0xZ31yszv0Q0cBmc07XmSqG6QeL1UbV+VAhNk4XzNKY3HEuXWTdGRkrV3aeSXKjzhwMPKMAsukE5dyntcunGb1qA59xSUo68YS7dmZNT2VQu2FFllPDSYDngr48E36VS1woYfKBMtg4t/DjJkqD8fQ2ER+POp+fM0f20n3xA1HO23Dbd2gp+Bo2E1DCKr+nQARdb0xszsbX8qAhusDebjD/tfn/W7633FolcCoKflGwRaRA2tpk2mGdg2oe9qAp6XmyLqZsHp6fu4RlxvjQvRk5pZPJfBh01iDjq2XK5RD6mp69s4Xrs6xWDECrUQ3PhlIuZ1YHbker7QJSiARtTeJkxGAL9+BzEk0WoBQNVB74nCDskkRnB1QkQN0ieyEmmV0+94qJ9MxKSlZsikGPNbeleyMC8Fpjvc7U0Qm50w+C9fjJJ4zjEDr1r3XEkW7eso/dBJwgy75l+VrJZfphR8HgoGaweGZbpZSodLKdlt+qQ1NkrtHXJGZ18slN3SiwDJlbbyy28PwjYJT6UhUOlE97bXpOOX9C1Ofv7ZYWn9pKe8sfEpCvRre0AtM2dwOUEO1RLeEqRQ3qqqZIQNE59e6rHzIpc1jGJQdyFdEHr5PY+/ONyKZ2j1DTcmLNSlSHHleEy5a/vNarhl2FVCR8N+fEKGtpGf++MMvb4cbzRT6Yn5x+Oe3flD5wBWIZxAA1ELXmB8Eh08vBb8JuKXzZ5bpb2h6l/MXmSEJ0B671zpq1ky6jvsw+RJZ6YMpYBpbyrUIewrv4USFW13Eti6lGULFw3JspN7ryNp82A1f3UMAX4JaONGISOTco6kAYhKs2XKZvCTaHgZbr4Sk4FE3xfyPAb9oHlYeBUxct0ybraSAu8h1P+gN/YBSqxuzrvTcQTtOcWM4UeQTzLuxuolRYxBKXgeQzDeTfTJdQ4QoaY7983Q6g1xLeXmJAu5bxXr/h23J25M3yMJ949l0dt6O6QwH7N0uNpoPnoZ46I+LpDBtzrQx2euuHwmNm0d1vV+zTa4npFsskFfinM/uCvYkFcuqdpoa3HhRAjlrAC4jR3UkVCe8hzBPbHDskAXIcFzZcfP92H3zxNZWMtR0MlwgRLeZpO/7XokAApQZzau+hyz0BLdmzQRxRlwaftCLG+1+fomY/u3DvzCQ3244me6uC3oPdN0Yna9RU/m17L8ckFmRF3ejXp3fp0xXb+IyBGSh3JH5fHEbh8Y99gOvjjjIdSP5UpdJ4NfKXO6Bq7WHbC93NKhAYXj3VEOc3ZcS7NTgBrvP2X73viiyYOQXeIFezinexxzMr2fSyL7UXGODibyK4nTKRO7xZ2XzHD/fxloeiq7cYtda86Honqz+B9ftb45BiXA5CxH3Fl2uwtH5uQkJ63dp6KP++qq7sGNecN0ep1K9DsGbclNqPx1xT2zEA1jm9cZTukDxc2uCxebgctyKNqJo4+0phXuZ3U1T2qZ0iz+FNnx3+mpTQexH2z7dd/Eb86TvwaCdtBzt+EfZun3aE7V3lH0dQtVeub6/6tvnHo//h+7OmhsdhFeKTBQjxCynOWRTmAUUsWo6sQfN+xRzv3/U3cMcHuDPzs7/AQP08cg=;--app.name;eNpLy8nMy9YtSMzMzc/TTUksScxJzE4FAFm8CCo=;--parallelism.default;2;--sql;eNqlUUtPhDAQvu+vmFs1AYIHT5s94AaVqGxSSPZIKgxrY2mxrdGfb4GS3c0+LnJo6Mz36syapkmZQpk8vKbQMMt2KOFmAe5rK4Nf3yhrhCwvA1/TTDaqO61UxmooSprlT1PDGkgKEKpmwvIOjWVdP3W2zpG+JfQFHjfU46xxrVvYZuWztye1khJrqzSBFRCfjUwSYQiqt1xJJvyPcbWJp9WPCXvUoUEn0ZAVufcs0nIUjYn2L4s++YiY75eBLr+2Dnl3GYKTWRyfQKYRRR2XZxXmNvu9yh9GHAmUO/sxyMRkGNly4c714RZ7zaWtLHsX+N9NjvVrWxm99jmyvEhpOUhujmIYFI5zkCOYzYIj11a7QH7Tyz+nE8bw
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: parallelism.default, 2
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.namespace, kube-system
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.numberOfTaskSlots, 2
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.rest-service.exposed.type, NodePort
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.type, rocksdb
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.container.image.ref, registry.cn-shenzhen.aliyuncs.com/flink-streampark/streamparkflinkjob-kube-system-flink-paimon-datalake
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.application.main, org.apache.streampark.flink.cli.SqlClient
2023-09-27 18:56:02,818 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.process.size, 1024mb
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.internal.jobmanager.entrypoint.class, org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: pipeline.name, flink-paimon-datalake
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: classloader.resolve-order, child-first
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.taskmanager, /opt/streampark/workspace/10005/flink-paimon-datalake@kube-system/pod-template.yaml
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.target, kubernetes-application
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.memory.process.size, 1024mb
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.port, 6123
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.rpc.port, 6122
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.default, /opt/streampark/workspace/10005/flink-paimon-datalake@kube-system/pod-template.yaml
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.checkpointing.interval, 3min
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.container.image.pull-policy, Always
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: internal.cluster.execution-mode, NORMAL
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.pipeline.job-id, 727418b2f2814fa198f9cd42b4960af4
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.checkpointing.externalized-checkpoint-retention, [DELETE_ON_CANCELLATION, RETAIN_ON_CANCELLATION]
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: pipeline.jars, local:///opt/flink/usrlib/streampark-flinkjob_flink-paimon-datalake.jar
2023-09-27 18:56:02,819 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.address, localhost
2023-09-27 18:56:02,820 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: kubernetes.pod-template-file.jobmanager, /opt/streampark/workspace/10005/flink-paimon-datalake@kube-system/pod-template.yaml
2023-09-27 18:56:02,820 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.dir, file:///opt/flink/checkpoints
2023-09-27 18:56:02,823 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager at akka://flink/user/rpc/resourcemanager_1 .
2023-09-27 18:56:02,830 INFO org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Starting the resource manager.
Beta Was this translation helpful? Give feedback.
All reactions