clear query| facets| time Search criteria: .   Results from 21 to 30 from 84 (0.0s).
Loading phrases to help you
refine your search...
[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
[expand - 2 more] - About KafkaConsumer and WM'ing and EventTime charactersitics - Flink - [mail # user]
...Thank you. This though is a little different.The producer of the kafka message attaches a time stamphttps://issues.apache.org/jira/browse/KAFKA-2511.  I do not see how I canget to that ...
   Author: Vishal Santoshi , 2019-01-30, 10:45
[expand - 2 more] - K8s and flink1.7.1 - Flink - [mail # user]
...And both worked.. I should have said   - modifying the docker entrypoint script to first configure   *taskmanager.host*  using the status.podIP as an override or in&...
   Author: Vishal Santoshi , 2019-01-26, 22:07