[
https://issues.apache.org/jira/browse/FLINK-30667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678003#comment-17678003
]
Chen Qin edited comment on FLINK-30667 at 1/19/23 7:19 AM:
---
parser should be
[
https://issues.apache.org/jira/browse/FLINK-30667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678003#comment-17678003
]
Chen Qin edited comment on FLINK-30667 at 1/19/23 7:16 AM:
---
Paper should be
[
https://issues.apache.org/jira/browse/FLINK-30667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-30667:
-
Summary: remove the planner @internal dependency in flink-connector-hive
(was: remove the planner
[
https://issues.apache.org/jira/browse/FLINK-30667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678003#comment-17678003
]
Chen Qin edited comment on FLINK-30667 at 1/18/23 3:58 AM:
---
ParserImpl and
[
https://issues.apache.org/jira/browse/FLINK-30667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678003#comment-17678003
]
Chen Qin commented on FLINK-30667:
--
ParserImpl and it's interface currently both Internal. Consider
[
https://issues.apache.org/jira/browse/FLINK-30659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-30659:
-
Summary: move flink-sql-parser-hive to flink-connector-hive-parent (was:
move flink-sql-parser-hive to
Chen Qin created FLINK-30667:
Summary: remove the planner dependency in flink-connector-hive
Key: FLINK-30667
URL: https://issues.apache.org/jira/browse/FLINK-30667
Project: Flink
Issue Type:
Chen Qin created FLINK-30664:
Summary: [Connector/Hive] cleanup hive/haoop package ambiguous
package dependencies
Key: FLINK-30664
URL: https://issues.apache.org/jira/browse/FLINK-30664
Project: Flink
Chen Qin created FLINK-30660:
Summary: move SQLClientHiveITCase and TestHiveCatalogFactory to
flink-connector-hive e2e
Key: FLINK-30660
URL: https://issues.apache.org/jira/browse/FLINK-30660
Project:
[
https://issues.apache.org/jira/browse/FLINK-30659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-30659:
-
Summary: move flink-sql-parser-hive to flink-connector-hive (was: move
Flink-sql-parser-hive to
[
https://issues.apache.org/jira/browse/FLINK-30658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-30658:
-
Summary: remove flink-sql-parser-hive dependency in table-planner (was:
remove Flink-sql-parser-hive
Chen Qin created FLINK-30659:
Summary: move Flink-sql-parser-hive to flink-connector-hive
Key: FLINK-30659
URL: https://issues.apache.org/jira/browse/FLINK-30659
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-30658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-30658:
-
Summary: remove Flink-sql-parser-hive dependency in table-planner (was:
remove Flink-sql-parser-hive
Chen Qin created FLINK-30658:
Summary: remove Flink-sql-parser-hive dependency on table-planner
Key: FLINK-30658
URL: https://issues.apache.org/jira/browse/FLINK-30658
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645799#comment-17645799
]
Chen Qin commented on FLINK-27640:
--
shall we exclude
Chen Qin created FLINK-30362:
Summary: Flink-connector-hive can't build with maven 3.8
Key: FLINK-30362
URL: https://issues.apache.org/jira/browse/FLINK-30362
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-27726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-27726:
-
Summary: shade thrift and fb303 in hive connector (was: shad thrift and
fb303 in hive connector)
>
Chen Qin created FLINK-27726:
Summary: shad thrift and fb303 in hive connector
Key: FLINK-27726
URL: https://issues.apache.org/jira/browse/FLINK-27726
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1733#comment-1733
]
Chen Qin commented on FLINK-10052:
--
Set timeline on leader change to new address null exception.
In
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330890#comment-17330890
]
Chen Qin commented on FLINK-10052:
--
here is another exception we observed in another job after apply
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330890#comment-17330890
]
Chen Qin edited comment on FLINK-10052 at 4/23/21, 4:13 PM:
here is another
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330858#comment-17330858
]
Chen Qin edited comment on FLINK-10052 at 4/23/21, 4:04 PM:
run load testing
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17330858#comment-17330858
]
Chen Qin commented on FLINK-10052:
--
run load testing on pr, found following exception when job
[
https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321877#comment-17321877
]
Chen Qin commented on FLINK-6113:
-
Seems community already get rid of split and select transformation in
[
https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin closed FLINK-6113.
---
Resolution: Fixed
> Implement split/select with Side Outputs
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-6113:
Attachment: split_select.patch
> Implement split/select with Side Outputs
>
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312867#comment-17312867
]
Chen Qin commented on FLINK-22081:
--
[~AHeise] could you assign this Jira to me and help review pr?
>
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-22081:
-
Description:
Using flink 1.11.2
I added the flink-s3-fs-hadoop jar in plugins dir but I am seeing the
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-22081:
-
Description:
Using flink 1.11.2
I added the flink-s3-fs-hadoop jar in plugins dir but I am seeing the
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-22081:
-
Attachment: image (13).png
> Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin
>
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-22081:
-
Description:
Using flink 1.11.2
I added the flink-s3-fs-hadoop jar in plugins dir but I am seeing the
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-22081:
-
Description:
Using flink 1.11.2
I added the flink-s3-fs-hadoop jar in plugins dir but I am seeing the
[
https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-22081:
-
Fix Version/s: 1.10.2
1.10.3
1.11.1
1.11.2
Chen Qin created FLINK-22081:
Summary: Entropy key not resolved if flink-s3-fs-hadoop is added
as a plugin
Key: FLINK-22081
URL: https://issues.apache.org/jira/browse/FLINK-22081
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311956#comment-17311956
]
Chen Qin commented on FLINK-17359:
--
[https://github.com/apache/flink/pull/15442]
> Entropy key is
[
https://issues.apache.org/jira/browse/FLINK-17359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307991#comment-17307991
]
Chen Qin commented on FLINK-17359:
--
Hi [~premsantosh], We see a regression of this bug with 1.11.2.
[
https://issues.apache.org/jira/browse/FLINK-18158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162956#comment-17162956
]
Chen Qin commented on FLINK-18158:
--
[~twalthr]what if user have nested struct definition in
[
https://issues.apache.org/jira/browse/FLINK-16392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin closed FLINK-16392.
Resolution: Feedback Received
> oneside sorted cache in intervaljoin
>
[
https://issues.apache.org/jira/browse/FLINK-16392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-16392:
-
Description:
Native intervaljoin rely on statebackend(e.g rocksdb) to insert/fetch left and
right
[
https://issues.apache.org/jira/browse/FLINK-16392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-16392:
-
Description:
IntervalJoin is getting lots of usecases in our side. Those use cases shares
following
[
https://issues.apache.org/jira/browse/FLINK-16392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-16392:
-
Description:
IntervalJoin is getting lots of usecases in our side. Those use cases shares
following
[
https://issues.apache.org/jira/browse/FLINK-16392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-16392:
-
Description:
IntervalJoin is getting lots of usecases in our side. Those use cases shares
following
[
https://issues.apache.org/jira/browse/FLINK-16392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-16392:
-
Description:
IntervalJoin is getting lots of usecases in our side. Those use cases shares
following
[
https://issues.apache.org/jira/browse/FLINK-16392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-16392:
-
Description:
IntervalJoin is getting lots of usecases in our side. Those use cases shares
following
Chen Qin created FLINK-16392:
Summary: oneside sorted cache in intervaljoin
Key: FLINK-16392
URL: https://issues.apache.org/jira/browse/FLINK-16392
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin reassigned FLINK-8437:
---
Assignee: Chen Qin
> SideOutput() API is ambiguous
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-7954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16260265#comment-16260265
]
Chen Qin commented on FLINK-7954:
-
[~phoenixjiangnan] Thanks for quick response. I think we can always
Chen Qin created FLINK-7954:
---
Summary: sideoutput in async function
Key: FLINK-7954
URL: https://issues.apache.org/jira/browse/FLINK-7954
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170922#comment-16170922
]
Chen Qin commented on FLINK-7635:
-
[~phoenixjiangnan] there are good reference in PorcessFunction.Context
Chen Qin created FLINK-7635:
---
Summary: support sideOutput in ProcessWindowFunciton &
ProcessAllWindowFunction
Key: FLINK-7635
URL: https://issues.apache.org/jira/browse/FLINK-7635
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin reassigned FLINK-7106:
---
Assignee: Chen Qin
> Make SubmittedJobGraphStore implementation configurable
>
[
https://issues.apache.org/jira/browse/FLINK-7106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-7106:
Summary: Make SubmittedJobGraphStore implementation configurable (was:
Make SubmittedJobGraphStore
Chen Qin created FLINK-7106:
---
Summary: Make SubmittedJobGraphStore configurable
Key: FLINK-7106
URL: https://issues.apache.org/jira/browse/FLINK-7106
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15945991#comment-15945991
]
Chen Qin edited comment on FLINK-6085 at 3/29/17 3:04 AM:
--
To unlock scenarios
[
https://issues.apache.org/jira/browse/FLINK-6085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15945991#comment-15945991
]
Chen Qin commented on FLINK-6085:
-
To unlock scenarios like blocking rpc call or async callback, I am
[
https://issues.apache.org/jira/browse/FLINK-6085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15939209#comment-15939209
]
Chen Qin edited comment on FLINK-6085 at 3/24/17 8:32 PM:
--
I would like to see if
[
https://issues.apache.org/jira/browse/FLINK-6085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-6085:
Description:
Track discussion around run flink as a micro service, includes but not limited
to
- RPC (web
[
https://issues.apache.org/jira/browse/FLINK-6085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-6085:
Attachment: Untitled document.jpg
I would like to see if we can agree on high level first. Service is
Chen Qin created FLINK-6113:
---
Summary: Implement split/select with OutputTag
Key: FLINK-6113
URL: https://issues.apache.org/jira/browse/FLINK-6113
Project: Flink
Issue Type: Improvement
Chen Qin created FLINK-6085:
---
Summary: flink as micro service
Key: FLINK-6085
URL: https://issues.apache.org/jira/browse/FLINK-6085
Project: Flink
Issue Type: Improvement
Components:
[
https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15856972#comment-15856972
]
Chen Qin commented on FLINK-4266:
-
When this jira was filed, there are multiple issues around incremental
[
https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-4266:
Summary: Cassandra SplitOver Statebackend (was: Remote Database
Statebackend)
> Cassandra SplitOver
[
https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin reassigned FLINK-4266:
---
Assignee: Chen Qin
Affects Version/s: (was: 1.2.0)
1.3.0
>
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin reassigned FLINK-4460:
---
Assignee: Chen Qin
> Side Outputs in Flink
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-4266:
Affects Version/s: (was: 1.0.3)
> Remote Database Statebackend
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15717166#comment-15717166
]
Chen Qin commented on FLINK-4460:
-
Ongoing implementation reflecting feedbacks, missing window stream impl
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-4460:
Affects Version/s: 1.1.3
Labels: latearrivingevents sideoutput (was: )
Chen Qin created FLINK-4460:
---
Summary: Expose Late Arriving Events
Key: FLINK-4460
URL: https://issues.apache.org/jira/browse/FLINK-4460
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15410474#comment-15410474
]
Chen Qin commented on FLINK-4266:
-
[
https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-4266:
Description:
Current FileSystem statebackend limits whole state size to disk space. Dealing
with scale out
[
https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-4266:
Summary: Remote Database Statebackend (was: Remote Storage Statebackend)
> Remote Database Statebackend
>
[
https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-4266:
Summary: Remote Storage Statebackend (was: Cassandra StateBackend)
> Remote Storage Statebackend
>
72 matches
Mail list logo
