[
https://issues.apache.org/jira/browse/FLINK-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460790#comment-16460790
]
ASF GitHub Bot commented on FLINK-9235:
---------------------------------------
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5901#discussion_r185445414
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -85,54 +88,75 @@ public void checkForProhibitedLogContents() {
public void testDetachedMode() throws InterruptedException, IOException
{
LOG.info("Starting testDetachedMode()");
addTestAppender(FlinkYarnSessionCli.class, Level.INFO);
- Runner runner =
- startWithArgs(new String[]{"-j",
flinkUberjar.getAbsolutePath(),
- "-t",
flinkLibFolder.getAbsolutePath(),
- "-n", "1",
- "-jm", "768",
- "-tm", "1024",
- "--name", "MyCustomName", //
test setting a custom name
- "--detached"},
- "Flink JobManager is now running on",
RunTypes.YARN_SESSION);
-
+ File exampleJarLocation =
getTestJarPath("StreamingWordCount.jar");
+ // get temporary file for reading input data for wordcount
example
+ File tmpInFile;
+ try {
+ tmpInFile = tmp.newFile();
+ FileUtils.writeStringToFile(tmpInFile,
WordCountData.TEXT);
+ }
+ catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ Runner runner = isNewMode ?
--- End diff --
The reason why the other method always starts a legacy cluster is this
line:
https://github.com/apache/flink/blob/af5279e9bd3dec18512a54c59982e3dc1f253cd2/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java#L531
We always set mode to legacy if there's Kerberos stuff in the config. I
don't know yet why that line is there.
> Add Integration test for Flink-Yarn-Kerberos integration for flip-6
> -------------------------------------------------------------------
>
> Key: FLINK-9235
> URL: https://issues.apache.org/jira/browse/FLINK-9235
> Project: Flink
> Issue Type: Test
> Affects Versions: 1.5.0
> Reporter: Shuyi Chen
> Assignee: Shuyi Chen
> Priority: Major
>
> We need to provide an integration test for flip-6 similar to
> YARNSessionFIFOSecuredITCase for the legacy deployment mode.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
