Hi all,
We are thinking about enabling RocksDB metrics to better monitor our
pipeline. However, since they will have performance impact, we will have to
be selective about which metrics we use.
Does anyone have experience about which metrics are more important than the
others ?
And what metrics
Hi all,
So I've checked the log and it seems that the expired delegation error was
triggered during resource localization.
Maybe there's something wrong with my Hadoop setup, NMs are supposed to get
a good token from RM in order to localize resources automatically.
Regards,
Kiên
2020-11-17
Hi all,
We are testing the new Idleness detection feature in Flink 1.11, however,
it does not work as we expected:
When we connect two data streams, of which one is idle, the output
watermark CoProcessOperator does not increase, hence the program cannot
progress.
I've made a small project to
Hi all,
Since both ReducingState and ValueState store a single value, there are
many use cases where both can be used.
When should we use one instead of the other ?
Best regards,
Kien
Hi,
When I submit a job using RemoteEnvironment without setting parallelism, it
always uses only one task slot.
Is this a bug or intentional ? I thought it was supposed to be the default
configuration of the server (parallelism.default=24 in my cases)
I'm using Flink in Standalone cluster mode.
Hi,
I'm looking for a way get the value of aggregators outside of iteration.
Specifically, I want the final aggregators' value after the iteration
has finished. Is there any API for that ?
Thanks,
Kien Truong
with us?
Cheers,
Till
On Nov 18, 2015 9:54 PM, "Truong Duc Kien" <duckientru...@gmail.com
<mailto:duckientru...@gmail.com>> wrote:
Hi,
I'm hitting Compiler Exception with some of my data set, but not
all of them.
Exception in thread "main"
Hi,
I'm hitting Compiler Exception with some of my data set, but not all of
them.
Exception in thread "main" org.apache.flink.optimizer.CompilerException: No
plan meeting the requirements could be created @ Bulk Iteration (Bulk
Iteration) (1:null). Most likely reason: Too restrictive plan hints.
Hi,
When running CoGroup between the solution set and a different dataset
inside a DeltaIteration, the CoGroupFunction only get called for items
that exist in the other dataset, simillar to an inner join. This is not
the documented behavior for CoGroup:
If a DataSet has a group with no
