-
Notifications
You must be signed in to change notification settings - Fork 1k
PHOENIX-7166 : Enable feature flags introduced by metadata caching redesign #1859
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
PHOENIX-7166 : Enable feature flags introduced by metadata caching redesign #1859
Conversation
This reverts commit 5d59a8c.
|
@shahrs87 Let me know if we can get this one in now? |
phoenix-core-client/src/main/java/org/apache/phoenix/execute/MutationState.java
Outdated
Show resolved
Hide resolved
shahrs87
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
some changes.
phoenix-core-client/src/main/java/org/apache/phoenix/util/ValidateLastDDLTimestampUtil.java
Outdated
Show resolved
Hide resolved
phoenix-core-client/src/main/java/org/apache/phoenix/util/ValidateLastDDLTimestampUtil.java
Outdated
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/end2end/UpdateCacheAcrossDifferentClientsIT.java
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/end2end/ViewIT.java
Outdated
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexFailureIT.java
Outdated
Show resolved
Hide resolved
shahrs87
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Some comments.
phoenix-core/src/it/java/org/apache/phoenix/end2end/AlterTableWithViewsIT.java
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/end2end/AlterTableWithViewsIT.java
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/end2end/AlterTableWithViewsIT.java
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/end2end/LogicalTableNameBaseIT.java
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/end2end/LogicalTableNameExtendedIT.java
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexAsyncThresholdIT.java
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/monitoring/PhoenixTableLevelMetricsIT.java
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/query/MetaDataCachingIT.java
Outdated
Show resolved
Hide resolved
phoenix-core/src/test/java/org/apache/phoenix/jdbc/ParallelPhoenixConnectionFailureTest.java
Outdated
Show resolved
Hide resolved
phoenix-core/src/test/java/org/apache/phoenix/query/BaseConnectionlessQueryTest.java
Outdated
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/end2end/LoadSystemTableSnapshotIT.java
Outdated
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/jdbc/HighAvailabilityTestingUtility.java
Outdated
Show resolved
Hide resolved
phoenix-core-client/src/main/java/org/apache/phoenix/schema/MetaDataClient.java
Outdated
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/monitoring/PhoenixTableLevelMetricsIT.java
Outdated
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/query/MetaDataCachingIT.java
Outdated
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/rpc/UpdateCacheConnectionLevelPropIT.java
Show resolved
Hide resolved
phoenix-core/src/it/java/org/apache/phoenix/rpc/UpdateCacheIT.java
Outdated
Show resolved
Hide resolved
| private static final Logger LOGGER = LoggerFactory.getLogger(MetaDataCachingIT.class); | ||
| private final Random RAND = new Random(11); | ||
|
|
||
| private boolean isLastDDLTimestampValidationEnabled = config.getBoolean( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Instead of duplicating this line in 3 different tests, do you mind creating a util method in ValidateLastDDLTimestampUtil something like getValidateLastDdlTimestampEnabled(Configuration config) similar to getValidateLastDdlTimestampEnabled(PhoenixConnection connection)
| public static ColumnResolver getResolver(SingleTableStatement statement, PhoenixConnection connection, Map<String, UDFParseNode> udfParseNodes) | ||
| throws SQLException { | ||
| SingleTableColumnResolver visitor = new SingleTableColumnResolver(connection, statement.getTable(), true, 0, udfParseNodes); | ||
| SingleTableColumnResolver visitor |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I see that we are calling this resolver from MetaDataClient#createIndex and CreateIndexCompiler#compile method. So we want to bypass cache for createIndex and resolve table always. So lets rename this method to getResolverForCreateIndex and add a comment on why we are setting alwaysHitServer to true.
shahrs87
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Other than 2 minor comments, +1 ltgm. Thank you @palashc for the change.
|
@shahrs87 Latest test report - https://ci-hadoop.apache.org/job/Phoenix/job/Phoenix-PreCommit-GitHub-PR/job/PR-1859/22/testReport/ |
No description provided.