[ 
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15836690#comment-15836690
 ] 

ASF GitHub Bot commented on FLINK-3551:
---------------------------------------

Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/2761#discussion_r97654855
  
    --- Diff: 
flink-examples/flink-examples-streaming/src/test/java/org/apache/flink/streaming/test/exampleScalaPrograms/iteration/IterateExampleITCase.java
 ---
    @@ -0,0 +1,49 @@
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more
    + * contributor license agreements.  See the NOTICE file distributed with
    + * this work for additional information regarding copyright ownership.
    + * The ASF licenses this file to You under the Apache License, Version 2.0
    + * (the "License"); you may not use this file except in compliance with
    + * the License.  You may obtain a copy of the License at
    + *
    + *    http://www.apache.org/licenses/LICENSE-2.0
    + *
    + * Unless required by applicable law or agreed to in writing, software
    + * distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    + * See the License for the specific language governing permissions and
    + * limitations under the License.
    + */
    +
    +package org.apache.flink.streaming.test.exampleScalaPrograms.iteration;
    +
    +import org.apache.flink.streaming.scala.examples.iteration.IterateExample;
    +import 
org.apache.flink.streaming.examples.iteration.util.IterateExampleData;
    +import org.apache.flink.streaming.util.StreamingProgramTestBase;
    +
    +public class IterateExampleITCase extends StreamingProgramTestBase {
    --- End diff --
    
    ITCases extending `StreamingProgramTestBase` are very expensive because 
they internally start a Flink minicluster which takes a significant amount of 
time, usually much more than the actual test.
    The class `StreamingMultipleProgramsTestBase` allows to reuse the 
minicluster across several tests.
    I would suggest to port all existing example tests (Java and Scala) into a 
single ITCase which extends `StreamingMultipleProgramsTestBase`. This should 
reduce Flink's build time.



> Sync Scala and Java Streaming Examples
> --------------------------------------
>
>                 Key: FLINK-3551
>                 URL: https://issues.apache.org/jira/browse/FLINK-3551
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Examples
>    Affects Versions: 1.0.0
>            Reporter: Stephan Ewen
>            Assignee: Lim Chee Hau
>
> The Scala Examples lack behind the Java Examples



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to