[jira] [Assigned] (FLINK-7602) Create sub tasks for porting the remaining rest handlers

[ https://issues.apache.org/jira/browse/FLINK-7602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7602: -- Assignee: (was: Tzu-Li (Gordon) Tai) > Create sub tasks for porting the rem

[jira] [Assigned] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7648: -- Assignee: (was: Tzu-Li (Gordon) Tai) > Port TaskManagersHandler to new REST

[jira] [Assigned] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7652: -- Assignee: Tzu-Li (Gordon) Tai > Port CurrentJobIdsHandler to new REST endpoint

[jira] [Resolved] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode

[ https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7508. Resolution: Fixed Thanks for the contribution [~phoenixjiangnan]. Resolved for {{ma

[jira] [Closed] (FLINK-7508) switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode rather than Per_Request mode

[ https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7508. -- > switch FlinkKinesisProducer to use KPL's ThreadingMode to ThreadedPool mode > rather than

[jira] [Closed] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception

[ https://issues.apache.org/jira/browse/FLINK-7600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7600. -- > shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to > avoid upd

[jira] [Resolved] (FLINK-7600) shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception

[ https://issues.apache.org/jira/browse/FLINK-7600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7600. Resolution: Fixed Thanks for the contribution! Fixed for {{master}} via 6c1a946562e

[jira] [Commented] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code

[ https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16177962#comment-16177962 ] Tzu-Li (Gordon) Tai commented on FLINK-7673: Yes, it would definitely be nice

[jira] [Comment Edited] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code

[ https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16177962#comment-16177962 ] Tzu-Li (Gordon) Tai edited comment on FLINK-7673 at 9/23/17 8:21 PM: ---

[jira] [Comment Edited] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code

[ https://issues.apache.org/jira/browse/FLINK-7673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16177962#comment-16177962 ] Tzu-Li (Gordon) Tai edited comment on FLINK-7673 at 9/23/17 8:23 PM: ---

[jira] [Resolved] (FLINK-4047) Fix documentation about determinism of KeySelectors

[ https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-4047. Resolution: Fixed Assignee: mingleizhang Thanks for the fix [~mingleizhang].

[jira] [Resolved] (FLINK-7670) typo in docs runtime section

[ https://issues.apache.org/jira/browse/FLINK-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7670. Resolution: Fixed Thanks for the fix Kewei. Fixed in {{release-1.3}} via 9437f7f489

[jira] [Resolved] (FLINK-7654) Update RabbitMQ Java client to 4.x

[ https://issues.apache.org/jira/browse/FLINK-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7654. Resolution: Fixed Thanks for the contribution [~haizhou]! Fixed in {{master}} via b

[jira] [Reopened] (FLINK-7654) Update RabbitMQ Java client to 4.x

[ https://issues.apache.org/jira/browse/FLINK-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-7654: > Update RabbitMQ Java client to 4.x > --- > >

[jira] [Closed] (FLINK-7647) Port JobManagerConfigHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7647. -- > Port JobManagerConfigHandler to new REST endpoint > --

[jira] [Resolved] (FLINK-7654) Update RabbitMQ Java client to 4.x

[ https://issues.apache.org/jira/browse/FLINK-7654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7654. Resolution: Fixed Release Note: The RabbitMQ Java client version used in the Ra

[jira] [Resolved] (FLINK-7647) Port JobManagerConfigHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7647. Resolution: Fixed Merged to {{master}} via 4ba3eecd8fc39af3f1949827b3d73addec77.

[jira] [Resolved] (FLINK-7393) Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest

[ https://issues.apache.org/jira/browse/FLINK-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-7393. Resolution: Fixed Thanks for the work! Merged to {{master}} via ff417e762032b100a74a

[jira] [Closed] (FLINK-7393) Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest

[ https://issues.apache.org/jira/browse/FLINK-7393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-7393. -- > Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to > KinesisConfigUtil

[jira] [Commented] (FLINK-7697) Add metrics for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16182195#comment-16182195 ] Tzu-Li (Gordon) Tai commented on FLINK-7697: +1, we previously had another use

[jira] [Created] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7703: -- Summary: Port JobExceptionsHandler to new REST endpoint Key: FLINK-7703 URL: https://issues.apache.org/jira/browse/FLINK-7703 Project: Flink Issu

[jira] [Updated] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7703: --- Fix Version/s: 1.4.0 > Port JobExceptionsHandler to new REST endpoint > --

[jira] [Updated] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7703: --- Description: Port existing {{JobExceptionsHandler}} to new REST endpoint. > Port JobEx

[jira] [Created] (FLINK-7704) Port JobPlanHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7704: -- Summary: Port JobPlanHandler to new REST endpoint Key: FLINK-7704 URL: https://issues.apache.org/jira/browse/FLINK-7704 Project: Flink Issue Type

[jira] [Updated] (FLINK-7703) Port JobExceptionsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7703: --- Labels: flip-6 (was: ) > Port JobExceptionsHandler to new REST endpoint > ---

[jira] [Created] (FLINK-7705) Port JobDetailsHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7705: -- Summary: Port JobDetailsHandler to new REST endpoint Key: FLINK-7705 URL: https://issues.apache.org/jira/browse/FLINK-7705 Project: Flink Issue T

[jira] [Created] (FLINK-7706) Port JobAccumulatorsHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7706: -- Summary: Port JobAccumulatorsHandler to new REST endpoint Key: FLINK-7706 URL: https://issues.apache.org/jira/browse/FLINK-7706 Project: Flink Is

[jira] [Created] (FLINK-7707) Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7707: -- Summary: Port CheckpointStatsDetailsSubtasksHandler to new REST endpoint Key: FLINK-7707 URL: https://issues.apache.org/jira/browse/FLINK-7707 Project: Fl

[jira] [Created] (FLINK-7708) Port CheckpointConfigHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7708: -- Summary: Port CheckpointConfigHandler to new REST endpoint Key: FLINK-7708 URL: https://issues.apache.org/jira/browse/FLINK-7708 Project: Flink I

[jira] [Created] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7709: -- Summary: Port CheckpointStatsDetailsHandler to new REST endpoint Key: FLINK-7709 URL: https://issues.apache.org/jira/browse/FLINK-7709 Project: Flink

[jira] [Created] (FLINK-7710) Port CheckpointStatsHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7710: -- Summary: Port CheckpointStatsHandler to new REST endpoint Key: FLINK-7710 URL: https://issues.apache.org/jira/browse/FLINK-7710 Project: Flink Is

[jira] [Created] (FLINK-7713) Port JarUploadHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7713: -- Summary: Port JarUploadHandler to new REST endpoint Key: FLINK-7713 URL: https://issues.apache.org/jira/browse/FLINK-7713 Project: Flink Issue Ty

[jira] [Created] (FLINK-7711) Port JarListHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7711: -- Summary: Port JarListHandler to new REST endpoint Key: FLINK-7711 URL: https://issues.apache.org/jira/browse/FLINK-7711 Project: Flink Issue Type

[jira] [Created] (FLINK-7714) Port JarPlanHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7714: -- Summary: Port JarPlanHandler to new REST endpoint Key: FLINK-7714 URL: https://issues.apache.org/jira/browse/FLINK-7714 Project: Flink Issue Type

[jira] [Created] (FLINK-7712) Port JarDeleteHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7712: -- Summary: Port JarDeleteHandler to new REST endpoint Key: FLINK-7712 URL: https://issues.apache.org/jira/browse/FLINK-7712 Project: Flink Issue Ty

[jira] [Created] (FLINK-7717) Port TaskManagerMetricsHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7717: -- Summary: Port TaskManagerMetricsHandler to new REST endpoint Key: FLINK-7717 URL: https://issues.apache.org/jira/browse/FLINK-7717 Project: Flink

[jira] [Created] (FLINK-7718) Port JobVertixMetricsHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7718: -- Summary: Port JobVertixMetricsHandler to new REST endpoint Key: FLINK-7718 URL: https://issues.apache.org/jira/browse/FLINK-7718 Project: Flink I

[jira] [Created] (FLINK-7715) Port JarRunHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7715: -- Summary: Port JarRunHandler to new REST endpoint Key: FLINK-7715 URL: https://issues.apache.org/jira/browse/FLINK-7715 Project: Flink Issue Type:

[jira] [Created] (FLINK-7716) Port JobManagerMetricsHandler to new REST endpoint

Tzu-Li (Gordon) Tai created FLINK-7716: -- Summary: Port JobManagerMetricsHandler to new REST endpoint Key: FLINK-7716 URL: https://issues.apache.org/jira/browse/FLINK-7716 Project: Flink

[jira] [Assigned] (FLINK-7715) Port JarRunHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7715: -- Assignee: Tzu-Li (Gordon) Tai > Port JarRunHandler to new REST endpoint > -

[jira] [Assigned] (FLINK-7712) Port JarDeleteHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7712: -- Assignee: Tzu-Li (Gordon) Tai > Port JarDeleteHandler to new REST endpoint > --

[jira] [Assigned] (FLINK-7714) Port JarPlanHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7714: -- Assignee: Tzu-Li (Gordon) Tai > Port JarPlanHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7711) Port JarListHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7711: -- Assignee: Tzu-Li (Gordon) Tai > Port JarListHandler to new REST endpoint >

[jira] [Assigned] (FLINK-7713) Port JarUploadHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7713: -- Assignee: Tzu-Li (Gordon) Tai > Port JarUploadHandler to new REST endpoint > --

[jira] [Created] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels

Tzu-Li (Gordon) Tai created FLINK-7721: -- Summary: StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels Key: FLINK-7721 URL: https://issues.apache.org/jira/bro

[jira] [Created] (FLINK-7728) StatusWatermarkValve has different min watermark advancement behavior depending on the ordering inputs become idle

Tzu-Li (Gordon) Tai created FLINK-7728: -- Summary: StatusWatermarkValve has different min watermark advancement behavior depending on the ordering inputs become idle Key: FLINK-7728 URL: https://issues.apache.

[jira] [Updated] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels

[ https://issues.apache.org/jira/browse/FLINK-7721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7721: --- Component/s: DataStream API > StatusWatermarkValve should output a new min watermark o

[jira] [Commented] (FLINK-7714) Port JarPlanHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199863#comment-16199863 ] Tzu-Li (Gordon) Tai commented on FLINK-7714: Hi [~till.rohrmann], my work on t

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16199865#comment-16199865 ] Tzu-Li (Gordon) Tai commented on FLINK-7711: Hi [~till.rohrmann], my work on t

[jira] [Assigned] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-5704: -- Assignee: Tzu-Li (Gordon) Tai > Deprecate FlinkKafkaConsumer constructors in fa

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

[ https://issues.apache.org/jira/browse/FLINK-7637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208993#comment-16208993 ] Tzu-Li (Gordon) Tai commented on FLINK-7637: Yes. > FlinkKinesisProducer viol

[jira] [Commented] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks

[ https://issues.apache.org/jira/browse/FLINK-5015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209119#comment-16209119 ] Tzu-Li (Gordon) Tai commented on FLINK-5015: Yes, have a branch almost ready f

[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=16209122#comment-16209122 ] Tzu-Li (Gordon) Tai commented on FLINK-6944: [~till.rohrmann] I agree. Have di

[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: --- Fix Version/s: (was: 1.4.0) 1.5.0 > Introduce DefaultTypeSerial

[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=16212384#comment-16212384 ] Tzu-Li (Gordon) Tai commented on FLINK-6951: I'll try to reproduce the issue o

[jira] [Resolved] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information

[ https://issues.apache.org/jira/browse/FLINK-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9377. Resolution: Fixed Merged to master (for 1.7.0): ac74a0ce6297ce3754744ceb07107f6024c

[jira] [Resolved] (FLINK-10361) Elasticsearch (v6.3.1) sink end-to-end test instable

[ https://issues.apache.org/jira/browse/FLINK-10361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-10361. - Resolution: Fixed Merged. 1.6.0: da03a2c49ecb60dc5d52a28ae0e59ccbc9247573 1.7.0

[jira] [Resolved] (FLINK-10316) Kinesalite bug fix (FLINK-9402) doesn't fully fix the problem.

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

[jira] [Resolved] (FLINK-9618) NullPointerException in FlinkKinesisProducer when aws.region is not set and aws.endpoint is set

[ https://issues.apache.org/jira/browse/FLINK-9618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9618. Resolution: Duplicate This has been fixed by FLINK-10316. > NullPointerException i

[jira] [Resolved] (FLINK-8936) Provide only AWS region or endpoint in line with the SDK

[ https://issues.apache.org/jira/browse/FLINK-8936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-8936. Resolution: Duplicate This has been fixed by FLINK-10316. > Provide only AWS regio

[jira] [Commented] (FLINK-7931) FlinkKinesisProducer violates at-least-once guarantees (1.3 branch)

[ https://issues.apache.org/jira/browse/FLINK-7931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16654956#comment-16654956 ] Tzu-Li (Gordon) Tai commented on FLINK-7931: [~till.rohrmann] I think it was

[jira] [Assigned] (FLINK-10605) Upgrade AvroSerializer snapshot to implement new TypeSerializerSnapshot interface

[ https://issues.apache.org/jira/browse/FLINK-10605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-10605: --- Assignee: Igal Shilman > Upgrade AvroSerializer snapshot to implement new T

[jira] [Closed] (FLINK-9574) Add a dedicated documentation page for state evolution

[ https://issues.apache.org/jira/browse/FLINK-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-9574. -- Resolution: Fixed Merged. master: 9df52f21cd27405b670b96c942004585b3d9f6a0 release-1.7

[jira] [Updated] (FLINK-9574) Add a dedicated documentation page for state evolution

[ https://issues.apache.org/jira/browse/FLINK-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9574: --- Fix Version/s: (was: 1.8.0) 1.7.0 > Add a dedicated documentat

[jira] [Reopened] (FLINK-9574) Add a dedicated documentation page for state evolution

[ https://issues.apache.org/jira/browse/FLINK-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-9574: > Add a dedicated documentation page for state evolution >

[jira] [Closed] (FLINK-9574) Add a dedicated documentation page for state evolution

[ https://issues.apache.org/jira/browse/FLINK-9574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-9574. -- Resolution: Fixed > Add a dedicated documentation page for state evolution > --

[jira] [Closed] (FLINK-9376) Allow upgrading to incompatible state serializers (state schema evolution)

[ https://issues.apache.org/jira/browse/FLINK-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-9376. -- Resolution: Fixed Fix Version/s: 1.7.0 Release Note: Before Flink 1.7, seri

[jira] [Updated] (FLINK-9376) Allow upgrading to incompatible state serializers (state schema evolution)

[ https://issues.apache.org/jira/browse/FLINK-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9376: --- Release Note: Before Flink 1.7, serializer snapshots were implemented as a `TypeSeri

[jira] [Closed] (FLINK-9376) Allow upgrading to incompatible state serializers (state schema evolution)

[ https://issues.apache.org/jira/browse/FLINK-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-9376. -- Resolution: Fixed > Allow upgrading to incompatible state serializers (state schema evo

[jira] [Reopened] (FLINK-9376) Allow upgrading to incompatible state serializers (state schema evolution)

[ https://issues.apache.org/jira/browse/FLINK-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reopened FLINK-9376: > Allow upgrading to incompatible state serializers (state schema evolution) >

[jira] [Closed] (FLINK-10798) Add the version number of Flink 1.7 to MigrationVersion

[ https://issues.apache.org/jira/browse/FLINK-10798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-10798. --- Resolution: Fixed Merged to master for 1.8.0: f08adb721d1a4b373ef328529313443f4af923

[jira] [Commented] (FLINK-10776) Update migration tests for Flink 1.7

[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706678#comment-16706678 ] Tzu-Li (Gordon) Tai commented on FLINK-10776: - [~yanghua] I've merged FLINK-

[jira] [Comment Edited] (FLINK-10776) Update migration tests for Flink 1.7

[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706678#comment-16706678 ] Tzu-Li (Gordon) Tai edited comment on FLINK-10776 at 12/3/18 5:30 AM:

[jira] [Updated] (FLINK-10798) Add the version number of Flink 1.7 to MigrationVersion

[ https://issues.apache.org/jira/browse/FLINK-10798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10798: Fix Version/s: 1.8.0 > Add the version number of Flink 1.7 to MigrationVersion > -

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708337#comment-16708337 ] Tzu-Li (Gordon) Tai commented on FLINK-11046: - Hi [~luoguohao], So, to clar

[jira] [Created] (FLINK-11073) Make serializers immutable / provide option TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer

Tzu-Li (Gordon) Tai created FLINK-11073: --- Summary: Make serializers immutable / provide option TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer Key: FLINK-11073 URL: https://issues.apac

[jira] [Created] (FLINK-11075) Remove redundant code path in CompatibilityUtil

Tzu-Li (Gordon) Tai created FLINK-11075: --- Summary: Remove redundant code path in CompatibilityUtil Key: FLINK-11075 URL: https://issues.apache.org/jira/browse/FLINK-11075 Project: Flink

[jira] [Updated] (FLINK-11075) Remove redundant code path in CompatibilityUtil

[ https://issues.apache.org/jira/browse/FLINK-11075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11075: Description: In {{CompatibilityUtil#resolveCompatibilityResult}}: {code} Compati

[jira] [Updated] (FLINK-11075) Remove redundant code path in CompatibilityUtil

[ https://issues.apache.org/jira/browse/FLINK-11075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11075: Description: In {{CompatibilityUtil#resolveCompatibilityResult}}: {code:java} Comp

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711495#comment-16711495 ] Tzu-Li (Gordon) Tai commented on FLINK-11087: - I checked the key / value ser

[jira] [Comment Edited] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711511#comment-16711511 ] Tzu-Li (Gordon) Tai edited comment on FLINK-11087 at 12/6/18 2:35 PM:

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711511#comment-16711511 ] Tzu-Li (Gordon) Tai commented on FLINK-11087: - I'm currently modifying the {

[jira] [Assigned] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-11087: --- Assignee: Tzu-Li (Gordon) Tai > Broadcast state migration Incompatibility f

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711635#comment-16711635 ] Tzu-Li (Gordon) Tai commented on FLINK-11087: - Confirmed, this is indeed a b

[jira] [Comment Edited] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711635#comment-16711635 ] Tzu-Li (Gordon) Tai edited comment on FLINK-11087 at 12/6/18 4:06 PM:

[jira] [Updated] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11087: Fix Version/s: 1.7.1 1.6.3 > Broadcast state migration Incompat

[jira] [Updated] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11087: Priority: Blocker (was: Major) > Broadcast state migration Incompatibility from 1

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711638#comment-16711638 ] Tzu-Li (Gordon) Tai commented on FLINK-11087: - Yes, will do. > Broadcast st

[jira] [Updated] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11087: Affects Version/s: 1.6.2 > Broadcast state migration Incompatibility from 1.5.3 to

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Summary: Restored state in RocksDBStateBackend that has not been accessed in resto

[jira] [Created] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in new execution causes NPE on snapshot

Tzu-Li (Gordon) Tai created FLINK-11094: --- Summary: Restored state in RocksDBStateBackend that has not been accessed in new execution causes NPE on snapshot Key: FLINK-11094 URL: https://issues.apache.org/jir

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in th

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in th

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in th

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in th

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in th

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in th

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in th

[jira] [Updated] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11094: Description: This was caused by changes in FLINK-10679. The problem is that in th

[jira] [Resolved] (FLINK-11094) Restored state in RocksDBStateBackend that has not been accessed in restored execution causes NPE on snapshot

[ https://issues.apache.org/jira/browse/FLINK-11094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-11094. - Resolution: Fixed Merged. 1.8.0 (master): 97f556ebd122dfe16dd8e148d3ac7c5386fd0

<    3   4   5   6   7   8   9   10   11   12   >