[jira] [Created] (FLINK-5399) Add more information to checkpoint result of TriggerSavepointSuccess

[shijinkui (JIRA)]

shijinkui created FLINK-5399:


 Summary: Add more information to checkpoint result of 
TriggerSavepointSuccess
 Key: FLINK-5399
 URL: https://issues.apache.org/jira/browse/FLINK-5399
 Project: Flink
  Issue Type: Improvement
  Components: State Backends, Checkpointing
Reporter: shijinkui


Add checkpointId and triggerTime to TriggerSavepointSuccess

We can record the history of trigger checkpoint out of Flink System.





--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-5398) Exclude generated files in module flink-batch-connectors in license checking

[Xiaogang Shi (JIRA)]

Xiaogang Shi created FLINK-5398:
---

 Summary: Exclude generated files in module flink-batch-connectors 
in license checking
 Key: FLINK-5398
 URL: https://issues.apache.org/jira/browse/FLINK-5398
 Project: Flink
  Issue Type: Bug
Reporter: Xiaogang Shi


Now the master branch fails to execute {{mvn install}} due to unlicensed files 
in the module flink-batch-connectors. We should exclude these generated files 
in the pom file.

Unapproved licenses:

  
flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/io/avro/generated/Address.java
  
flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/io/avro/generated/Colors.java
  
flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/io/avro/generated/Fixed16.java
  
flink-batch-connectors/flink-avro/src/test/java/org/apache/flink/api/io/avro/generated/User.java



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[jira] [Created] (FLINK-5397) Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors

[Xiaogang Shi (JIRA)]

Xiaogang Shi created FLINK-5397:
---

 Summary: Fail to deserialize savepoints in v1.1 when there exist 
missing fields in class serialization descriptors
 Key: FLINK-5397
 URL: https://issues.apache.org/jira/browse/FLINK-5397
 Project: Flink
  Issue Type: Bug
  Components: State Backends, Checkpointing
Reporter: Xiaogang Shi


To restore from the savepoints in previous versions, Flink now keeps all 
classes whose serialization is changed and put them in a separated package 
("migration"). 

When deserializing the old savepoints, flink will look up correct descriptors 
({{ObjectStreamClass}}) for these classes, without using those ones written in 
serialized data. The implementation however is problematic when there exist 
missing field descriptors in the serialized data. 

When deserializing an object, Java will only write the descriptors of those 
non-null fields. But when we look up class descriptors with given classes, all 
fields will be put into the descriptors. As a result, we will deserialize the 
savepoints with incorrect descriptors, leading to serialization exceptions.

A simple resolution is to update the name of read descriptors using 
Reflections, without using a different descriptors.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

[FLINK-3615] Add support for non-native SQL types

[Alexander Chermenin]

Hi all.

Is FLINK-3615  an actual
issue now? Or it has been solved in FLINK-3916
?

Regards,
Alex