You are viewing a plain text version of this content. The canonical link for it is here.
- A small Project I've been working on - posted by Aljoscha Krettek <al...@apache.org> on 2015/04/01 08:43:31 UTC, 10 replies.
- Re: [DISCUSS] Inconsistent naming of intermediate results - posted by Ufuk Celebi <uc...@apache.org> on 2015/04/01 10:39:07 UTC, 1 replies.
- Re: [DISCUSS] Gelly iteration abstractions - posted by Stephan Ewen <se...@apache.org> on 2015/04/01 10:48:38 UTC, 1 replies.
- Re: Question about Infinite Streaming Job on Mini Cluster and ITCase - posted by Márton Balassi <ba...@gmail.com> on 2015/04/01 11:09:13 UTC, 3 replies.
- Make docs searchable - posted by Ufuk Celebi <uc...@apache.org> on 2015/04/01 12:10:38 UTC, 11 replies.
- Re: HBase TableOutputFormat fix (Flink 0.8.1) - posted by Flavio Pompermaier <po...@okkam.it> on 2015/04/01 13:44:21 UTC, 15 replies.
- [jira] [Created] (FLINK-1810) UpdateTask message contains unused information - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/01 14:54:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1811) Allow users to pass custom buffer sizes and timeouts to PersistentKafkaSource - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/01 15:10:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1812) TaskManager shell scripts restart JVMs on process failures - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/01 15:51:52 UTC, 0 replies.
- Re: [QUESTION] In the DataExchangeMode.BATCH how does the consumer being notified to start consumer the data? - posted by Henry Saputra <he...@gmail.com> on 2015/04/01 16:08:17 UTC, 0 replies.
- [jira] [Created] (FLINK-1813) Barrier broadcast sometimes causes illegal state exception in source RecordWriter - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/01 22:19:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1814) Revisit the documentation to add new operator - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/04/02 08:29:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1815) Add methods to read and write a Graph as adjacency list - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/04/02 09:25:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1816) DegreesWithExceptionITCase.testGetDegreesInvalidEdgeSrcId fails with wrong exception - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/02 10:18:53 UTC, 0 replies.
- Canceling a Cluster Job from Java - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/04/02 10:57:20 UTC, 2 replies.
- [jira] [Created] (FLINK-1817) ClassLoaderObjectInputStream fails with ClassNotFoundException for primitive classes - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/04/02 11:31:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1818) Provide API to cancel running job - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/02 15:28:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/04/02 15:48:54 UTC, 0 replies.
- Re: Travis-CI builds queuing up - posted by Robert Metzger <rm...@apache.org> on 2015/04/02 15:58:36 UTC, 1 replies.
- Should collect() and count() be treated as data sinks? - posted by Felix Neutatz <ne...@googlemail.com> on 2015/04/02 17:33:20 UTC, 7 replies.
- Rework of the window-join semantics - posted by Gyula Fóra <gy...@apache.org> on 2015/04/02 18:32:21 UTC, 25 replies.
- Re: [DISCUSS] Make a release to be announced at ApacheCon - posted by Robert Metzger <rm...@apache.org> on 2015/04/02 19:06:42 UTC, 0 replies.
- Storm compatibility layer for Flink (first beta available) - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/04/02 19:31:24 UTC, 11 replies.
- [jira] [Created] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0 - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2015/04/03 00:03:56 UTC, 0 replies.
- Test sources in wrong folder - posted by Flavio Pompermaier <po...@okkam.it> on 2015/04/03 00:11:22 UTC, 4 replies.
- Release 0.9.0-milestone-1 preview - posted by Robert Metzger <rm...@apache.org> on 2015/04/03 10:49:28 UTC, 3 replies.
- NullPointerException in DeltaIteration when no ForwardedFileds annotation - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/04/03 12:46:43 UTC, 8 replies.
- [jira] [Created] (FLINK-1821) simplify coding - posted by "Liu Jiongzhou (JIRA)" <ji...@apache.org> on 2015/04/03 14:33:55 UTC, 0 replies.
- [jira] [Created] (FLINK-1822) Update "Community" page on website with a "Getting Help" section - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/03 15:10:52 UTC, 0 replies.
- [jira] [Created] (FLINK-1823) Rename linq.md to something like table.md to avoid potential trademark issue - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/04/03 17:36:53 UTC, 0 replies.
- [jira] [Created] (FLINK-1824) Allow missing types for DataStreams - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/03 17:48:54 UTC, 0 replies.
- [jira] [Created] (FLINK-1825) Fix the constructor comments with correct parameter in DefaultMemoryManager - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/04/04 04:26:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1826) Remove the code never be executed in function getNumPages - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/04/04 06:54:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/04/04 12:53:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1828) Impossible to output data to an HBase table - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/04/04 13:08:33 UTC, 0 replies.
- [jira] [Created] (FLINK-1829) Conflicting Jackson version in the Flink POMs - posted by "Alexander Alexandrov (JIRA)" <ji...@apache.org> on 2015/04/04 15:57:33 UTC, 0 replies.
- Parquet Article / Tutorial - posted by Felix Neutatz <ne...@googlemail.com> on 2015/04/05 15:30:28 UTC, 10 replies.
- [jira] [Created] (FLINK-1830) java.io.IOException: Network stream corrupted - posted by "Stefan Bunk (JIRA)" <ji...@apache.org> on 2015/04/06 14:01:12 UTC, 0 replies.
- [QUESTION] Sort Key Types - posted by Stephan Ewen <se...@apache.org> on 2015/04/06 14:34:39 UTC, 5 replies.
- Too many log4j.properties files - posted by Stephan Ewen <se...@apache.org> on 2015/04/06 21:01:45 UTC, 7 replies.
- Gelly message type - posted by Yi ZHOU <zh...@hotmail.com> on 2015/04/06 21:26:03 UTC, 1 replies.
- [jira] [Created] (FLINK-1831) runtime.taskmanager.RegistrationTests fails sporiously - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/04/07 09:52:12 UTC, 1 replies.
- [jira] [Created] (FLINK-1832) start-local.bat/start-local.sh does not work if there is a white space in the file path (windows) - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2015/04/07 10:34:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1833) Refactor partition availability notification in ExecutionGraph - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/07 11:10:24 UTC, 0 replies.
- [jira] [Created] (FLINK-1834) Is mapred.output.dir conf parameter really required? - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/04/07 11:25:15 UTC, 0 replies.
- [jira] [Created] (FLINK-1835) Spurious failure of YARN tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/07 12:53:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1836) just test - posted by "zhu (JIRA)" <ji...@apache.org> on 2015/04/07 13:41:12 UTC, 0 replies.
- Flink Forward 2015 - posted by Kostas Tzoumas <kt...@apache.org> on 2015/04/07 14:24:34 UTC, 1 replies.
- [jira] [Created] (FLINK-1837) Throw an exceptions for iterative streaming programs with checkpointing enabled - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/04/07 16:05:27 UTC, 0 replies.
- [jira] [Created] (FLINK-1838) Update streaming programming guide - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/07 16:20:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1839) Failures in TwitterStreamITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/07 18:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1840) Job execution fails on Windows (native and Cygwin) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/04/07 21:21:12 UTC, 0 replies.
- [DISCUSS] Break up streaming connectors into subprojects - posted by Stephan Ewen <se...@apache.org> on 2015/04/07 21:21:27 UTC, 5 replies.
- [jira] [Created] (FLINK-1841) WindowJoinITCase fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/04/08 00:18:14 UTC, 0 replies.
- Hbase OutputFormat examples - posted by santosh_rajaguru <sa...@gmail.com> on 2015/04/08 10:00:14 UTC, 1 replies.
- [jira] [Created] (FLINK-1842) ApplicationMaster for YARN FIFO tests does not shut down properly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/08 11:26:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1843) Job History gets cleared too fast - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/04/08 11:29:13 UTC, 1 replies.
- [jira] [Created] (FLINK-1844) Add Normaliser to ML library - posted by "Faye Beligianni (JIRA)" <ji...@apache.org> on 2015/04/08 13:07:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1845) NonReusingSortMergeCoGroupIterator uses ReusingKeyGroupedIterator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/08 14:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1846) Sinks inside of iterations - posted by "Markus Holzemer (JIRA)" <ji...@apache.org> on 2015/04/08 14:43:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1847) Change Scala collect() method to return a Seq - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/08 15:18:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/04/08 15:45:12 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.9.0-milestone-1 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2015/04/08 23:00:50 UTC, 10 replies.
- [jira] [Created] (FLINK-1849) Refactor StreamingRuntimeContext - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/04/09 03:19:12 UTC, 0 replies.
- 答复: [VOTE] Release Apache Flink 0.9.0-milestone-1 (RC1) - posted by Matadorhong <ho...@huawei.com> on 2015/04/09 10:24:41 UTC, 2 replies.
- [jira] [Created] (FLINK-1850) Snapshot docs overview page refers to wrong version - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/09 11:24:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1851) Java Table API does not support Casting - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/04/09 11:36:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1852) Scala API's count and collect methods are declared without parenthesis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/09 12:17:12 UTC, 0 replies.
- help me - posted by hager sallah <lo...@yahoo.com.INVALID> on 2015/04/09 15:35:49 UTC, 2 replies.
- Quickstart build - Fat Jar is empty - posted by "Papp, Stefan" <St...@Teradata.com> on 2015/04/09 15:44:28 UTC, 16 replies.
- [jira] [Created] (FLINK-1853) TopSpeedWindowing example cannot be run from the ComandLine or Webclient - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/09 15:59:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1854) Planvisualizer cannot visualize the streaming iteration example - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/09 16:15:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1855) SocketTextStreamWordCount example cannot be run from the webclient - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/09 16:17:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1856) Add required imports to Scala API examples - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/09 16:22:12 UTC, 0 replies.
- broadcast set sizes - posted by Martin Neumann <mn...@spotify.com> on 2015/04/09 16:44:55 UTC, 0 replies.
- Other Mailing Lists for Issues and Commits - posted by sirinath <si...@gmail.com> on 2015/04/09 17:05:37 UTC, 1 replies.
- broadcast set size - posted by Martin Neumann <mn...@sics.se> on 2015/04/09 17:36:46 UTC, 2 replies.
- [jira] [Created] (FLINK-1857) Flakey SimpleRecoveryITCase#testRestartMultipleTimes test - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/10 11:32:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1858) Add further checks to QA bot - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/10 11:48:13 UTC, 0 replies.
- [DISCUSS] Spargel vs. Gelly - posted by Ufuk Celebi <uc...@apache.org> on 2015/04/10 12:13:04 UTC, 6 replies.
- [jira] [Created] (FLINK-1859) MultiTriggerPolicyTest sometimes fails on Travis - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/04/10 12:26:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1860) Release script out of sync with build artifacts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/10 13:49:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1861) Rename doc deployment directories - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/10 13:52:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1862) Collect() does not support non-serializable user types - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/10 14:34:16 UTC, 0 replies.
- [jira] [Created] (FLINK-1863) RemoteInputChannelTest.testConcurrentOnBufferAndRelease fails on travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/10 15:31:15 UTC, 0 replies.
- [jira] [Created] (FLINK-1864) Investigate Travis build success when locally not building - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/10 15:45:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1865) Unstable test KafkaITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/10 16:10:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1866) In StreamConfig IN_STREAM_EDGES and OUT_STREAM_EDGES have same config key - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/04/10 16:18:12 UTC, 0 replies.
- Question about StreamGraph - posted by Aljoscha Krettek <al...@apache.org> on 2015/04/10 16:56:43 UTC, 3 replies.
- [jira] [Created] (FLINK-1867) TaskManagerFailureRecoveryITCase causes stalled travis builds - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/10 17:17:14 UTC, 0 replies.
- [jira] [Created] (FLINK-1868) EnvironmentInformationTest.testJavaMemory fails on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/10 17:25:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1869) Make StreamDiscretizers chainable - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/10 18:14:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1870) Reintroduce Indexed reader functionality to streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/10 18:25:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1871) Add a Spargel to Gelly migration guide - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/04/11 11:56:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1872) How can generation dataset in flink automatic depend on number of filed and data type - posted by "hagersaleh (JIRA)" <ji...@apache.org> on 2015/04/11 14:19:12 UTC, 0 replies.
- [Gelly] question about vertex-centric Iteration - posted by Yi ZHOU <zh...@hotmail.com> on 2015/04/11 18:01:45 UTC, 1 replies.
- [RESULT] [VOTE] Release Apache Flink 0.9.0-milestone-1 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2015/04/12 10:12:33 UTC, 2 replies.
- Apache Mahout 0.10.0 Released - posted by Suneel Marthi <sm...@apache.org> on 2015/04/12 12:48:17 UTC, 0 replies.
- [QUESTION] Scala Table API syntax - posted by Ufuk Celebi <uc...@apache.org> on 2015/04/12 13:12:57 UTC, 5 replies.
- [DISCUSS] Create a Flink 0.8.2 release - posted by Robert Metzger <rm...@apache.org> on 2015/04/12 17:13:42 UTC, 2 replies.
- Apache Ignite - posted by sirinath <si...@gmail.com> on 2015/04/12 18:53:14 UTC, 4 replies.
- [jira] [Created] (FLINK-1873) Distributed matrix implementation - posted by "liaoyuxi (JIRA)" <ji...@apache.org> on 2015/04/13 04:08:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1874) Break up streaming connectors into submodules - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/13 09:49:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1875) Add figure to documentation describing - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/13 10:30:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1876) Refactor StreamGraph to be node centric - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/13 11:31:21 UTC, 0 replies.
- [jira] [Created] (FLINK-1877) Stalled Flink on Tez build - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/13 12:04:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1878) Add mode to Environments to deactivate sysout printing - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/13 12:49:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1879) Simplify JobClient - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/13 12:51:15 UTC, 0 replies.
- [jira] [Created] (FLINK-1880) TaskManagerTest fails spuriously - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/04/13 12:57:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1881) want link explain Table API Java in flink and what is important - posted by "hagersaleh (JIRA)" <ji...@apache.org> on 2015/04/13 15:05:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1882) Remove RemoteCollectorOutputFormat - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/13 16:35:12 UTC, 0 replies.
- Flink 0.9.0-milestone1 released - posted by Kostas Tzoumas <kt...@apache.org> on 2015/04/13 17:10:40 UTC, 3 replies.
- Flink - Avro - AvroTypeInfo issue - Index out of bounds exception - posted by Filip Łęczycki <fi...@gmail.com> on 2015/04/13 18:25:34 UTC, 3 replies.
- [jira] [Created] (FLINK-1883) Add Min Vertex ID Propagation Library Method and Example - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/04/13 19:16:12 UTC, 0 replies.
- Major Streaming refactoring - posted by Gyula Fóra <gy...@apache.org> on 2015/04/13 21:36:14 UTC, 1 replies.
- [jira] [Created] (FLINK-1884) Outdated Spargel docs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/04/13 23:02:16 UTC, 0 replies.
- [jira] [Created] (FLINK-1885) Bulk mode for gelly - posted by "Markus Holzemer (JIRA)" <ji...@apache.org> on 2015/04/14 09:16:12 UTC, 0 replies.
- Re: Queries regarding RDFs with Flink - posted by Flavio Pompermaier <po...@okkam.it> on 2015/04/14 09:37:03 UTC, 3 replies.
- [jira] [Created] (FLINK-1886) how can handles left join ,right join , FULL OUTER JOIN in flink - posted by "hagersaleh (JIRA)" <ji...@apache.org> on 2015/04/14 11:04:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1887) Fix the message in runtime exception - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/04/14 12:16:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1888) Download page doesn't contain Maven dependencies for 0.9.0-milestone-1 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/04/14 14:07:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1889) Create optimization framework - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/04/14 14:08:13 UTC, 0 replies.
- Fwd: Collect of user defined classes doesn't work - posted by Felix Neutatz <ne...@googlemail.com> on 2015/04/14 15:36:01 UTC, 6 replies.
- Flink interactive Scala shell - posted by nse sik <ni...@gmail.com> on 2015/04/14 17:26:30 UTC, 6 replies.
- [jira] [Created] (FLINK-1890) Add withReadFields or sth. similar to Scala API - posted by "Stefan Bunk (JIRA)" <ji...@apache.org> on 2015/04/14 20:04:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1891) Add isEmpty check when the input dir - posted by "Sibao Hong (JIRA)" <ji...@apache.org> on 2015/04/15 12:17:59 UTC, 0 replies.
- About Operator and OperatorBase - posted by Aljoscha Krettek <al...@apache.org> on 2015/04/15 14:11:07 UTC, 13 replies.
- [jira] [Created] (FLINK-1892) Local job execution does not exit. - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/04/16 12:04:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1893) Add Scala support for Flink on Tez - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/04/16 12:05:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1894) Add Tez execution mode to Flink command-line tools - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/04/16 12:08:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1896) Add broadcast variables feature to Flink on Tez - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/04/16 12:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1895) Add task chaining to Flink on Tez - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/04/16 12:09:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1897) Add accummulators and counters feature to Flink on Tez - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/04/16 12:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1898) Add support for self-joins to Flink on Tez - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/04/16 12:19:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1899) Table API Bug - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2015/04/16 13:44:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1900) Table API documentation example does not work - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/04/16 14:08:59 UTC, 0 replies.
- TableAPI - Join on two keys - posted by Felix Neutatz <ne...@googlemail.com> on 2015/04/16 14:28:01 UTC, 6 replies.
- [jira] [Created] (FLINK-1901) Create sample operator for Dataset - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/04/16 15:50:58 UTC, 0 replies.
- [Gelly] Vertex-centric iteration updateVertex does not get called - posted by Hermann Gábor <re...@gmail.com> on 2015/04/16 21:44:14 UTC, 3 replies.
- [jira] [Created] (FLINK-1902) Web interface reports false (the default) jobmanager.rpc.port on YARN - posted by "Zoltán Zvara (JIRA)" <ji...@apache.org> on 2015/04/17 08:54:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1904) Add cross() to Table API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/04/17 09:45:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1903) Joins where one side uses a field more than once don't work - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/04/17 09:45:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1905) Add tests for parallelism > 1 for Kafka sources - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/17 11:58:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1906) Add tip to work around plain Tuple return type of project operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/04/17 12:58:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1907) Scala Interactive Shell - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2015/04/17 18:24:59 UTC, 0 replies.
- [DISCUSS] Replace user@f.a.o with Stackoverflow - posted by Ufuk Celebi <uc...@apache.org> on 2015/04/18 11:16:13 UTC, 7 replies.
- [jira] [Created] (FLINK-1908) JobManager startup delay isn't considered when using start-cluster.sh script - posted by "Lukas Raska (JIRA)" <ji...@apache.org> on 2015/04/18 13:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1909) Refactor streaming scala api to use returns for adding typeinfo - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/18 14:48:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1910) why this code flink not reurn value when use variable in filter - posted by "hagersaleh (JIRA)" <ji...@apache.org> on 2015/04/18 15:47:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1911) DataStream and DataSet projection is out of sync - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/18 22:52:01 UTC, 0 replies.
- Gelly, problem vertex centric iteration - posted by Yi ZHOU <zh...@hotmail.com> on 2015/04/19 14:58:12 UTC, 2 replies.
- problem when use this coding please found slove - posted by hager sallah <lo...@yahoo.com.INVALID> on 2015/04/19 15:17:12 UTC, 1 replies.
- [jira] [Created] (FLINK-1912) how can get top 10 row in flink - posted by "hagersaleh (JIRA)" <ji...@apache.org> on 2015/04/19 16:09:59 UTC, 0 replies.
- Merge Python API - posted by Robert Metzger <rm...@apache.org> on 2015/04/20 11:03:23 UTC, 9 replies.
- Question about Flink Project - posted by Matthias <ma...@campus.tu-berlin.de> on 2015/04/20 11:15:51 UTC, 2 replies.
- Hadoop ETLing with Flink - posted by "Papp, Stefan" <St...@Teradata.com> on 2015/04/20 13:29:11 UTC, 4 replies.
- [jira] [Created] (FLINK-1913) Document how to access data in HCatalog - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/20 14:52:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1914) Wrong FS while starting YARN session without correct HADOOP_HOME - posted by "Zoltán Zvara (JIRA)" <ji...@apache.org> on 2015/04/20 16:06:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1915) Faulty plan selection by optimizer - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/20 19:55:59 UTC, 0 replies.
- Periodic full stream aggregations - posted by Gyula Fóra <gy...@apache.org> on 2015/04/20 22:32:07 UTC, 9 replies.
- Fault Tolerance for Flink Iterations - posted by Markus Holzemer <ho...@googlemail.com> on 2015/04/21 08:58:58 UTC, 3 replies.
- [jira] [Created] (FLINK-1916) EOFException when running delta-iteration job - posted by "Stefan Bunk (JIRA)" <ji...@apache.org> on 2015/04/21 12:52:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1917) EOFException when running delta-iteration job - posted by "Stefan Bunk (JIRA)" <ji...@apache.org> on 2015/04/21 12:53:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1918) NullPointerException at org.apache.flink.client.program.Client's constructor while using ExecutionEnvironment.createRemoteEnvironment - posted by "Zoltán Zvara (JIRA)" <ji...@apache.org> on 2015/04/21 13:28:58 UTC, 0 replies.
- Akka transparency and serialisation - posted by Paris Carbone <pa...@kth.se> on 2015/04/21 13:41:14 UTC, 1 replies.
- [jira] [Created] (FLINK-1919) Add HCatOutputFormat for Tuple data types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/04/21 15:40:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1920) Passing -D akka.ask.timeout=5 min to yarn client does not work - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/22 11:16:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1921) Rework parallelism/slots handling for per-job YARN sessions - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/22 11:26:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1922) Failed task deployment causes NPE on input split assignment - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/22 12:03:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1923) Replace asynchronous logging in JobManager with regular slf4j logging - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/22 12:15:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1924) [Py] Refactor a few minor things - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/04/22 12:17:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1925) Split SubmitTask method up into two phases: Receive TDD and instantiation of TDD - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/22 12:18:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1926) [Py] Sync Python API with otehr API's - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/04/22 12:26:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1927) [Py] Rework operator distribution - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/04/22 12:33:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1928) BlobManager can be a bottleneck on large deployments - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/22 12:34:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1929) Add code to cleanly stop a running streaming topology - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/22 15:02:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1930) NullPointerException in vertex-centric iteration - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/04/22 16:34:59 UTC, 0 replies.
- [jira] [Created] (FLINK-1931) Add ADMM to optimization framework - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/22 18:25:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1932) Add L-BFGS to the optimization framework - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/22 18:30:58 UTC, 0 replies.
- Re: Extracting detailed Flink execution plan - posted by Amit Pawar <am...@gmail.com> on 2015/04/23 02:01:11 UTC, 6 replies.
- [jira] [Created] (FLINK-1933) Add distance measure interface and basic implementation to machine learning library - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/04/23 06:33:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/23 10:00:48 UTC, 0 replies.
- [jira] [Created] (FLINK-1935) Reimplement PersistentKafkaSource using high level Kafka API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/23 14:52:55 UTC, 0 replies.
- [jira] [Created] (FLINK-1936) Normalize keys and default values in ConfigConstants.java - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/04/23 15:23:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1937) Cannot create SparseVector with only one non-zero element. - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/04/24 05:23:38 UTC, 0 replies.
- Apache Mahout - posted by sirinath <si...@gmail.com> on 2015/04/24 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-1938) Add Grunt for building the front-end - posted by "Vikhyat Korrapati (JIRA)" <ji...@apache.org> on 2015/04/24 16:13:38 UTC, 0 replies.
- [Documentation] Broken links - posted by Andra Lungu <lu...@gmail.com> on 2015/04/24 17:00:50 UTC, 1 replies.
- Join with a custom predicate - posted by "Kirschnick, Johannes" <jo...@tu-berlin.de> on 2015/04/24 20:55:23 UTC, 4 replies.
- [jira] [Created] (FLINK-1939) Add Parquet Documentation to Wiki - posted by "Felix Neutatz (JIRA)" <ji...@apache.org> on 2015/04/26 10:31:39 UTC, 0 replies.
- Adding a new operator - posted by Andra Lungu <lu...@gmail.com> on 2015/04/26 12:26:00 UTC, 7 replies.
- [jira] [Created] (FLINK-1940) StockPrice example cannot be visualized - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/26 12:56:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1941) Add documentation for Gelly-GSA - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/04/26 14:13:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1942) Add configuration options to Gelly-GSA - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/04/26 14:19:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1943) Add Gelly-GSA compiler and translation tests - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/04/26 14:22:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1944) Add a Gelly-GSA PageRank example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/04/26 14:35:38 UTC, 0 replies.
- how can handle left outer join for any two dataset this dataset inlcude any filed number - posted by hager sallah <lo...@yahoo.com.INVALID> on 2015/04/26 21:07:14 UTC, 1 replies.
- [jira] [Created] (FLINK-1945) Make python tests less verbose - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/27 10:20:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1946) Make yarn tests logging less verbose - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/27 10:24:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1947) Make Avro and Tachyon test logging less verbose - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/04/27 10:32:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1948) Add manual task slot handling for streaming jobs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/04/27 14:31:39 UTC, 0 replies.
- [jira] [Created] (FLINK-1949) YARNSessionFIFOITCase sometimes fails to detect when the detached session finishes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/27 15:21:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1950) Increase default heap cutoff ratio from 20% to 30% and move default value to ConfigConstants - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/27 16:09:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1951) NullPointerException in DeltaIteration when no ForwardedFileds - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/04/27 17:13:38 UTC, 0 replies.
- outofmemory error. help. - posted by 东方不败 <da...@163.com> on 2015/04/28 08:45:43 UTC, 1 replies.
- [DISCUSS] Change semantics of print() to "eager" - posted by Aljoscha Krettek <al...@apache.org> on 2015/04/28 10:18:26 UTC, 12 replies.
- [jira] [Created] (FLINK-1952) Cannot run ConnectedComponents example: Could not allocate a slot on instance - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/28 12:35:06 UTC, 0 replies.
- Task failures and error handling - posted by Ufuk Celebi <uc...@apache.org> on 2015/04/28 13:18:07 UTC, 1 replies.
- Failing Builds on Travis - posted by Robert Metzger <rm...@apache.org> on 2015/04/28 13:34:06 UTC, 6 replies.
- Flink Streaming Next Steps - posted by Stephan Ewen <se...@apache.org> on 2015/04/28 14:10:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1953) Rework Checkpoint Coordinator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/04/28 14:49:06 UTC, 0 replies.
- [DISCUSS] Flink and Ignite integration - posted by Konstantin Boudnik <co...@apache.org> on 2015/04/28 23:57:53 UTC, 5 replies.
- [jira] [Created] (FLINK-1954) Task Failures and Error Handling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/29 12:19:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1955) Improve error handling of sender task failures - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/29 12:30:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1956) Runtime context not initialized in RichWindowMapFunction - posted by "Daniel Bali (JIRA)" <ji...@apache.org> on 2015/04/29 12:33:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1957) Improve error handling of transport failures - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/29 12:35:07 UTC, 0 replies.
- [jira] [Created] (FLINK-1958) Improve error handling of receiver task failures - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/04/29 13:56:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1959) Accumulators BROKEN after Partitioning - posted by "mustafa elbehery (JIRA)" <ji...@apache.org> on 2015/04/29 15:50:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1960) Add comments and docs for withForwardedFields and related operators - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/04/29 16:05:07 UTC, 0 replies.
- [jira] [Created] (FLINK-1961) DataSet.partitionCustom not documented - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/29 16:29:06 UTC, 0 replies.
- Question about SlidingPreReducers - posted by Aljoscha Krettek <al...@apache.org> on 2015/04/29 16:44:57 UTC, 10 replies.
- Flink's multi-user support - posted by Maximilian Michels <mx...@apache.org> on 2015/04/29 17:33:31 UTC, 7 replies.
- Scala compatibility in Gelly - posted by Pieter-Jan Van Aeken <pi...@euranova.eu> on 2015/04/29 18:27:46 UTC, 1 replies.
- Migrating our website from SVN to Git - posted by Maximilian Michels <mx...@apache.org> on 2015/04/30 11:29:06 UTC, 7 replies.
- [jira] [Created] (FLINK-1962) Add Gelly Scala API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/04/30 12:06:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1963) Improve distinct() transformation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/04/30 14:09:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1964) Rework TwitterSource to use a Properties object instead of a file path - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/04/30 16:17:06 UTC, 0 replies.
- [jira] [Created] (FLINK-1965) Implement the Orthant-wise Limited Memory QuasiNewton optimization algorithm, a variant of L-BFGS that handles L1 regularization - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/04/30 17:33:07 UTC, 0 replies.
- Gzip support - posted by "Kruse, Sebastian" <Se...@hpi.de> on 2015/04/30 17:41:16 UTC, 2 replies.
- Change Streaming Source Function Interface - posted by Stephan Ewen <se...@apache.org> on 2015/04/30 20:30:19 UTC, 3 replies.
- Making state in streaming more explicit - posted by Stephan Ewen <se...@apache.org> on 2015/04/30 20:47:15 UTC, 6 replies.