Hi,
I'm currently familiarizing myself with the Flink Code and I have a
question regarding operator chaining, maybe somebody could explain this
to me?
The default Chaining Strategy is HEAD (meaning that the predecessor of
the operator will not be chained, thus this operator may be the start of
a
Any modifications to "flink-shaded-include-yarn-tests" with respect to the
dependency inclusion/exclusion does not get reflected in the
"flink-yarn-tests" test case since the referenced packages from
"flink-shaded-include-yarn-tests" are not being used (though the pom file
establish the
I am seeing below failure consistently with the latest trunk code when I run
"mvn clean verify". Is anyone seeing similar error in your environment?
Failed tests:
LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers:166
Thread
Greg Hogan created FLINK-4117:
-
Summary: Wait for CuratorFramework connection to be established
Key: FLINK-4117
URL: https://issues.apache.org/jira/browse/FLINK-4117
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-4116:
---
Summary: Document metrics
Key: FLINK-4116
URL: https://issues.apache.org/jira/browse/FLINK-4116
Project: Flink
Issue Type: Improvement
