Skip to content

Conversation

@bkahloon
Copy link
Contributor

@bkahloon bkahloon commented Feb 27, 2021

@github-actions github-actions bot added the spark label Feb 27, 2021
String fsscheme = "no_exist";
try {
Configuration conf = SparkSession.active().sessionState().newHadoopConf();
Configuration conf = new Configuration(activeSparkSession().sessionState().newHadoopConf());
Copy link
Contributor

@shardulm94 shardulm94 Feb 28, 2021

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Many changes in this file seems to be copied over from LinkedIn's fork which are not relevant to apache/iceberg. Can you remove these?

linkedin/iceberg#48 does not have these changes either. So not sure how those were copied over.

tasks().stream()
.allMatch(combinedScanTask -> !combinedScanTask.isDataTask() && combinedScanTask.files()
.stream()
.allMatch(fileScanTask -> OrcRowFilterUtils.rowFilterFromTask(fileScanTask) == null));
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This code was also not touched by linkedin/iceberg#48 and does not exist in apache/iceberg. Can you remove this?

These are several other changes in the files which are linkedin specific and were not touched by linkedin/iceberg#48

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@shardulm94 sorry yea, you're correct. I think I messed up while merging. I'll create new PR

@bkahloon bkahloon closed this Feb 28, 2021
@bkahloon bkahloon deleted the spark-parquet-read-ts-as-tstz branch February 28, 2021 02:01
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants