[jira] [Commented] (FLINK-18450) FLIP-182: Support watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-18450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518179#comment-17518179 ] Alexey Trenikhin commented on FLINK-18450: -- Will this feature align partitions for Kafka topic,

[jira] [Commented] (FLINK-18450) FLIP-182: Support watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-18450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444901#comment-17444901 ] Alexey Trenikhin commented on FLINK-18450: -- Very interested in this feature, is it still

[jira] [Commented] (FLINK-12675) Event time synchronization in Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350597#comment-17350597 ] Alexey Trenikhin commented on FLINK-12675: -- Does new  Source interface support suspend/resume ?

[jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"

[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267686#comment-17267686 ] Alexey Trenikhin commented on FLINK-8093: - Same issue with Flink 1.12 > flink job fail because

[jira] [Reopened] (FLINK-12410) KafkaTopicPartition cannot be used as a POJO type because not all fields are valid POJO fields

[ https://issues.apache.org/jira/browse/FLINK-12410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Trenikhin reopened FLINK-12410: -- The original reporter did not serialize KafkaTopicPartiton, it is Flink Kafka connector

[jira] [Commented] (FLINK-12410) KafkaTopicPartition cannot be used as a POJO type because not all fields are valid POJO fields

[ https://issues.apache.org/jira/browse/FLINK-12410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040182#comment-17040182 ] Alexey Trenikhin commented on FLINK-12410: -- If it is treated as GenericType, then it is

[jira] [Created] (FLINK-11523) TestHarness should provide way to configure TypeSerailizers for side output

Alexey Trenikhin created FLINK-11523: Summary: TestHarness should provide way to configure TypeSerailizers for side output Key: FLINK-11523 URL: https://issues.apache.org/jira/browse/FLINK-11523

[jira] [Updated] (FLINK-10621) BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when running locally

[ https://issues.apache.org/jira/browse/FLINK-10621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Trenikhin updated FLINK-10621: - Attachment: threaddump-1540049768201.tdump >

[jira] [Created] (FLINK-10621) BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when running locally

Alexey Trenikhin created FLINK-10621: Summary: BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when running locally Key: FLINK-10621 URL: https://issues.apache.org/jira/browse/FLINK-10621

[jira] [Updated] (FLINK-10127) Add TypeInformation and serializers for JDK8 Instant

[ https://issues.apache.org/jira/browse/FLINK-10127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Trenikhin updated FLINK-10127: - Description: Currently Flink's basic types include all Java primitives and their boxed

[jira] [Updated] (FLINK-10127) Add TypeInformation and serializers for JDK8 Instant

[ https://issues.apache.org/jira/browse/FLINK-10127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Trenikhin updated FLINK-10127: - Summary: Add TypeInformation and serializers for JDK8 Instant (was: Add

[jira] [Created] (FLINK-10127) Add TypeInformation and serializers for JDK7 Instant

Alexey Trenikhin created FLINK-10127: Summary: Add TypeInformation and serializers for JDK7 Instant Key: FLINK-10127 URL: https://issues.apache.org/jira/browse/FLINK-10127 Project: Flink

[jira] [Commented] (FLINK-8354) Flink Kafka connector ignores Kafka message headers

[ https://issues.apache.org/jira/browse/FLINK-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559157#comment-16559157 ] Alexey Trenikhin commented on FLINK-8354: - In our case we are using Headers to propagate avro