[jira] [Commented] (FLINK-26827) FlinkSQL和hive整合报错

[ https://issues.apache.org/jira/browse/FLINK-26827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511753#comment-17511753 ] Jark Wu commented on FLINK-26827: - [~luoyuxia], could you help to have a look? > FlinkSQL和hive整合报错 >

[jira] [Commented] (FLINK-26827) FlinkSQL和hive整合报错

[ https://issues.apache.org/jira/browse/FLINK-26827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511750#comment-17511750 ] Jark Wu commented on FLINK-26827: - [~zhushifeng], please translate the title and environment as well .

[jira] [Commented] (FLINK-26819) AppendOnlyFirstNFunction produce wrong result when with offset and without rank number

[ https://issues.apache.org/jira/browse/FLINK-26819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511277#comment-17511277 ] Jark Wu commented on FLINK-26819: - [~lincoln.86xy] could you open pull requests to backport the fix to

[jira] [Closed] (FLINK-26819) AppendOnlyFirstNFunction produce wrong result when with offset and without rank number

[ https://issues.apache.org/jira/browse/FLINK-26819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26819. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in - master:

[jira] [Assigned] (FLINK-23882) Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently not supported by Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-23882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-23882: --- Assignee: TANG ZHAO > Documentation of TIMESTAMP WITH TIME ZONE should state that it is currently

[jira] [Commented] (FLINK-26595) Improve the PostgresDialect method for getting upsert statements.

[ https://issues.apache.org/jira/browse/FLINK-26595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506170#comment-17506170 ] Jark Wu commented on FLINK-26595: - [~hapihu], if Postgres allows no primary key fields in {{DO UPDATE

[jira] [Closed] (FLINK-26534) shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism

[ https://issues.apache.org/jira/browse/FLINK-26534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26534. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 15d2239376244ecae6b52d0a365510ff1883a8a0 >

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505973#comment-17505973 ] Jark Wu commented on FLINK-26498: - Hi [~paul8263], as I mentioned before, we can introduce a

[jira] [Commented] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505244#comment-17505244 ] Jark Wu commented on FLINK-26565: - Thanks [~hehuiyuan], could you add a test in your PR which should be

[jira] [Commented] (FLINK-26595) Improve the PostgresDialect method for getting upsert statements.

[ https://issues.apache.org/jira/browse/FLINK-26595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504867#comment-17504867 ] Jark Wu commented on FLINK-26595: - +1 to [~martijnvisser] said. It seems MatrixDB is not fully

[jira] [Commented] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504825#comment-17504825 ] Jark Wu commented on FLINK-26565: - What's the problem with current implementation? Could you give an

[jira] [Commented] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504822#comment-17504822 ] Jark Wu commented on FLINK-26565: - Is this a duplicate of FLINK-26498? > Use lateTrigger when the

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504810#comment-17504810 ] Jark Wu commented on FLINK-26498: - [~hehuiyuan], [~paul8263], the current behavior works as expect with

[jira] [Comment Edited] (FLINK-26595) Improve the PostgresDialect method for getting upsert statements.

[ https://issues.apache.org/jira/browse/FLINK-26595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504808#comment-17504808 ] Jark Wu edited comment on FLINK-26595 at 3/11/22, 8:56 AM: --- [~hapihu], is it a

[jira] [Commented] (FLINK-26595) Improve the PostgresDialect method for getting upsert statements.

[ https://issues.apache.org/jira/browse/FLINK-26595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504808#comment-17504808 ] Jark Wu commented on FLINK-26595: - [~hapihu], is it a problem in matrixDB? Why the existing can pass

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503607#comment-17503607 ] Jark Wu commented on FLINK-26498: - Yes, the "00:59:20.100" is cleaned up before fired. > The window

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503439#comment-17503439 ] Jark Wu commented on FLINK-26498: - They are different concepts: lateness vs out-of-order. The

[jira] [Commented] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503396#comment-17503396 ] Jark Wu commented on FLINK-26437: - [~arindbha], please download the orc format jar in this page[1].

[jira] [Comment Edited] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503393#comment-17503393 ] Jark Wu edited comment on FLINK-26498 at 3/9/22, 8:42 AM: -- Thanks [~hehuiyuan],

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503393#comment-17503393 ] Jark Wu commented on FLINK-26498: - Thanks [~hehuiyuan], I got what you mean. The window has been fired

[jira] [Commented] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503325#comment-17503325 ] Jark Wu commented on FLINK-26437: - [~straw] please just put the flink-hadoop-uber jar[1] instead of

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503321#comment-17503321 ] Jark Wu commented on FLINK-26498: - I don't think we should emit window result when cleanup time

[jira] [Commented] (FLINK-25684) Support enhanced show databases syntax

[ https://issues.apache.org/jira/browse/FLINK-25684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503297#comment-17503297 ] Jark Wu commented on FLINK-25684: - Sure. I will review it. > Support enhanced show databases syntax >

[jira] [Assigned] (FLINK-25684) Support enhanced show databases syntax

[ https://issues.apache.org/jira/browse/FLINK-25684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25684: --- Assignee: Moses > Support enhanced show databases syntax > --

[jira] [Commented] (FLINK-26457) Introduce Join Accumulator for Wide table

[ https://issues.apache.org/jira/browse/FLINK-26457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503278#comment-17503278 ] Jark Wu commented on FLINK-26457: - Is this to support partial update on table store? Is "Join

[jira] [Created] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

Jark Wu created FLINK-26541: --- Summary: SQL Client should support submitting SQL jobs in application mode Key: FLINK-26541 URL: https://issues.apache.org/jira/browse/FLINK-26541 Project: Flink

[jira] [Closed] (FLINK-25799) Translate table/filesystem.md page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-25799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-25799. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 8f88e8f5963ab25a3ed1eb35134dbde045c14afe >

[jira] [Closed] (FLINK-25631) Support enhanced `show tables` statement

[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-25631. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 8d9489d7b34676a7dcdd86bb9ae54343b2a978b4 >

[jira] [Assigned] (FLINK-26460) Fix Unsupported type when convertTypeToSpec: MAP

[ https://issues.apache.org/jira/browse/FLINK-26460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26460: --- Assignee: tartarus > Fix Unsupported type when convertTypeToSpec: MAP >

[jira] [Closed] (FLINK-26320) Update hive doc for 1 m->1 min

[ https://issues.apache.org/jira/browse/FLINK-26320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26320. --- Fix Version/s: 1.16.0 Assignee: hehuiyuan Resolution: Fixed Fixed in master:

[jira] [Assigned] (FLINK-25761) Translate Avro format page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-25761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25761: --- Assignee: baisike > Translate Avro format page into Chinese. >

[jira] [Closed] (FLINK-25761) Translate Avro format page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-25761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-25761. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: c511c9a49fd1898b9319dc1e594e62e999f92346 >

[jira] [Assigned] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26360: --- Assignee: luoyuxia > [Umbrella] Improvement for Hive Query Syntax Compatibility >

[jira] [Updated] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26360: Fix Version/s: 1.16.0 > [Umbrella] Improvement for Hive Query Syntax Compatibility >

[jira] [Commented] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is g

[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497319#comment-17497319 ] Jark Wu commented on FLINK-26204: - [~jingzhang] do you want to have a look this problem? > set

[jira] [Commented] (FLINK-26348) Maybe ChangelogNormalize should ignore unused columns when deduplicate

[ https://issues.apache.org/jira/browse/FLINK-26348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497317#comment-17497317 ] Jark Wu commented on FLINK-26348: - +1 for this. The project push down should also be able to pass

[jira] [Updated] (FLINK-26348) Maybe ChangelogNormalize should ignore unused columns when deduplicate

[ https://issues.apache.org/jira/browse/FLINK-26348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26348: Component/s: Table SQL / Planner > Maybe ChangelogNormalize should ignore unused columns when deduplicate

[jira] [Commented] (FLINK-26320) Update hive doc for 1 m->1 min

[ https://issues.apache.org/jira/browse/FLINK-26320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497124#comment-17497124 ] Jark Wu commented on FLINK-26320: - [~hehuiyuan] do you want to help fixing this? > Update hive doc for

[jira] [Updated] (FLINK-26320) Update hive doc for 1 m->1 min

[ https://issues.apache.org/jira/browse/FLINK-26320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26320: Component/s: Connectors / Hive > Update hive doc for 1 m->1 min > -- > >

[jira] [Commented] (FLINK-26327) throw not a literal exception in callContext.getArgumentValue when getTypeInference

[ https://issues.apache.org/jira/browse/FLINK-26327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497123#comment-17497123 ] Jark Wu commented on FLINK-26327: - Could you share the full exception stack ? > throw not a literal

[jira] [Assigned] (FLINK-26259) Partial insert and partition insert cannot work with sql hint

[ https://issues.apache.org/jira/browse/FLINK-26259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26259: --- Assignee: Junwen Yi > Partial insert and partition insert cannot work with sql hint >

[jira] [Assigned] (FLINK-26295) 'HELP ;', 'QUIT ;' and other sql-client commands fail with CalciteException: Non-query expression encountered in illegal context

[ https://issues.apache.org/jira/browse/FLINK-26295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26295: --- Assignee: Sergey Nuyanzin > 'HELP ;', 'QUIT ;' and other sql-client commands fail with

[jira] [Commented] (FLINK-26204) set table.optimizer.distinct-agg.split.enabled to true and using Window TVF CUMULATE to count users, It will appear that the value of the current step window time is g

[ https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496055#comment-17496055 ] Jark Wu commented on FLINK-26204: - This looks weird. There is no retraction streams when

[jira] [Commented] (FLINK-21871) Support watermark for Hive and Filesystem streaming source

[ https://issues.apache.org/jira/browse/FLINK-21871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496046#comment-17496046 ] Jark Wu commented on FLINK-21871: - [~pnowojski] this feature is not urgent, so I think we can wait until

[jira] [Updated] (FLINK-26152) Translate the page of SQL/queries/WITH clause

[ https://issues.apache.org/jira/browse/FLINK-26152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26152: Fix Version/s: 1.15.0 (was: 1.16.0) > Translate the page of SQL/queries/WITH

[jira] [Closed] (FLINK-26152) Translate the page of SQL/queries/WITH clause

[ https://issues.apache.org/jira/browse/FLINK-26152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26152. --- Resolution: Fixed > Translate the page of SQL/queries/WITH clause >

[jira] [Commented] (FLINK-26152) Translate the page of SQL/queries/WITH clause

[ https://issues.apache.org/jira/browse/FLINK-26152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495864#comment-17495864 ] Jark Wu commented on FLINK-26152: - Fixed in master: 84530f4d2af96641dc891b7fedefed8c6b1b5c4f >

[jira] [Updated] (FLINK-26152) Translate the page of SQL/queries/WITH clause

[ https://issues.apache.org/jira/browse/FLINK-26152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26152: Fix Version/s: 1.16.0 (was: 1.14.0) > Translate the page of SQL/queries/WITH

[jira] [Commented] (FLINK-21871) Support watermark for Hive and Filesystem streaming source

[ https://issues.apache.org/jira/browse/FLINK-21871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495832#comment-17495832 ] Jark Wu commented on FLINK-21871: - Hi [~pnowojski], yes, I planned to implement it in the Hive source.

[jira] [Commented] (FLINK-26259) Partial insert and partition insert cannot work with sql hint

[ https://issues.apache.org/jira/browse/FLINK-26259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495147#comment-17495147 ] Jark Wu commented on FLINK-26259: - [~schumiyi] do you have cases to reproduce the problem? And could you

[jira] [Commented] (FLINK-26191) Incorrect license in Elasticsearch connectors

[ https://issues.apache.org/jira/browse/FLINK-26191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494888#comment-17494888 ] Jark Wu commented on FLINK-26191: - Yes, I think so. > Incorrect license in Elasticsearch connectors >

[jira] [Commented] (FLINK-26191) Incorrect license in Elasticsearch connectors

[ https://issues.apache.org/jira/browse/FLINK-26191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494716#comment-17494716 ] Jark Wu commented on FLINK-26191: - [~chesnay], sorry, ASLv2 is compabible with Elastic License 2.0? >

[jira] [Commented] (FLINK-26191) Incorrect license in Elasticsearch connectors

[ https://issues.apache.org/jira/browse/FLINK-26191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494595#comment-17494595 ] Jark Wu commented on FLINK-26191: - [~chesnay] it seems the elasticsearch-rest-high-level-client is

[jira] [Commented] (FLINK-26191) Incorrect license in Elasticsearch connectors

[ https://issues.apache.org/jira/browse/FLINK-26191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494548#comment-17494548 ] Jark Wu commented on FLINK-26191: - [~chesnay] does that mean we have to exclude elasticsearch connector

[jira] (FLINK-25095) Case when would be translated into different expression in Hive dialect and default dialect

[ https://issues.apache.org/jira/browse/FLINK-25095 ] Jark Wu deleted comment on FLINK-25095: - was (Author: jark): [~icshuo] do you want to fix this? ;) > Case when would be translated into different expression in Hive dialect and > default

[jira] [Updated] (FLINK-20765) ScalarOperatorGens doesn't set proper nullability for result type of generated expressions

[ https://issues.apache.org/jira/browse/FLINK-20765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20765: Priority: Major (was: Not a Priority) > ScalarOperatorGens doesn't set proper nullability for result

[jira] [Commented] (FLINK-25095) Case when would be translated into different expression in Hive dialect and default dialect

[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494476#comment-17494476 ] Jark Wu commented on FLINK-25095: - [~icshuo] do you want to fix this? ;) > Case when would be

[jira] [Assigned] (FLINK-26152) Translate the page of SQL/queries/WITH clause

[ https://issues.apache.org/jira/browse/FLINK-26152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26152: --- Assignee: wenyibo > Translate the page of SQL/queries/WITH clause >

[jira] [Commented] (FLINK-18652) JDBCAppendTableSink to ClickHouse (data always repeating)

[ https://issues.apache.org/jira/browse/FLINK-18652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493019#comment-17493019 ] Jark Wu commented on FLINK-18652: - [~afedulov], I closed this issue. [~mzz_q] please reopen it if the

[jira] [Closed] (FLINK-18652) JDBCAppendTableSink to ClickHouse (data always repeating)

[ https://issues.apache.org/jira/browse/FLINK-18652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18652. --- Resolution: Not A Problem > JDBCAppendTableSink to ClickHouse (data always repeating) >

[jira] [Closed] (FLINK-26077) Support operators send request to Coordinator and return a response

[ https://issues.apache.org/jira/browse/FLINK-26077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26077. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: fdb80108a3c0e4fb12dbc3f89ecb2327d97deebf >

[jira] [Assigned] (FLINK-26077) Support operators send request to Coordinator and return a response

[ https://issues.apache.org/jira/browse/FLINK-26077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-26077: --- Assignee: Jark Wu > Support operators send request to Coordinator and return a response >

[jira] [Updated] (FLINK-26077) Support operators send request to Coordinator and return a response

[ https://issues.apache.org/jira/browse/FLINK-26077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26077: Component/s: Runtime / Coordination > Support operators send request to Coordinator and return a response

[jira] [Created] (FLINK-26077) Support operators send request to Coordinator and return a response

Jark Wu created FLINK-26077: --- Summary: Support operators send request to Coordinator and return a response Key: FLINK-26077 URL: https://issues.apache.org/jira/browse/FLINK-26077 Project: Flink

[jira] [Updated] (FLINK-25562) hive sql connector dependency conflicts

[ https://issues.apache.org/jira/browse/FLINK-25562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25562: Priority: Major (was: Minor) > hive sql connector dependency conflicts >

[jira] [Updated] (FLINK-25562) hive sql connector dependency conflicts

[ https://issues.apache.org/jira/browse/FLINK-25562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25562: Summary: hive sql connector dependency conflicts (was: hive sql connector 依赖冲突) > hive sql connector

[jira] [Updated] (FLINK-25562) hive sql connector dependency conflicts

[ https://issues.apache.org/jira/browse/FLINK-25562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25562: Issue Type: Bug (was: Improvement) > hive sql connector dependency conflicts >

[jira] [Assigned] (FLINK-25562) hive sql connector 依赖冲突

[ https://issues.apache.org/jira/browse/FLINK-25562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25562: --- Assignee: luoyuxia > hive sql connector 依赖冲突 > --- > > Key:

[jira] [Commented] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

[ https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477073#comment-17477073 ] Jark Wu commented on FLINK-25614: - Currently, we only support TIMESTAMP(<=3) as the rowtime attribute,

[jira] [Commented] (FLINK-25631) Support enhanced `show tables` statement

[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475133#comment-17475133 ] Jark Wu commented on FLINK-25631: - Thanks [~liyubin117], this feature sounds good to me. You can take

[jira] [Assigned] (FLINK-25631) Support enhanced `show tables` statement

[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25631: --- Assignee: Yubin Li > Support enhanced `show tables` statement >

[jira] [Updated] (FLINK-25592) Improvement of parser, optimizer and execution for Flink Batch SQL

[ https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25592: Priority: Major (was: Minor) > Improvement of parser, optimizer and execution for Flink Batch SQL >

[jira] [Updated] (FLINK-25592) Improvement of parser, optimizer and execution for Flink Batch SQL

[ https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25592: Component/s: Table SQL / API Table SQL / Planner Table SQL / Runtime >

[jira] [Closed] (FLINK-25010) Speed up hive's createMRSplits by multi thread

[ https://issues.apache.org/jira/browse/FLINK-25010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-25010. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 2824c908b39e6d236cc6f6080cd462ca64c1b501 >

[jira] [Updated] (FLINK-15017) add a thrift server for Flink

[ https://issues.apache.org/jira/browse/FLINK-15017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15017: Priority: Major (was: Not a Priority) > add a thrift server for Flink > - >

[jira] [Assigned] (FLINK-25010) Speed up hive's createMRSplits by multi thread

[ https://issues.apache.org/jira/browse/FLINK-25010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25010: --- Assignee: Liu > Speed up hive's createMRSplits by multi thread >

[jira] [Assigned] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14902: --- Assignee: ranqiqiang > JDBCTableSource support AsyncLookupFunction >

[jira] (FLINK-24626) Flink JDBC Sink may lose data in left join

[ https://issues.apache.org/jira/browse/FLINK-24626 ] Jark Wu deleted comment on FLINK-24626: - was (Author: jark): cc @lincoln.86xy > Flink JDBC Sink may lose data in left join > -- > > Key:

[jira] (FLINK-24626) Flink JDBC Sink may lose data in left join

[ https://issues.apache.org/jira/browse/FLINK-24626 ] Jark Wu deleted comment on FLINK-24626: - was (Author: jark): cc @lincoln.86xy > Flink JDBC Sink may lose data in left join > -- > > Key:

[jira] [Commented] (FLINK-24626) Flink JDBC Sink may lose data in left join

[ https://issues.apache.org/jira/browse/FLINK-24626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457126#comment-17457126 ] Jark Wu commented on FLINK-24626: - cc [~lincoln.86xy] > Flink JDBC Sink may lose data in left join >

[jira] [Commented] (FLINK-24626) Flink JDBC Sink may lose data in left join

[ https://issues.apache.org/jira/browse/FLINK-24626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457125#comment-17457125 ] Jark Wu commented on FLINK-24626: - cc @lincoln.86xy > Flink JDBC Sink may lose data in left join >

[jira] [Commented] (FLINK-24626) Flink JDBC Sink may lose data in left join

[ https://issues.apache.org/jira/browse/FLINK-24626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457124#comment-17457124 ] Jark Wu commented on FLINK-24626: - cc @lincoln.86xy > Flink JDBC Sink may lose data in left join >

[jira] [Commented] (FLINK-24413) Casting to a CHAR() and VARCHAR() doesn't trim the string to the specified precision

[ https://issues.apache.org/jira/browse/FLINK-24413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450799#comment-17450799 ] Jark Wu commented on FLINK-24413: - +1 for option 2 with a config option. > Casting to a CHAR() and

[jira] [Updated] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-25049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25049: Component/s: Connectors / Hive (was: Connectors / FileSystem) > sql-client.sh

[jira] [Commented] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-25049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450797#comment-17450797 ] Jark Wu commented on FLINK-25049: - cc [~luoyuxia], it seems the tmpPath is removed by someone when

[jira] [Commented] (FLINK-24939) Support 'SHOW CREATE CATALOG' syntax

[ https://issues.apache.org/jira/browse/FLINK-24939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450421#comment-17450421 ] Jark Wu commented on FLINK-24939: - [~shenzhu0127], no, I don't think they should be stored in

[jira] [Closed] (FLINK-25065) Update lookup document for jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-25065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-25065. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: c782735a872b2b25ee49e019eae21e174e6330e2 >

[jira] [Commented] (FLINK-25077) Postgresql connector fails in case column with nested arrays

[ https://issues.apache.org/jira/browse/FLINK-25077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450222#comment-17450222 ] Jark Wu commented on FLINK-25077: - I think this might because JDBC connector with PG dialect just

[jira] [Assigned] (FLINK-25065) Update lookup document for jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-25065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25065: --- Assignee: Gaurav Miglani > Update lookup document for jdbc connector >

[jira] [Updated] (FLINK-25065) Update lookup document for jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-25065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25065: Component/s: Connectors / JDBC > Update lookup document for jdbc connector >

[jira] [Assigned] (FLINK-25050) Translate "Metrics" page of "Operations" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-25050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25050: --- Assignee: ZhiJie Yang > Translate "Metrics" page of "Operations" into Chinese >

[jira] [Commented] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-25049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450217#comment-17450217 ] Jark Wu commented on FLINK-25049: - [~macdoor615], could you share the DDL of the tables used in your

[jira] [Updated] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-25049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25049: Component/s: Table SQL / Ecosystem > sql-client.sh execute batch job in async mode failed with >

[jira] [Updated] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-25049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25049: Environment: (was: {code:java} //代码占位符 {code}) > sql-client.sh execute batch job in async mode failed

[jira] [Updated] (FLINK-25049) sql-client.sh execute batch job in async mode failed with java.io.FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-25049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25049: Component/s: Connectors / FileSystem (was: Table SQL / Client) > sql-client.sh

[jira] [Commented] (FLINK-25054) Improve exception message for unsupported hashLength for SHA2 function

[ https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450215#comment-17450215 ] Jark Wu commented on FLINK-25054: - Yes, I think the exception message should be improved. > Improve

[jira] [Commented] (FLINK-25054) Improve exception message for unsupported hashLength for SHA2 function

[ https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450216#comment-17450216 ] Jark Wu commented on FLINK-25054: - Yes, I think the exception message should be improved. > Improve

[jira] [Updated] (FLINK-25054) Improve exception message for unsupported hashLength for SHA2 function

[ https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25054: Language: (was: JAVA) > Improve exception message for unsupported hashLength for SHA2 function >

[jira] [Updated] (FLINK-25054) Improve exception message for unsupported hashLength for SHA2 function

[ https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25054: Summary: Improve exception message for unsupported hashLength for SHA2 function (was: flink sql System

[jira] [Updated] (FLINK-25054) Improve exception message for unsupported hashLength for SHA2 function

[ https://issues.apache.org/jira/browse/FLINK-25054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25054: Component/s: Table SQL / API (was: Build System) > Improve exception message for

<    3   4   5   6   7   8   9   10   11   12   >