[
https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100602#comment-17100602
]
颖 commented on FLINK-17438:
---
[~zenfenan] [~lzljs3620320] Problem has been solved, mainly is th
[
https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100492#comment-17100492
]
颖 commented on FLINK-17438:
---
native kafka 0.11 consumption,code :
val topics = sourceKafkaTo
[
https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097163#comment-17097163
]
Sivaprasanna Sethuraman commented on FLINK-17438:
-
If the StringExtracto
[
https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095218#comment-17095218
]
颖 commented on FLINK-17438:
---
[~lzljs3620320] [~zenfenan]Again, no effect
> Flink StreamingFi
[
https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095076#comment-17095076
]
Sivaprasanna Sethuraman commented on FLINK-17438:
-
[~why198852] I agree
[
https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095066#comment-17095066
]
Jingsong Lee commented on FLINK-17438:
--
[~why198852] Have you checked your hive cha
[
https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095065#comment-17095065
]
颖 commented on FLINK-17438:
---
[~zenfenan] I wonder if you have any solution?
> Flink Streaming
[
https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095027#comment-17095027
]
颖 commented on FLINK-17438:
---
[~lzljs3620320] yes,I used this to specify the encoding utf-8, bu
[
https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094434#comment-17094434
]
Sivaprasanna Sethuraman commented on FLINK-17438:
-
I think this is an en
[
https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094432#comment-17094432
]
Jingsong Lee commented on FLINK-17438:
--
Try implement a Extractor:
{code:java}
@
10 matches
Mail list logo