GitHub user fi-ecavc closed a discussion: When the job is executed, the job
automatically exits
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:
- name: flink-main-container
volumeMounts:
- name: juicefs-sc-datalake-pv
mountPath: /opt/flink/datalake
- name: flink-config-volume
mountPath: /opt/flink/conf
volumes:
- name: juicefs-sc-datalake-pv
persistentVolumeClaim:
claimName: juicefs-sc-datalake-pvc
- name: flink-config-volume
configMap:
name: flink-config
items:
- key: flink-conf.yaml
path: flink-conf.yaml
- key: log4j-console.properties
path: log4j-console.properties
imagePullSecrets:
- name: secretstreampark
**### 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/8O9
Op+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+yjwJl8xBdT3Go8sRodmtSR4kSTpM4u9lQQZyhVNIR42jwjAADqdoElhgJhSEUGnQG4jtEiTnO9Dw
ZkbIvidP5A9sWXNQc/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/rcPMFhYE7i519Xb0bN6dZYIdJhMFNm9BMKdyrEqm5iCw1lXN7cRKwOml0G8uQ5vDIGCHt80
LLWfvQsK8MwFdYhfGQudWOjmWOtuyNlTbKCOH/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/B6M3Bfx7cE5Ju3xL9Q58kt5ci33NTZXdMP1IuHyHHS
OQtmxHQlcGr7c2ZTTtK9WD8uwbNzwxyf8cM13MduQEuncONcJ8c4HqLiYIfNluDsc1YBAlHqnICVVnP/S10v0RzSAXBobOR9AucJtQZUzeqoyxGdgjUp8zNoyQEPHIDAV5hUyB0q8AR7CHoU7KErH6TxKHmd5XGUb4nzXeHnml0S04vgjeXGxMfn6I555ZQNCmCSzNls7J4ZHjOLCdFx6h9mPAzsLy3u0v9e1/xTRDboErzyKUDtALVep+WkTtd5/KnluGEZC+OKj0xZ31yszv0Q0cBmc07XmSqG6QeL1UbV+VAhNk4XzNKY3HEuXWTdGRkrV3aeSXKjzhwMPKMAsukE5dyntcunGb1qA59xSUo68YS7dmZNT2VQu2FFllPDSYDngr48E36VS1woYfKBMtg4t/DjJkqD8fQ2ER+POp+fM0f20n3xA1HO23Dbd2gp+Bo2E1DCKr+nQARdb0xszsbX8qAhusDebjD/tfn/W7633FolcCoKflGwRaRA2tpk2mGdg2oe9qAp6XmyLqZsHp6fu4RlxvjQvRk5pZPJfBh01iDjq2XK5RD6mp69s4Xrs6xWDECrUQ3PhlIuZ1YHbker7QJSiARtTeJkxGAL9+BzEk0WoBQNVB74nCDskkRnB1QkQN0ieyEmmV0+94qJ9MxKSlZsikGPNbeleyMC8Fpjvc7U0Qm50w+C9fjJJ4zjEDr1r3XEkW7eso/dBJwgy75l+VrJZfphR8HgoGaweGZbpZSodLKdlt+qQ1NkrtHXJGZ18slN3SiwDJlbbyy28PwjYJT6UhUOlE97bXpOOX9C1Ofv7ZYWn9pKe8sfEpCvRre0AtM2dwOUEO1RLeEqRQ3qqqZIQNE59e6rHzIpc1jGJQdyFdEHr5PY+/ONyKZ2j1DTcmLNSlSHHleEy5a/vNarhl2FVCR8N+fEKGtpGf++MMvb4cbzRT6Yn5x+Oe3flD5wBWIZxAA1ELXmB8Eh08vBb8JuKXzZ5bpb2
h6l/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+vmFs1AYIHT5s94AaVqGxSSPZI
KgxrY2mxrdGfb4GS3c0+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/bj2Wpc3frFbqLO1CmFcIIUneaezih4JWMlMW
AWQBm5WmorOCYr4xWbJmqEX0W1nFejoBKAEOIqMUGVkzY2iA9CrK5NR5C1hyziihJDM+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+/lEexr
7/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+gXss
RVVu2dAmy44rq/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/ITHCSXrbGqq9WFgEabaRIXjELb3T28OXhzuD20e1RGIe0FxSqQ
EkoP342wIFUF66t2kCO0ZJILdXtxOVbyM+BWtPbYIt/B6M3Bfx7cE5Ju3xL9Q58kt5ci33NTZXdMP1IuHyHHSOQtmxHQlcGr7c2ZTTtK9WD8uwbNzwxyf8cM13MduQEuncONcJ8c4HqLiYIfNluDsc1YBAlHqnICVVnP/S10v0RzSAXBobOR9AucJtQZUzeqoyxGdgjUp8zNoyQEPHIDAV5hUyB0q8AR7CHoU7KErH6TxKHmd5XGUb4nzXeHnml0S04vgjeXGxMfn6I555ZQNCmCSzNls7J4ZHjOLCdFx6h9mPAzsLy3u0v9e1/xTRDboErzyKUDtALVep+WkTtd5/KnluGEZC+OKj0xZ31yszv0Q0cBmc07XmSqG6QeL1UbV+VAhNk4XzNKY3HEuXWTdGRkrV3aeSXKjzhwMPKMAsukE5dyntcunGb1qA59xSUo68YS7dmZNT2VQu2FFllPDSYDngr48E36VS1woYfKBMtg4t/DjJkqD8fQ2ER+POp+fM0f20n3xA1HO23Dbd2gp+Bo2E1DCKr+nQARdb0xszsbX8qAhusDebjD/tfn/W7633FolcCoKflGwRaRA2tpk2mGdg2oe9qAp6XmyLqZsHp6fu4RlxvjQvRk5pZPJfBh01iDjq2XK5RD6mp69s4Xrs6xWDECrUQ3PhlIuZ1YHbker7QJSiARtTeJkxGAL9+BzEk0WoBQNVB74nCDskkRnB1QkQN0ieyEmmV0+94qJ9MxKSlZsikGPNbeleyMC8Fpjvc7U0Qm50w+C9fjJJ4zjEDr1r3XEkW7eso/dBJwgy75l+VrJZfphR8HgoGaweGZbpZSodLKdlt+qQ1NkrtHXJGZ18slN3SiwDJlbbyy28PwjYJT6UhUOlE97bXpOOX9C1Ofv7ZYWn9pKe8sfEpCvRre0AtM2dwOUEO1RLeEqRQ3qqqZIQNE59e6rHzIpc1jGJQdyFdEHr5PY+/ONyKZ2j1DTcmLNSlSHHleE
y5a/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/TTUksSc
xJzE4FAFm8CCo=;--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-cluster` has 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-cluster` has 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/bj2Wpc3frFbqLO1CmFcIIUneaezih4JWMlMW
AWQBm5WmorOCYr4xWbJmqEX0W1nFejoBKAEOIqMUGVkzY2iA9CrK5NR5C1hyziihJDM+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+/lEexr
7/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+gXss
RVVu2dAmy44rq/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/ITHCSXrbGqq9WFgEabaRIXjELb3T28OXhzuD20e1RGIe0FxSqQ
EkoP342wIFUF66t2kCO0ZJILdXtxOVbyM+BWtPbYIt/B6M3Bfx7cE5Ju3xL9Q58kt5ci33NTZXdMP1IuHyHHSOQtmxHQlcGr7c2ZTTtK9WD8uwbNzwxyf8cM13MduQEuncONcJ8c4HqLiYIfNluDsc1YBAlHqnICVVnP/S10v0RzSAXBobOR9AucJtQZUzeqoyxGdgjUp8zNoyQEPHIDAV5hUyB0q8AR7CHoU7KErH6TxKHmd5XGUb4nzXeHnml0S04vgjeXGxMfn6I555ZQNCmCSzNls7J4ZHjOLCdFx6h9mPAzsLy3u0v9e1/xTRDboErzyKUDtALVep+WkTtd5/KnluGEZC+OKj0xZ31yszv0Q0cBmc07XmSqG6QeL1UbV+VAhNk4XzNKY3HEuXWTdGRkrV3aeSXKjzhwMPKMAsukE5dyntcunGb1qA59xSUo68YS7dmZNT2VQu2FFllPDSYDngr48E36VS1woYfKBMtg4t/DjJkqD8fQ2ER+POp+fM0f20n3xA1HO23Dbd2gp+Bo2E1DCKr+nQARdb0xszsbX8qAhusDebjD/tfn/W7633FolcCoKflGwRaRA2tpk2mGdg2oe9qAp6XmyLqZsHp6fu4RlxvjQvRk5pZPJfBh01iDjq2XK5RD6mp69s4Xrs6xWDECrUQ3PhlIuZ1YHbker7QJSiARtTeJkxGAL9+BzEk0WoBQNVB74nCDskkRnB1QkQN0ieyEmmV0+94qJ9MxKSlZsikGPNbeleyMC8Fpjvc7U0Qm50w+C9fjJJ4zjEDr1r3XEkW7eso/dBJwgy75l+VrJZfphR8HgoGaweGZbpZSodLKdlt+qQ1NkrtHXJGZ18slN3SiwDJlbbyy28PwjYJT6UhUOlE97bXpOOX9C1Ofv7ZYWn9pKe8sfEpCvRre0AtM2dwOUEO1RLeEqRQ3qqqZIQNE59e6rHzIpc1jGJQdyFdEHr5PY+/ONyKZ2j1DTcmLNSlSHHleE
y5a/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/TTUksSc
xJzE4FAFm8CCo=;--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.
GitHub link: https://github.com/apache/incubator-streampark/discussions/3205
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]