[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638123#comment-17638123
]
Durgesh Mishra commented on FLINK-29711:
[~martijnvisser] Yes you are correct w
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637628#comment-17637628
]
Martijn Visser commented on FLINK-29711:
[~durgeshkumarmishragfx] I've verified
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626950#comment-17626950
]
Durgesh Mishra commented on FLINK-29711:
[~mason6345] Not sure that will be iss
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626947#comment-17626947
]
Mason Chen commented on FLINK-29711:
No, the fix is included in 1.17.
That's your i
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626946#comment-17626946
]
Durgesh Mishra commented on FLINK-29711:
[~mason6345] Yes TripSerializer can re
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626939#comment-17626939
]
Mason Chen commented on FLINK-29711:
Yes, I'm wondering about the TripSerializer imp
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626933#comment-17626933
]
Durgesh Mishra commented on FLINK-29711:
[~mason6345] Please find below example
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626127#comment-17626127
]
Mason Chen commented on FLINK-29711:
[~durgeshkumarmishragfx] can you post a minimal
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625746#comment-17625746
]
Durgesh Mishra commented on FLINK-29711:
[~martijnvisser] I checked with micros
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624881#comment-17624881
]
Durgesh Mishra commented on FLINK-29711:
[~mason6345] I added logs in TripSeria
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624591#comment-17624591
]
Mason Chen commented on FLINK-29711:
Can you provide exact details where you added l
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624500#comment-17624500
]
Martijn Visser commented on FLINK-29711:
Is this something that you can make rep
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624467#comment-17624467
]
Durgesh Mishra commented on FLINK-29711:
[~mason6345] I added the logs but didn
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623589#comment-17623589
]
Mason Chen commented on FLINK-29711:
Hi, I did a quick pass over the source code. Ca
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623561#comment-17623561
]
Durgesh Mishra commented on FLINK-29711:
[~martijnvisser] and [~mason6345] Can
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622190#comment-17622190
]
Durgesh Mishra commented on FLINK-29711:
[~martijnvisser] I am using the KafkaDi
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622133#comment-17622133
]
Martijn Visser commented on FLINK-29711:
Which Kafka sink are you using, FlinkKa
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622124#comment-17622124
]
Durgesh Mishra commented on FLINK-29711:
Hello [~martijnvisser] We created one
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622105#comment-17622105
]
Martijn Visser commented on FLINK-29711:
Please add more information to the tick
19 matches
Mail list logo