mirror of https://github.com/apache/nifi.git
NIFI-10602: Fix GetHubSpot and GetShopify state handling on NiFi restart
This closes #6495. Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
This commit is contained in:
parent
da0fb234d6
commit
ad08e8befc
|
@ -201,7 +201,7 @@ public class GetHubSpot extends AbstractProcessor {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onPropertyModified(final PropertyDescriptor descriptor, final String oldValue, final String newValue) {
|
public void onPropertyModified(final PropertyDescriptor descriptor, final String oldValue, final String newValue) {
|
||||||
if (OBJECT_TYPE.equals(descriptor) || IS_INCREMENTAL.equals(descriptor)) {
|
if (isConfigurationRestored() && (OBJECT_TYPE.equals(descriptor) || IS_INCREMENTAL.equals(descriptor))) {
|
||||||
isObjectTypeModified = true;
|
isObjectTypeModified = true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -231,7 +231,7 @@ public class GetShopify extends AbstractProcessor {
|
||||||
private volatile boolean isResetState;
|
private volatile boolean isResetState;
|
||||||
|
|
||||||
public void onPropertyModified(final PropertyDescriptor descriptor, final String oldValue, final String newValue) {
|
public void onPropertyModified(final PropertyDescriptor descriptor, final String oldValue, final String newValue) {
|
||||||
if (RESET_STATE_PROPERTY_NAMES.contains(descriptor.getName())) {
|
if (isConfigurationRestored() && RESET_STATE_PROPERTY_NAMES.contains(descriptor.getName())) {
|
||||||
isResetState = true;
|
isResetState = true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue