[jira] [Created] (FLINK-3690) Create documentation on the new ResourceManager component
Henry Saputra created FLINK-3690: Summary: Create documentation on the new ResourceManager component Key: FLINK-3690 URL: https://issues.apache.org/jira/browse/FLINK-3690 Project: Flink Issue Type: Sub-task Components: Documentation, ResourceManager Affects Versions: 1.1.0 Reporter: Henry Saputra Assignee: Maximilian Michels Need proper documentation for the new ResourceManager and how it will impact deployment in different supported modes. Also, we have been very good adding new docs for our internal in the wiki [1] so would like that to happen for people evaluating Flink. [1] https://cwiki.apache.org/confluence/display/FLINK/Flink+Internals -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-2872) Update the documentation for Scala part to add readFileOfPrimitives
Henry Saputra created FLINK-2872: Summary: Update the documentation for Scala part to add readFileOfPrimitives Key: FLINK-2872 URL: https://issues.apache.org/jira/browse/FLINK-2872 Project: Flink Issue Type: Bug Components: Documentation Reporter: Henry Saputra Assignee: Henry Saputra Priority: Minor Currently the Scala part of the ExecutionEnvironment missing readFileOfPrimitives to create Dataset from file for primitive types. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-2847) Fix flaky test in StormTestBase.testJob
Henry Saputra created FLINK-2847:
Summary: Fix flaky test in StormTestBase.testJob
Key: FLINK-2847
URL: https://issues.apache.org/jira/browse/FLINK-2847
Project: Flink
Issue Type: Bug
Components: Tests
Reporter: Henry Saputra
Priority: Minor
{code}
testJob(org.apache.flink.storm.wordcount.WordCountLocalITCase) Time elapsed:
12.845 sec <<< FAILURE!
java.lang.AssertionError: Different number of lines in expected and obtained
result. expected:<801> but was:<0>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:743)
at org.junit.Assert.assertEquals(Assert.java:118)
at org.junit.Assert.assertEquals(Assert.java:555)
at
org.apache.flink.test.util.TestBaseUtils.compareResultsByLinesInMemory(TestBaseUtils.java:305)
at
org.apache.flink.test.util.TestBaseUtils.compareResultsByLinesInMemory(TestBaseUtils.java:291)
at
org.apache.flink.storm.wordcount.WordCountLocalITCase.postSubmit(WordCountLocalITCase.java:38)
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.815 sec - in
org.apache.flink.storm.wordcount.BoltTokenizerWordCountWithNamesITCase
Running org.apache.flink.storm.wordcount.BoltTokenizerWordCountITCase
Running org.apache.flink.storm.wordcount.BoltTokenizerWordCountPojoITCase
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.55 sec - in
org.apache.flink.storm.wordcount.BoltTokenizerWordCountPojoITCase
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.801 sec - in
org.apache.flink.storm.wordcount.BoltTokenizerWordCountITCase
Results :
Failed tests:
WordCountLocalITCase>StormTestBase.testJob:98->postSubmit:38->TestBaseUtils.compareResultsByLinesInMemory:291->TestBaseUtils.compareResultsByLinesInMemory:305
Different number of lines in expected and obtained result. expected:<801> but
was:<0>
Tests run: 11, Failures: 1, Errors: 0, Skipped: 0
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Created] (FLINK-2815) [REFACTOR] Remove Pact from class and file names since it is no longer valid reference
Henry Saputra created FLINK-2815: Summary: [REFACTOR] Remove Pact from class and file names since it is no longer valid reference Key: FLINK-2815 URL: https://issues.apache.org/jira/browse/FLINK-2815 Project: Flink Issue Type: Task Reporter: Henry Saputra Assignee: Henry Saputra Priority: Minor Remove Pact word from class and file names in Apache Flink. Pact was the name used in Stratosphere time to refer to concept of distributed datasets (similar to Flink Dataset). It was used when Pact and Nephele still separate concept. As part of 0.10 cleanup effort, let's remove the Pact names to avoid confusion. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly
Henry Saputra created FLINK-2786: Summary: Remove Spargel from source code and update documentation in favor of Gelly Key: FLINK-2786 URL: https://issues.apache.org/jira/browse/FLINK-2786 Project: Flink Issue Type: Task Components: Documentation, Spargel Reporter: Henry Saputra With Gelly getting more mature and ready to be top level project for Flink, we need to remove deprecated Spargel library from source and documentation. Gelly copies the library needed from Spargel so there should not be hard dependency between the 2 modules. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-2650) Fix broken link in the Table API doc
Henry Saputra created FLINK-2650: Summary: Fix broken link in the Table API doc Key: FLINK-2650 URL: https://issues.apache.org/jira/browse/FLINK-2650 Project: Flink Issue Type: Bug Components: Documentation Reporter: Henry Saputra In the Table API doc [1] there is a broken link to programming guide: https://ci.apache.org/projects/flink/flink-docs-master/libs/programming_guide.html which returns 404 [1] https://ci.apache.org/projects/flink/flink-docs-master/libs/table.html -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-2485) Handle removal of Java Unsafe in Java9
Henry Saputra created FLINK-2485: Summary: Handle removal of Java Unsafe in Java9 Key: FLINK-2485 URL: https://issues.apache.org/jira/browse/FLINK-2485 Project: Flink Issue Type: Task Components: Core Reporter: Henry Saputra With potential Oracle will remove Java Unsafe[1] from Java9 we need to make sure we have upgrade path for Apache Flink [1] https://docs.google.com/document/d/1GDm_cAxYInmoHMor-AkStzWvwE9pw6tnz_CebJQxuUE/edit?pli=1 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-2453) Update POM to use Java7 as the source and target version
Henry Saputra created FLINK-2453: Summary: Update POM to use Java7 as the source and target version Key: FLINK-2453 URL: https://issues.apache.org/jira/browse/FLINK-2453 Project: Flink Issue Type: Sub-task Reporter: Henry Saputra This sub task is created to track effort to update POM files to move to Java7 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-2347) Rendering problem with Documentation website
Henry Saputra created FLINK-2347: Summary: Rendering problem with Documentation website Key: FLINK-2347 URL: https://issues.apache.org/jira/browse/FLINK-2347 Project: Flink Issue Type: Bug Components: Documentation Affects Versions: 0.9 Reporter: Henry Saputra After the new doc site update for 0.9 release, seemed like the release version has some rendering problem that cut some portion of the top of the body. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-2005) Remove dependencies on Record APIs for flink-jdbc module
Henry Saputra created FLINK-2005: Summary: Remove dependencies on Record APIs for flink-jdbc module Key: FLINK-2005 URL: https://issues.apache.org/jira/browse/FLINK-2005 Project: Flink Issue Type: Sub-task Reporter: Henry Saputra Need to remove dependency on old Record API in the flink-jdbc module. Hopefully we could just move them to use common operators APIs instead. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1988) Port Record API based tests in the common.io
Henry Saputra created FLINK-1988: Summary: Port Record API based tests in the common.io Key: FLINK-1988 URL: https://issues.apache.org/jira/browse/FLINK-1988 Project: Flink Issue Type: Sub-task Reporter: Henry Saputra As part of removing old Record API, need to remove more tests that relying on Record API. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1983) Remove dependencies on Record APIs for Spargel
Henry Saputra created FLINK-1983: Summary: Remove dependencies on Record APIs for Spargel Key: FLINK-1983 URL: https://issues.apache.org/jira/browse/FLINK-1983 Project: Flink Issue Type: Sub-task Components: Spargel Reporter: Henry Saputra Need to remove usage of Record API in Spargel -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1982) Remove dependencies of Record for Flink runtime and core
Henry Saputra created FLINK-1982: Summary: Remove dependencies of Record for Flink runtime and core Key: FLINK-1982 URL: https://issues.apache.org/jira/browse/FLINK-1982 Project: Flink Issue Type: Sub-task Components: Core Reporter: Henry Saputra Seemed like there are several uses of Record API in core and runtime module that need to be updated before Record API could be removed. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1823) Rename linq.md to something like table.md to avoid potential trademark issue
Henry Saputra created FLINK-1823: Summary: Rename linq.md to something like table.md to avoid potential trademark issue Key: FLINK-1823 URL: https://issues.apache.org/jira/browse/FLINK-1823 Project: Flink Issue Type: Bug Components: Documentation Reporter: Henry Saputra Priority: Minor Since LINQ is trademarked to Microsoft in related to language integrated query, I suggest we rename docs/linq.md to something else like table.md or integratedquery.md to just avoid potential issue. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1785) Master tests in flink-tachyon fail with java.lang.NoSuchFieldError: IBM_JAVA
Henry Saputra created FLINK-1785:
Summary: Master tests in flink-tachyon fail with
java.lang.NoSuchFieldError: IBM_JAVA
Key: FLINK-1785
URL: https://issues.apache.org/jira/browse/FLINK-1785
Project: Flink
Issue Type: Bug
Components: test
Reporter: Henry Saputra
The master fail in flink-tachyon test when running mvn test:
{code}
---
T E S T S
---
---
T E S T S
---
Running org.apache.flink.tachyon.HDFSTest
Running org.apache.flink.tachyon.TachyonFileSystemWrapperTest
java.lang.NoSuchFieldError: IBM_JAVA
at
org.apache.hadoop.security.UserGroupInformation.getOSLoginModuleName(UserGroupInformation.java:303)
at
org.apache.hadoop.security.UserGroupInformation.clinit(UserGroupInformation.java:348)
at org.apache.hadoop.hdfs.server.namenode.NameNode.format(NameNode.java:807)
at org.apache.hadoop.hdfs.server.namenode.NameNode.format(NameNode.java:266)
at org.apache.hadoop.hdfs.DFSTestUtil.formatNameNode(DFSTestUtil.java:122)
at
org.apache.hadoop.hdfs.MiniDFSCluster.createNameNodesAndSetConf(MiniDFSCluster.java:775)
at
org.apache.hadoop.hdfs.MiniDFSCluster.initMiniDFSCluster(MiniDFSCluster.java:642)
at org.apache.hadoop.hdfs.MiniDFSCluster.init(MiniDFSCluster.java:334)
at org.apache.hadoop.hdfs.MiniDFSCluster$Builder.build(MiniDFSCluster.java:316)
at org.apache.flink.tachyon.HDFSTest.createHDFS(HDFSTest.java:62)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:271)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:70)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:238)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:63)
...
Results :
Failed tests:
HDFSTest.createHDFS:76 Test failed IBM_JAVA
HDFSTest.createHDFS:76 Test failed Could not initialize class
org.apache.hadoop.security.UserGroupInformation
TachyonFileSystemWrapperTest.testTachyon:149 Test failed with
exception: Cannot initialize task 'DataSink (CsvOutputFormat (path:
tachyon://x1carbon:18998/result, delimiter: ))': Could not initialize
class org.apache.hadoop.security.UserGroupInformation
Tests in error:
HDFSTest.destroyHDFS:83 NullPointer
HDFSTest.destroyHDFS:83 NullPointer
TachyonFileSystemWrapperTest.testHadoopLoadability:116 ยป
NoClassDefFound Could...
Tests run: 6, Failures: 3, Errors: 3, Skipped: 0
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Created] (FLINK-1744) Change the reference of slaves to workers to match the description of the system
Henry Saputra created FLINK-1744: Summary: Change the reference of slaves to workers to match the description of the system Key: FLINK-1744 URL: https://issues.apache.org/jira/browse/FLINK-1744 Project: Flink Issue Type: Improvement Components: core, Documentation Reporter: Henry Saputra There are some references to slaves which actually mean workers. Need to change it to use workers whenever possible, unless it is needed when communicating with external system like Apache Hadoop -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1647) Push master documentation (latest) to Flink website
Henry Saputra created FLINK-1647: Summary: Push master documentation (latest) to Flink website Key: FLINK-1647 URL: https://issues.apache.org/jira/browse/FLINK-1647 Project: Flink Issue Type: Task Reporter: Henry Saputra Assignee: Max Michels Per discussions in dev ist we would like to push latest (master) doc to Flink website. This will help new contributors to follow what we are cooking in master branch. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1651) Running mvn test got stuck
Henry Saputra created FLINK-1651: Summary: Running mvn test got stuck Key: FLINK-1651 URL: https://issues.apache.org/jira/browse/FLINK-1651 Project: Flink Issue Type: Bug Components: test Reporter: Henry Saputra I keep getting my test stuck at this state: ... Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.006 sec - in org.apache.flink.runtime.types.TypeTest Running org.apache.flink.runtime.util.AtomicDisposableReferenceCounterTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.561 sec - in org.apache.flink.runtime.util.AtomicDisposableReferenceCounterTest Running org.apache.flink.runtime.util.DataInputOutputSerializerTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 14.848 sec - in org.apache.flink.runtime.operators.DataSourceTaskTest Running org.apache.flink.runtime.util.DelegatingConfigurationTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.003 sec - in org.apache.flink.runtime.util.DelegatingConfigurationTest Running org.apache.flink.runtime.util.EnvironmentInformationTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 20.563 sec - in org.apache.flink.runtime.io.network.serialization.LargeRecordsTest Running org.apache.flink.runtime.util.event.TaskEventHandlerTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.007 sec - in org.apache.flink.runtime.util.event.TaskEventHandlerTest Running org.apache.flink.runtime.util.LRUCacheMapTest Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.012 sec - in org.apache.flink.runtime.util.LRUCacheMapTest Running org.apache.flink.runtime.util.MathUtilTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.002 sec - in org.apache.flink.runtime.util.MathUtilTest Running org.apache.flink.runtime.util.NonReusingKeyGroupedIteratorTest Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.064 sec - in org.apache.flink.runtime.util.NonReusingKeyGroupedIteratorTest Running org.apache.flink.runtime.util.ReusingKeyGroupedIteratorTest Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.003 sec - in org.apache.flink.runtime.util.ReusingKeyGroupedIteratorTest Tests run: 5, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.238 sec - in org.apache.flink.runtime.taskmanager.TaskManagerTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.616 sec - in org.apache.flink.runtime.profiling.impl.InstanceProfilerTest Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.303 sec - in org.apache.flink.runtime.util.DataInputOutputSerializerTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.488 sec - in org.apache.flink.runtime.util.EnvironmentInformationTest Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 6.81 sec - in org.apache.flink.runtime.taskmanager.TaskManagerProcessReapingTest Tests run: 46, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.653 sec - in org.apache.flink.runtime.operators.MatchTaskTest Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 15.071 sec - in org.apache.flink.runtime.operators.sort.LargeRecordHandlerTest Tests run: 7, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 22.534 sec - in org.apache.flink.runtime.operators.DataSinkTaskTest Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 24.98 sec - in org.apache.flink.runtime.operators.sort.NormalizedKeySorterTest Tests run: 6, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 49.017 sec - in org.apache.flink.runtime.io.disk.ChannelViewsTest After this seemed like nothing happen. And the program just hang. I am using MacOSX with Java version 1.7.0_71 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1653) Setting up Apache Jenkins CI for continuous tests
Henry Saputra created FLINK-1653: Summary: Setting up Apache Jenkins CI for continuous tests Key: FLINK-1653 URL: https://issues.apache.org/jira/browse/FLINK-1653 Project: Flink Issue Type: Task Components: Build System Reporter: Henry Saputra Assignee: Henry Saputra Priority: Minor We already have Travis build for Apache Flink Github mirror. This task is used to track effort to setup Flink Jenkins CI in ASF environment [1] [1] https://builds.apache.org -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release
Henry Saputra created FLINK-1639: Summary: Document the Flink deployment scripts to make sure others know how to make release Key: FLINK-1639 URL: https://issues.apache.org/jira/browse/FLINK-1639 Project: Flink Issue Type: Task Components: release Reporter: Henry Saputra Currently, Robert knows the detail about Flink deployment and release scripts to support both Hadoop versions. Need to document details black magic used in the scripts to make sure other knows how the flow work just in case we need to push release and Robert is not available. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1611) Rename classes and packages with Nephele
Henry Saputra created FLINK-1611: Summary: Rename classes and packages with Nephele Key: FLINK-1611 URL: https://issues.apache.org/jira/browse/FLINK-1611 Project: Flink Issue Type: Improvement Components: other Reporter: Henry Saputra Assignee: Henry Saputra Priority: Minor We have several classes and packages names that have Nephele names: ./flink-compiler/src/main/java/org/apache/flink/compiler/plantranslate/NepheleJobGraphGenerator.java ./flink-tests/src/test/java/org/apache/flink/test/broadcastvars/BroadcastVarsNepheleITCase.java ./flink-tests/src/test/java/org/apache/flink/test/broadcastvars/KMeansIterativeNepheleITCase.java ./flink-tests/src/test/java/org/apache/flink/test/iterative/nephele/ConnectedComponentsNepheleITCase.java ./flink-tests/src/test/java/org/apache/flink/test/iterative/nephele/DanglingPageRankNepheleITCase.java ./flink-tests/src/test/java/org/apache/flink/test/iterative/nephele/DanglingPageRankWithCombinerNepheleITCase.java ./flink-tests/src/test/java/org/apache/flink/test/iterative/nephele/IterationWithChainingNepheleITCase.java Nephele was the older name used by Flink in early years to describe the Flink processing engine. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1612) Add guidelines to avoid duplicate class names and more JavaDoc for new addition
Henry Saputra created FLINK-1612: Summary: Add guidelines to avoid duplicate class names and more JavaDoc for new addition Key: FLINK-1612 URL: https://issues.apache.org/jira/browse/FLINK-1612 Project: Flink Issue Type: Improvement Components: website, Documentation Reporter: Henry Saputra Per discssions in dev@ list would like to add extra guidelines to code style on how to contribute in Flink website: -) Add guide to avoid same class names, even though in different packages, in non client facing (eg: Scala vs Java) APIs code. This will allow easier way for new contributors to trace and understand the internal of Flink. -) Add guide to make sure new Java and Scala classes have JavaDoc explaining why the are they added and how it relates to existing code and flows. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1603) Update how to contribute doc to include information to send Github PR instead of attaching patch
Henry Saputra created FLINK-1603: Summary: Update how to contribute doc to include information to send Github PR instead of attaching patch Key: FLINK-1603 URL: https://issues.apache.org/jira/browse/FLINK-1603 Project: Flink Issue Type: Task Components: Documentation Reporter: Henry Saputra The current how to contribute doc [1] only contains submit patch to JIRA as way to contribute. While this is acceptable, in practice we are actually been accepting Github PRs as the main way to accept contributions. The issue is created to update the doc to reflect this mechanism.D -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1542) Test case at BlobUtilsTest should not assume user could not create new item in root directory
Henry Saputra created FLINK-1542: Summary: Test case at BlobUtilsTest should not assume user could not create new item in root directory Key: FLINK-1542 URL: https://issues.apache.org/jira/browse/FLINK-1542 Project: Flink Issue Type: Bug Reporter: Henry Saputra The test at BlobUtilsTest #testExceptionOnCreateStorageDirectoryFailure assume that current user cannot create new directory at root. In my MacOSX, my user has admin group so the test will always fail. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1440) Missing plan visualizer image for http://flink.apache.org/docs/0.8/programming_guide.html page
Henry Saputra created FLINK-1440: Summary: Missing plan visualizer image for http://flink.apache.org/docs/0.8/programming_guide.html page Key: FLINK-1440 URL: https://issues.apache.org/jira/browse/FLINK-1440 Project: Flink Issue Type: Bug Components: Project Website Reporter: Henry Saputra In the http://flink.apache.org/docs/0.8/programming_guide.html page looks like we are missing http://flink.apache.org/docs/0.8/img/plan_visualizer2.png file. I could not find it anywhere in the source. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-1402) Remove extra extend Serializable in InputFormat interface
Henry Saputra created FLINK-1402: Summary: Remove extra extend Serializable in InputFormat interface Key: FLINK-1402 URL: https://issues.apache.org/jira/browse/FLINK-1402 Project: Flink Issue Type: Bug Reporter: Henry Saputra Assignee: Henry Saputra Priority: Minor The org.apache.flink.api.common.io.InputFormat currently defined as: public interface InputFormatOT, T extends InputSplit extends InputSplitSourceT, Serializable however, InputSplitSource already extend Serializable: public interface InputSplitSourceT extends InputSplit extends Serializable so no need for InputFormat to explicitly extend Serializable interface. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
