Hello Nico,
took me a while to respond. Thank you for the comments. I had explored a
little more the docker-image and startup scripts. That allowed me to
better understand the log4j properties file used but I am still facing
this odd behavior.
I created a stackoverflow entry for this
https://sta
the command starting the docker image.
>
>
> Nico
>
> [1]
> https://github.com/docker-flink/docker-flink/tree/master/1.4/hadoop28-scala_2.11-alpine
>
> On 27/02/18 18:25, JP de Vooght wrote:
>> Hello Nico,
>>
>> took me a while to respond. Thank you for the com
Nico, all,
I am still stuck with this. Upgraded the docker image to 1.4.2 and the
AMIDST library to 0.7.0
Just noticed this issue which signals logging issues outside transforms:
https://issues.apache.org/jira/browse/FLINK-7990
Could this be related? Although I don't see the relation to logback.
time jar from
the opt to the lib folder.
jobmanager_1 | ## BEFORE UPDATEMODEL ##
taskmanager_1 | The operator name DataSource (at
main(ParallelMLExample.java:30)
(org.apache.flink.api.java.io.CollectionInputFormat)) exceeded the 80
characters length limit and was truncated.
On
Hello,
When I submit a WordCount job from the examples, without any parameter,
to a standalone cluster running on Docker, I cannot see the
System.out.println() message. Instead I notice the
org.apache.flink.metrics.MetricGroup entry below (last)
jobmanager_1 | Starting Job Manager
jobmanager_1
d Yu wrote:
> bq. To enable Queryable State, please move the
> flink-queryable-state-runtime jar from the opt to the lib folder.
>
> Have you noticed the above and taken corresponding action ?
>
> Thanks
>
> On Sat, Apr 21, 2018 at 3:15 PM, JP de Vooght <mailto:j...@voogh
ted taskmanager_1 |
Slf4jLogger started jobmanager_1 | ## BEFORE UPDATEMODEL
## taskmanager_1 | The operator name DataSource (at
main(SimpleExample.java:30)
(org.apache.flink.api.java.io.CollectionInputFormat)) exceeded the 80
characters length limit and was truncated. |
Any advice?
On
depends_on:
- jobmanager
environment:
- JOB_MANAGER_RPC_ADDRESS=jobmanager
Going to enjoy some AMIDST solutions to ML problems now :-)
JP
On 04/07/2018 06:31 PM, JP de Vooght wrote:
> Just to recap
>
> I use Flink 1.4.2 with Docker compose which launches a jobmanager and
&g
