clear query| facets| time Search criteria: .   Results from 21 to 30 from 86 (0.0s).
Loading phrases to help you
refine your search...
What are savepoint state manipulation support plans - Flink - [mail # user]
...+1On Thu, Mar 28, 2019, 5:01 AM Ufuk Celebi  wrote:> I think such a tool would be really valuable to users.>> @Gordon: What do you think about creating an umbrella ticket for t...
   Author: Vishal Santoshi , 2019-03-28, 09:16
[expand - 2 more] - Discrepancy between the part length file's length and the part file length during recover - Flink - [mail # user]
...Thank you for your email.Would then the assumption that this possibility ( part reported length >part file size ( reported by FileStatus  on NN)  ) is only attributable tothis e...
   Author: Vishal Santoshi , 2019-03-26, 13:27
[expand - 1 more] - EOF on scraping flink metrics - Flink - [mail # user]
...Thank you,                This is followinghttps://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html#prometheus-orgapacheflinkmet...
   Author: Vishal Santoshi , 2019-03-22, 20:31
[expand - 1 more] - Is a subtask index and kafka partition affinity retained after a restore ? - Flink - [mail # user]
...We are almost sure that there is no affinity.On Mon, Mar 18, 2019, 12:31 PM Vishal Santoshi wrote:> If a flink pipeline with a kafka source was to be re stored from a> checkpoint, woul...
   Author: Vishal Santoshi , 2019-03-18, 17:36
[expand - 5 more] - StandAlone job on k8s fails with "Unknown method truncate" on restore - Flink - [mail # user]
...We reverted back to BucketingSink and that works as expected. In conclusionRollingFileSink needs hadoop 2.7 for for hadoop File System.On Sat, Feb 23, 2019 at 2:30 PM Vishal Santoshi wrote:&...
   Author: Vishal Santoshi , 2019-03-09, 12:31
[expand - 6 more] - fllink 1.7.1 and RollingFileSink - Flink - [mail # user]
...Awesome, thanks!  Will open a new thread. But yes the inprogress file washelpful.On Thu, Feb 14, 2019, 7:50 AM Kostas Kloudas <[EMAIL PROTECTED] wrote:> Hi Vishal,>> For the...
   Author: Vishal Santoshi , 2019-02-14, 13:22
HA HDFS - Flink - [mail # user]
...One more thing I had to do.In HA set up, the TMs are not able to resolve the job manager's random portthrough the jobmanager.rpc.portsetting.Setup high-availability.jobmanager.port as a pred...
   Author: Vishal Santoshi , 2019-02-11, 09:41
[expand - 1 more] - Running JobManager as Deployment instead of Job - Flink - [mail # user]
...In one case however, we do want to retain the same cluster id ( thinkingress on k8s  and thus SLAs with external touch points ) but it isessentially a new job ( added an incompatible ch...
   Author: Vishal Santoshi , 2019-02-08, 22:26
1.7.1 and hadoop pre 2.7 - Flink - [mail # user]
...Is there . a work around forhttps://issues.apache.org/jira/browse/FLINK-10203 or do have to be hadoop2.7 ?...
   Author: Vishal Santoshi , 2019-02-05, 21:21
[expand - 2 more] - KakfaConsumer - Flink - [mail # user]
...In fact "*Checkpointing enabled:* if checkpointing is enabled, the FlinkKafka Consumer will commit the offsets stored in the checkpointed stateswhen the checkpoints are completed. This ensur...
   Author: Vishal Santoshi , 2019-02-05, 01:18