buptljy created FLINK-10239:
---
Summary: Register eventtime timer only once in eventtrigger
Key: FLINK-10239
URL: https://issues.apache.org/jira/browse/FLINK-10239
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-10202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy closed FLINK-10202.
---
Resolution: Fixed
[~StephanEwen] Yes, you're right... It's already fixed...
> Enable configuration for stat
[
https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591288#comment-16591288
]
buptljy commented on FLINK-10206:
-
[~igloo1986] I think we should have a HBaseBatchTable
[
https://issues.apache.org/jira/browse/FLINK-10202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16591188#comment-16591188
]
buptljy commented on FLINK-10202:
-
[~StephanEwen] Here is my code. I think the checkpoin
[
https://issues.apache.org/jira/browse/FLINK-10202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy updated FLINK-10202:
Description:
Usually we can set state.checkpoint.dir in flink-conf.yaml, but sometimes we
run a flink job
[
https://issues.apache.org/jira/browse/FLINK-10202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy updated FLINK-10202:
Summary: Enable configuration for state.checkpoint.dir in
StreamExecutionEnvironment (was: Enable configu
[
https://issues.apache.org/jira/browse/FLINK-10202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy updated FLINK-10202:
Description:
Usually we can set state.checkpoint.dir in flink-conf.yaml, but sometimes we
run a flink job
[
https://issues.apache.org/jira/browse/FLINK-10202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy updated FLINK-10202:
Summary: Enable configuration for state.checkpoint.dir in environment
(was: Enable configuration for stat
buptljy created FLINK-10202:
---
Summary: Enable configuration for state.checkpoint.dir with
environment
Key: FLINK-10202
URL: https://issues.apache.org/jira/browse/FLINK-10202
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-10170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy updated FLINK-10170:
Comment: was deleted
(was: I think this is duplicated by FLINK-10120, can you help implement the
same thi
[
https://issues.apache.org/jira/browse/FLINK-10170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16585210#comment-16585210
]
buptljy commented on FLINK-10170:
-
I think this duplicates FLINK-10120, can you help imp
[
https://issues.apache.org/jira/browse/FLINK-10170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16585204#comment-16585204
]
buptljy commented on FLINK-10170:
-
I think this is duplicated by FLINK-10120, can you he
[
https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16585121#comment-16585121
]
buptljy commented on FLINK-10168:
-
[~phoenixjiangnan] You're right. The second solution
[
https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16584675#comment-16584675
]
buptljy commented on FLINK-10168:
-
[~phoenixjiangnan] Thanks! I think this will be a goo
[
https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-10168:
---
Assignee: buptljy
> support filtering files by modified/created time in
> StreamExecutionEnvironme
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16582731#comment-16582731
]
buptljy commented on FLINK-10119:
-
[~twalthr] Your suggestion sounds good to me. Can you
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579779#comment-16579779
]
buptljy edited comment on FLINK-10119 at 8/16/18 9:55 AM:
--
[~tw
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579779#comment-16579779
]
buptljy edited comment on FLINK-10119 at 8/16/18 7:43 AM:
--
[~tw
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579779#comment-16579779
]
buptljy commented on FLINK-10119:
-
[~twalthr] Okay, I am going to add two optional prope
[
https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577877#comment-16577877
]
buptljy commented on FLINK-10126:
-
[~yanghua] Ok, it makes sense to me.
> There should
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577862#comment-16577862
]
buptljy commented on FLINK-9964:
[~twalthr] Could you review my PR ?
> Add a CSV table f
buptljy created FLINK-10128:
---
Summary: Timeout on transfering jars on travis-ci
Key: FLINK-10128
URL: https://issues.apache.org/jira/browse/FLINK-10128
Project: Flink
Issue Type: Bug
Comp
[
https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577785#comment-16577785
]
buptljy commented on FLINK-10126:
-
[~yanghua] Hi, I'm interested in how you're going to
[
https://issues.apache.org/jira/browse/FLINK-10120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-10120:
---
Assignee: buptljy
> Support string representation for types like array
> --
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16577448#comment-16577448
]
buptljy commented on FLINK-10119:
-
[~twalthr] I can help to do this.
You mean add an ad
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-10119:
---
Assignee: buptljy
> JsonRowDeserializationSchema deserialize kafka message
> --
[
https://issues.apache.org/jira/browse/FLINK-10120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575975#comment-16575975
]
buptljy commented on FLINK-10120:
-
[~fhueske] Sorry, the description before was a bit co
[
https://issues.apache.org/jira/browse/FLINK-10120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy updated FLINK-10120:
Description:
In TypeStringUtils.readTypeInfo:
{code:java}
case _: BasicArrayTypeInfo[_, _] | _: Object
buptljy created FLINK-10120:
---
Summary: Support string representation for types like array
Key: FLINK-10120
URL: https://issues.apache.org/jira/browse/FLINK-10120
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574750#comment-16574750
]
buptljy commented on FLINK-9964:
[~twalthr] I mean the json schema of a csv format data.
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574323#comment-16574323
]
buptljy commented on FLINK-9964:
[~twalthr] Should we support json schema for csv format?
[
https://issues.apache.org/jira/browse/FLINK-10039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567834#comment-16567834
]
buptljy commented on FLINK-10039:
-
I think only ByteArrayDeserializer is supported accor
[
https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567721#comment-16567721
]
buptljy edited comment on FLINK-10036 at 8/3/18 3:39 AM:
-
This i
[
https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567721#comment-16567721
]
buptljy commented on FLINK-10036:
-
This is very similar to this
[JIRA](https://issues.a
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16559502#comment-16559502
]
buptljy edited comment on FLINK-9964 at 7/27/18 9:50 AM:
-
[~twalt
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16559502#comment-16559502
]
buptljy commented on FLINK-9964:
[~twalthr] I've tried some tests on the Jackson library,
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16559381#comment-16559381
]
buptljy commented on FLINK-9964:
[~twalthr] Thank you for your description above, it alre
[
https://issues.apache.org/jira/browse/FLINK-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-9966:
--
Assignee: buptljy
> Add a ORC table factory
> ---
>
> Key: FLINK-9
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-9964:
--
Assignee: buptljy
> Add a CSV table format factory
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555175#comment-16555175
]
buptljy commented on FLINK-9941:
[~lemonjing] You're right. I'll fix it.
> Flush in Scal
[
https://issues.apache.org/jira/browse/FLINK-9941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-9941:
--
Assignee: buptljy
> Flush in ScalaCsvOutputFormat before close method
> --
[
https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555165#comment-16555165
]
buptljy commented on FLINK-6935:
I am very interested in the CEP part. And my team is exp
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-6938:
--
Assignee: Jark Wu (was: buptljy)
> IterativeCondition should support RichFunction interface
> ---
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-6938:
--
Assignee: buptljy (was: Jark Wu)
> IterativeCondition should support RichFunction interface
> ---
[
https://issues.apache.org/jira/browse/FLINK-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy closed FLINK-9834.
--
Resolution: Won't Do
> Unable to support scala BasicArrayTypeInfo
> --
[
https://issues.apache.org/jira/browse/FLINK-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16555157#comment-16555157
]
buptljy commented on FLINK-9834:
It seems that we can use _*implicitly[TypeInformation[Ar
[
https://issues.apache.org/jira/browse/FLINK-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16554185#comment-16554185
]
buptljy commented on FLINK-9834:
[~aljoscha]
I think we should implement the *_createSer
[
https://issues.apache.org/jira/browse/FLINK-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-9834:
--
Assignee: buptljy
> Unable to support scala BasicArrayTypeInfo
> -
[
https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16551722#comment-16551722
]
buptljy commented on FLINK-7205:
[~fhueske]
I find that we cannot test _*UUID*_ function
[
https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16551569#comment-16551569
]
buptljy commented on FLINK-7205:
We can use java.util.UUID(also use RFC 4122) to implemen
[
https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-7205:
--
Assignee: buptljy
> Add UUID supported in TableAPI/SQL
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546071#comment-16546071
]
buptljy edited comment on FLINK-6895 at 7/18/18 6:13 AM:
-
[~twalt
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546071#comment-16546071
]
buptljy edited comment on FLINK-6895 at 7/17/18 6:10 AM:
-
[~twalt
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16546071#comment-16546071
]
buptljy commented on FLINK-6895:
[~twalthr]
I think we can use "isOperandLiteral" functio
buptljy created FLINK-9834:
--
Summary: Unable to support scala BasicArrayTypeInfo
Key: FLINK-9834
URL: https://issues.apache.org/jira/browse/FLINK-9834
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16530933#comment-16530933
]
buptljy commented on FLINK-9178:
[~tzulitai] I'd like to add something about this issue,
[
https://issues.apache.org/jira/browse/FLINK-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16509099#comment-16509099
]
buptljy commented on FLINK-7554:
[~twalthr] Can you help review my PR ?
> Add a testing
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16455677#comment-16455677
]
buptljy commented on FLINK-9178:
[~app-tarush] I think so, and there is another option is
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453686#comment-16453686
]
buptljy edited comment on FLINK-9178 at 4/26/18 8:46 AM:
-
[~app-ta
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16453686#comment-16453686
]
buptljy commented on FLINK-9178:
[~app-tarush] Of course. Thanks !
> Add rate control for
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16443563#comment-16443563
]
buptljy commented on FLINK-8785:
[~Zentol] Can you help review my PR ?
> JobSubmitHandler
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-6895:
--
Assignee: buptljy (was: Aegeaner)
> Add STR_TO_DATE supported in SQL
> ---
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy updated FLINK-9178:
---
Description:
When I want to run the flink program from the earliest offset in Kafka, it'll
be very easy to ca
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16442918#comment-16442918
]
buptljy commented on FLINK-9178:
[~till.rohrmann] Do you have ideas about this issue ? May
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
buptljy reassigned FLINK-8785:
--
Assignee: buptljy
> JobSubmitHandler does not handle JobSubmissionExceptions
>
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16441047#comment-16441047
]
buptljy commented on FLINK-8785:
[~Zentol]
Okay, I've already known how to do this. I wi
buptljy created FLINK-9178:
--
Summary: Add rate control for kafka source
Key: FLINK-9178
URL: https://issues.apache.org/jira/browse/FLINK-9178
Project: Flink
Issue Type: Improvement
Compone
[
https://issues.apache.org/jira/browse/FLINK-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16428541#comment-16428541
]
buptljy commented on FLINK-7554:
[~twalthr] I find that it seems to be a bit harder for te
68 matches
Mail list logo
