dev@flink.apache.org, 2016-06

You are viewing a plain text version of this content. The canonical link for it is here.

- Re: [PROPOSAL] Structure the Flink Open Source Development - posted by "Tzu-Li (Gordon) Tai" <tz...@gmail.com> on 2016/06/01 03:46:33 UTC, 21 replies.
- [jira] [Created] (FLINK-4000) Exception: Could not restore checkpointed state to operators and functions; during Job Restart (Job restart is triggered due to one of the task manager failure) - posted by "Aride Chettali (JIRA)" <ji...@apache.org> on 2016/06/01 05:12:12 UTC, 0 replies.
- baseurl not overridden in documentation's Jekyll serve for local previewing - posted by "Tzu-Li (Gordon) Tai" <tz...@gmail.com> on 2016/06/01 09:00:39 UTC, 2 replies.
- [jira] [Created] (FLINK-4001) Add event time support to filesystem connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/01 10:09:59 UTC, 0 replies.
- HA Cluster restart behaviour - posted by Gyula Fóra <gy...@gmail.com> on 2016/06/01 11:42:35 UTC, 4 replies.
- [jira] [Created] (FLINK-4002) [py] Improve testing infraestructure - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/06/01 11:58:59 UTC, 0 replies.
- Client communication and akka.framesize - posted by fs...@posteo.de on 2016/06/01 13:51:27 UTC, 1 replies.
- [jira] [Created] (FLINK-4003) Use intrinsics for MathUtils logarithms - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/01 16:28:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/01 18:11:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4005) LocalExecutorITCase.testLocalExecutorWithWordCount fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/01 22:28:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4006) ExecutionGraph.restartStrategy field can't be serialized - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/06/02 03:54:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4007) Flink Kafka Consumer throws Null Pointer Exception when using DataStream keyBy - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/02 06:33:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4008) Hello,I am not able to create jar of flink-streaming-connectors ...I am able to create jar of others like twitter,kafka,flume but I am not able to create jar of flink-streaming connectors ?? How can I create this jar ?? - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/02 06:34:59 UTC, 0 replies.
- Flink Kafka Consumer throwing Null Pointer Exception - posted by Akshay Thaka Shingote <ak...@yash.com> on 2016/06/02 10:55:37 UTC, 1 replies.
- Re: [ANNOUNCE] Build Issues Solved - posted by Ufuk Celebi <uc...@apache.org> on 2016/06/02 11:14:41 UTC, 3 replies.
- How to run table api in 1.1-SNAPSHOT - posted by Cody Innowhere <e....@gmail.com> on 2016/06/02 11:56:13 UTC, 3 replies.
- [jira] [Created] (FLINK-4009) Scala Shell fails to find library for inclusion in test - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/02 12:20:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4010) Scala Shell tests may fail because of a locked STDIN - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/02 13:02:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4011) Unable to access completed job in web frontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/02 13:28:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4012) Docs: Links to "Iterations" are broken (404) - posted by "Bernd Louis (JIRA)" <ji...@apache.org> on 2016/06/02 14:26:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4013) GraphAlgorithms to simplify directed and undirected graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/02 19:37:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4014) Jobs hang， Maybe NetworkBufferPool and Local、 - posted by "ZhengBowen (JIRA)" <ji...@apache.org> on 2016/06/03 10:18:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/06/03 11:57:59 UTC, 0 replies.
- [Issue] Unable to pass VM arguments - posted by Vinay Patil <vi...@gmail.com> on 2016/06/03 13:46:10 UTC, 1 replies.
- [jira] [Created] (FLINK-4016) FoldApplyWindowFunction is not properly initialized - posted by "RWenden (JIRA)" <ji...@apache.org> on 2016/06/03 14:50:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4017) [py] Add Aggregation support to Python API - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/06/03 15:32:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 02:59:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 09:14:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/04 09:40:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection - posted by "Zhijiang Wang (JIRA)" <ji...@apache.org> on 2016/06/04 16:45:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/05 07:38:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open() - posted by "Michal Harish (JIRA)" <ji...@apache.org> on 2016/06/05 15:22:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/05 17:36:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue - posted by "Dominik Bruhn (JIRA)" <ji...@apache.org> on 2016/06/05 21:28:59 UTC, 0 replies.
- Apache Flink Web Monitor Api - posted by Ozan DENİZ <oz...@outlook.com> on 2016/06/06 07:57:34 UTC, 2 replies.
- [jira] [Created] (FLINK-4026) Fix code, grammar, and link issues in the Streaming documentation - posted by "Dyana Rose (JIRA)" <ji...@apache.org> on 2016/06/06 15:18:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/06/06 21:08:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4028) AbstractAlignedProcessingTimeWindowOperator creates wrong TimeWindow - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/07 15:45:21 UTC, 0 replies.
- DataStream split/select behaviour - posted by CPC <ac...@gmail.com> on 2016/06/07 16:26:05 UTC, 2 replies.
- Future of Python support - posted by Julius Neuffer <ju...@gmail.com> on 2016/06/08 08:03:11 UTC, 1 replies.
- [jira] [Created] (FLINK-4029) Multi-field "sum" function just like "keyBy" - posted by "Rami (JIRA)" <ji...@apache.org> on 2016/06/08 11:11:20 UTC, 0 replies.
- Broadcast data sent increases with # slots per TM - posted by "Kunft, Andreas" <an...@tu-berlin.de> on 2016/06/08 11:45:37 UTC, 6 replies.
- [jira] [Created] (FLINK-4030) ScalaShellITCase - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/08 13:05:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4031) Nightly Jenkins job doesn't deploy sources - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/06/08 13:27:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4032) Replace all usage of Guava Preconditions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/08 15:10:22 UTC, 0 replies.
- [jira] [Created] (FLINK-4033) Missing Scala example snippets for the Kinesis Connector documentation - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/08 16:48:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo - posted by "Vladislav Pernin (JIRA)" <ji...@apache.org> on 2016/06/08 18:47:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0 - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/06/08 21:02:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4036) Potential deadlock in StreamIterationSink - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/09 08:41:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 09:09:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/09 09:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/09 09:45:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/06/09 09:49:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4041) Failure while asking ResourceManager for RegisterResource - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 10:46:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4042) TwitterStream example does not work - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/09 11:23:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4043) Generalize RabbitMQ connector into AMQP connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 12:39:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4044) Rename RabbitMQ connector to AMQP connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 12:41:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4045) Test AMQP connector using Apache ActiveMQ - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 12:43:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/09 13:50:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4047) Fix documentation about determinism of KeySelectors - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/09 14:07:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 14:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4049) Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 14:43:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4050) FlinkKafkaProducer API Refactor - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2016/06/09 15:37:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4051) RabbitMQ Source might not react to cancel signal - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/09 16:07:21 UTC, 0 replies.
- incremental Checkpointing , Rocksdb HA - posted by Chen Qin <qi...@gmail.com> on 2016/06/09 16:18:53 UTC, 5 replies.
- [jira] [Created] (FLINK-4052) Unstable test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/06/09 19:33:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4053) Return value from Connection should be checked against null - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/09 19:41:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4054) Inconsistent Reporter synchronization within report() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 12:17:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4055) EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/10 12:36:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4056) SavepointITCase.testCheckpointHasBeenRemoved failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/10 12:44:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4057) Expose JobManager Metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/10 13:44:20 UTC, 0 replies.
- Adding a Histogram Metric - posted by Stephan Ewen <se...@apache.org> on 2016/06/10 14:10:48 UTC, 15 replies.
- [Issue] No Class Definition Found Error - posted by Vinay Patil <vi...@gmail.com> on 2016/06/10 16:35:26 UTC, 6 replies.
- [jira] [Created] (FLINK-4058) Error uploading JAR with dependencies using flink.bat on a Windows stand-alone instance - posted by "Mark Nadelson (JIRA)" <ji...@apache.org> on 2016/06/10 21:52:20 UTC, 0 replies.
- About Memory usage - posted by Davood Rafiei <ra...@gmail.com> on 2016/06/11 11:11:27 UTC, 1 replies.
- [jira] [Created] (FLINK-4059) Requirement of Streaming layer for Complex Event Processing - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/13 07:03:20 UTC, 0 replies.
- How to contribute to Streaming Table API and StreamSQL - posted by Jark Wu <wu...@alibaba-inc.com> on 2016/06/13 09:31:30 UTC, 7 replies.
- [jira] [Created] (FLINK-4060) WebRuntimeMonitorITCase.testStandaloneWebRuntimeMonitor failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/13 09:42:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug - posted by "dengchangfu (JIRA)" <ji...@apache.org> on 2016/06/13 09:45:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4062) Update Window Documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 10:10:20 UTC, 0 replies.
- Scheduling task slots in round-robin - posted by Gyula Fóra <gy...@apache.org> on 2016/06/13 10:46:46 UTC, 5 replies.
- [FLINK-3867] Flink-VM: Vagrant/Ansible based VMs to easily setup Flink - posted by Julius Neuffer <ju...@gmail.com> on 2016/06/13 11:05:00 UTC, 1 replies.
- [jira] [Created] (FLINK-4063) Add Metrics Support for Triggers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 12:17:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4064) Allow calling MetricGroup methods multiple times - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/13 12:39:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4065) Unstable Kafka09ITCase.testMultipleSourcesOnePartition test - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/13 12:57:20 UTC, 0 replies.
- [jira] [Created] (FLINK-4066) RabbitMQ source, customize queue arguments - posted by "Kanstantsin Kamkou (JIRA)" <ji...@apache.org> on 2016/06/13 13:36:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4067) Add version header to savepoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/13 15:16:21 UTC, 0 replies.
- [jira] [Created] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/13 15:34:20 UTC, 0 replies.
- [Discussion] Query regarding Join - posted by Vinay Patil <vi...@gmail.com> on 2016/06/13 16:53:51 UTC, 17 replies.
- [jira] [Created] (FLINK-4069) Kafka Consumer should not initialize on construction - posted by "Shannon Carey (JIRA)" <ji...@apache.org> on 2016/06/13 20:48:41 UTC, 0 replies.
- Yarn Integration Test - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2016/06/14 12:34:50 UTC, 3 replies.
- Meet up at Hadoop Summit? - posted by "THORMAN, ROBERT D" <rt...@att.com> on 2016/06/14 13:22:57 UTC, 2 replies.
- [jira] [Created] (FLINK-4070) Support literals on left side of binary expressions - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/06/15 07:44:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4071) JobManagerHAJobGraphRecoveryITCase.testJobManagerCleanUp failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/15 08:17:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4072) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/15 08:19:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4073) YARNSessionCapacitySchedulerITCase.testTaskManagerFailure failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/15 08:22:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4074) Reporter can block TaskManager shutdown - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/15 10:08:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4075) ContinuousFileProcessingCheckpointITCase failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/15 11:45:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4076) BoltWrapper#dispose() should call AbstractStreamOperator#dispose() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/15 13:50:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4077) Register Pojo DataSet/DataStream as Table requires alias expression. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/15 15:06:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4078) Use ClosureCleaner for CoGroup where - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/15 15:31:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4079) YARN properties file used for per-job cluster - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/15 15:55:09 UTC, 0 replies.
- [jira] [Created] (FLINK-4080) Kinesis consumer not exactly-once if stopped in the middle of processing aggregated records - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/06/15 16:47:09 UTC, 0 replies.
- Testing for FLINK-3839 - posted by "THORMAN, ROBERT D" <rt...@att.com> on 2016/06/15 17:50:00 UTC, 4 replies.
- [DISCUSS] Releasing Flink 1.1.0 - posted by Robert Metzger <rm...@apache.org> on 2016/06/15 19:55:30 UTC, 14 replies.
- [jira] [Created] (FLINK-4081) FieldParsers should support empty strings - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/06/16 09:29:05 UTC, 0 replies.
- kafka partition assignment - posted by Michal Hariš <mi...@gmail.com> on 2016/06/16 11:49:40 UTC, 4 replies.
- Re: [jira] [Updated] (FLINK-2155) Add an additional checkstyle validation for illegal imports - posted by Kostas Kloudas <k....@data-artisans.com> on 2016/06/16 12:28:13 UTC, 0 replies.
- [jira] [Created] (FLINK-4082) Add Setting for LargeRecordHandler - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/06/16 12:36:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4083) Use ClosureCleaner for Join where and equalTo - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/06/16 13:18:05 UTC, 0 replies.
- DagConnection tempMode vs breakPipeline property - posted by CPC <ac...@gmail.com> on 2016/06/16 14:46:25 UTC, 0 replies.
- [jira] [Created] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/16 16:05:05 UTC, 0 replies.
- Kafka doesn't work in very simple test - posted by Adrian Portabales <ad...@gmail.com> on 2016/06/17 08:53:39 UTC, 6 replies.
- [jira] [Created] (FLINK-4085) Set Kinesis Consumer Agent to Flink - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/17 11:39:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4086) Hide internal Expression methods from Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/17 13:24:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4087) JMXReporter can't handle port conflicts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/17 13:47:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4088) Add interface to save and load TableSources - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/06/17 14:57:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4089) Ineffective null check in YarnClusterClient#getApplicationStatus() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/17 17:08:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4090) Close of OutputStream should be in finally clause in FlinkYarnSessionCli#writeYarnProperties() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/17 17:10:05 UTC, 0 replies.
- offheap memory allocation and memory leak bug - posted by CPC <ac...@gmail.com> on 2016/06/17 17:26:42 UTC, 5 replies.
- [jira] [Created] (FLINK-4091) flink-connector-cassandra has conflicting guava version - posted by "Dominik Bruhn (JIRA)" <ji...@apache.org> on 2016/06/17 20:36:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4092) Stringify map function's type conversion problem is breaking running provided example in documents - posted by "Shahin Azad (JIRA)" <ji...@apache.org> on 2016/06/19 08:49:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4093) Expose metric interfaces - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/20 09:14:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4094) Off heap memory deallocation might not work properly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/20 10:31:05 UTC, 0 replies.
- [jira] [Created] (FLINK-4095) Add configDir argument to shell scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/20 12:23:05 UTC, 0 replies.
- Shading Plugin + Hadoop Dependency - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2016/06/20 16:18:48 UTC, 9 replies.
- [jira] [Created] (FLINK-4096) Nested FileOutputStream is not closed in JarFileCreator - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/06/20 23:32:57 UTC, 0 replies.
- Advice - Drools in Flink - posted by Anton <ku...@gmail.com> on 2016/06/21 05:55:03 UTC, 7 replies.
- [jira] [Created] (FLINK-4097) Cassandra Sink throws NPE on closing if server is not available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/21 09:50:58 UTC, 0 replies.
- Re: UDP support in Streaming API - posted by Sarvani <sa...@gmail.com> on 2016/06/21 14:31:56 UTC, 0 replies.
- [jira] [Created] (FLINK-4098) Iteration support in Python API - posted by "Geoffrey Mon (JIRA)" <ji...@apache.org> on 2016/06/21 15:18:58 UTC, 0 replies.
- Flink Table & SQL doesn't work in very simple example - posted by Jark Wu <wu...@alibaba-inc.com> on 2016/06/22 01:52:08 UTC, 1 replies.
- [jira] [Created] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/22 08:57:58 UTC, 0 replies.
- [jira] [Created] (FLINK-4100) RocksDBStateBackend#close() can throw NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/22 10:48:57 UTC, 0 replies.
- UDF in Flink table API - posted by Cody Innowhere <e....@gmail.com> on 2016/06/22 12:58:49 UTC, 1 replies.
- [jira] [Created] (FLINK-4101) Calculating average in Flink DataStream on window time - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/22 14:10:57 UTC, 0 replies.
- [jira] [Created] (FLINK-4102) Test failure with checkpoint barriers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 15:10:59 UTC, 0 replies.
- [jira] [Created] (FLINK-4103) Modify CsvTableSource to implement StreamTableSource - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/06/22 16:34:57 UTC, 0 replies.
- [Issue] java.lang.UnsatisfiedLinkError - posted by Vinay Patil <vi...@gmail.com> on 2016/06/22 17:17:25 UTC, 0 replies.
- [jira] [Created] (FLINK-4104) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:08:12 UTC, 0 replies.
- [jira] [Created] (FLINK-4105) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:08:56 UTC, 0 replies.
- [jira] [Created] (FLINK-4106) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:09:07 UTC, 0 replies.
- [jira] [Created] (FLINK-4107) Restructure Gelly docs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/22 19:09:07 UTC, 0 replies.
- [jira] [Created] (FLINK-4108) NPE in Row.productArity - posted by "Martin Scholl (JIRA)" <ji...@apache.org> on 2016/06/22 22:20:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4109) Change the name of ternary condition operator 'eval' to '?' - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/23 02:18:16 UTC, 0 replies.
- Re: [Discuss] java.lang.UnsatisfiedLinkError - posted by Vinay Patil <vi...@gmail.com> on 2016/06/23 03:15:20 UTC, 1 replies.
- [jira] [Created] (FLINK-4110) Provide testing skeleton in quickstarts - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/23 06:53:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4111) Flink Table & SQL doesn't work in very simple example - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2016/06/23 12:11:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4112) Replace SuppressRestartException with disabling RestartStrategy - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/06/23 13:09:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4113) Always copy first value in ChainedAllReduceDriver - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/23 16:37:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4114) Need a way to manage multiple named, long-lived jobs on a single YARN cluster in an automated manner - posted by "Chris Hogue (JIRA)" <ji...@apache.org> on 2016/06/23 19:44:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4115) FsStateBackend filesystem verification can cause classpath exceptions - posted by "Josh Forman-Gornall (JIRA)" <ji...@apache.org> on 2016/06/23 20:08:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4116) Document metrics - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/24 09:59:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4117) Wait for CuratorFramework connection to be established - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/24 14:44:16 UTC, 0 replies.
- IT Test - posted by Vijay Srinivasaraghavan <vi...@yahoo.com.INVALID> on 2016/06/24 14:47:18 UTC, 8 replies.
- Understanding Operator Chaining - posted by Marius Melzer <ma...@rasumi.net> on 2016/06/24 16:52:52 UTC, 2 replies.
- [jira] [Created] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down - posted by "Ismaël Mejía (JIRA)" <ji...@apache.org> on 2016/06/25 06:19:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4119) Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/06/25 14:02:37 UTC, 0 replies.
- [jira] [Created] (FLINK-4120) Lightweight fault tolerance through recomputing lost state - posted by "Dénes Vadász (JIRA)" <ji...@apache.org> on 2016/06/26 22:27:51 UTC, 0 replies.
- forward() - posted by Marius Melzer <ma...@rasumi.net> on 2016/06/26 23:56:59 UTC, 2 replies.
- [jira] [Created] (FLINK-4121) Add timeunit (ms) to docs for timestamps and watermarks - posted by "Jonas Traub (JIRA)" <ji...@apache.org> on 2016/06/27 09:18:52 UTC, 0 replies.
- [jira] [Created] (FLINK-4122) Cassandra jar contains 2 guava versions - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/27 10:23:52 UTC, 0 replies.
- [jira] [Created] (FLINK-4123) CassandraWriteAheadSink can hang on cassandra failure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/06/27 10:28:52 UTC, 0 replies.
- [jira] [Created] (FLINK-4124) Unstable test WrapperSetupHelperTest.testCreateTopologyContext - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/27 21:27:16 UTC, 0 replies.
- [jira] [Created] (FLINK-4125) Yarn CLI incorrectly calculates slotsPerTM when parallelism < task manager count - posted by "Chris Hogue (JIRA)" <ji...@apache.org> on 2016/06/27 21:47:57 UTC, 0 replies.
- [jira] [Created] (FLINK-4126) Unstable test ZooKeeperLeaderElectionTest.testZooKeeperReelection - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2016/06/28 06:49:56 UTC, 0 replies.
- Re: support launch more than one pipeline in a yarn session - posted by Till Rohrmann <tr...@apache.org> on 2016/06/28 08:09:03 UTC, 0 replies.
- [jira] [Created] (FLINK-4127) Clean up configuration and check breaking API changes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/28 12:06:57 UTC, 0 replies.
- [DISCUSS] FLIP 1 - Flink Improvement Proposal - posted by Aljoscha Krettek <al...@apache.org> on 2016/06/28 16:26:12 UTC, 1 replies.
- [jira] [Created] (FLINK-4128) compile error about git-commit-id-plugin - posted by "Mao, Wei (JIRA)" <ji...@apache.org> on 2016/06/28 17:12:57 UTC, 0 replies.
- [jira] [Created] (FLINK-4129) HITSAlgorithm should test for element-wise convergence - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/28 19:27:57 UTC, 0 replies.
- primitiveDefaultValue in CodeGenUtils in Table API - posted by Cody Innowhere <e....@gmail.com> on 2016/06/29 03:24:54 UTC, 4 replies.
- [Discuss] Why different job's tasks can run in the single process. - posted by Longda Feng <zh...@alibaba-inc.com> on 2016/06/29 07:18:22 UTC, 5 replies.
- [jira] [Created] (FLINK-4130) CallGenerator could generate illegal code when taking no operands - posted by "Cody (JIRA)" <ji...@apache.org> on 2016/06/29 08:17:36 UTC, 0 replies.
- [jira] [Created] (FLINK-4131) Confusing error for out dated RequestPartitionState - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/06/29 11:47:37 UTC, 0 replies.
- Re: [Discussion] Query regarding Join and Windows - posted by Vinay Patil <vi...@gmail.com> on 2016/06/29 12:14:35 UTC, 4 replies.
- [jira] [Created] (FLINK-4132) Fix boxed comparison in CommunityDetection algorithm - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/29 13:03:37 UTC, 0 replies.
- [jira] [Created] (FLINK-4133) Reflect streaming file source changes in documentation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/29 13:13:37 UTC, 0 replies.
- Web dashboard binaries and licensing - posted by Till Rohrmann <tr...@apache.org> on 2016/06/29 15:17:45 UTC, 5 replies.
- Python API design doc? - posted by Daniel Li <da...@gmail.com> on 2016/06/29 20:53:12 UTC, 1 replies.
- [jira] [Created] (FLINK-4134) EventTimeSessionWindows trigger for empty windows when dropping late events - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2016/06/30 12:48:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4135) Replace ChecksumHashCode as GraphAnalytic - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/06/30 12:55:10 UTC, 0 replies.
- Failure in flink-storm when building Flink - posted by "F. Beligianni" <fa...@gmail.com> on 2016/06/30 13:26:19 UTC, 5 replies.
- [jira] [Created] (FLINK-4136) Add a JobHistory Server service - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/06/30 14:25:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/06/30 15:21:10 UTC, 0 replies.
- [jira] [Created] (FLINK-4138) error with Kinesis connector - posted by "Zhenhao Li (JIRA)" <ji...@apache.org> on 2016/06/30 20:20:10 UTC, 0 replies.