Issue #32

mattcasters · Feb 14, 2019 · 936c013 · 936c013
1 parent 7e3652b
commit 936c013
Showing 1 changed file with 20 additions and 1 deletion.
diff --git a/src/main/java/org/kettle/beam/metastore/BeamJobConfig.java b/src/main/java/org/kettle/beam/metastore/BeamJobConfig.java
@@ -125,44 +125,63 @@ public class BeamJobConfig {
   //
   // Flink options
   //
+  @MetaStoreAttribute
   private String flinkMaster;
 
+  @MetaStoreAttribute
   private String flinkParallelism;
 
+  @MetaStoreAttribute
   private String flinkCheckpointingInterval;
 
+  @MetaStoreAttribute
   private String flinkCheckpointingMode;
 
+  @MetaStoreAttribute
   private String flinkCheckpointTimeoutMillis;
 
+  @MetaStoreAttribute
   private String flinkMinPauseBetweenCheckpoints;
 
+  @MetaStoreAttribute
   private String flinkNumberOfExecutionRetries;
 
+  @MetaStoreAttribute
   private String flinkExecutionRetryDelay;
 
+  @MetaStoreAttribute
   private String flinkObjectReuse;
 
+  @MetaStoreAttribute
   private String flinkStateBackend;
 
+  @MetaStoreAttribute
   private String flinkEnableMetrics;
 
+  @MetaStoreAttribute
   private String flinkExternalizedCheckpointsEnabled;
 
+  @MetaStoreAttribute
   private String flinkRetainExternalizedCheckpointsOnCancellation;
 
+  @MetaStoreAttribute
   private String flinkMaxBundleSize;
 
+  @MetaStoreAttribute
   private String flinkMaxBundleTimeMills;
 
+  @MetaStoreAttribute
   private String flinkShutdownSourcesOnFinalWatermark;
 
+  @MetaStoreAttribute
   private String flinkLatencyTrackingInterval;
 
+  @MetaStoreAttribute
   private String flinkAutoWatermarkInterval;
 
+  @MetaStoreAttribute
   private String flinkExecutionModeForBatch;
-  
+
 
   public BeamJobConfig() {
     parameters = new ArrayList<>();