dev@flink.apache.org, 2017-07

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

- [jira] [Created] (FLINK-7061) Fix quantifier range starting from 0 - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/07/02 05:10:00 UTC, 0 replies.
- Re: [DISCUSS] FLIP-21 - Improve object Copying/Reuse Mode for Streaming Runtime - posted by Stephan Ewen <se...@apache.org> on 2017/07/02 16:12:18 UTC, 3 replies.
- [jira] [Created] (FLINK-7062) Support the basic functionality of MATCH_RECOGNIZE - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/07/03 03:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7063) test instability in OperatorStateBackendTest.testSnapshotAsyncCancel - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/03 09:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7064) test instability in WordCountMapreduceITCase - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/03 09:55:00 UTC, 0 replies.
- Problem to deploy of flink program in cluster - posted by simone sguazza <si...@hotmail.com> on 2017/07/03 09:55:03 UTC, 4 replies.
- [jira] [Created] (FLINK-7065) separate the flink-streaming-java module from flink-clients - posted by "Xu Pingyong (JIRA)" <ji...@apache.org> on 2017/07/03 10:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7066) Kafka integration tests failing in "airplane mode" - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/07/03 11:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/07/03 12:08:00 UTC, 0 replies.
- [DISCUSS] First release of flink-shaded - posted by Chesnay Schepler <ch...@apache.org> on 2017/07/03 12:32:01 UTC, 10 replies.
- [jira] [Created] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/03 12:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7069) Catch exceptions for each reporter separately - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/03 13:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7070) Rework ScalaShellITCase#testSubmissionOfExternalLibraryStream - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/03 14:00:01 UTC, 0 replies.
- [DISCUSS] Long-term plan for build times - posted by Chesnay Schepler <ch...@apache.org> on 2017/07/03 14:42:27 UTC, 1 replies.
- Re: [DISCUSS] FLIP proposal for Model Serving over Flink - posted by Robert Metzger <rm...@apache.org> on 2017/07/03 18:18:13 UTC, 4 replies.
- [jira] [Created] (FLINK-7071) Create RESTful client - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 21:29:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7072) Create RESTful cluster endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 21:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7073) Create RESTful JobManager endpoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 21:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7074) Add entry point for TaskManagerRunner - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 21:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7075) Implement Flip-6 standalone mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 22:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7076) Add support for dynamic container allocation to ResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 22:10:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7077) Implement task release to support dynamic scaling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 22:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7078) Support fencing tokens to filter out outdated messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 22:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7079) Refactor ClusterDescriptor to support cluster deployment with job - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 22:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7080) Deploy Yarn cluster with job - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 22:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7081) Deploy Mesos framework with job - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 22:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7082) Flip-6: Generic entry point for Flink sessions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 22:41:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7083) Adapt WebRuntimeMonitor to work with Flip-6 architecture - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/03 22:47:00 UTC, 0 replies.
- Tips to fix IDEA strange problem after updating master code - posted by Jark Wu <ja...@apache.org> on 2017/07/04 03:56:06 UTC, 10 replies.
- [jira] [Created] (FLINK-7084) Flip-6 testing - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7085) Test slot allocation protocol - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 06:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7086) Create entry point for standalone session mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 06:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7087) Implement Flip-6 container entry point - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 06:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7088) Rework TaskMonitor to not depend on Akka - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 06:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7090) Rework ConnectionMonitor to not depend on Akka - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7089) Rework LaunchCoordinator to not depend on Akka - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 06:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7091) Rework ReconciliationCoordinator to not depend on Akka - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 06:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7092) Shutdown ResourceManager components properly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 06:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7093) Send SlotReport as part of the heartbeat payload to the RM - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 06:42:00 UTC, 0 replies.
- Re: [外部邮件] Tips to fix IDEA strange problem after updating master code - posted by 郭健 <gu...@immomo.com> on 2017/07/04 07:49:36 UTC, 0 replies.
- [jira] [Created] (FLINK-7094) Update outdated doc release 1.2 to latest stable release 1.3 - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/04 07:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 10:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7096) Adapt start-up scripts to start Flip-6 cluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 10:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7097) Start TaskExecutor via start-up script - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 10:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7098) Start standalone cluster entry point via start-up script - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 10:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7099) Replace usages of deprecated JOB_MANAGER_IPC_PORT_KEY - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/04 11:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7100) TaskManager metrics are registered twice - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/04 11:53:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7101) Fix Non-windowed group-aggregate error when using `minIdleStateRetentionTime` config and retract agg - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/07/04 12:37:01 UTC, 0 replies.
- refactor StreamConfig - posted by xu <xu...@163.com> on 2017/07/04 13:56:23 UTC, 6 replies.
- Re:refactor StreamConfig （Appending a picture） - posted by xu <xu...@163.com> on 2017/07/04 14:09:08 UTC, 0 replies.
- Re: refactor StreamConfig （Appending a picture） - posted by Ted Yu <yu...@gmail.com> on 2017/07/04 14:53:09 UTC, 0 replies.
- [jira] [Created] (FLINK-7102) improve ClassLoaderITCase - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/04 15:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7103) Implement dispatcher component - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/04 16:05:00 UTC, 0 replies.
- Re: Streaming Graph processing - posted by Paris Carbone <pa...@kth.se> on 2017/07/04 16:13:57 UTC, 0 replies.
- Re: connect data stream with parameter stream - posted by Aljoscha Krettek <al...@apache.org> on 2017/07/04 16:33:44 UTC, 1 replies.
- [DISCUSS] FLIP-22: Eager State Declaration - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/07/04 18:00:17 UTC, 6 replies.
- [jira] [Created] (FLINK-7104) AccessDeniedException get when FileUtilsTest#testDeleteDirectoryConcurrently call - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/05 02:26:01 UTC, 0 replies.
- Task assignment - posted by Andrey Zhylka <An...@epam.com> on 2017/07/05 10:13:40 UTC, 1 replies.
- [jira] [Created] (FLINK-7105) Make ActorSystem creation per default non-daemonic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/05 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7106) Make SubmittedJobGraphStore configurable - posted by "Chen Qin (JIRA)" <ji...@apache.org> on 2017/07/05 19:06:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7107) Start Yarn session via start-up script - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/05 21:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7108) Implement Session cluster entry point - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/05 21:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7109) HadoopUtils#getHadoopConfiguration should not load global configuration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/05 22:59:00 UTC, 0 replies.
- Re: [DISCUSS] Release 1.3.2 planning - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/07/06 05:19:16 UTC, 14 replies.
- Make SubmittedJobGraphStore configurable - posted by Chen Qin <qi...@gmail.com> on 2017/07/06 05:19:40 UTC, 4 replies.
- [jira] [Created] (FLINK-7110) Add deploy with job to ClusterDescriptor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/06 07:30:00 UTC, 0 replies.
- [DISCUSS] Managing announcements of breaking API / state compatibility changes in major releases - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/07/06 07:59:44 UTC, 3 replies.
- [jira] [Created] (FLINK-7111) flink-scala-shell fails on mvn verify - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/06 08:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7112) YARNSessionCapacitySchedulerITCase uses example jar without dependency - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/06 09:41:00 UTC, 0 replies.
- Re: [DISCUSS] Managing announcements of breaking API / state compatibility changes in major releases - posted by Ted Yu <yu...@gmail.com> on 2017/07/06 10:35:15 UTC, 0 replies.
- [jira] [Created] (FLINK-7113) Make ClusterDescriptor independent of Flink cluster size - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/06 12:01:07 UTC, 0 replies.
- Re:[DISCUSS]refactor StreamConfig - posted by Xu Pingyong <xu...@163.com> on 2017/07/06 14:55:10 UTC, 1 replies.
- [jira] [Created] (FLINK-7114) Remove the hardcoded way in flink - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/06 15:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7115) test instability in MiniClusterITCase.runJobWithMultipleJobManagers - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/06 15:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7116) Add getPort method to RpcService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/06 21:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7117) Add JobManagerLeaderRetrieval method with default JobManager address - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/06 22:31:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7118) Remove hadoop1.x code in HadoopUtils - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/07 01:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7119) Remove the hardcoded way in HadoopUtils - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/07 01:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7120) Remove the hardcoded way in Utils - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/07 02:01:07 UTC, 0 replies.
- How to set jobmanager.rpc.address in TaskManger node in HA cluster - posted by Mu Kong <ko...@gmail.com> on 2017/07/07 02:08:42 UTC, 2 replies.
- [jira] [Created] (FLINK-7121) Remove the hardcoded way in core - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/07 02:09:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7122) When metric name contains special characters then Graphite will not display them - posted by "wyp (JIRA)" <ji...@apache.org> on 2017/07/07 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7123) Support timesOrMore in CEP - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/07/07 06:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7124) Allow to rescale JobGraph on JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/07 07:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7125) Remove configuration loading from AbstractYarnClusterDescriptor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/07 07:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7126) Support Distinct for Stream SQL and Table API - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/07/07 08:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7127) Remove unnecessary null check or add null check - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/07/07 09:39:00 UTC, 0 replies.
- Clarification of TypesSerializers - posted by Dawid Wysakowicz <wy...@gmail.com> on 2017/07/07 09:57:49 UTC, 4 replies.
- [jira] [Created] (FLINK-7128) Timestamp types in Table API documenation not correct - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/07/07 10:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7129) Dynamically changing patterns - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/07 11:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7130) Remove eventSerializer from NFA - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/07 11:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7131) Streaming wordcount jar does not contain WordCountData - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/07 12:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7132) Fix BulkIteration parallelism - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/07 13:17:00 UTC, 0 replies.
- Request for contributor permissions - posted by Yueting Chen <ye...@gmail.com> on 2017/07/07 13:54:40 UTC, 7 replies.
- [jira] [Created] (FLINK-7133) Fix Elasticsearch version interference - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/07/07 14:03:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7134) Remove hadoop1.x code in mapreduce.utils.HadoopUtils - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/07 14:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7135) Pass in proper Configuration to Dispatcher component - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/07 17:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7136) Docs search can be customized to be more useful - posted by "David Anderson (JIRA)" <ji...@apache.org> on 2017/07/07 20:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7137) Flink table API defaults top level fields as nullable and all nested fields within CompositeType as non-nullable - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/07/07 23:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7138) Storm example jars do not contain WordCountData - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/08 06:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7139) Refine currentTimeMillis to nanoTime - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/08 10:55:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7140) include a UUID/random name into the BlobKey - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/10 07:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7141) enable travis cache again - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/10 10:16:00 UTC, 0 replies.
- [ANNOUNCE] New Flink committer Jincheng Sun - posted by Fabian Hueske <fh...@gmail.com> on 2017/07/10 13:17:05 UTC, 12 replies.
- [ANNOUNCE] New Flink PMC member: Tzu-Li (Gordon) Tai - posted by Robert Metzger <rm...@apache.org> on 2017/07/10 14:44:20 UTC, 17 replies.
- [jira] [Created] (FLINK-7142) Scala DataSet API ignores ResultTypeQueryable interface - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/07/10 16:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7143) Partition assignment for Kafka consumer is not stable - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2017/07/10 23:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7144) Optimize multiple LogicalAggregate into one - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2017/07/11 03:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7145) Flink SQL API should support multiple parameters for UserDefinedAggFunction - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2017/07/11 07:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7146) FLINK SQLs support DDL - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2017/07/11 08:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7147) Support greedy quantifier in CEP - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/07/11 08:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7148) Flink SQL API support DDL - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2017/07/11 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7149) Add checkpoint ID to 'sendValues()' in GenericWriteAheadSink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/11 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7150) Code improvements to the ElasticSearch connector - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/11 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7151) FLINK SQL support create temporary function and table - posted by "yuemeng (JIRA)" <ji...@apache.org> on 2017/07/11 11:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7152) use CombineOutputSelector instead of outputSelector list - posted by "Xu Pingyong (JIRA)" <ji...@apache.org> on 2017/07/11 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7153) JM can't allocate source for ExecutionGraph correctly - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2017/07/11 11:53:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7154) Missing call to build CsvTableSource example - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/11 13:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7155) Add Influxdb metrics reporter - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2017/07/11 14:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7156) Re-enabled external jar ScalaShellITCase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/11 18:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7157) Provide support for asynchronous operations over connected streams - posted by "Pedro Miguel Rainho Chaves (JIRA)" <ji...@apache.org> on 2017/07/11 18:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7158) Wrong test jar dependency in flink-clients - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/11 19:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7159) Semantics of OVERLAPS in Table API diverge from the SQL standard - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/07/12 01:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7160) Support hive like udtf - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2017/07/12 01:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7161) Fix misusage of Double.MIN_VALUE and Float.MIN_VALUE - posted by "Kurt Young (JIRA)" <ji...@apache.org> on 2017/07/12 06:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7162) Tests should not write outside 'target' directory. - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/12 07:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7163) Make LogicalTableFunctionCall immutable - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/07/12 07:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7164) Extend integration tests for (externalised) checkpoints, checkpoint store - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/07/12 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7165) Flink can't deploy on hadoop 2.6.0-cdh5.5.1 yarn - posted by "刘喆 (JIRA)" <ji...@apache.org> on 2017/07/12 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7166) generated avro sources not cleaned up or re-created after changes - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/12 10:01:00 UTC, 0 replies.
- Re: [POLL] Who still uses Java 7 with Flink ? - posted by Stephan Ewen <se...@apache.org> on 2017/07/12 13:56:20 UTC, 12 replies.
- Re: [DISCUSS] NOTICE - posted by Stephan Ewen <se...@apache.org> on 2017/07/12 14:34:19 UTC, 0 replies.
- Re: [DISCUSS] Backwards compatibility policy. - posted by Stephan Ewen <se...@apache.org> on 2017/07/12 14:37:13 UTC, 0 replies.
- Use Flink's actor system - posted by Lorenzo Affetti <lo...@gmail.com> on 2017/07/12 15:05:08 UTC, 4 replies.
- [jira] [Created] (FLINK-7167) Job can set checkpoint meta directory to cover the system setting state.checkpoints.dir - posted by "yuqi (JIRA)" <ji...@apache.org> on 2017/07/13 02:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7168) Add support for Table API & SQL steam-stream inner/left join - posted by "Ruidong Li (JIRA)" <ji...@apache.org> on 2017/07/13 03:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API - posted by "Yueting Chen (JIRA)" <ji...@apache.org> on 2017/07/13 05:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7170) Fix until condition when the contiguity is strict - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/07/13 09:20:00 UTC, 0 replies.
- Feel confused for the illustration of tumbling window - posted by jincheng sun <su...@gmail.com> on 2017/07/13 09:43:28 UTC, 6 replies.
- [jira] [Created] (FLINK-7171) Remove identity project for time attributes - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/07/13 10:04:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7172) Add a event logical id field to ValueTimeWrapper - posted by "Yueting Chen (JIRA)" <ji...@apache.org> on 2017/07/13 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7173) Fix the illustration of tumbling window. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/07/13 11:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7174) Bump dependency of Kafka 0.10.x to the latest one - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/07/13 11:59:01 UTC, 0 replies.
- Ship files to flink on yarn-cluster mode - posted by Guy Harmach <Gu...@Amdocs.com> on 2017/07/13 14:40:13 UTC, 1 replies.
- [jira] [Created] (FLINK-7175) Add simple benchmark suite for Flink - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/07/13 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7176) Failed builds (due to compilation) don't upload logs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/13 15:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7177) [table] Using Table API to perform aggregation on another Table API / SQL result table causes runVolcanoPlanner failed on physicalPlan generation - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2017/07/13 18:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7178) Datadog Metric Reporter Jar is Lacking Dependencies - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/07/13 18:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7179) Projectable ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor - posted by "Zhenqiu Huang (JIRA)" <ji...@apache.org> on 2017/07/13 19:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7180) CoGroupStream perform checkpoint failed - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2017/07/14 07:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7181) Activate checkstyle flink-java/operators - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 08:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7182) Activate checkstyle flink-java/functions - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7183) Activate checkstyle flink-java/aggregation - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7185) Activate checkstyle flink-java/io - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7186) Activate checkstyle flink-java/sampling - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7184) Activate checkstyle flink-java/hadoop - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 08:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7187) Activate checkstyle flink-java/sca - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7188) Activate checkstyle flink-java/summarize - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7189) Activate checkstyle flink-java/utils - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 08:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7190) Activate checkstyle flink-java/* - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7191) Activate checkstyle flink-java/operators/translation - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 09:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7192) Activate checkstyle flink-java/test/operator - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/14 09:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7193) Update all OVER window ProcessFunction implementations to use SortedQueueState - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/07/14 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/07/14 10:06:03 UTC, 0 replies.
- Exported metrics by Datadog/Statsd cannot be grouped due to varying metric name - posted by Mustafa AKIN <mu...@gmail.com> on 2017/07/14 10:51:48 UTC, 1 replies.
- [jira] [Created] (FLINK-7195) FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/07/14 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7196) add a TTL to transient BLOB files - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/14 12:30:00 UTC, 0 replies.
- Akka dissassociated - posted by Greg Hogan <co...@greghogan.com> on 2017/07/14 17:11:24 UTC, 2 replies.
- [jira] [Created] (FLINK-7197) Missing call to GraphAlgorithmWrappingBase#canMergeConfigurationWith() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/07/14 18:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7198) Datadog Metric Reporter reports incorrect host for JobManager - posted by "Robert Batts (JIRA)" <ji...@apache.org> on 2017/07/14 20:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7199) Graph simplification does not set parallelism - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/14 20:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7200) Make metrics more Datadog friendly - posted by "Robert Batts (JIRA)" <ji...@apache.org> on 2017/07/14 21:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7201) ConcurrentModificationException in JobLeaderIdService - posted by "Xu Pingyong (JIRA)" <ji...@apache.org> on 2017/07/15 02:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7202) Split supressions for flink-core, flink-java, flink-optimizer per package - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/15 09:16:00 UTC, 0 replies.
- Re: Facebook BSD+patents license and Apache products - posted by Andrew Palumbo <ap...@outlook.com> on 2017/07/15 21:39:30 UTC, 3 replies.
- [jira] [Created] (FLINK-7203) Remove useless "flink-avro" module - posted by "Hai Zhou (JIRA)" <ji...@apache.org> on 2017/07/16 07:53:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7204) CombineHint.NONE - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/16 11:25:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7205) Add UUID supported in TableAPI/SQL - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2017/07/16 23:48:00 UTC, 0 replies.
- Re: Greetings and question - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/07/17 04:55:41 UTC, 1 replies.
- [jira] [Created] (FLINK-7206) Implementation of DataView to support state access for UDAGG - posted by "Kaibo Zhou (JIRA)" <ji...@apache.org> on 2017/07/17 08:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7207) Support getAccumulatorType when use DataView - posted by "Kaibo Zhou (JIRA)" <ji...@apache.org> on 2017/07/17 08:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView - posted by "Kaibo Zhou (JIRA)" <ji...@apache.org> on 2017/07/17 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7209) Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself - posted by "Kaibo Zhou (JIRA)" <ji...@apache.org> on 2017/07/17 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7210) Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic way) - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/07/17 09:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7211) Exclude Gelly javadoc jar from release - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/17 09:30:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7212) JobManagerLeaderSessionIDITSuite not executed - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/17 12:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7213) Introduce state management by OperatorID in TaskManager - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/07/17 13:01:00 UTC, 0 replies.
- Flink Connector for AWS SQS - posted by Ray Ruvinskiy <ra...@arcticwolf.com> on 2017/07/17 14:50:20 UTC, 1 replies.
- [DISCUSS] A more thorough Pull Request check list and template - posted by Stephan Ewen <se...@apache.org> on 2017/07/17 16:36:43 UTC, 19 replies.
- [jira] [Created] (FLINK-7214) Add a sink that writes to ORCFile on HDFS - posted by "Robert Rapplean (JIRA)" <ji...@apache.org> on 2017/07/17 17:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7215) Typo in FAQ page - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/07/17 17:51:00 UTC, 0 replies.
- Using native library in Flink - posted by Mike Accola <ma...@us.ibm.com> on 2017/07/17 19:30:09 UTC, 3 replies.
- [jira] [Created] (FLINK-7216) ExecutionGraph can perform concurrent global restarts to scheduling - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/17 19:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7217) Give hints about unsupported SQL / Table API features. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/07/18 08:15:00 UTC, 0 replies.
- Re: [DISCUSS] GitBox - posted by Chesnay Schepler <ch...@apache.org> on 2017/07/18 10:21:53 UTC, 10 replies.
- [jira] [Created] (FLINK-7218) ExecutionVertex.getPreferredLocationsBasedOnInputs() will always return empty - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2017/07/18 13:43:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7219) Current allocate strategy cann‘t achieve the optimal effect with input's location - posted by "Sihua Zhou (JIRA)" <ji...@apache.org> on 2017/07/18 13:55:00 UTC, 0 replies.
- Dropping Java 7 support - posted by Stephan Ewen <se...@apache.org> on 2017/07/18 14:31:03 UTC, 5 replies.
- [jira] [Created] (FLINK-7220) Update RocksDB dependency to 5.5.1 - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/07/18 15:11:00 UTC, 0 replies.
- 回复：[DISCUSS] A more thorough Pull Request check list and template - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2017/07/18 16:34:24 UTC, 0 replies.
- [jira] [Created] (FLINK-7221) JDBCOutputFormat swallows errors on last batch - posted by "Ken Geis (JIRA)" <ji...@apache.org> on 2017/07/18 17:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7222) Kafka010ITCase fails on windows - posted by "Fang Yong (JIRA)" <ji...@apache.org> on 2017/07/19 01:30:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7223) Increase DEFAULT_SHARD_DISCOVERY_INTERVAL_MILLIS for Flink-kinesis-connector - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2017/07/19 04:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7224) Incorrect Javadoc description in all Kafka consumer versions - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/07/19 06:16:00 UTC, 0 replies.
- Re: Latency Measurement - posted by Chesnay Schepler <ch...@apache.org> on 2017/07/19 10:00:13 UTC, 0 replies.
- [jira] [Created] (FLINK-7225) Cutoff exception message in StateDescriptor - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/19 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7226) REST responses contain invalid content-encoding header - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/19 11:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7227) OR expression with more than 2 predicates is not pushed into a TableSource - posted by "Usman Younas (JIRA)" <ji...@apache.org> on 2017/07/19 11:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7228) Harden HistoryServerStaticFileHandlerTest - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/19 12:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7229) Flink doesn't deleted old checkpoint - posted by "Jason Zhou (JIRA)" <ji...@apache.org> on 2017/07/19 13:07:00 UTC, 0 replies.
- [DISCUSS] Release testing procedures, Flink 1.3.2 - posted by Aljoscha Krettek <al...@apache.org> on 2017/07/19 13:11:48 UTC, 7 replies.
- [VOTE] Release Apache Flink-shaded 1.0 (RC1) - posted by Chesnay Schepler <ch...@apache.org> on 2017/07/19 13:59:19 UTC, 5 replies.
- [jira] [Created] (FLINK-7230) Travis sometimes fails due to java version imcompatibilities - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/19 14:08:00 UTC, 0 replies.
- Fwd: Re: AVRO Union type support in Flink - posted by Timo Walther <tw...@apache.org> on 2017/07/19 14:57:16 UTC, 1 replies.
- [jira] [Created] (FLINK-7231) SlotSharingGroups are not always released in time for new restarts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/19 16:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7232) Update checkstyle docs regarding test inclusion - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/19 18:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7233) TaskManagerHeapSizeCalculationJavaBashTest failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/19 18:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7234) Fix CombineHint documentation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/19 18:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14 - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/07/19 21:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7236) Bump up the Calcite version to 1.14 - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/07/19 21:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7237) Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14 - posted by "Haohui Mai (JIRA)" <ji...@apache.org> on 2017/07/19 21:21:00 UTC, 0 replies.
- [apache/flink] [Flink-7218] [JobManager] ExecutionVertex.getPreferredLocationsBasedOnInputs() will always return empty - posted by 周思华 <su...@163.com> on 2017/07/20 02:24:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7238) Kafka integration tests do not restart Kafka brokers properly - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2017/07/20 07:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7239) GroupWindow and OverWindow aggregates do not check correctly for updating input - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/07/20 12:31:00 UTC, 0 replies.
- is flink' states functionality futile? - posted by ziv <zi...@gmail.com> on 2017/07/20 16:22:29 UTC, 5 replies.
- [jira] [Created] (FLINK-7240) Externalized RocksDB can fail with stackoverflow - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/20 18:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7241) Fix YARN high availability documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/07/21 15:41:00 UTC, 0 replies.
- Flink savepoints - Confused - posted by chouicha <ma...@yahoo.com> on 2017/07/21 19:24:12 UTC, 0 replies.
- [jira] [Created] (FLINK-7242) Drop Java 7 Support - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2017/07/22 00:18:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7243) Add ParquetInputFormat - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/07/23 11:12:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7244) Add ParquetTableSource Implementation based on ParquetInputFormat - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2017/07/23 11:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7245) Enhance the operators to support holding back watermarks - posted by "Xingcan Cui (JIRA)" <ji...@apache.org> on 2017/07/23 12:42:02 UTC, 0 replies.
- [flink-shaded] Some suggestions for improvements - posted by Stephan Ewen <se...@apache.org> on 2017/07/23 13:42:30 UTC, 3 replies.
- Re: [DISCUSS] Planning Release 1.4 - posted by Stephan Ewen <se...@apache.org> on 2017/07/23 13:55:17 UTC, 2 replies.
- [jira] [Created] (FLINK-7246) Big latency shown on operator.latency - posted by "yinhua.dai (JIRA)" <ji...@apache.org> on 2017/07/23 14:09:02 UTC, 0 replies.
- [DISCUSS] Service Authorization (redux) - posted by Eron Wright <er...@gmail.com> on 2017/07/24 01:11:13 UTC, 0 replies.
- [jira] [Created] (FLINK-7247) Replace travis java 7 profiles - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/24 08:25:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7248) Invalid checkRestoredNullCheckpointWhenFetcherNotReady test in FlinkKafkaConsumerBaseTest - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/07/24 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7250) Drop the jdk8 build profile - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/24 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7249) Bump Java version in build plugind - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/24 08:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7252) Remove Flink Futures or back them by CompletableFutures - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/24 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7251) Merge the flink-java8 project into flink-core - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/24 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7253) Remove all 'assume Java 8' code in tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/24 08:46:00 UTC, 0 replies.
- [CANCEL][VOTE] Release Apache Flink-shaded 1.0 (RC1) - posted by Chesnay Schepler <ch...@apache.org> on 2017/07/24 08:49:39 UTC, 0 replies.
- [jira] [Created] (FLINK-7254) java8 module pom disables checkstyle - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/24 12:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7255) ListStateDescriptor example uses wrong constructor - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/24 13:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7256) End-to-end tests should only be run after successful compilation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/24 13:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7257) Extend flink-runtime checkstyle coverage to tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/24 14:00:07 UTC, 0 replies.
- [jira] [Created] (FLINK-7258) IllegalArgumentException in Netty bootstrap with large memory state segment size - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2017/07/24 15:33:00 UTC, 0 replies.
- [VOTE] Release Apache Flink-shaded 1.0 (RC2) - posted by Chesnay Schepler <ch...@apache.org> on 2017/07/24 15:43:55 UTC, 3 replies.
- Connect more than two streams - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2017/07/24 21:38:07 UTC, 0 replies.
- Towards a spec for robust streaming SQL, Part 2 - posted by Tyler Akidau <ta...@apache.org> on 2017/07/24 23:34:49 UTC, 5 replies.
- [jira] [Created] (FLINK-7259) Match not exhaustive in TaskMonitor - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/25 07:50:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7260) Match not exhaustive in WindowJoinUtil.scala - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/07/25 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7261) avoid unnecessary exceptions in the logs in non-HA cases - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/25 11:00:09 UTC, 0 replies.
- [jira] [Created] (FLINK-7262) remove unused FallbackLibraryCacheManager - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/25 11:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7263) Improve Pull Request Template - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/25 12:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7264) travis watchdog is killed before tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/25 13:34:00 UTC, 0 replies.
- [DISCUSS] Table API / SQL internal timestamp handling - posted by Fabian Hueske <fh...@gmail.com> on 2017/07/25 14:21:35 UTC, 14 replies.
- [jira] [Created] (FLINK-7265) FileSystems should describe their kind and consistency level - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/25 15:30:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7266) Don't attempt to delete parent directory on S3 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2017/07/25 15:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7267) Add support for lists of hosts to connect - posted by "Hu Hailin (JIRA)" <ji...@apache.org> on 2017/07/26 06:14:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7268) Zookeeper Checkpoint Store interacting with Incremental State Handles can lead to loss of handles - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/07/26 08:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7269) Refactor passing of dynamic properties - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/26 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7270) Add support for dynamic properties to cluster entry point - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/26 09:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7271) ExpressionReducer does not optimize string-to-time conversion - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/07/26 09:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7272) Support SQL IN with more 20 elements in streaming - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/07/26 09:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7273) Gelly tests with empty graphs - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/26 14:41:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7274) ParserError NUMERIC_VALUE_FORMAT_ERROR - posted by "Egor Litvinenko (JIRA)" <ji...@apache.org> on 2017/07/26 14:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7275) Differentiate between normal and power-user cli options in Gelly examples - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/26 19:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7276) Gelly algorithm parameters - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/26 19:20:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7277) Weighted PageRank - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/26 20:00:06 UTC, 0 replies.
- [jira] [Created] (FLINK-7278) Flink job can stuck while ZK leader reelected during ZK cluster migration - posted by "Zhenzhong Xu (JIRA)" <ji...@apache.org> on 2017/07/27 04:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7279) MiniCluster can deadlock at shut down - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/27 08:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7280) Wrong clearing SharedBuffer of Equal elements with same Timestamp - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2017/07/27 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7281) Fix various issues in (Maven) release infrastructure - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/07/27 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7282) Credit-based Network Flow Control - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2017/07/27 10:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7283) PythonPlanBinderTest issues with python paths - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/27 14:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7284) Verify compile time and runtime version of Hadoop - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/27 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7285) allow submission of big job graphs - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/27 15:35:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources - posted by "Elias Levy (JIRA)" <ji...@apache.org> on 2017/07/27 16:00:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7287) test instability in Kafka010ITCase.testCommitOffsetsToKafka - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/27 16:13:00 UTC, 0 replies.
- [RESULT][VOTE] Release Apache Flink-shaded 1.0 (RC2) - posted by Chesnay Schepler <ch...@apache.org> on 2017/07/27 16:54:28 UTC, 0 replies.
- [jira] [Created] (FLINK-7288) YarnEntrypointUtils contain testing code - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/28 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2017/07/28 08:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7290) Make release scripts modular - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2017/07/28 10:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7291) Incorrect return value of getArity() in ListTypeInfo and MapTypeInfo - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/07/28 12:20:01 UTC, 0 replies.
- [jira] [Created] (FLINK-7292) Fix EMPTY MATCH bug in CEP. - posted by "zhangxiaoyu (JIRA)" <ji...@apache.org> on 2017/07/28 12:33:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7293) Support custom order by in PatternStream - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2017/07/28 12:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7294) mesos.resourcemanager.framework.role not working - posted by "Bhumika Bayani (JIRA)" <ji...@apache.org> on 2017/07/28 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7295) Add callback for proper RpcEndpoint shut down - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/28 13:53:01 UTC, 0 replies.
- Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release - posted by Stephan Ewen <se...@apache.org> on 2017/07/28 14:03:33 UTC, 1 replies.
- [ANNOUNCE] New Flink PMC member: Chesnay Schepler - posted by Greg Hogan <co...@greghogan.com> on 2017/07/28 14:05:35 UTC, 13 replies.
- [jira] [Created] (FLINK-7296) Validate commit messages in git pre-receive hook - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2017/07/28 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7297) Instable Kafka09ProducerITCase.testCustomPartitioning test case - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/28 16:17:00 UTC, 0 replies.
- [VOTE] Release 1.3.2, release candidate #1 - posted by Aljoscha Krettek <al...@apache.org> on 2017/07/29 06:06:21 UTC, 0 replies.
- [CANCEL] [VOTE] Release 1.3.2, release candidate #1 - posted by Aljoscha Krettek <al...@apache.org> on 2017/07/30 07:03:42 UTC, 0 replies.
- [VOTE] Release 1.3.2, release candidate #2 - posted by Aljoscha Krettek <al...@apache.org> on 2017/07/30 07:07:03 UTC, 0 replies.
- [jira] [Created] (FLINK-7298) Records can be cleared when all data in state is invalid - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2017/07/31 02:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7299) Write GenericRecord using AvroOutputFormat - posted by "Vishnu Viswanath (JIRA)" <ji...@apache.org> on 2017/07/31 04:50:02 UTC, 0 replies.
- [DISCUSS] api changes to support dml operations like ‘insert into’ clause in TableAPI&SQL - posted by Lin Li <li...@gmail.com> on 2017/07/31 04:50:09 UTC, 2 replies.
- [jira] [Created] (FLINK-7300) End-to-end tests are instable on Travis - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2017/07/31 06:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7301) Rework state documentation - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/07/31 08:25:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7302) Failed to run CorrelateITCase class under windows environment - posted by "mingleizhang (JIRA)" <ji...@apache.org> on 2017/07/31 09:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7303) Build elasticsearch5 by default - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/31 09:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7304) Simnplify garbage collector configuration in taskmanager.sh - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/31 09:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7305) Add new import block for shaded dependencies - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2017/07/31 10:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7306) function notFollowedBy in CEP dont return a Pattern object - posted by "Hanmiao Li (JIRA)" <ji...@apache.org> on 2017/07/31 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7307) Add proper command line parsing tool to ClusterEntrypoint - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7308) Kafka end to end test unstable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 12:02:01 UTC, 0 replies.
- KeyBy fields do not support java.lang.Array? - posted by Xu Pingyong <xu...@163.com> on 2017/07/31 13:16:36 UTC, 1 replies.
- [jira] [Created] (FLINK-7309) NullPointerException in CodeGenUtils.timePointToInternalCode() generated code - posted by "Liangliang Chen (JIRA)" <ji...@apache.org> on 2017/07/31 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7310) always use HybridMemorySegment - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/31 13:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7311) refrain from using fail(Exception#getMessage()) in core memory tests - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/31 13:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7312) activate checkstyle for flink/core/memory/* - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/31 13:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7313) Add conversion utilities (Scala and old Flink futures) - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 13:57:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7314) Remove Flink's futures from TaskManagerLogHandler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 13:57:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7315) use flink's buffers in netty - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/31 14:18:02 UTC, 0 replies.
- [jira] [Created] (FLINK-7316) always use off-heap network buffers - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2017/07/31 14:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7317) Remove Flink's futures from ExecutionGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7318) Remove Flink's futures from StackTraceSampleCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 15:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7319) Remove Flink's futures from MesosResourceManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7320) Remove Flink's futures from Scheduler - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 16:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7321) Remove Flink's futures from HeartbeatManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7322) Remove Flink's futures from CheckpointCoordinator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7323) Remove Flink's futures from MasterHooks - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 17:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7324) Remove Flink's futures from SlotPool - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 17:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7325) Remove Flink's futures from MiniCluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 17:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7326) Remove Flink's futures from RegisteredRpcConnection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 18:13:00 UTC, 0 replies.
- Class Cache - posted by Mike Accola <ma...@us.ibm.com> on 2017/07/31 18:18:11 UTC, 5 replies.
- [jira] [Created] (FLINK-7327) Remove Flink's futures from StreamRecordQueueEntry - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 19:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7328) Remove Flink's futures from SlotManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2017/07/31 19:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7329) Unable to use FileInputStream with StreamExecutionEnvironment.readFile with interval - posted by "Mohit Anchlia (JIRA)" <ji...@apache.org> on 2017/07/31 23:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-7330) Unable to read file on windows - InvalidFilePathException - posted by "Mohit Anchlia (JIRA)" <ji...@apache.org> on 2017/07/31 23:22:00 UTC, 0 replies.