Hi all,
Currently i am running my flink application in yarn session mode and
using below commnad :
*bin/yarn-session.sh -d -s 3 -jm 1024 -tm 4096*
when taskmanager complete to started,i found the container launching
command is :
* bin/java -Xms2765m -Xmx2765m -XX:MaxDirectMemorySize=1331m .
Hi all,
Is it possible to join records read from a kafka stream with one(or
more) dimension tables which are saved as mysql table using flink streaming
sql.
:58 AM, Fabian Hueske wrote:
>
>> Hi XiangWei,
>>
>> I don't think this is a public interface, but Till (in CC) might know
>> better.
>>
>> Best,
>> Fabian
>>
>> 2017-11-06 3:27 GMT+01:00 XiangWei Huang :
>>
>>> Hi Fli
Hi Flink users,
Flink Jobmanager throw a NotSerializableException when i used
JobMasterGateway to get ExecutionGraph of a specific job with
message RequestJob(jobID). Blow is the detail of Exception:
[ERROR] [akka.remote.EndpointWriter] - Transient association error (association
remain
;
> Cheers,
> Till
>
> On Wed, Sep 20, 2017 at 5:46 AM, XiangWei Huang <mailto:xw.huang...@gmail.com>> wrote:
> Hi Till,
>
> Thanks for your answer,it worked when i use StandaloneMiniCluster,but
> another problem is that i can’t find a way to cancel
>
n, I recommend starting a local
> standalone cluster and let the code run there.
>
> Cheers,
> Till
>
>
> On Wed, Sep 13, 2017 at 6:21 AM, XiangWei Huang <mailto:xw.huang...@gmail.com>> wrote:
> dear all,
>
> Below is the code i execute:
>
> im
dear all,
Below is the code i execute:
import java.io._
import java.net.{URL, URLClassLoader}
import java.nio.charset.Charset
import java.util.Collections
import java.util.concurrent.atomic.AtomicBoolean
import com.netease.atom.common.util.logging.Logging
import com.netease.atom.interpreter.Code
It seems so,thanks for your reply Chesnay.
> 在 2017年8月8日，22:23，Chesnay Schepler [via Apache Flink User Mailing List
> archive.] 写道：
>
> FLINK-7368 may be the reason for this behavior.
>
> On 31.07.2017 03:54, XiangWei Huang wrote:
>> 1. yes and yes.
>>
> Are the metrics you selected shown correctly?
>
> Did you modify the "jobmanager.web.refresh-interval" setting? (maybe check
> the flink-conf-yaml for the current setting)
>
> On 26.07.2017 04:57, XiangWei Huang wrote:
>> hi,
>>
>> The browser
ybe try out if the issue persists with a different one)
>
> Regards,
> Chesnay
>
> On 25.07.2017 05:20, XiangWei Huang wrote:
>> hi,
>>
>> Sorry for replying so late.
>> I have met this issue again and the list is constantly keep growing even if
>> i clo
hi,
Sorry for replying so late.
I have met this issue again and the list is constantly keep growing even if
i close the page ,until the website is been unavailable.
This issue appeared each time i add metrics for a job from web ui.
by the way ,the version of Flink is 1.3.1
Regards,
Xia
Hi,
When restart flink jobmanager jars which uploaded by user from web ui will be
deleted .
Is there anyway to avoid this.
Hi,
I met a problem when use jedis in flink.When using jedis to get a connection to
redis if the redis server is not available then jedis will keep trying and
never end,the problem is that the job’s status is not set to RUNNING by flink,
that means it can’t be killed by flink.The only way to br
13 matches
Mail list logo
