Hi,
I have started flink in cluster mode. ..flink1.4.2/bin/$
./start-cluster.sh (no config changes ie., default settings)
And trying to connect to it,
ExecutionEnvironment.createRemoteEnvironment("localhost", 6123, "xxx.jar");
I am not seeing any response, did not find anything in jobmanager lo
org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException:
Adjusted frame length exceeds 10485760: 1195725860 - discarded
On Wed, Jul 11, 2018 at 5:44 PM Chesnay Schepler wrote:
> Did/could you enable logging in the submitting code?
>
> On 11.07.2018 13:57, Mohan mohan wrote:
> > Hi,
> &g
e enabled
> b) running 1.5.
>
> Please ensure that both the flink versions match for client and server,
> and that both run/do not run in flip6 mode.
>
> On 11.07.2018 14:26, Mohan mohan wrote:
>
> Attached log file. (Log level : Trace)
>
> Is this the issue ? Trying wit
On Thu, Jul 12, 2018 at 9:32 PM Mohan mohan wrote:
> Yep, that is due to version mismatch. Working fine now.
> Thank you Chesnay Schepler.
>
>
> On Wed, Jul 11, 2018 at 6:05 PM Chesnay Schepler
> wrote:
>
>> Based on the logs your client is using the RestClusterClien
uot;legacyCode" maven profile
> * for the client, configure the mode
> <https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/config.html#mode>
> parameter.
>
> On 13.07.2018 12:20, Mohan mohan wrote:
>
> Hi,
> what is flip6? "Flink Improvement Proposal
Updated akka's 'reference.conf' file in my app shadow jar. Working fine now.
Thank you.
On Fri, Jul 13, 2018 at 10:46 PM Mohan mohan wrote:
> Hi Chesnay,
>
> Now server and client/IDE both are using 1.4.0.
> When I submit job from
Hi,
*Context* :
# Started cluster with 2 nodes
node1 (Master & slave)
node2 (Slave)
# Source path to CsvInputFormat is like
"*ftp*://test:test@x.x.x.x:5678/source.csv"
and DataSet parallelism is 2
# Path to FileOutputFormat is like "*ftp*://test:test@x.x.x.x:5678/target.csv"
and DataSi
