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
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) Thu, 14 Sep, 14:30
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" Thu, 14 Sep, 14:45
Aljoscha Krettek (JIRA) [jira] [Assigned] (FLINK-4796) Add new Sink interface with access to more meta data Thu, 14 Sep, 14:46
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-4796) Add new Sink interface with access to more meta data Thu, 14 Sep, 14:48
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-4796) Add new Sink interface with access to more meta data Thu, 14 Sep, 14:50
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-4796) Add new Sink interface with access to more meta data Thu, 14 Sep, 14:52
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata Thu, 14 Sep, 15:08
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7606) CEP operator leaks state Fri, 15 Sep, 09:50
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata Fri, 15 Sep, 09:54
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) Fri, 15 Sep, 09:56
Aljoscha Krettek (JIRA) [jira] [Reopened] (FLINK-4796) Add new Sink interface with access to more meta data Fri, 15 Sep, 09:58
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-4796) Add new Sink interface with access to more meta data Fri, 15 Sep, 10:00
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile() Sat, 16 Sep, 12:42
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-6383) Add versioning for AbstractStreamOperator state Tue, 19 Sep, 08:50
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2 Tue, 19 Sep, 08:52
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-4858) Remove Legacy Checkpointing Interfaces Tue, 19 Sep, 09:01
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7635) Support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction Tue, 19 Sep, 14:10
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7635) Support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction Tue, 19 Sep, 14:11
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile() Tue, 19 Sep, 15:05
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails Wed, 20 Sep, 14:40
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails Wed, 20 Sep, 14:40
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails Wed, 20 Sep, 14:40
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails Wed, 20 Sep, 14:41
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() Wed, 20 Sep, 14:46
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() Wed, 20 Sep, 14:46
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7553) Use new SinkFunction interface in FlinkKafkaProducer010 Thu, 21 Sep, 11:52
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7552) Extend SinkFunction interface with SinkContext Thu, 21 Sep, 11:52
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7442) Add option for using a child-first classloader for loading user code Thu, 21 Sep, 13:04
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state Thu, 21 Sep, 15:46
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks Fri, 22 Sep, 08:39
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work Fri, 22 Sep, 09:19
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig Fri, 22 Sep, 13:39
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig Fri, 22 Sep, 15:39
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-3986) Rename readFileStream from the StreamExecutionEnvironment Tue, 26 Sep, 12:31
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig Tue, 26 Sep, 12:33
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist Tue, 26 Sep, 13:21
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-7700) State merging in RocksDB backend leaves old state Wed, 27 Sep, 11:07
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-2268) Provide Flink binary release without Hadoop Wed, 27 Sep, 11:11
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment Wed, 27 Sep, 11:11
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-7729) Remove Scala 2.10 support; add Scala 2.12 support Thu, 28 Sep, 12:58
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7413) Release Hadoop 2.8.x convenience binaries for 1.3.x Thu, 28 Sep, 14:59
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable Thu, 28 Sep, 15:34
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-7692) Support user-defined variables in Metrics Thu, 28 Sep, 15:37
Andrey (JIRA) [jira] [Updated] (FLINK-5787) Unable to run jobs uploaded from IE Fri, 22 Sep, 09:14
Andrey (JIRA) [jira] [Created] (FLINK-7682) Invalid state size formatting Mon, 25 Sep, 12:08
Ashish Pokharel (JIRA) [jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6) Mon, 11 Sep, 03:00
Ashish Pokharel (JIRA) [jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6) Mon, 11 Sep, 11:35
Bill Liu (JIRA) [jira] [Created] (FLINK-7688) ContaineredTaskManagerParameters sets off heap memory size incorrectly unlimited Tue, 26 Sep, 01:13
Bin Wang (JIRA) [jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field Sat, 23 Sep, 08:14
Bin Wang (JIRA) [jira] [Created] (FLINK-7740) Add parameter support in CassandraInputFormat Fri, 29 Sep, 19:25
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
Bowen Li (JIRA) [jira] [Created] (FLINK-7587) Flink doesn't delete checkpoint file's dir from s3 Tue, 05 Sep, 18:02
Bowen Li (JIRA) [jira] [Commented] (FLINK-7587) Flink doesn't delete checkpoint file's dir from s3 Tue, 05 Sep, 19:04
Bowen Li (JIRA) [jira] [Updated] (FLINK-7587) Flink doesn't delete empty checkpoint file's dir from s3 Tue, 05 Sep, 19:05
Bowen Li (JIRA) [jira] [Created] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) Tue, 05 Sep, 21:59
Bowen Li (JIRA) [jira] [Created] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing Tue, 05 Sep, 22:27
Bowen Li (JIRA) [jira] [Updated] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout Tue, 05 Sep, 22:28
Bowen Li (JIRA) [jira] [Commented] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout Thu, 07 Sep, 02:38
Bowen Li (JIRA) [jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) Thu, 07 Sep, 04:05
Bowen Li (JIRA) [jira] [Commented] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout Thu, 07 Sep, 04:09
Bowen Li (JIRA) [jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode Thu, 07 Sep, 04:10
Bowen Li (JIRA) [jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode Thu, 07 Sep, 04:14
Bowen Li (JIRA) [jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode Thu, 07 Sep, 05:38
Bowen Li (JIRA) [jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode Thu, 07 Sep, 05:43
Bowen Li (JIRA) [jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode Thu, 07 Sep, 05:51
Bowen Li (JIRA) [jira] [Created] (FLINK-7597) broken flink-connectors-kinesis setup in Intellij that potentially results from improper pom.xml Thu, 07 Sep, 06:30
Bowen Li (JIRA) [jira] [Updated] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode Thu, 07 Sep, 17:27
Bowen Li (JIRA) [jira] [Commented] (FLINK-7597) broken flink-connectors-kinesis setup in Intellij that potentially results from improper pom.xml Thu, 07 Sep, 21:15
Bowen Li (JIRA) [jira] [Closed] (FLINK-7597) broken flink-connectors-kinesis setup in Intellij that potentially results from improper pom.xml Thu, 07 Sep, 21:15
Bowen Li (JIRA) [jira] [Created] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception Thu, 07 Sep, 21:35
Bowen Li (JIRA) [jira] [Commented] (FLINK-6125) Commons httpclient is not shaded anymore in Flink 1.2 Thu, 07 Sep, 23:33
Bowen Li (JIRA) [jira] [Assigned] (FLINK-6703) Document how to take a savepoint on YARN Thu, 07 Sep, 23:46
Bowen Li (JIRA) [jira] [Commented] (FLINK-6703) Document how to take a savepoint on YARN Thu, 07 Sep, 23:49
Bowen Li (JIRA) [jira] [Comment Edited] (FLINK-6703) Document how to take a savepoint on YARN Thu, 07 Sep, 23:50
Bowen Li (JIRA) [jira] [Assigned] (FLINK-5095) Add explicit notifyOfAddedX methods to MetricReporter interface Thu, 07 Sep, 23:55
Bowen Li (JIRA) [jira] [Assigned] (FLINK-6957) WordCountTable example cannot be run Thu, 07 Sep, 23:56
Bowen Li (JIRA) [jira] [Assigned] (FLINK-6549) Improve error message for type mismatches with side outputs Thu, 07 Sep, 23:56
Bowen Li (JIRA) [jira] [Created] (FLINK-7609) WindowWordCount example doesn't print countWindow output with default configs Fri, 08 Sep, 20:40
Bowen Li (JIRA) [jira] [Updated] (FLINK-7609) WindowWordCount example doesn't print countWindow output with default configs Fri, 08 Sep, 20:43
Bowen Li (JIRA) [jira] [Updated] (FLINK-7609) WindowWordCount example doesn't print countWindow output with default configs Fri, 08 Sep, 20:46
Bowen Li (JIRA) [jira] [Resolved] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) Mon, 11 Sep, 05:33
Bowen Li (JIRA) [jira] [Commented] (FLINK-6957) WordCountTable example cannot be run Mon, 11 Sep, 19:34
Bowen Li (JIRA) [jira] [Issue Comment Deleted] (FLINK-6703) Document how to take a savepoint on YARN Mon, 11 Sep, 20:55
Bowen Li (JIRA) [jira] [Commented] (FLINK-6703) Document how to take a savepoint on YARN Mon, 11 Sep, 21:09
Bowen Li (JIRA) [jira] [Comment Edited] (FLINK-6703) Document how to take a savepoint on YARN Mon, 11 Sep, 21:10
Bowen Li (JIRA) [jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536) Thu, 14 Sep, 16:08
Bowen Li (JIRA) [jira] [Commented] (FLINK-7622) Respect local KPL queue size in FlinkKinesisProducer when adding records to KPL client Thu, 14 Sep, 20:24
Bowen Li (JIRA) [jira] [Commented] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction Mon, 18 Sep, 04:34
Bowen Li (JIRA) [jira] [Assigned] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction Mon, 18 Sep, 23:51
Bowen Li (JIRA) [jira] [Commented] (FLINK-7635) support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction Tue, 19 Sep, 03:20
Bowen Li (JIRA) [jira] [Closed] (FLINK-6549) Improve error message for type mismatches with side outputs Tue, 19 Sep, 17:17
Bowen Li (JIRA) [jira] [Commented] (FLINK-7643) HadoopFileSystem always reloads GlobalConfiguration Tue, 19 Sep, 21:29
Bowen Li (JIRA) [jira] [Updated] (FLINK-7635) Support sideOutput in ProcessWindowFunciton Thu, 21 Sep, 05:21
Bowen Li (JIRA) [jira] [Created] (FLINK-7660) Support sideOutput in ProcessAllWindowFunction Thu, 21 Sep, 05:24
Bowen Li (JIRA) [jira] [Commented] (FLINK-7635) Support sideOutput in ProcessWindowFunciton Thu, 21 Sep, 05:30
Bowen Li (JIRA) [jira] [Assigned] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest Fri, 22 Sep, 05:28
Bowen Li (JIRA) [jira] [Updated] (FLINK-7659) Unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest Fri, 22 Sep, 05:37
Bowen Li (JIRA) [jira] [Commented] (FLINK-5726) Add the RocketMQ plugin for the Apache Flink Fri, 22 Sep, 06: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