Hi,
I am having an error while running some Flink transformations in a
DataStream Scala API.
The error I get is:
Timeout while waiting for JobManager answer. Job time exceeded 21474835
seconds
...
Caused by: akka.pattern.AskTimeoutException: Ask timed out on
[Actor[akka://flink/user/$a#18398405
Nick Dimiduk created FLINK-3228:
---
Summary: Cannot submit multiple streaming involving JDBC drivers
Key: FLINK-3228
URL: https://issues.apache.org/jira/browse/FLINK-3228
Project: Flink
Issue Typ
Fabian Hueske created FLINK-3227:
Summary: Translate physical Table API plan into DataSet program
Key: FLINK-3227
URL: https://issues.apache.org/jira/browse/FLINK-3227
Project: Flink
Issue Ty
Fabian Hueske created FLINK-3226:
Summary: Translate optimized logical Table API plans into physical
plans representing DataSet programs
Key: FLINK-3226
URL: https://issues.apache.org/jira/browse/FLINK-3226
Fabian Hueske created FLINK-3225:
Summary: Optimize logical Table API plans in Calcite
Key: FLINK-3225
URL: https://issues.apache.org/jira/browse/FLINK-3225
Project: Flink
Issue Type: Sub-tas
Nick Dimiduk created FLINK-3224:
---
Summary: The Streaming API does not call setInputType if a format
implements InputTypeConfigurable
Key: FLINK-3224
URL: https://issues.apache.org/jira/browse/FLINK-3224
Fabian Hueske created FLINK-3223:
Summary: Translate Table API query into logical relational plans
for Apache Calcite
Key: FLINK-3223
URL: https://issues.apache.org/jira/browse/FLINK-3223
Project: Fli
Ted Yu created FLINK-3222:
-
Summary: Incorrect shift amount in
OperatorCheckpointStats#hashCode()
Key: FLINK-3222
URL: https://issues.apache.org/jira/browse/FLINK-3222
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-3221:
Summary: Move Table API on top of Apache Calcite
Key: FLINK-3221
URL: https://issues.apache.org/jira/browse/FLINK-3221
Project: Flink
Issue Type: Task
Robert Metzger created FLINK-3220:
-
Summary: Flink does not start on Hortonworks Sandbox 2.3.2 due to
missing class
Key: FLINK-3220
URL: https://issues.apache.org/jira/browse/FLINK-3220
Project: Flink
You can import the project directly by using "File -> Import -> Maven ->
Existing Maven Projects” menu.
> On Jan 12, 2016, at 8:32 PM, Vasudevan, Ramkrishna S
> wrote:
>
>
> This is scala IDE Release 4.4.0. So without doing mvn eclipse:eclipse - how
> to you import the project directly?
>
This is scala IDE Release 4.4.0. So without doing mvn eclipse:eclipse - how to
you import the project directly?
Regards
Ram
-Original Message-
From: Chiwan Park [mailto:chiwanp...@apache.org]
Sent: Tuesday, January 12, 2016 4:54 PM
To: dev@flink.apache.org
Subject: Re: Naive question
Because I tested with Scala IDE 4.3.0 only, the process in the documentation is
slightly different with my experience.
> On Jan 12, 2016, at 8:21 PM, Stephan Ewen wrote:
>
> @Chiwan: Is this still up to date from your experience?
>
> https://ci.apache.org/projects/flink/flink-docs-release-0.10
@Chiwan: Is this still up to date from your experience?
https://ci.apache.org/projects/flink/flink-docs-release-0.10/internals/ide_setup.html
On Tue, Jan 12, 2016 at 12:04 PM, Chiwan Park wrote:
> Hi Ram,
>
> Because there are some Scala IDE (Eclipse) plugins needed, I recommend to
> avoid `mvn
Hi Ram,
Because there are some Scala IDE (Eclipse) plugins needed, I recommend to avoid
`mvn eclipse:eclipse` command. Could you try just run `mvn clean install
-DskipTests` and import the project to Scala IDE directly? In middle of
importing process, Scala IDE suggests some plugins needed.
An
Actually, the latest master should have this fix. The Dashboard ignores the
log fiel if not found...
On Tue, Jan 12, 2016 at 10:32 AM, Fabian Hueske wrote:
> Hi Arjun,
>
> yes, it is possible to start the web dashboard also when running jobs from
> the IDE.
> It is a bit hacky though...
>
> You
Yes. I added it as Maven project only. I did mvn eclipse:eclipse to create the
project and also built the code using mvn clean install -DskipTests.
Regards
Ram
-Original Message-
From: ewenstep...@gmail.com [mailto:ewenstep...@gmail.com] On Behalf Of Stephan
Ewen
Sent: Tuesday, January
Sorry to hear that it did not work out with Eclipse at all in the end, even
with all adjustments.
Just making sure: You imported Flink as a Maven project, not manually
adding the big Flink dependency JAR?
On Tue, Jan 12, 2016 at 5:15 AM, Vasudevan, Ramkrishna S <
ramkrishna.s.vasude...@intel.com>
Hi Arjun,
yes, it is possible to start the web dashboard also when running jobs from
the IDE.
It is a bit hacky though...
You can do it by creating a LocalStreamExecutionEnvironment as follows:
val config = new Configuration()
config.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true)
config
19 matches
Mail list logo
