flink-issues mailing list archives: September 2017

Site index · List index
Message list1 · 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
Mike Dias (JIRA) [jira] [Commented] (FLINK-7430) ContinuousFileReaderOperator swallows exceptions Fri, 01 Sep, 00:59
lincoln-lil [GitHub] flink pull request #3829: [FLINK-6442] [table] Extend TableAPI Support Sink ... Fri, 01 Sep, 03:17
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6442) Extend TableAPI Support Sink Table Registration and ‘insert into’ Clause in SQL Fri, 01 Sep, 03:18
mbode [GitHub] flink pull request #4586: [FLINK-7502] [metrics] Improve PrometheusReporter Fri, 01 Sep, 05:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7502) PrometheusReporter improvements Fri, 01 Sep, 05:55
Bowen Li (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 Fri, 01 Sep, 06:18
Bowen Li (JIRA) [jira] [Updated] (FLINK-7566) if there's only one checkpointing metadata file in <dir>, `flink run -s <dir>` should successfully resume from that metadata file Fri, 01 Sep, 06:21
Bowen Li (JIRA) [jira] [Commented] (FLINK-7223) Increase DEFAULT_SHARD_DISCOVERY_INTERVAL_MILLIS for Flink-kinesis-connector Fri, 01 Sep, 07:16
Shuyi Chen (JIRA) [jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL Fri, 01 Sep, 07:18
xccui [GitHub] flink pull request #4633: [FLINK-7564] [table] Fix Watermark semantics in Ro... Fri, 01 Sep, 08:20
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7564) Fix Watermark semantics in Table API Fri, 01 Sep, 08:21
aljoscha [GitHub] flink issue #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / Use in ... Fri, 01 Sep, 08:38
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7552) Extend SinkFunction interface with SinkContext Fri, 01 Sep, 08:39
aljoscha [GitHub] flink issue #4422: [FLINK-7299][AVRO] Write GenericRecord using AvroOutputFo... Fri, 01 Sep, 08:51
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7299) Write GenericRecord using AvroOutputFormat Fri, 01 Sep, 08:52
ASF GitHub Bot (JIRA) [jira] [Commented] (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 [GitHub] flink issue #4627: [FLINK-7422][kinesis] Upgrade Kinesis Client Library (KCL... Fri, 01 Sep, 09:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7422) Upgrade Kinesis Client Library (KCL) and AWS SDK in flink-connector-kinesis Fri, 01 Sep, 09:02
soniclavier [GitHub] flink pull request #4422: [FLINK-7299][AVRO] Write GenericRecord using AvroO... Fri, 01 Sep, 09:02
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7299) Write GenericRecord using AvroOutputFormat Fri, 01 Sep, 09:03
Xingcan Cui (JIRA) [jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API Fri, 01 Sep, 09:33
Peter Ertl (JIRA) [jira] [Created] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work Fri, 01 Sep, 09:36
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
Hai Zhou (JIRA) [jira] [Assigned] (FLINK-5944) Flink should support reading Snappy Files Fri, 01 Sep, 11:01
Hai Zhou (JIRA) [jira] [Assigned] (FLINK-5944) Flink should support reading Snappy Files Fri, 01 Sep, 11:02
mlipkovich [GitHub] flink issue #4630: [FLINK-6733] Remove commented out AvgAggregationFunction.... Fri, 01 Sep, 11:45
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6733) Remove commented out AvgAggregationFunction.java Fri, 01 Sep, 11:46
asfgit [GitHub] flink pull request #4331: [FLINK-7169][CEP] Support AFTER MATCH SKIP functio... Fri, 01 Sep, 12:33
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API Fri, 01 Sep, 12:34
pnowojski [GitHub] flink pull request #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / ... Fri, 01 Sep, 12:35
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7552) Extend SinkFunction interface with SinkContext Fri, 01 Sep, 12:36
aljoscha [GitHub] flink pull request #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / ... Fri, 01 Sep, 13:36
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7552) Extend SinkFunction interface with SinkContext Fri, 01 Sep, 13:37
aljoscha [GitHub] flink pull request #4634: [FLINK-7568] Improve Windowing Documentation Fri, 01 Sep, 13:37
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve Fri, 01 Sep, 13:38
Chesnay Schepler (JIRA) [jira] [Closed] (FLINK-6860) update Apache Beam in page Ecosystem Fri, 01 Sep, 14:06
zentol [GitHub] flink issue #4630: [FLINK-6733] Remove commented out AvgAggregationFunction.... Fri, 01 Sep, 14:10
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-6733) Remove commented out AvgAggregationFunction.java Fri, 01 Sep, 14:11
olivier sohn (JIRA) [jira] [Created] (FLINK-7569) '1 record' delay for counted windowed streams Fri, 01 Sep, 15:24
olivier sohn (JIRA) [jira] [Updated] (FLINK-7569) '1 record' delay for counted windowed streams Fri, 01 Sep, 15:26
yew1eb [GitHub] flink issue #4570: [FLINK-7438][DataStream API]Remove useless import, avoid ... Fri, 01 Sep, 15:53
yew1eb [GitHub] flink issue #4614: [FLINK-7547] AsyncFunction.scala extends Function, serial... Fri, 01 Sep, 15:53
yew1eb [GitHub] flink issue #4575: [FLINK-7494][travis] Add license headers to '.travis.yml'... Fri, 01 Sep, 15:53
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7494) No license headers in ".travis.yml" file Fri, 01 Sep, 15:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable Fri, 01 Sep, 15:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7438) Some classes are eclipsed by classes in package scala Fri, 01 Sep, 15:54
EronWright [GitHub] flink pull request #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / ... Fri, 01 Sep, 16:26
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7552) Extend SinkFunction interface with SinkContext Fri, 01 Sep, 16:27
EronWright [GitHub] flink pull request #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / ... Fri, 01 Sep, 16:29
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7552) Extend SinkFunction interface with SinkContext Fri, 01 Sep, 16:30
EronWright [GitHub] flink pull request #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / ... Fri, 01 Sep, 16:34
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7552) Extend SinkFunction interface with SinkContext Fri, 01 Sep, 16:35
Mikhail Lipkovich (JIRA) [jira] [Assigned] (FLINK-5944) Flink should support reading Snappy Files Fri, 01 Sep, 16:47
Mikhail Lipkovich (JIRA) [jira] [Assigned] (FLINK-6733) Remove commented out AvgAggregationFunction.java Fri, 01 Sep, 16:48
Mikhail Lipkovich (JIRA) [jira] [Commented] (FLINK-6016) Newlines should be valid in quoted strings in CSV Fri, 01 Sep, 16:57
Luke Hutchison (JIRA) [jira] [Commented] (FLINK-6016) Newlines should be valid in quoted strings in CSV Fri, 01 Sep, 17:20
bowenli86 [GitHub] flink pull request #4627: [FLINK-7422][kinesis] Upgrade Kinesis Client Libra... Fri, 01 Sep, 17:25
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7422) Upgrade Kinesis Client Library (KCL) and AWS SDK in flink-connector-kinesis Fri, 01 Sep, 17:26
Hai Zhou (JIRA) [jira] [Created] (FLINK-7570) Fix broken link on faq page Fri, 01 Sep, 17:41
Hai Zhou (JIRA) [jira] [Commented] (FLINK-7570) Fix broken link on faq page Fri, 01 Sep, 17:45
Fabian Hueske (JIRA) [jira] [Created] (FLINK-7571) Execution of TableSources with Time Indicators fails Fri, 01 Sep, 20:06
fhueske [GitHub] flink pull request #4635: [FLINK-7571] [table] Fix translation of TableSourc... Fri, 01 Sep, 20:12
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7571) Execution of TableSources with Time Indicators fails Fri, 01 Sep, 20:13
suez1224 [GitHub] flink issue #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInfo; add ... Fri, 01 Sep, 21:01
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL Fri, 01 Sep, 21:02
Shuyi Chen (JIRA) [jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6) Fri, 01 Sep, 23:48
Shuyi Chen (JIRA) [jira] [Comment Edited] (FLINK-4319) Rework Cluster Management (FLIP-6) Fri, 01 Sep, 23:48
Ted Yu (JIRA) [jira] [Updated] (FLINK-7432) Unclosed HighAvailabilityServices instance in QueryableStateClient Sat, 02 Sep, 03:28
Ted Yu (JIRA) [jira] [Updated] (FLINK-7433) Lack of synchronization accessing inProgress in JobCancellationWithSavepointHandlers Sat, 02 Sep, 03:28
tedyu [GitHub] flink issue #4562: [FLINK-7402] Fix ineffective null check in NettyMessage#w... Sat, 02 Sep, 03:28
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7402) Ineffective null check in NettyMessage#write() Sat, 02 Sep, 03:29
Ted Yu (JIRA) [jira] [Comment Edited] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish Sat, 02 Sep, 14:42
Till Rohrmann (JIRA) [jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6) Sat, 02 Sep, 21:53
Ted Yu (JIRA) [jira] [Resolved] (FLINK-6997) SavepointITCase fails in master branch sometimes Sun, 03 Sep, 01:56
pnowojski [GitHub] flink pull request #4616: [FLINK-7552] [FLINK-7553] Enhance SinkInterface / ... Sun, 03 Sep, 13:57
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7552) Extend SinkFunction interface with SinkContext Sun, 03 Sep, 13:58
aljoscha [GitHub] flink issue #4634: [FLINK-7568] Improve Windowing Documentation Sun, 03 Sep, 16:29
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7568) Bring window documentation up-to-date with latest changes and improve Sun, 03 Sep, 16:30
Hai Zhou (JIRA) [jira] [Commented] (FLINK-7284) Verify compile time and runtime version of Hadoop Sun, 03 Sep, 19:50
tillrohrmann [GitHub] flink issue #4527: [FLINK-7409] [web] Make WebRuntimeMonitor reactive Sun, 03 Sep, 20:52
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7409) WebRuntimeMonitor blocks serving threads Sun, 03 Sep, 20:53
Hai Zhou (JIRA) [jira] [Commented] (FLINK-4831) Implement a slf4j metric reporter Sun, 03 Sep, 20:54
tillrohrmann [GitHub] flink issue #4540: [FLINK-7444] [rpc] Make external calls non-blocking Sun, 03 Sep, 20:54
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7444) Make external calls non-blocking Sun, 03 Sep, 20:55
tillrohrmann [GitHub] flink issue #4548: [FLINK-7457] Make Dispatcher highly available Sun, 03 Sep, 20:59
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7457) Make dispatcher highly available Sun, 03 Sep, 21:00
asfgit [GitHub] flink pull request #4548: [FLINK-7457] Make Dispatcher highly available Sun, 03 Sep, 21:02
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7457) Make dispatcher highly available Sun, 03 Sep, 21:03
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7457) Make dispatcher highly available Sun, 03 Sep, 21:03
tillrohrmann [GitHub] flink issue #4573: [FLINK-7489] Remove startJobExecution and suspendExecutio... Sun, 03 Sep, 21:04
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7489) Remove job lifecycle methods from public JobMasterGateway interface Sun, 03 Sep, 21:05
asfgit [GitHub] flink pull request #4573: [FLINK-7489] Remove startJobExecution and suspendE... Sun, 03 Sep, 21:06
tillrohrmann [GitHub] flink issue #4579: [FLINK-7500] Set JobMaster leader session id in main thre... Sun, 03 Sep, 21:06
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7489) Remove job lifecycle methods from public JobMasterGateway interface Sun, 03 Sep, 21:07
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7500) Set JobMaster leader session id in main thread Sun, 03 Sep, 21:07
Till Rohrmann (JIRA) [jira] [Closed] (FLINK-7489) Remove job lifecycle methods from public JobMasterGateway interface Sun, 03 Sep, 21:07
tillrohrmann [GitHub] flink issue #4580: [FLINK-7501] Generalize RegisteredRpcConnection to suppor... Sun, 03 Sep, 21:08
ASF GitHub Bot (JIRA) [jira] [Commented] (FLINK-7501) Generalize leader id of RegisteredRpcConnection Sun, 03 Sep, 21:09
Message list1 · 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
May 20194965
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