回复：Changing timeout for cancel command

Hi Jürgen,      You can set the timeout in the configuration by this key "akka.ask.timeout", and the current default value is 10 s. Hope it can help you. cheers,zhijiang --发件人：Jürgen Thomann

Re: Cassandra connector POJO - tombstone question

Thanks Chesnay, this will work. Best, Tarandeep On Wed, Apr 12, 2017 at 2:42 AM, Chesnay Schepler wrote: > Hello, > > what i can do is add hook like we do for the ClusterBuilder with which you > can provide a set of options that will > be used for every call to the mapper.

Maintaining Stream Partitioning after Mapping?

Greetings, Is there a means of maintaining a stream's partitioning after running it through an operation such as map or filter? I have a pipeline stage S that operates on a stream partitioned by an ID field. S flat maps objects of type A to type B, which both have an "ID" field, and where each

Re: has insufficient permissions to access it - Error

I'm not sure whether it needs to be absolute, but you apparently gave it an absolute file path (starting with "/") so that's where it is looking for the file. Nico On Wednesday, 12 April 2017 18:04:36 CEST Kaepke, Marc wrote: > Hi Nico, > > so I need an absolute file path? Because I moved

Re: has insufficient permissions to access it - Error

Hi Nico, so I need an absolute file path? Because I moved the file into my project and IntelliJ did an autocomplete for the file path How can I use a relative file path? Because I work on two different systems Marc > Am 11.04.2017 um 10:19 schrieb Nico Kruber : > >

Re: Flink job on secure Yarn fails after many hours

Niels, are you still facing this issue? As far as I understood it, the security changes in Flink 1.2.0 use a new Kerberos mechanism that allows infinite token renewal. On Thu, Mar 17, 2016 at 7:30 AM, Maximilian Michels wrote: > Hi Niels, > > Thanks for the feedback. As far as

Changing timeout for cancel command

Hi, We currently get the following exception if we cancel a job which writes to Hadoop: ERROR org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink - Error while trying to hflushOrSync! java.io.InterruptedIOException: Interrupted while waiting for data to be acknowledged by

Re: Cassandra connector POJO - tombstone question

Hello, what i can do is add hook like we do for the ClusterBuilder with which you can provide a set of options that will be used for every call to the mapper. This would provide you access with all options that are listed on the page you linked. You can find an implementation of this here:

Re: Custom timer implementation using Flink

Hi Gordon I somehow missed this in the docs. Looks really helpful for this use case. Thanks. I now have some other ideas for this use case. I will post here if I use this or not. If not, will post the approach which I will take. -- View this message in context: