File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed
articles/hdinsight-aks/flink Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -316,18 +316,27 @@ public class DeltaSourceExample {
316
316
</build>
317
317
</project>
318
318
```
319
+
319
320
## Package the jar and submit it to Flink cluster to run
320
321
321
322
1 . Upload the jar to ABFS.
322
323
:::image type="content" source="./media/use-flink-delta-connector/app-mode-jar.png" alt-text="Screenshot showing App mode jar files." lightbox="./media/use-flink-delta-connector/app-mode-jar.png":::
324
+
323
325
1 . Pass the job jar information in AppMode cluster.
326
+
324
327
:::image type="content" source="./media/use-flink-delta-connector/cluster-configuration.png" alt-text="Screenshot showing cluster configuration." lightbox="./media/use-flink-delta-connector/cluster-configuration.png":::
328
+
325
329
1 . Enable ` hadoop.classpath.enable ` .
330
+
326
331
1 . Submit the cluster, you should be able to see the job in Flink UI.
332
+
327
333
:::image type="content" source="./media/use-flink-delta-connector/flink-dashboard.png" alt-text="Screenshot showing Flink dashboard." lightbox="./media/use-flink-delta-connector/flink-dashboard.png":::
334
+
328
335
1 . Find Results in ADLS.
336
+
329
337
:::image type="content" source="./media/use-flink-delta-connector/output.png" alt-text="Screenshot showing the output." lightbox="./media/use-flink-delta-connector/output.png":::
330
338
339
+
331
340
## Power BI integration
332
341
333
342
Once the data is in delta sink, you can run the query in Power BI desktop and create a report.
You can’t perform that action at this time.
0 commit comments