Q Kang created FLINK-25730:
--
Summary: Fix chaining strategy (and typo?) in
RowTimeMiniBatchAssginerOperator
Key: FLINK-25730
URL: https://issues.apache.org/jira/browse/FLINK-25730
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Q Kang updated FLINK-25614:
---
Fix Version/s: 1.15.0
Issue Type: Bug (was: Improvement)
> Let LocalWindowAggregate be chained with
[
https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478706#comment-17478706
]
Q Kang commented on FLINK-25614:
[~MartijnVisser] I have fixed other `getLong`s in `Slic
[
https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17478347#comment-17478347
]
Q Kang commented on FLINK-25614:
[~jingzhang] Sorry for the late response. [~wenlong.lwl
[
https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475897#comment-17475897
]
Q Kang commented on FLINK-25614:
Hi [~wenlong.lwl] , I have fixed `SlicingWindowAggOpera
[
https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17473245#comment-17473245
]
Q Kang edited comment on FLINK-25614 at 1/12/22, 2:23 AM:
--
The
[
https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17473245#comment-17473245
]
Q Kang commented on FLINK-25614:
The original intention of this change is to eliminate s
Q Kang created FLINK-25614:
--
Summary: Let LocalWindowAggregate be chained with upstream
Key: FLINK-25614
URL: https://issues.apache.org/jira/browse/FLINK-25614
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-21573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451493#comment-17451493
]
Q Kang commented on FLINK-21573:
Hi [~godfreyhe] [~lzljs3620320] , I've come up with a s
[
https://issues.apache.org/jira/browse/FLINK-23721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405782#comment-17405782
]
Q Kang commented on FLINK-23721:
[~yunta] [~jark]
According to my observation, there a
[
https://issues.apache.org/jira/browse/FLINK-23721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405637#comment-17405637
]
Q Kang commented on FLINK-23721:
[~yunta] Sorry for the late reply. For RocksDB backend,
Q Kang created FLINK-23721:
--
Summary: Flink SQL state TTL has no effect when using
non-incremental RocksDBStateBackend
Key: FLINK-23721
URL: https://issues.apache.org/jira/browse/FLINK-23721
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263910#comment-17263910
]
Q Kang commented on FLINK-20926:
[~jark] `primary-key-columns` maps to `primary_key_col
[
https://issues.apache.org/jira/browse/FLINK-20926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17263323#comment-17263323
]
Q Kang commented on FLINK-20926:
In my opinion, the must-have metadata definitions are a
[
https://issues.apache.org/jira/browse/FLINK-20926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262574#comment-17262574
]
Q Kang commented on FLINK-20926:
[~jark] We utilize Maxwell in our production environmen
Q Kang created FLINK-20926:
--
Summary: Allow to read metadata for maxwell-json format
Key: FLINK-20926
URL: https://issues.apache.org/jira/browse/FLINK-20926
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-20861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259839#comment-17259839
]
Q Kang commented on FLINK-20861:
All right, let's stick to `json.encode.decimal-as-plain
[
https://issues.apache.org/jira/browse/FLINK-20861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259481#comment-17259481
]
Q Kang commented on FLINK-20861:
That sounds good, but in my opinion maybe `json.encode.
[
https://issues.apache.org/jira/browse/FLINK-20861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259455#comment-17259455
]
Q Kang commented on FLINK-20861:
Also if the community thinks this is worth doing, pleas
Q Kang created FLINK-20861:
--
Summary: Provide an option for serializing DECIMALs in JSON as
plain number instead of scientific notation
Key: FLINK-20861
URL: https://issues.apache.org/jira/browse/FLINK-20861
[
https://issues.apache.org/jira/browse/FLINK-18611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Q Kang updated FLINK-18611:
---
Description:
According to the documentation of FileSystem SQL Connector, if we try to create
a table with t
[
https://issues.apache.org/jira/browse/FLINK-18611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Q Kang updated FLINK-18611:
---
Description:
According to the documentation of FileSystem SQL Connector, if we try to create
a table with t
Q Kang created FLINK-18611:
--
Summary: Include `m` as time unit expression for MINUTE in SQL
Key: FLINK-18611
URL: https://issues.apache.org/jira/browse/FLINK-18611
Project: Flink
Issue Type: Improve
23 matches
Mail list logo
