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:
[
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
[
https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591288#comment-16591288
]
buptljy commented on FLINK-10206:
-
[~igloo1986] I think we should have a HBaseBatchTableSink first? From
[
https://issues.apache.org/jira/browse/FLINK-10202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16591188#comment-16591188
]
buptljy commented on FLINK-10202:
-
[~StephanEwen] Here is my code. I think the checkpoint directory in
[
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
[
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
[
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
[
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-10170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585210#comment-16585210
]
buptljy commented on FLINK-10170:
-
I think this duplicates FLINK-10120, can you help implement the same
[
https://issues.apache.org/jira/browse/FLINK-10170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585204#comment-16585204
]
buptljy commented on FLINK-10170:
-
I think this is duplicated by FLINK-10120, can you help implement the
[
https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585121#comment-16585121
]
buptljy commented on FLINK-10168:
-
[~phoenixjiangnan] You're right. The second solution makes more sense
[
https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584675#comment-16584675
]
buptljy commented on FLINK-10168:
-
[~phoenixjiangnan] Thanks! I think this will be a good improvement.
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582731#comment-16582731
]
buptljy commented on FLINK-10119:
-
[~twalthr] Your suggestion sounds good to me. Can you review my PR?
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579779#comment-16579779
]
buptljy edited comment on FLINK-10119 at 8/16/18 9:55 AM:
--
[~twalthr]
So I am
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579779#comment-16579779
]
buptljy edited comment on FLINK-10119 at 8/16/18 7:43 AM:
--
[~twalthr] I don't
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579779#comment-16579779
]
buptljy commented on FLINK-10119:
-
[~twalthr] Okay, I am going to add two optional properties.
1.
[
https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577877#comment-16577877
]
buptljy commented on FLINK-10126:
-
[~yanghua] Ok, it makes sense to me.
> There should be a Scala
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577862#comment-16577862
]
buptljy commented on FLINK-9964:
[~twalthr] Could you review my PR ?
> Add a CSV table format factory
>
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
[
https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16577785#comment-16577785
]
buptljy commented on FLINK-10126:
-
[~yanghua] Hi, I'm interested in how you're going to improve this.
[
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=16577448#comment-16577448
]
buptljy commented on FLINK-10119:
-
[~twalthr] I can help to do this.
You mean add an additional field
[
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=16575975#comment-16575975
]
buptljy commented on FLINK-10120:
-
[~fhueske] Sorry, the description before was a bit confusing, I've
[
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[_, _] | _:
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:
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574750#comment-16574750
]
buptljy commented on FLINK-9964:
[~twalthr] I mean the json schema of a csv format data. For example, I
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574323#comment-16574323
]
buptljy commented on FLINK-9964:
[~twalthr] Should we support json schema for csv format?
If json schema
[
https://issues.apache.org/jira/browse/FLINK-10039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567834#comment-16567834
]
buptljy commented on FLINK-10039:
-
I think only ByteArrayDeserializer is supported according to
[
https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567721#comment-16567721
]
buptljy edited comment on FLINK-10036 at 8/3/18 3:39 AM:
-
This is very similar
[
https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567721#comment-16567721
]
buptljy commented on FLINK-10036:
-
This is very similar to this
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559502#comment-16559502
]
buptljy edited comment on FLINK-9964 at 7/27/18 9:50 AM:
-
[~twalthr] I've tried
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559502#comment-16559502
]
buptljy commented on FLINK-9964:
[~twalthr] I've tried some tests on the Jackson library, and it looks
[
https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16559381#comment-16559381
]
buptljy commented on FLINK-9964:
[~twalthr] Thank you for your description above, it already helps me a
[
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:
[
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=16555175#comment-16555175
]
buptljy commented on FLINK-9941:
[~lemonjing] You're right. I'll fix it.
> Flush in ScalaCsvOutputFormat
[
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=16555165#comment-16555165
]
buptljy commented on FLINK-6935:
I am very interested in the CEP part. And my team is exploring this
[
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=16555157#comment-16555157
]
buptljy commented on FLINK-9834:
It seems that we can use _*implicitly[TypeInformation[Array[Byte]]]*_ to
[
https://issues.apache.org/jira/browse/FLINK-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554185#comment-16554185
]
buptljy commented on FLINK-9834:
[~aljoscha]
I think we should implement the *_createSerializer_* in
[
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=16551722#comment-16551722
]
buptljy commented on FLINK-7205:
[~fhueske]
I find that we cannot test _*UUID*_ function in
[
https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551569#comment-16551569
]
buptljy commented on FLINK-7205:
We can use java.util.UUID(also use RFC 4122) to implement this.
>
[
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=16546071#comment-16546071
]
buptljy edited comment on FLINK-6895 at 7/18/18 6:13 AM:
-
[~twalthr]
I've submit
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546071#comment-16546071
]
buptljy edited comment on FLINK-6895 at 7/17/18 6:10 AM:
-
[~twalthr]
I think we
[
https://issues.apache.org/jira/browse/FLINK-6895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16546071#comment-16546071
]
buptljy commented on FLINK-6895:
[~twalthr]
I think we can use "isOperandLiteral" function in
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
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530933#comment-16530933
]
buptljy commented on FLINK-9178:
[~tzulitai] I'd like to add something about this issue, whick is very
[
https://issues.apache.org/jira/browse/FLINK-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16509099#comment-16509099
]
buptljy commented on FLINK-7554:
[~twalthr] Can you help review my PR ?
> Add a testing RuntimeContext
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16455677#comment-16455677
]
buptljy commented on FLINK-9178:
[~app-tarush] I think so, and there is another option is using the
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16453686#comment-16453686
]
buptljy edited comment on FLINK-9178 at 4/26/18 8:46 AM:
-
[~app-tarush] It seems
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16453686#comment-16453686
]
buptljy commented on FLINK-9178:
[~app-tarush] Of course. Thanks !
> Add rate control for kafka source
>
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443563#comment-16443563
]
buptljy commented on FLINK-8785:
[~Zentol] Can you help review my PR ?
> JobSubmitHandler does not handle
[
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
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442918#comment-16442918
]
buptljy commented on FLINK-9178:
[~till.rohrmann] Do you have ideas about this issue ? Maybe it can be a
[
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=16441047#comment-16441047
]
buptljy commented on FLINK-8785:
[~Zentol]
Okay, I've already known how to do this. I will assign this
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
[
https://issues.apache.org/jira/browse/FLINK-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16428541#comment-16428541
]
buptljy commented on FLINK-7554:
[~twalthr] I find that it seems to be a bit harder for testing streaming
68 matches
Mail list logo
