[
https://issues.apache.org/jira/browse/FLINK-12955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870853#comment-16870853
]
Jark Wu commented on FLINK-12955:
-
We should also support an HBase AsyncLookupableTableS
[
https://issues.apache.org/jira/browse/FLINK-12904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-12904.
---
Resolution: Fixed
Fixed in 1.9.0: bf55c547655006be2c03dd1afa1f7db6dda6c0f4
> Remove TableSource#getTableSta
Jark Wu created FLINK-12971:
---
Summary: Remove the constraint that lookup join needs a primary
key or index key
Key: FLINK-12971
URL: https://issues.apache.org/jira/browse/FLINK-12971
Project: Flink
Jark Wu created FLINK-12977:
---
Summary: Port CsvTableSource and CsvTableSink to api-java-bridge
Key: FLINK-12977
URL: https://issues.apache.org/jira/browse/FLINK-12977
Project: Flink
Issue Type: Tas
Jark Wu created FLINK-12978:
---
Summary: Support LookupableTableSource for CsvTableSource
Key: FLINK-12978
URL: https://issues.apache.org/jira/browse/FLINK-12978
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-12911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-12911.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in 1.9.0: a70bd35e306640ae813813294cc2516b96647e73
> Po
[
https://issues.apache.org/jira/browse/FLINK-12971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-12971.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in 1.9.0: cb922bbfa0a26e147638d22aeceaf3e83b01e1d3
> Re
Jark Wu created FLINK-13003:
---
Summary: Support Temporal TableFunction Join in processing time
and event time
Key: FLINK-13003
URL: https://issues.apache.org/jira/browse/FLINK-13003
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-13004:
Component/s: Table SQL / Planner
> Correct the logic of needToCleanupState in
> KeyedProcessFunctionWithC
[
https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873756#comment-16873756
]
Jark Wu commented on FLINK-13004:
-
I think the {{timestamp}} parameter should be primiti
[
https://issues.apache.org/jira/browse/FLINK-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873786#comment-16873786
]
Jark Wu commented on FLINK-12848:
-
Hi [~aloyszhang] [~yanghua] [~enricoc], thanks for re
[
https://issues.apache.org/jira/browse/FLINK-20399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823859#comment-17823859
]
Jark Wu commented on FLINK-20399:
-
[~lorenzo.affetti] Yes, I think so. Thank you for the
[
https://issues.apache.org/jira/browse/FLINK-20399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20399.
---
Assignee: (was: Lorenzo Affetti)
Resolution: Fixed
> Migrate test_sql_client.sh
>
Jark Wu created FLINK-34654:
---
Summary: Add "Special Thanks" Page on the Flink Website
Key: FLINK-34654
URL: https://issues.apache.org/jira/browse/FLINK-34654
Project: Flink
Issue Type: New Feature
Jark Wu created FLINK-33600:
---
Summary: Print cost time for batch queries in SQL Client
Key: FLINK-33600
URL: https://issues.apache.org/jira/browse/FLINK-33600
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-27331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-27331:
---
Assignee: Peter Huang
> Support Avro microsecond precision for TIME
> -
[
https://issues.apache.org/jira/browse/FLINK-34147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17810723#comment-17810723
]
Jark Wu commented on FLINK-34147:
-
I agree it is ambiguous. Currently, {{TimestampData}}
[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20281:
---
Assignee: xuyang
> Window aggregation supports changelog stream input
> ---
[
https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-24939:
---
Assignee: Yubin Li
> Support 'SHOW CREATE CATALOG' syntax
>
>
[
https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834844#comment-17834844
]
Jark Wu commented on FLINK-33934:
-
[~yunta] yes, I think the row format should avoid reu
[
https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834844#comment-17834844
]
Jark Wu edited comment on FLINK-33934 at 4/8/24 8:31 AM:
-
[~yunt
Jark Wu created FLINK-3577:
--
Summary: Display anchor links when hovering over headers.
Key: FLINK-3577
URL: https://issues.apache.org/jira/browse/FLINK-3577
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-3577:
---
Description: This is useful to share the document url if display anchor
links when hovering over headers. Cur
[
https://issues.apache.org/jira/browse/FLINK-3153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15329356#comment-15329356
]
Jark Wu commented on FLINK-3153:
It seems that String Comparison has been supported ?
>
[
https://issues.apache.org/jira/browse/FLINK-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15329610#comment-15329610
]
Jark Wu commented on FLINK-3580:
I would happily try to work on this issue if nobody else
[
https://issues.apache.org/jira/browse/FLINK-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331429#comment-15331429
]
Jark Wu commented on FLINK-4070:
This is a useful feature. I can try to work on this if no
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331446#comment-15331446
]
Jark Wu commented on FLINK-4068:
I tested some cases and find that tableAPI will automatic
[
https://issues.apache.org/jira/browse/FLINK-4070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15331571#comment-15331571
]
Jark Wu commented on FLINK-4070:
The Table API does not support literals on left side of
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4068:
--
Assignee: Jark Wu
> Move constant computations out of code-generated `flatMap` functions.
> ---
[
https://issues.apache.org/jira/browse/FLINK-3942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15334042#comment-15334042
]
Jark Wu commented on FLINK-3942:
I can try to work on it if nobody else is already work on
[
https://issues.apache.org/jira/browse/FLINK-3942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-3942:
--
Assignee: Jark Wu
> Add support for INTERSECT
> -
>
> Key: FLIN
[
https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-35877:
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
(was: BuildSystem / Shad
[
https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-35877:
Fix Version/s: 2.0.0
(was: 1.19.2)
> Shade protobuf in flink
>
[
https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-35877:
---
Assignee: zhuanshenbsj1
> Shade protobuf in flink
> ---
>
> Key
[
https://issues.apache.org/jira/browse/FLINK-35877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-35877.
---
Resolution: Fixed
This is fixed on master: 68d8174c996f05b2fbf9c50d0220a72f29e3a56b
> Shade protobuf in fli
[
https://issues.apache.org/jira/browse/FLINK-36004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872257#comment-17872257
]
Jark Wu commented on FLINK-36004:
-
[~xuyangzhong] could you help have a look at this iss
[
https://issues.apache.org/jira/browse/FLINK-20400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20400:
---
Assignee: Muhammet Orazov
> Migrate test_streaming_sql.sh
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-35353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-35353:
---
Assignee: Juan Zifeng
> Translate "Profiler" page into Chinese
> -
[
https://issues.apache.org/jira/browse/FLINK-33015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761195#comment-17761195
]
Jark Wu commented on FLINK-33015:
-
Maybe duplicated with https://issues.apache.org/jira/
[
https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-33063:
Fix Version/s: 1.19.0
> udaf with user defined pojo object throw error while generate record equaliser
> -
[
https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763319#comment-17763319
]
Jark Wu commented on FLINK-33063:
-
Fixed in
- master: 01cb6ef008273100718cd8a8cfd921c02
[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20281:
Priority: Major (was: Not a Priority)
> Window aggregation supports changelog stream input
>
Jark Wu created FLINK-20421:
---
Summary: Support canal-protobuf format
Key: FLINK-20421
URL: https://issues.apache.org/jira/browse/FLINK-20421
Project: Flink
Issue Type: Sub-task
Components
[
https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240689#comment-17240689
]
Jark Wu commented on FLINK-20375:
-
[~gaoyunhaii], do you know about this? Is this on pur
[
https://issues.apache.org/jira/browse/FLINK-20419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240691#comment-17240691
]
Jark Wu commented on FLINK-20419:
-
Hi [~lirui], are you in streaming mode? Order by regu
[
https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240713#comment-17240713
]
Jark Wu commented on FLINK-20388:
-
[~chesnay], however, if we generate a shorter name fo
[
https://issues.apache.org/jira/browse/FLINK-20419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240715#comment-17240715
]
Jark Wu commented on FLINK-20419:
-
Got it [~lirui].
> Insert fails due to failure to ge
[
https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240738#comment-17240738
]
Jark Wu commented on FLINK-20388:
-
I was thinking to generate an unique id for the opera
[
https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20385:
---
Assignee: Nicholas Jiang
> Allow to read metadata for Canal-json format
> -
[
https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20385:
Parent: FLINK-18822
Issue Type: Sub-task (was: New Feature)
> Allow to read metadata for Canal-js
Jark Wu created FLINK-20454:
---
Summary: Allow to read metadata for debezium-avro-confluent format
Key: FLINK-20454
URL: https://issues.apache.org/jira/browse/FLINK-20454
Project: Flink
Issue Type: S
[
https://issues.apache.org/jira/browse/FLINK-20437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20437:
Component/s: Table SQL / Planner
> Port ExecNode to Java
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242445#comment-17242445
]
Jark Wu commented on FLINK-20388:
-
Operator description sounds good to me [~chesnay].
>
[
https://issues.apache.org/jira/browse/FLINK-20452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20452.
---
Resolution: Not A Problem
> Mysql JDBC Sink UpsertStreamTableSink requires that Table has a full primary
>
[
https://issues.apache.org/jira/browse/FLINK-20373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242450#comment-17242450
]
Jark Wu commented on FLINK-20373:
-
Sorry, I still can't understand what feature do you w
[
https://issues.apache.org/jira/browse/FLINK-20447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242456#comment-17242456
]
Jark Wu commented on FLINK-20447:
-
Even if {{Code}} is the primary key, you still have t
[
https://issues.apache.org/jira/browse/FLINK-20447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20447.
---
Resolution: Not A Problem
> Querying grouy by PK does not work
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20454:
---
Assignee: hailong wang
> Allow to read metadata for debezium-avro-confluent format
> --
[
https://issues.apache.org/jira/browse/FLINK-20454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242884#comment-17242884
]
Jark Wu commented on FLINK-20454:
-
Sure [~hailong wang]. You can take a look the impleme
[
https://issues.apache.org/jira/browse/FLINK-20456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20456:
Component/s: Table SQL / Ecosystem
> Make streaming SQL concepts more approachable
> -
[
https://issues.apache.org/jira/browse/FLINK-20458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20458:
Component/s: Table SQL / Ecosystem
> Translate page 'SQL-gettingStarted' into Chinese
> --
[
https://issues.apache.org/jira/browse/FLINK-20459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20459.
---
Resolution: Duplicate
Let's fix this in FLINK-20321.
> Handle null message correctly in JSON RowData deser
Jark Wu created FLINK-20460:
---
Summary: Support async lookup for HBase connector
Key: FLINK-20460
URL: https://issues.apache.org/jira/browse/FLINK-20460
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-20419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242986#comment-17242986
]
Jark Wu commented on FLINK-20419:
-
[~lirui], the logic of {{BatchExecSinkRule}} is copie
[
https://issues.apache.org/jira/browse/FLINK-20361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20361:
Priority: Critical (was: Blocker)
> Using sliding window with duration of hours in Table API returns wron
[
https://issues.apache.org/jira/browse/FLINK-20361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242994#comment-17242994
]
Jark Wu commented on FLINK-20361:
-
Hi [~leukonoe], you said "This behaviour repeats if u
[
https://issues.apache.org/jira/browse/FLINK-20361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242995#comment-17242995
]
Jark Wu commented on FLINK-20361:
-
cc [~sjwiesman] the author of the example.
> Using s
[
https://issues.apache.org/jira/browse/FLINK-20463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243140#comment-17243140
]
Jark Wu commented on FLINK-20463:
-
[~MengYao], you can add {{'json.ignore-parse-errors'
Jark Wu created FLINK-20470:
---
Summary: MissingNode can't be casted to ObjectNode when
deserializing JSON
Key: FLINK-20470
URL: https://issues.apache.org/jira/browse/FLINK-20470
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-20373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243298#comment-17243298
]
Jark Wu commented on FLINK-20373:
-
A duplicate problem of FLINK-17855? [~HideOnBush]
>
[
https://issues.apache.org/jira/browse/FLINK-20470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20470:
---
Assignee: zhuxiaoshang
> MissingNode can't be casted to ObjectNode when deserializing JSON
> --
[
https://issues.apache.org/jira/browse/FLINK-20473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243669#comment-17243669
]
Jark Wu commented on FLINK-20473:
-
+1
> when get metrics option, its hard to see the fu
[
https://issues.apache.org/jira/browse/FLINK-20478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20478:
Description:
Currently, the explain result includes "Abstract Syntax Tree", "Optimized
Logical Plan" and
[
https://issues.apache.org/jira/browse/FLINK-20478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20478:
---
Assignee: (was: Jark Wu)
> Adjust the explain result
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-20478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20478:
---
Assignee: Jark Wu
> Adjust the explain result
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-20478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243679#comment-17243679
]
Jark Wu commented on FLINK-20478:
-
I think the current "Physical Execution Plan" is not
[
https://issues.apache.org/jira/browse/FLINK-19946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243747#comment-17243747
]
Jark Wu commented on FLINK-19946:
-
[~zhisheng], the legacy connector is not planned to s
[
https://issues.apache.org/jira/browse/FLINK-20373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20373.
---
Resolution: Duplicate
> Flink table jsonArray access all
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-20437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20437:
Fix Version/s: 1.13.0
> Port ExecNode to Java
> -
>
> Key: FLINK-20437
[
https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243877#comment-17243877
]
Jark Wu commented on FLINK-20386:
-
[~873925...@qq.com], I think we can go ahead with thi
[
https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20386:
---
Assignee: jiawen xiao
> ClassCastException when lookup join a JDBC table on INT UNSIGNED column
> -
[
https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243878#comment-17243878
]
Jark Wu commented on FLINK-20481:
-
Please use BIGINT in Flink SQL for INT UNSIGNED types
[
https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-20481.
---
Resolution: Duplicate
> java.lang.ClassCastException: java.lang.Long cannot be cast to
> java.lang.Integer
[
https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20487:
Description:
{code}
EXCEPTION: org.apache.flink.table.api.TableException: Group Window Aggregate:
Retrac
[
https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20487:
Issue Type: New Feature (was: Bug)
> Support to consume retractions for window aggregate operator
> -
[
https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20487:
Summary: Support to consume retractions for window aggregate operator
(was: FLINK SQL GROUP BY TUMBLE AND
[
https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20487:
Fix Version/s: 1.13.0
> Support to consume retractions for window aggregate operator
> ---
[
https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243889#comment-17243889
]
Jark Wu commented on FLINK-20487:
-
This is a known unsupported feature. I changed the is
[
https://issues.apache.org/jira/browse/FLINK-19607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19607:
Fix Version/s: 1.13.0
> Implement streaming window TopN operator
> ---
[
https://issues.apache.org/jira/browse/FLINK-19604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19604:
Fix Version/s: 1.13.0
> FLIP-145: Support SQL windowing table-valued function
> --
[
https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20486:
Issue Type: Bug (was: Improvement)
> Hive temporal join shouldn't require a minimal 1h monitor interval
>
[
https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20486:
Priority: Critical (was: Major)
> Hive temporal join shouldn't require a minimal 1h monitor interval
> --
[
https://issues.apache.org/jira/browse/FLINK-20485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20485:
Priority: Critical (was: Major)
> Map views are deserialized multiple times
> ---
[
https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243894#comment-17243894
]
Jark Wu commented on FLINK-20486:
-
Big +1.
I think a feature must can be tried in testin
[
https://issues.apache.org/jira/browse/FLINK-20485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20485:
Fix Version/s: 1.12.0
> Map views are deserialized multiple times
> --
[
https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20486:
---
Assignee: Leonard Xu
> Hive temporal join shouldn't require a minimal 1h monitor interval
> ---
[
https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20484:
---
Assignee: Leonard Xu
> Improve hive temporal table exception
> ---
[
https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20484:
Fix Version/s: 1.12.0
> Improve hive temporal table exception
> --
>
[
https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-19863.
---
Resolution: Fixed
Fixed in
- master (1.13.0): 6c183175c9bc61625c30e74287c7a10929ce328f
- release-1.12: ae
[
https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19435:
Description:
when we sink data to multi jdbc outputformat ,
{code}
protected void establishConnection()
601 - 700 of 8787 matches
Mail list logo
