獲取新數據為每分鍾運動。

[pranathisg97]

我想從運動源獲取新數據的每一分鍾。

我用“minFetchPeriod”選項,指定的60年代。但這似乎並不成功。

流媒體查詢:

火花\

.readStream \

.format \(“運動”)

.option (“streamName”, kinesis_stream_name) \

.option \(“區域”,地區名稱)

.option(“初始位置”、“最新”)\

.option (“awsAccessKey”, awsAccessKey) \

.option (“awsSecretKey”, aws_secret_access_key) \

.option (“minFetchPeriod”、“六十年代”)

誰能幫助我嗎?我這個話題。

[Debayan]

嗨,什麼是運行的DBR嗎?有什麼錯誤你當它是不工作嗎?

[pranathisg97]

嗨,DBR是12.1

錯誤:" . lang。IllegalArgumentException: maxFetchDuration需要時間字符串“10”等10秒或2米2分鍾。也需要大於minFetchPeriod為了避免落後流”。

我需要配置maxFetchDuration每當我配置minFetchPeriod ?

[Vidula_Khanna]

嗨@Pranathi Girish

希望一切都好!隻是想檢查如果你能解決你的問題,你會很高興分享解決方案或答案標記為最佳?其他的請讓我們知道如果你需要更多的幫助。

我們很想聽到你的聲音。

謝謝!

[pranathisg97 · Accepted solution]

你好,

我能夠解決這個問題通過指定超過minFetchPeriod maxFetchDuration價值。但是我沒有得到指定的目的maxFetchDuration值大於或等於minFetchPeriod價值。

火花\

.readStream \

.format \(“運動”)

.option (“streamName”, kinesis_stream_name) \

.option \(“區域”,地區名稱)

.option(“初始位置”、“最新”)\

.option (“awsAccessKey”, awsAccessKey) \

.option (“awsSecretKey”, aws_secret_access_key) \

.option (“maxFetchDuration”、“六十年代”)\

.option (“minFetchPeriod”、“六十年代”)