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 configurat
[
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
[
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
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
[
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 t
[
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. ignore
[
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 Sc
[
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 fact
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
[
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 ar
[
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 mess
[
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
[
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
[JIRA](https://issues.apache.org/jira
[
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
[
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
> ---
>
>
[
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 fact
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/6412
Duplicate. Close.
---
Github user buptljy closed the pull request at:
https://github.com/apache/flink/pull/6412
---
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/6412
[FLINK-9941] Flush in ScalaCsvOutputFormat before close
## What is the purpose of the change
- Flush in ScalaCsvOutputFormat before close.We've already finished
[
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 ScalaCsvOutputFor
[
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 met
[
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
[
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 interf
[
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 interf
[
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 BasicArrayTypeI
[
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
[
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_
[
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 BasicArrayTypeI
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/6381
[FLINK-7205] [table]Add UUID supported in SQL and TableApi
## What is the purpose of the change
* Add UUID supported in SQL and TableApi.
## Brief change log
* Add UUID function
[
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
[
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
[
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/
Github user buptljy commented on a diff in the pull request:
https://github.com/apache/flink/pull/6359#discussion_r203268495
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/StrToDateCallGen.scala
---
@@ -0,0 +1,45
[
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
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5628
Submit another [Pull Request](https://github.com/apache/flink/pull/6359)
according to the discussion in FLINK-6895.
---
Github user buptljy closed the pull request at:
https://github.com/apache/flink/pull/5628
---
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/6359
[FLINK-6895][table]Add STR_TO_DATE supported in SQL
## What is the purpose of the change
Add STR_TO_DATE Function supported in SQL
## Brief change log
* STR_TO_DATE(str string, format
[
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"
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5628
@twalthr
Sorry for late reply here.
This can be closed now, and I'll submit another PR this week.
I've posted my solution in FLINK-6895, we can have a discussion there.
---
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
Github user buptljy closed the pull request at:
https://github.com/apache/flink/pull/5877
---
[
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 RuntimeCont
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/6148
[FLINK-7554][Tests] Add a testing RuntimeContext to test utilities
## What is the purpose of the change
This pull request adds a TestingRuntimeContext to help developers test
their own user
[
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
[
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 sou
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5877
@zentol ok, I thought that it was a small change before, so you mean we
can make more changes on the messages of the exceptions and let them reported
more properly ?
I will test all the cases
[
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 han
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/5877
[FLINK-8785][Job-Submission]Handle JobSubmissionExceptions
## What is the purpose of the change
We will get an "Internal server error" exception if we submit
[
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
[
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
[
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
[
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 JobSubmissionExcepti
[
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
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
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5638
@walterddr What else should I do for this PR ?
---
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5638
@walterddr As explained in
[FLINK-8930](https://issues.apache.org/jira/browse/FLINK-8930), the reason that
"LOG(-1)" and "LOG(1, 100)" succeed is that they're simplified in c
Github user buptljy commented on a diff in the pull request:
https://github.com/apache/flink/pull/5638#discussion_r173897783
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/expressionDsl.scala
---
@@ -1130,4 +1130,13 @@ object concat_ws
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5638
@walterddr I'm not able to add a validation test because I am blocked by
[FLINK-8930](https://issues.apache.org/jira/browse/FLINK-8930).
---
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5638
@suez1224 Docs are added in both java and scala.
---
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/5638
[FLINK-6924][table]ADD LOG(X) supported in TableAPI
## What is the purpose of the change
* Add LOG(X) function in TableAPI.
## Brief change log
* Add LOG(X) function in TableAPI
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5628
Actually I am not sure if it is appropriate to return "string" because it
should be the inverse of the "DATE_FORMAT()". However, If I return
DATE/TIME/DATETIME as the jira issue
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/5628
[FLINK-6895][table]Add STR_TO_DATE supported in SQL
## What is the purpose of the change
Add STR_TO_DATE Function supported in SQL
## Brief change log
* STR_TO_DATE(str string, format
Github user buptljy closed the pull request at:
https://github.com/apache/flink/pull/5618
---
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/5618
[FLINK-6895][table]Add STR_TO_DATE supported in SQL
## What is the purpose of the change
Add STR_TO_DATE Function supported in SQL
## Brief change log
* STR_TO_DATE(str string, format
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5618
Actually I am not sure if it is appropriate to return "string" because it
should be the inverse of the "DATE_FORMAT()". However, If I return
DATE/TIME/DATETIME as the jira issue
Github user buptljy closed the pull request at:
https://github.com/apache/flink/pull/5615
---
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5615
Actually I am not sure if it is appropriate to return "string" because it
should be the inverse of the "DATE_FORMAT()". However, If I return
DATE/TIME/DATETIME as the jira issue
GitHub user buptljy opened a pull request:
https://github.com/apache/flink/pull/5615
[FLINK-6895][table]Add STR_TO_DATE supported in SQL
## What is the purpose of the change
Add STR_TO_DATE Function supported in SQL
## Brief change log
* STR_TO_DATE(str string, format
95 matches
Mail list logo
