Skip to content

Commit

Permalink
Wrong property displayed in error message when table doesn't have pri…
Browse files Browse the repository at this point in the history
…mary key. (#224)
  • Loading branch information
yjhawar authored Apr 21, 2023
1 parent 4001b69 commit bfb3c98
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/main/java/io/cdap/delta/bigquery/BigQueryAssessor.java
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ public TableAssessment assess(StandardizedTableDetail tableDetail) {
new Problem("Missing Primary Key",
String.format("Table '%s' in database '%s' must have a primary key in order to be replicated",
tableName, dbName),
"Please set the property 'source.connector.custom.primary.key' = " +
"Please set the property 'source.connector.message.key.columns' = " +
"`<fully-qualified table>:<a comma-separated list of columns>' in the preferences to columns " +
"that can be used as an indexes. An index column is required to create a primary key in " +
"BigQuery to facilitate merges, and correct handling of updates.",
Expand Down

0 comments on commit bfb3c98

Please sign in to comment.