Skip to content

Commit

Permalink
[FLINK-10817] Upgrade presto dependency to support path-style access
Browse files Browse the repository at this point in the history
  • Loading branch information
aljoscha committed Jan 17, 2019
1 parent 20ede03 commit 8e1e12e
Show file tree
Hide file tree
Showing 7 changed files with 19 additions and 15 deletions.
8 changes: 4 additions & 4 deletions NOTICE-binary
Original file line number Diff line number Diff line change
Expand Up @@ -2551,12 +2551,12 @@ The Apache Software Foundation (https://www.apache.org/).

This project bundles the following dependencies under the Apache Software License 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)

- com.facebook.presto:presto-hive:0.185
- com.facebook.presto:presto-hive:0.187
- com.facebook.presto.hadoop:hadoop-apache2:2.7.3-1
- com.google.guava:guava:21.0
- io.airlift:configuration:0.148
- io.airlift:log:0.148
- io.airlift:stats:0.148
- io.airlift:configuration:0.153
- io.airlift:log:0.153
- io.airlift:stats:0.153
- io.airlift:units:1.0
- io.airlift:slice:0.31
- com.fasterxml.jackson.core:jackson-annotations:2.8.1
Expand Down
2 changes: 1 addition & 1 deletion docs/ops/filesystems.md
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ including any NFS or SAN that is mounted into that local file system.
the classpath to use them. Both internally use some Hadoop code, but "shade away" all classes to avoid any dependency conflicts.

- `flink-s3-fs-presto`, registered under the scheme *"s3:https://"* and *"s3p:https://"*, is based on code from the [Presto project](https://prestodb.io/).
You can configure it the same way you can [configure the Presto file system](https://prestodb.io/docs/0.185/connector/hive.html#amazon-s3-configuration).
You can configure it the same way you can [configure the Presto file system](https://prestodb.io/docs/0.187/connector/hive.html#amazon-s3-configuration).

- `flink-s3-fs-hadoop`, registered under *"s3:https://"* and *"s3a:https://"*, based on code from the [Hadoop Project](https://hadoop.apache.org/).
The file system can be [configured exactly like Hadoop's s3a](https://hadoop.apache.org/docs/stable/hadoop-aws/tools/hadoop-aws/index.html#S3A).
Expand Down
6 changes: 5 additions & 1 deletion flink-filesystems/flink-s3-fs-presto/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ under the License.
<packaging>jar</packaging>

<properties>
<presto.version>0.185</presto.version>
<presto.version>0.187</presto.version>
</properties>

<dependencies>
Expand Down Expand Up @@ -134,6 +134,10 @@ under the License.
<groupId>io.airlift</groupId>
<artifactId>aircompressor</artifactId>
</exclusion>
<exclusion>
<groupId>io.airlift</groupId>
<artifactId>log-manager</artifactId>
</exclusion>
<exclusion>
<groupId>javax.inject</groupId>
<artifactId>javax.inject</artifactId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
import org.apache.flink.fs.s3.common.writer.S3AccessHelper;
import org.apache.flink.util.FlinkRuntimeException;

import com.facebook.presto.hive.PrestoS3FileSystem;
import com.facebook.presto.hive.s3.PrestoS3FileSystem;
import org.apache.hadoop.fs.FileSystem;

import javax.annotation.Nullable;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,12 @@ The Apache Software Foundation (https://www.apache.org/).

This project bundles the following dependencies under the Apache Software License 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)

- com.facebook.presto:presto-hive:0.185
- com.facebook.presto:presto-hive:0.187
- com.facebook.presto.hadoop:hadoop-apache2:2.7.3-1
- com.google.guava:guava:21.0
- io.airlift:configuration:0.148
- io.airlift:log:0.148
- io.airlift:stats:0.148
- io.airlift:configuration:0.153
- io.airlift:log:0.153
- io.airlift:stats:0.153
- io.airlift:units:1.0
- io.airlift:slice:0.31
- com.fasterxml.jackson.core:jackson-annotations:2.8.1
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,16 +34,16 @@
import java.util.List;
import java.util.UUID;

import static com.facebook.presto.hive.PrestoS3FileSystem.S3_USE_INSTANCE_CREDENTIALS;
import static com.facebook.presto.hive.s3.PrestoS3FileSystem.S3_USE_INSTANCE_CREDENTIALS;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.fail;

/**
* Unit tests for the S3 file system support via Presto's {@link com.facebook.presto.hive.PrestoS3FileSystem}.
* Unit tests for the S3 file system support via Presto's {@link com.facebook.presto.hive.s3.PrestoS3FileSystem}.
*
* <p><strong>BEWARE</strong>: tests must take special care of S3's
* <a href="https://docs.aws.amazon.com/AmazonS3/latest/dev/Introduction.html#ConsistencyModel">consistency guarantees</a>
* and what the {@link com.facebook.presto.hive.PrestoS3FileSystem} offers.
* and what the {@link com.facebook.presto.hive.s3.PrestoS3FileSystem} offers.
*/
@RunWith(Parameterized.class)
public class PrestoS3FileSystemITCase extends AbstractHadoopFileSystemITTest {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.services.s3.AmazonS3Client;
import com.facebook.presto.hive.PrestoS3FileSystem;
import com.facebook.presto.hive.s3.PrestoS3FileSystem;
import org.junit.Test;

import java.lang.reflect.Field;
Expand Down

0 comments on commit 8e1e12e

Please sign in to comment.