flink-issues mailing list archives: September 2017

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · Next »Thread · Author · Date
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7720) Centralize creation of backends and state related resources Thu, 28 Sep, 19:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException Fri, 29 Sep, 02:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7632) Better documentation and examples on C* sink usage for Pojo and Tuples data types Fri, 29 Sep, 03:56
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 05:51
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 05:56
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7521) Remove the 10MB limit from the current REST implementation. Fri, 29 Sep, 06:47
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6864) Remove confusing "invalid POJO type" messages from TypeExtractor Fri, 29 Sep, 07:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7660) Support sideOutput in ProcessAllWindowFunction Fri, 29 Sep, 07:30
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7695) Port JobConfigHandler to new REST endpoint Fri, 29 Sep, 07:58
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7695) Port JobConfigHandler to new REST endpoint Fri, 29 Sep, 08:26
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7667) Add serializable AccessExecutionGraph implementation Fri, 29 Sep, 08:34
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7667) Add serializable AccessExecutionGraph implementation Fri, 29 Sep, 08:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder Fri, 29 Sep, 08:37
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder Fri, 29 Sep, 08:44
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder Fri, 29 Sep, 08:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling Fri, 29 Sep, 09:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling Fri, 29 Sep, 09:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7728) StatusWatermarkValve has different min watermark advancement behavior depending on the ordering inputs become idle Fri, 29 Sep, 09:35
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API Fri, 29 Sep, 09:58
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API Fri, 29 Sep, 09:59
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7708) Port CheckpointConfigHandler to new REST endpoint Fri, 29 Sep, 10:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder Fri, 29 Sep, 10:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability Fri, 29 Sep, 13:10
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7072) Create RESTful cluster endpoint Fri, 29 Sep, 13:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7710) Port CheckpointStatsHandler to new REST endpoint Fri, 29 Sep, 13:27
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7739) Improve Kafka*ITCase tests stability Fri, 29 Sep, 13:39
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7710) Port CheckpointStatsHandler to new REST endpoint Fri, 29 Sep, 14:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7700) State merging in RocksDB backend leaves old state Fri, 29 Sep, 15:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 16:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based Fri, 29 Sep, 16:31
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 17:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB Fri, 29 Sep, 18:31
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB Fri, 29 Sep, 19:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB Fri, 29 Sep, 19:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB Fri, 29 Sep, 19:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 19:11
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based Fri, 29 Sep, 19:14
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API Sat, 30 Sep, 01:04
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7741) Fix NPE when throw new SlotNotFoundException Sat, 30 Sep, 06:24
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7742) Fix array access might be out of bounds Sat, 30 Sep, 07:32
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7474) Flink supports consuming data from and sink data to Azure eventhubs Sat, 30 Sep, 11:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7009) dogstatsd mode in statsd reporter Sat, 30 Sep, 22:34
Addison Higham (JIRA) [jira] [Created] (FLINK-7615) Under mesos when using a role, TaskManagers fail to schedule Wed, 13 Sep, 21:08
Addison Higham (JIRA) [jira] [Commented] (FLINK-7615) Under mesos when using a role, TaskManagers fail to schedule Wed, 13 Sep, 21:10
Aitozi [GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data... Tue, 12 Sep, 07:06
Aitozi [GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data... Wed, 13 Sep, 03:09
Aitozi [GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data... Wed, 13 Sep, 03:12
Aitozi [GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data... Thu, 14 Sep, 01:29
Aitozi [GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data... Thu, 14 Sep, 03:24
Aitozi [GitHub] flink issue #4665: [Flink-7611]add metrics to measure the num of data droppe... Thu, 14 Sep, 16:19
Aitozi [GitHub] flink issue #4665: [Flink-7611]add metrics to measure the num of data droppe... Fri, 15 Sep, 11:41
Aitozi [GitHub] flink issue #4665: [Flink-7611]add metrics to measure the num of data droppe... Tue, 19 Sep, 11:19
Aitozi [GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data... Tue, 19 Sep, 16:15
Aitozi [GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data... Wed, 20 Sep, 10:40
Aitozi [GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data... Sat, 23 Sep, 14:33
Aitozi [GitHub] flink pull request #4665: [Flink-7611]add metrics to measure the num of data... Sat, 23 Sep, 14:50
Aitozi [GitHub] flink issue #4665: [Flink-7611]add metrics to measure the num of data droppe... Mon, 25 Sep, 09:24
Aitozi [GitHub] flink issue #4665: [Flink-7611]add metrics to measure the num of data droppe... Thu, 28 Sep, 15:18
Alexey Diomin (JIRA) [jira] [Commented] (FLINK-7735) Improve date/time handling in publically-facing Expressions Fri, 29 Sep, 15:44
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7299) Write GenericRecord using AvroOutputFormat Fri, 01 Sep, 08:52
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7422) Upgrade Kinesis Client Library (KCL) and AWS SDK in flink-connector-kinesis Fri, 01 Sep, 09:01
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve Fri, 01 Sep, 10:04
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6163) Document per-window state in ProcessWindowFunction Fri, 01 Sep, 10:05
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7566) if there's only one checkpointing metadata file in <dir>, `flink run -s <dir>` should successfully resume from that metadata file Mon, 04 Sep, 12:46
Aljoscha Krettek (JIRA) [jira] [Assigned] (FLINK-6163) Document per-window state in ProcessWindowFunction Tue, 05 Sep, 15:31
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-6163) Document per-window state in ProcessWindowFunction Tue, 05 Sep, 15:31
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve Tue, 05 Sep, 16:09
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-7586) Report Watermark metrics in all operators Tue, 05 Sep, 16:23
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions Wed, 06 Sep, 08:26
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7266) Don't attempt to delete parent directory on S3 Wed, 06 Sep, 10:24
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout Wed, 06 Sep, 10:26
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) Wed, 06 Sep, 10:26
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4812) Export currentLowWatermark metric also for sources Wed, 06 Sep, 11:38
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4812) Export currentLowWatermark metric also for sources Wed, 06 Sep, 11:38
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7586) Report Watermark metrics in all operators Wed, 06 Sep, 11:39
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-4812) Report Watermark metrics in all operators Wed, 06 Sep, 11:39
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4812) Report Watermark metrics in all operators Wed, 06 Sep, 11:39
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7586) Report Watermark metrics in all operators Wed, 06 Sep, 11:40
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work Wed, 06 Sep, 12:16
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work Wed, 06 Sep, 13:31
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state Thu, 14 Sep, 12:44
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state Thu, 14 Sep, 12:45
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7608) LatencyGauge change to histogram metric Thu, 14 Sep, 13:48
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout Thu, 14 Sep, 13:50
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout Thu, 14 Sep, 13:50
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7606) CEP operator leaks state Thu, 14 Sep, 13:59
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7606) CEP operator leaks state Thu, 14 Sep, 14:00
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7607) Web Frontend Hangs with Large Numbers of Tasks Thu, 14 Sep, 14:02
Aljoscha Krettek (JIRA) [jira] [Assigned] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin Thu, 14 Sep, 14:05
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · Next »Thread · Author · Date
Box list
Feb 20204480
Jan 20208835
Dec 201913015
Nov 201911280
Oct 201911647
Sep 20198451
Aug 201910193
Jul 201911502
Jun 20198159
May 20197326
Apr 20195671
Mar 20194764
Feb 20195750
Jan 20194225
Dec 20183613
Nov 20186764
Oct 20186946
Sep 20184634
Aug 20185670
Jul 20187170
Jun 20184380
May 20185152
Apr 20183465
Mar 20184883
Feb 20185764
Jan 20184880
Dec 20172682
Nov 20174639
Oct 20174859
Sep 20173958
Aug 20174518
Jul 20175392
Jun 20174893
May 20176475
Apr 20174390
Mar 20177839
Feb 20175379
Jan 20175351
Dec 20163688
Nov 20164834
Oct 20164002
Sep 20163620
Aug 20165065
Jul 20163523
Jun 20164191
May 20163116
Apr 20163318
Mar 20163053
Feb 20164198
Jan 20162281
Dec 20151770
Nov 20153847
Oct 20153578
Sep 20153866
Aug 20154488
Jul 20152905
Jun 20153211
May 20152758
Apr 20152329
Mar 20152558
Feb 20151980
Jan 20151685
Dec 2014836
Nov 20141506
Oct 2014575
Sep 2014744
Aug 2014435
Jul 20141002
Jun 2014300