[jira] [Commented] (FLINK-7635) Support sideOutput in ProcessWindowFunciton

[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325372#comment-16325372 ] Bowen Li commented on FLINK-7635: - [~srichter] > Support sideOutput in ProcessWindowFunci

[jira] [Comment Edited] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

[ https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325346#comment-16325346 ] Dongwon Kim edited comment on FLINK-8431 at 1/13/18 10:55 PM: --

[jira] [Commented] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

[ https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325364#comment-16325364 ] Dongwon Kim commented on FLINK-8431: Eron, I saw a discussion on [GPU_RESOURCES|https

[jira] [Commented] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

[ https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325346#comment-16325346 ] Dongwon Kim commented on FLINK-8431: Eron, thanks for the comment on {noformat}com.ne

[jira] [Comment Edited] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

[ https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325339#comment-16325339 ] Eron Wright edited comment on FLINK-8431 at 1/13/18 9:19 PM: --

[jira] [Commented] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

[ https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325339#comment-16325339 ] Eron Wright commented on FLINK-8431: - Note that, as per the Mesos docs, Flink will ne

[jira] [Commented] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

[ https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325337#comment-16325337 ] Eron Wright commented on FLINK-8431: - Good news, it appears that Fenzo supports gener

[jira] [Commented] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway

[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325161#comment-16325161 ] ASF GitHub Bot commented on FLINK-8317: --- Github user asfgit closed the pull request

[GitHub] flink pull request #5223: [FLINK-8317][flip6] Implement Triggering of Savepo...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5223 ---

[jira] [Resolved] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway

[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8317. -- Resolution: Fixed Fixed via 782ec6dc4c3a4d4825c8f99af0b596be766c1312 > Enable Triggering of Sav

[jira] [Commented] (FLINK-8414) Gelly performance seriously decreases when using the suggested parallelism configuration

[ https://issues.apache.org/jira/browse/FLINK-8414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325157#comment-16325157 ] flora karniav commented on FLINK-8414: -- Thank you for the information, I understand

[GitHub] flink pull request #5293: [hotfix][docs] Mention maven dependency for RocksD...

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/5293 [hotfix][docs] Mention maven dependency for RocksDB state backend This hotfix adds a note to the RocksDB state backend page, mentioning that it requires a maven dependency to be added to the users'

[jira] [Assigned] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

[ https://issues.apache.org/jira/browse/FLINK-8431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dongwon Kim reassigned FLINK-8431: -- Assignee: Dongwon Kim > Allow to specify # GPUs for TaskManager in Mesos >

[jira] [Created] (FLINK-8431) Allow to specify # GPUs for TaskManager in Mesos

Dongwon Kim created FLINK-8431: -- Summary: Allow to specify # GPUs for TaskManager in Mesos Key: FLINK-8431 URL: https://issues.apache.org/jira/browse/FLINK-8431 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway

[ https://issues.apache.org/jira/browse/FLINK-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325064#comment-16325064 ] ASF GitHub Bot commented on FLINK-8317: --- Github user GJL commented on a diff in the

[GitHub] flink pull request #5223: [FLINK-8317][flip6] Implement Triggering of Savepo...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5223#discussion_r161368455 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java --- @@ -0,0 +1,337 @@ +/* + * Licensed

[jira] [Updated] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

[ https://issues.apache.org/jira/browse/FLINK-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6856: --- Priority: Critical (was: Major) > Eagerly check if serializer config snapshots are de

[jira] [Updated] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

[ https://issues.apache.org/jira/browse/FLINK-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6856: --- Fix Version/s: 1.5.0 > Eagerly check if serializer config snapshots are deserializable

[jira] [Updated] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6944: --- Priority: Blocker (was: Major) > Introduce DefaultTypeSerializerConfigSnapshot as a b

[jira] [Commented] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325063#comment-16325063 ] Tzu-Li (Gordon) Tai commented on FLINK-6944: Marking this as a blocker for 1.5

[jira] [Updated] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers

[ https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6764: --- Fix Version/s: 1.5.0 > Deduplicate stateless TypeSerializers when serializing composit

[jira] [Updated] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers

[ https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6764: --- Priority: Blocker (was: Major) > Deduplicate stateless TypeSerializers when serializi

[jira] [Commented] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers

[ https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325062#comment-16325062 ] Tzu-Li (Gordon) Tai commented on FLINK-6764: It seems like we forgot completel

[jira] [Updated] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format

[ https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6763: --- Priority: Blocker (was: Major) > Inefficient PojoSerializerConfigSnapshot serializati

[jira] [Updated] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format

[ https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6763: --- Fix Version/s: 1.5.0 > Inefficient PojoSerializerConfigSnapshot serialization format >

[jira] [Comment Edited] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format

[ https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325059#comment-16325059 ] Tzu-Li (Gordon) Tai edited comment on FLINK-6763 at 1/13/18 9:20 AM: ---

[jira] [Commented] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format

[ https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325059#comment-16325059 ] Tzu-Li (Gordon) Tai commented on FLINK-6763: It seems like we forgot completel

[jira] [Commented] (FLINK-8276) Annotation for Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-8276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325038#comment-16325038 ] Tzu-Li (Gordon) Tai commented on FLINK-8276: Merged for 1.5: 4ceabed9ad108acd6

[jira] [Resolved] (FLINK-8276) Annotation for Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-8276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8276. Resolution: Fixed > Annotation for Kafka connector > --

[jira] [Resolved] (FLINK-8199) Annotation for Elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8199. Resolution: Fixed > Annotation for Elasticsearch connector > ---

[jira] [Resolved] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods

[ https://issues.apache.org/jira/browse/FLINK-8306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8306. Resolution: Fixed > FlinkKafkaConsumerBaseTest has invalid mocks on final methods >

[jira] [Commented] (FLINK-8217) Properly annotate APIs of flink-connector-kinesis

[ https://issues.apache.org/jira/browse/FLINK-8217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325036#comment-16325036 ] Tzu-Li (Gordon) Tai commented on FLINK-8217: Merged for 1.5: 30734d55660bfe00c

[jira] [Commented] (FLINK-8199) Annotation for Elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-8199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325037#comment-16325037 ] Tzu-Li (Gordon) Tai commented on FLINK-8199: Merged for 1.5: 9b5fce6b1d5520505

[jira] [Resolved] (FLINK-8217) Properly annotate APIs of flink-connector-kinesis

[ https://issues.apache.org/jira/browse/FLINK-8217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8217. Resolution: Fixed > Properly annotate APIs of flink-connector-kinesis >

[jira] [Commented] (FLINK-8306) FlinkKafkaConsumerBaseTest has invalid mocks on final methods

[ https://issues.apache.org/jira/browse/FLINK-8306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325033#comment-16325033 ] Tzu-Li (Gordon) Tai commented on FLINK-8306: Merged. 1.4: c4bfc7de36201d7a144

[jira] [Closed] (FLINK-8296) Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection

[ https://issues.apache.org/jira/browse/FLINK-8296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-8296. -- Resolution: Fixed > Rework FlinkKafkaConsumerBestTest to not use Java reflection for dep

[jira] [Commented] (FLINK-8296) Rework FlinkKafkaConsumerBestTest to not use Java reflection for dependency injection

[ https://issues.apache.org/jira/browse/FLINK-8296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325031#comment-16325031 ] Tzu-Li (Gordon) Tai commented on FLINK-8296: Merged. 1.4: 968683f15378122478e

[jira] [Resolved] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8162. Resolution: Fixed > Kinesis Connector to report millisBehindLatest metric >

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325030#comment-16325030 ] Tzu-Li (Gordon) Tai commented on FLINK-8162: Merged for 1.5: 8e23264a4511d3372

[jira] [Resolved] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables

[ https://issues.apache.org/jira/browse/FLINK-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8324. Resolution: Fixed > Expose another offsets metrics by using new metric API to specif

[jira] [Commented] (FLINK-8324) Expose another offsets metrics by using new metric API to specify user defined variables

[ https://issues.apache.org/jira/browse/FLINK-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325028#comment-16325028 ] Tzu-Li (Gordon) Tai commented on FLINK-8324: Merged for 1.5: 82a9ae596e185a3fd

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325027#comment-16325027 ] Tzu-Li (Gordon) Tai commented on FLINK-6951: Merged. 1.3: e10fec8236af98709ec

[jira] [Resolved] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6951. Resolution: Fixed Fix Version/s: 1.4.1 1.5.0 > Incompatibl

[jira] [Resolved] (FLINK-8271) upgrade from deprecated classes to AmazonKinesis

[ https://issues.apache.org/jira/browse/FLINK-8271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8271. Resolution: Fixed > upgrade from deprecated classes to AmazonKinesis > -

[jira] [Commented] (FLINK-8271) upgrade from deprecated classes to AmazonKinesis

[ https://issues.apache.org/jira/browse/FLINK-8271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16325026#comment-16325026 ] Tzu-Li (Gordon) Tai commented on FLINK-8271: Merged for 1.5.0: d53a722e769e8ff