https://flink.apache.org/ logo
Join Slack
Powered by
can i ask why is it that if i have loaded the oper...
# troubleshooting
h
can i ask why is it that if i have loaded the operator with the plugin for s3 and have 
apiVersion: <http://flink.apache.org/v1beta1|flink.apache.org/v1beta1>
kind: FlinkDeployment
metadata:
name: basic-session-deployment-example
spec:
image: flink:1.17
flinkVersion: v1_17c
i need to load the plugin here as well for s3 file system can someone explain
s
Copy code
containers:
        # Do not change the main container name
        - name: flink-main-container
          imagePullPolicy: Always
          env:
            # <https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/resource-providers/standalone/docker/#using-filesystem-plugins>
            - name: ENABLE_BUILT_IN_PLUGINS
              value: flink-s3-fs-hadoop-1.17.1.jar
you need to enable the plugin like I did it here for hadoop
h
thanks i missed that . Cheers
✅ 1
so for the kind:FlinkDeployment env: - name: ENABLE_BUILT_IN_PLUGINS value: "flink-s3-fs-presto-1.17.1.jar" 
[] - Plugin loader with ID found, reusing it: flink-s3-fs-presto-1.17.
Thats nice but the operator is failing 
Caused by: org.apache.flink.core.fs.UnsupportedFileSystemSchemeException: Could not find a file system implementation for scheme 's3p'. The scheme is directly supported by Flink through the following plugin(s): flink-s3-fs-presto. Please ensure that each plugin resides within its own subfolder within the plugins directory.
Even if i put it in the a folder its not loading
s
value: “flink-s3-fs-presto-1.17.1.jar”
please remove the double quotes and try
h
Same error ,
6 Views
Open in Slack
PreviousNext
Powered by