Hi,guysThere are some codes in scheduleForExecution Function in Execution.java:
1. SlotAllocationFuture future = scheduler.scheduleQueued(toSchedule); 2.
future.setFutureAction(new SlotAllocationFutureAction() {..})
When scheduler finds some slot between line1 and line 2 the sc
Greg Hogan created FLINK-2545:
-
Summary: NegativeArraySizeException while creating hash table
bloom filters
Key: FLINK-2545
URL: https://issues.apache.org/jira/browse/FLINK-2545
Project: Flink
I
There appears to be some issue in DriverTestBase. I have observed two
failures recently, once in MatchTaskTest and MapTaskTest, both with the
following trace:
Exception in thread "Thread-154" java.lang.AssertionError: Canceling task
failed: java.lang.NullPointerException
at
org.apache.flink.runti
Hi!
This looks like your IDE setup is not quite correct. The Scala library is
probably not in the classpath when you launch the program.
Please check if you correctly installed your Scala Plugin, of the Scala Lib
has been added to the build path in the project properties, ...
Greetings,
Stephan
Till Rohrmann created FLINK-2544:
Summary: Some test cases using PowerMock fail with Java 8u20
Key: FLINK-2544
URL: https://issues.apache.org/jira/browse/FLINK-2544
Project: Flink
Issue Type:
Hi Stephan,
Yes, you are right.
This thinking doesn`t work if the "getMaxPartition()" is rare use.
Greetings,
Huangwei
===
Hi!
The thinking is good. Although in this case, it is probably not beneficial to
replace the list by a heap or so, due to the rare usage of that function.
A
Hi!
The thinking is good. Although in this case, it is probably not beneficial
to replace the list by a heap or so, due to the rare usage of that function.
As you said, the cost depends on how often the "getMaxPartition()" is
called.
Current approach: seldom O(n) - (only on function call)
Heap a
Robert Metzger created FLINK-2543:
-
Summary: State handling does not support deserializing classes
through the UserCodeClassloader
Key: FLINK-2543
URL: https://issues.apache.org/jira/browse/FLINK-2543
Hi Pieter!
The pattern you need is common and we have code for such loops in the
works. It is being delayed right now due to work on fault-tolerance / high
availability, but we plan to resume with that
after those issues are done.
Greetings,
Stephan
On Tue, Aug 18, 2015 at 12:38 PM, Pieter-Jan
Gabor Gevay created FLINK-2542:
--
Summary: It should be documented that it is required from a join
key to override hashCode(), when it is not a POJO
Key: FLINK-2542
URL: https://issues.apache.org/jira/browse/FLINK-254
Chesnay Schepler created FLINK-2541:
---
Summary: TypeComparator creation fails for T2, byte[]>
Key: FLINK-2541
URL: https://issues.apache.org/jira/browse/FLINK-2541
Project: Flink
Issue Type:
Can you open a JIRA with instructions to reproduce the bug?
Thanks,
Fabian
2015-08-18 12:33 GMT+02:00 Chesnay Schepler :
> While running the following job i run into an exception:
> Tuple comparator creation has a bug
> java.lang.IllegalArgumentException: Tuple comparator creation has a bug
>
Hi,
Thanks for the quick response. Thinking of a workaround right now, where I
simply run the same application 100 times but I would like to avoid as much
duplicate work as possible. Is it possible to "broadcast" nodes and edges
datasets from one execution environment to the next without passing
While running the following job i run into an exception:
Tuple comparator creation has a bug
java.lang.IllegalArgumentException: Tuple comparator creation has a bug
at
org.apache.flink.api.java.typeutils.TupleTypeInfo.getNewComparator(TupleTypeInfo.java:131)
...
job:
ExecutionEnvironme
big +1
On Tue, Aug 18, 2015 at 10:43 AM, Till Rohrmann
wrote:
> +1, there is no point in arguing with Knuth.
>
> On Mon, Aug 17, 2015 at 1:07 AM, Henry Saputra
> wrote:
>
> > +1 as well.
> >
> > This is a great follow-up from my previous email about adding details
> > in JIRA, which also being
Hello Pieter,
Nested iterations are indeed not supported in Flink.
http://mail-archives.apache.org/mod_mbox/flink-user/201504.mbox/%3Cop.xw24u7fhf7e33m@vaio-sb%3E
The problem is not in your code.
On Tue, Aug 18, 2015 at 11:27 AM, Pieter-Jan Van Aeken <
pieterjan.vanae...@euranova.eu> wrote:
>
Gabor Gevay created FLINK-2540:
--
Summary: LocalBufferPool.requestBuffer gets into infinite loop
Key: FLINK-2540
URL: https://issues.apache.org/jira/browse/FLINK-2540
Project: Flink
Issue Type: B
Hi,
I found some like the code following may affect performance( Time complexity is
O(n) ):
private int getMaxPartition() {
int maxPartition = 0;
for(InMemoryPartition p1 : this.partitions) {
if(p1.getBlockCount() > maxPartition) {
maxPartition = p1.getBlockCount();
}
Hello all,
I am having some troubles getting nested iterations to work. The basic
outline of my application looks like this :
1. create vertex dataset
2. create edge dataset
3. bulk iterate 100 times on edges {
3a. Create graph from nodes and edges
3b. Perform GatherSumApply (delta itera
Hi Chesnay,
Sorry for reply late.
It works!
Thank you!
Greetings Huangwei
=
How about something like this:
DataStream> sink = user
.join(area)
.onWindow(15, TimeUnit.MINUTES)
.where(0)
.equalTo(0)
.
Creating a JIRA issue [1] is done.
Regards,
Chiwan Park
[1] https://issues.apache.org/jira/browse/FLINK-2539
> On Aug 18, 2015, at 5:28 PM, Till Rohrmann wrote:
>
> Good initiative Chiwan. +1 for a more unified code style.
>
> On Tue, Aug 18, 2015 at 10:25 AM, Chiwan Park wrote:
>
>> Okay,
Chiwan Park created FLINK-2539:
--
Summary: More unified code style for Scala code
Key: FLINK-2539
URL: https://issues.apache.org/jira/browse/FLINK-2539
Project: Flink
Issue Type: Improvement
+1, there is no point in arguing with Knuth.
On Mon, Aug 17, 2015 at 1:07 AM, Henry Saputra
wrote:
> +1 as well.
>
> This is a great follow-up from my previous email about adding details
> in JIRA, which also being echoed by Fabian.
>
> - Henry
>
> On Sun, Aug 16, 2015 at 3:45 PM, Fabian Hueske
Good initiative Chiwan. +1 for a more unified code style.
On Tue, Aug 18, 2015 at 10:25 AM, Chiwan Park wrote:
> Okay, I’ll create a JIRA issue covered this topic.
>
> Regards,
> Chiwan Park
>
> > On Aug 17, 2015, at 1:17 AM, Stephan Ewen wrote:
> >
> > +1 for formatting templates for Eclipse a
Okay, I’ll create a JIRA issue covered this topic.
Regards,
Chiwan Park
> On Aug 17, 2015, at 1:17 AM, Stephan Ewen wrote:
>
> +1 for formatting templates for Eclipse and IntelliJ.
>
> On Sun, Aug 16, 2015 at 6:06 PM, Sachin Goel
> wrote:
>
>> We should also write up a matching configuration
25 matches
Mail list logo
