flink-issues mailing list archives: August 2018

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
[jira] [Updated] (FLINK-9727) Allow user to pass resource tag expression in command line
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9727) Allow user to pass resource tag expression in command line Mon, 06 Aug, 08:34
[jira] [Updated] (FLINK-9724) Add tag support to yarn resource manager
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9724) Add tag support to yarn resource manager Mon, 06 Aug, 08:34
[jira] [Updated] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures Mon, 06 Aug, 08:34
[jira] [Updated] (FLINK-9725) Add tag support to standalone cluster manager.
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9725) Add tag support to standalone cluster manager. Mon, 06 Aug, 08:34
GitBox [GitHub] twalthr commented on a change in pull request #6486: [FLINK-10051][tests][sql] Add missing depenendeices for sql client E2E test Mon, 06 Aug, 08:34
[jira] [Updated] (FLINK-9723) Add tags support to mesos resource manager
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9723) Add tags support to mesos resource manager Mon, 06 Aug, 08:35
[jira] [Updated] (FLINK-9722) Add resource tag predicate into slot manager
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9722) Add resource tag predicate into slot manager Mon, 06 Aug, 08:35
[jira] [Updated] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis Mon, 06 Aug, 08:35
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis Mon, 06 Aug, 13:35
Thomas Weise (JIRA)   [jira] [Commented] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis Mon, 06 Aug, 13:36
Thomas Weise (JIRA)   [jira] [Updated] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis Mon, 06 Aug, 13:39
Thomas Weise (JIRA)   [jira] [Resolved] (FLINK-9691) Modify run loop in Kinesis ShardConsumer to not sleep for a fixed fetchIntervalMillis Mon, 06 Aug, 13:39
[jira] [Updated] (FLINK-9721) Introduce ResourceTagExpression class
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9721) Introduce ResourceTagExpression class Mon, 06 Aug, 08:35
[jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests Mon, 06 Aug, 08:35
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests Mon, 06 Aug, 08:35
[jira] [Updated] (FLINK-9693) Possible memory leak in jobmanager retaining archived checkpoints
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9693) Possible memory leak in jobmanager retaining archived checkpoints Mon, 06 Aug, 08:35
Steven Zhen Wu (JIRA)   [jira] [Closed] (FLINK-9693) Possible memory leak in jobmanager retaining archived checkpoints Sun, 12 Aug, 04:19
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9693) Possible memory leak in jobmanager retaining archived checkpoints Thu, 23 Aug, 08:21
[jira] [Updated] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files Mon, 06 Aug, 08:36
[jira] [Updated] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9608) Add test base for TypeSerializer snapshotting / restore / migration to be used by all Flink serializers Mon, 06 Aug, 08:36
[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Mon, 06 Aug, 08:36
Till Rohrmann (JIRA)   [jira] [Commented] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Mon, 06 Aug, 08:37
ASF GitHub Bot (JIRA)   [jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Mon, 06 Aug, 11:03
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Mon, 06 Aug, 11:03
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Mon, 06 Aug, 11:03
[jira] [Updated] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on Travis
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9646) ExecutionGraphCoLocationRestartTest.testConstraintsAfterRestart failed on Travis Mon, 06 Aug, 08:36
[jira] [Updated] (FLINK-9582) dist assemblies access jars outside of flink-dist
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9582) dist assemblies access jars outside of flink-dist Mon, 06 Aug, 08:36
[jira] [Updated] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition Mon, 06 Aug, 08:37
[jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect Mon, 06 Aug, 08:38
[jira] [Updated] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9481) FlinkKafkaProducer011ITCase deadlock in initializeState Mon, 06 Aug, 08:38
[jira] [Closed] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator
Aljoscha Krettek (JIRA)   [jira] [Closed] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator Mon, 06 Aug, 08:38
Aljoscha Krettek (JIRA)   [jira] [Reopened] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator Mon, 06 Aug, 08:38
[jira] [Reopened] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator
Aljoscha Krettek (JIRA)   [jira] [Reopened] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator Mon, 06 Aug, 08:38
Aljoscha Krettek (JIRA)   [jira] [Closed] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator Mon, 06 Aug, 08:38
[jira] [Updated] (FLINK-9478) Use Yarn application proxy to communicate with Flink cluster
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9478) Use Yarn application proxy to communicate with Flink cluster Mon, 06 Aug, 08:38
[jira] [Updated] (FLINK-9462) Disentangle flink-json and flink-table
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9462) Disentangle flink-json and flink-table Mon, 06 Aug, 08:39
[jira] [Updated] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json Mon, 06 Aug, 08:39
[jira] [Updated] (FLINK-9400) change import statement for flink-scala
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9400) change import statement for flink-scala Mon, 06 Aug, 08:39
ASF GitHub Bot (JIRA)   [jira] [Updated] (FLINK-9400) change import statement for flink-scala Mon, 13 Aug, 14:58
Chesnay Schepler (JIRA)   [jira] [Closed] (FLINK-9400) change import statement for flink-scala Mon, 13 Aug, 14:58
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9400) change import statement for flink-scala Mon, 13 Aug, 14:58
[jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations Mon, 06 Aug, 08:39
[jira] [Updated] (FLINK-9382) Inconsistent file storage behavior in FileCache
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9382) Inconsistent file storage behavior in FileCache Mon, 06 Aug, 08:40
[jira] [Updated] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable Mon, 06 Aug, 08:40
[jira] [Commented] (FLINK-9364) Add doc of the memory usage in flink
Till Rohrmann (JIRA)   [jira] [Commented] (FLINK-9364) Add doc of the memory usage in flink Mon, 06 Aug, 08:40
Sihua Zhou (JIRA)   [jira] [Commented] (FLINK-9364) Add doc of the memory usage in flink Tue, 07 Aug, 01:51
Sihua Zhou (JIRA)   [jira] [Updated] (FLINK-9364) Add doc of the memory usage in flink Tue, 07 Aug, 01:51
[jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down Mon, 06 Aug, 08:41
[jira] [Updated] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers Mon, 06 Aug, 08:41
[jira] [Updated] (FLINK-9195) Delete non-well-defined output methods on DataStream
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9195) Delete non-well-defined output methods on DataStream Mon, 06 Aug, 08:42
[jira] [Updated] (FLINK-9193) Deprecate non-well-defined output methods on DataStream
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9193) Deprecate non-well-defined output methods on DataStream Mon, 06 Aug, 08:42
[jira] [Created] (FLINK-10067) Add Kafka 1.0.0/1.1.0 connectors
Aljoscha Krettek (JIRA)   [jira] [Created] (FLINK-10067) Add Kafka 1.0.0/1.1.0 connectors Mon, 06 Aug, 08:42
Elias Levy (JIRA)   [jira] [Commented] (FLINK-10067) Add Kafka 1.0.0/1.1.0 connectors Mon, 06 Aug, 15:40
vinoyang (JIRA)   [jira] [Commented] (FLINK-10067) Add Kafka 1.0.0/1.1.0 connectors Tue, 07 Aug, 12:16
Aljoscha Krettek (JIRA)   [jira] [Commented] (FLINK-10067) Add Kafka 1.0.0/1.1.0 connectors Tue, 07 Aug, 13:03
Aljoscha Krettek (JIRA)   [jira] [Closed] (FLINK-10067) Add Kafka 1.0.0/1.1.0 connectors Tue, 07 Aug, 15:14
[jira] [Updated] (FLINK-9205) Delete non-well-defined SinkFunctions
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9205) Delete non-well-defined SinkFunctions Mon, 06 Aug, 08:42
[jira] [Updated] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job Mon, 06 Aug, 08:42
GitBox [GitHub] TisonKun commented on issue #6499: [hotfix] loose dependency to mockito Mon, 06 Aug, 08:43
[jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 08:49
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 16:44
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 16:44
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 16:44
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 16:44
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 16:44
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 16:44
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 16:44
ASF GitHub Bot (JIRA)   [jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 16:44
ASF GitHub Bot (JIRA)   [jira] [Updated] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 16:44
ASF GitHub Bot (JIRA)   [jira] [Commented] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 16:44
Fabian Hueske (JIRA)   [jira] [Assigned] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 17:00
Andrey Zagrebin (JIRA)   [jira] [Assigned] (FLINK-9126) Creation of the CassandraPojoInputFormat class to output data into a Custom Cassandra Annotated Pojo Mon, 06 Aug, 17:02
[jira] [Updated] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1 Mon, 06 Aug, 08:49
[jira] [Closed] (FLINK-9182) async checkpoints for timer service
Till Rohrmann (JIRA)   [jira] [Closed] (FLINK-9182) async checkpoints for timer service Mon, 06 Aug, 08:49
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
Jan 20207737
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