[jira] [Created] (FLINK-24501) Unexpected behavior of cumulate window aggregate for late event after recover from sp/cp

JING ZHANG created FLINK-24501: -- Summary: Unexpected behavior of cumulate window aggregate for late event after recover from sp/cp Key: FLINK-24501 URL: https://issues.apache.org/jira/browse/FLINK-24501

Re: [NOTICE] CiBot improvements

mes I'm not sure the passed cases in the last build could still success in the new build because of introduced updates in new commit. Best, JING ZHANG Yangze Guo 于2021年10月11日周一 上午10:31写道： > Thanks for that great job, Chesnay! "Rerun failed jobs" will help a lot. > > Best, &

Re: [ANNOUNCE] Apache Flink 1.14.0 released

Great! Thanks David, Joe, Xintong and everyone who makes this possible. Best, JING ZHANG Leonard Xu 于2021年10月1日周五 上午10:20写道： > Congratulations! > > Thanks Dawid, Xintong and Joe for being our release managers and everyone > who contributed to this release. > > Best, > Leon

Re: [VOTE] Release 1.14.0, release candidate #3

pache.org/repos/dist/dev/flink/flink-1.14.0-rc3/flink-1.14.0-bin-scala_2.12.tgz> - test window TVF related sql, query result is expected Best, JING ZHANG Zhu Zhu 于2021年9月26日周日 下午6:38写道： > +1 (binding) > - checked signatures and checksums > - built from source > - ran large s

Re: 退订

...@flink.apache.org For more information, please go to [1]. [1] https://flink.apache.org/community.html#mailing-lists Best, JING ZHANG maozhaolin 于2021年9月26日周日 下午3:28写道： > 退订

Re: [DISCUSS] Automated architectural tests

` could be covered by all `MetadataHandler`s. Currently this rule not exists yet. Best regards, JING ZHANG Ingo Bürk 于2021年9月9日周四 下午6:49写道： > Great! I'll work on getting the PR into an actual, proper shape now, > including looking at found violations more carefully and eventually > fr

Re: [ANNOUNCE] Flink mailing lists archive service has migrated to Apache Archive service

Thanks Leonard for driving this. The information is helpful. Best, JING ZHANG Jark Wu 于2021年9月6日周一 下午4:59写道： > Thanks Leonard, > > I have seen many users complaining that the Flink mailing list doesn't > work (they were using Nabble). > I think this information would be ve

[jira] [Created] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate on Match because the output type does not updated after input rowtime attribute changed from rowtime

JING ZHANG created FLINK-24168: -- Summary: Rowtime type is not correct for windowTableFunction or OverAggregate on Match because the output type does not updated after input rowtime attribute changed from rowtime to rowtime_ltz Key

Re: One idea for Graceful Application Evolvement

operator has changed, whether need to fulfill the data, whether need to recover state, and how? Best, JING ZHANG Kurt Young 于2021年9月3日周五 上午9:15写道： > Could you explain why you need a backfill after you take v2 into > production? > > Best, > Kurt > > > On Fri, Sep 3, 2021 at 2:

[jira] [Created] (FLINK-24024) Fix syntax mistake in session Window TVF

JING ZHANG created FLINK-24024: -- Summary: Fix syntax mistake in session Window TVF Key: FLINK-24024 URL: https://issues.apache.org/jira/browse/FLINK-24024 Project: Flink Issue Type: Bug

Re: How heap state backend serialization happens during snapshotting

, JING ZHANG Muhammad Haseeb Asif 于2021年8月27日周五 上午2:41写道： > Hello, > > I have been trying to understand how serialization works for the Flink > Heap Keyed state backend when a checkpoint happens. I want to know how > Flink knows which type of serializer to use to serialize the values

[jira] [Created] (FLINK-24002) Support count window with the window TVF in planner

JING ZHANG created FLINK-24002: -- Summary: Support count window with the window TVF in planner Key: FLINK-24002 URL: https://issues.apache.org/jira/browse/FLINK-24002 Project: Flink Issue Type

[jira] [Created] (FLINK-24001) Support evaluating individual window table-valued function in runtime

JING ZHANG created FLINK-24001: -- Summary: Support evaluating individual window table-valued function in runtime Key: FLINK-24001 URL: https://issues.apache.org/jira/browse/FLINK-24001 Project: Flink

[jira] [Created] (FLINK-24000) window aggregate support allow lateness

JING ZHANG created FLINK-24000: -- Summary: window aggregate support allow lateness Key: FLINK-24000 URL: https://issues.apache.org/jira/browse/FLINK-24000 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23999) Support evaluating individual window table-valued function

JING ZHANG created FLINK-23999: -- Summary: Support evaluating individual window table-valued function Key: FLINK-23999 URL: https://issues.apache.org/jira/browse/FLINK-23999 Project: Flink Issue

[jira] [Created] (FLINK-23997) SQL windowing table-valued function improvement

JING ZHANG created FLINK-23997: -- Summary: SQL windowing table-valued function improvement Key: FLINK-23997 URL: https://issues.apache.org/jira/browse/FLINK-23997 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23886) An exception is thrown out when recover job timers from savepoint file

JING ZHANG created FLINK-23886: -- Summary: An exception is thrown out when recover job timers from savepoint file Key: FLINK-23886 URL: https://issues.apache.org/jira/browse/FLINK-23886 Project: Flink

Re: Were Bundles meant to be internal?

assed in you case. Best, JING ZHANG David Anderson 于2021年8月19日周四 下午10:15写道： > Most of the table/bundle related classes such as > MapBundleFunction, MapBundleOperator, and CountBundleTrigger aren't marked > as either @Internal or @Public. What was the intention? > > I ask be

[jira] [Created] (FLINK-23751) Testing Window Top-N after Windowing TVF

JING ZHANG created FLINK-23751: -- Summary: Testing Window Top-N after Windowing TVF Key: FLINK-23751 URL: https://issues.apache.org/jira/browse/FLINK-23751 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23750) Add document for Window Top-N after Windowing TVF

JING ZHANG created FLINK-23750: -- Summary: Add document for Window Top-N after Windowing TVF Key: FLINK-23750 URL: https://issues.apache.org/jira/browse/FLINK-23750 Project: Flink Issue Type

[jira] [Created] (FLINK-23749) Testing Window Join

JING ZHANG created FLINK-23749: -- Summary: Testing Window Join Key: FLINK-23749 URL: https://issues.apache.org/jira/browse/FLINK-23749 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-23748) Testing session window

JING ZHANG created FLINK-23748: -- Summary: Testing session window Key: FLINK-23748 URL: https://issues.apache.org/jira/browse/FLINK-23748 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-23747) Teting Window TVF offset

JING ZHANG created FLINK-23747: -- Summary: Teting Window TVF offset Key: FLINK-23747 URL: https://issues.apache.org/jira/browse/FLINK-23747 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

JING ZHANG created FLINK-23687: -- Summary: Add Sql query hint to enable LookupJoin shuffle by join key of left input Key: FLINK-23687 URL: https://issues.apache.org/jira/browse/FLINK-23687 Project: Flink

[jira] [Created] (FLINK-23650) A sql contains 'Case when' could not run successfully when choose Hive Dialect

JING ZHANG created FLINK-23650: -- Summary: A sql contains 'Case when' could not run successfully when choose Hive Dialect Key: FLINK-23650 URL: https://issues.apache.org/jira/browse/FLINK-23650

[jira] [Created] (FLINK-23638) Field names are not kept after apply ProjectToWindowRule#ProjectToLogicalProjectAndWindowRule

JING ZHANG created FLINK-23638: -- Summary: Field names are not kept after apply ProjectToWindowRule#ProjectToLogicalProjectAndWindowRule Key: FLINK-23638 URL: https://issues.apache.org/jira/browse/FLINK-23638

[jira] [Created] (FLINK-23582) Add document for session window

JING ZHANG created FLINK-23582: -- Summary: Add document for session window Key: FLINK-23582 URL: https://issues.apache.org/jira/browse/FLINK-23582 Project: Flink Issue Type: Sub-task

Re: [VOTE] Release 1.12.5, release candidate #3

c.tgz <https://dist.apache.org/repos/dist/dev/flink/flink-1.12.5-rc3/flink-1.12.5-src.tgz> Best, JING ZHANG Dian Fu 于2021年8月2日周一 上午9:59写道： > +1 (binding) > > - checked the website PR > - verified the signatures and checksum > - Installed the Python wheel package of Python 3.8 on MacO

[jira] [Created] (FLINK-23565) Window TVF Supports session window in runtime

JING ZHANG created FLINK-23565: -- Summary: Window TVF Supports session window in runtime Key: FLINK-23565 URL: https://issues.apache.org/jira/browse/FLINK-23565 Project: Flink Issue Type: Sub

Re: [VOTE] Release 1.11.4, release candidate #1

Thanks @godfrey for driving this. +1 (non-binding) 1. built from source code flink-1.11.4-src.tgz succeeded 2. Started a local Flink cluster, ran the WordCount example, WebUI looks good, no suspicious output/lo

[jira] [Created] (FLINK-23554) SqlCli throws an exception and hang

JING ZHANG created FLINK-23554: -- Summary: SqlCli throws an exception and hang Key: FLINK-23554 URL: https://issues.apache.org/jira/browse/FLINK-23554 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23544) Window TVF Supports session window

JING ZHANG created FLINK-23544: -- Summary: Window TVF Supports session window Key: FLINK-23544 URL: https://issues.apache.org/jira/browse/FLINK-23544 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23543) Window TVF Supports session window

JING ZHANG created FLINK-23543: -- Summary: Window TVF Supports session window Key: FLINK-23543 URL: https://issues.apache.org/jira/browse/FLINK-23543 Project: Flink Issue Type: Bug

Re: Still receiving these emails.. please unsubscribe me

...@flink.apache.org For more information, please go to [1]. [1] https://flink.apache.org/community.html Best, JING ZHANG R Bhaaagi 于2021年7月23日周五 下午5:45写道： > Hi Team, > > Please unsubscribe me from all these emails > > On Fri, 23 Jul 2021 at 2:19 PM, LINZ, Arnaud >

[jira] [Created] (FLINK-23414) Split Match_ROWTIME return type converter into a separator class

JING ZHANG created FLINK-23414: -- Summary: Split Match_ROWTIME return type converter into a separator class Key: FLINK-23414 URL: https://issues.apache.org/jira/browse/FLINK-23414 Project: Flink

[jira] [Created] (FLINK-23413) Port RelTimeIndicatorConverter from SCALA to JAVA

JING ZHANG created FLINK-23413: -- Summary: Port RelTimeIndicatorConverter from SCALA to JAVA Key: FLINK-23413 URL: https://issues.apache.org/jira/browse/FLINK-23413 Project: Flink Issue Type

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yuan Mei

Congratulations, Yuan! Rui Li 于2021年7月8日周四 上午10:52写道： > Congratulations Yuan! > > On Thu, Jul 8, 2021 at 10:51 AM Yun Gao > wrote: > > > Congratulations Yuan! > > > > Best, > > Yun > > > > > > > > --Original Mail -- > > Sender:Zhilong Hong > > Send Date:Thu Jul

Re: [VOTE] Release 1.12.5, release candidate #1

n some e2e sql queries using SQL Client, query result is expected. 4. Repeat Step 2 and 3 with flink-1.12.5-bin-scala_2.11.tgz <https://dist.apache.org/repos/dist/dev/flink/flink-1.12.5-rc1/flink-1.12.5-bin-scala_2.11.tgz> Best, JING ZHANG Yang Wang 于2021年7月7日周三 上午11:36写道： >

Re: [VOTE] Release 1.13.2, release candidate #1

run some e2e sql queries using SQL Client, query result is expected. 5. Repeat Step 3 and 4 with flink-1.13.2-bin-scala_2.11.tgz <https://dist.apache.org/repos/dist/dev/flink/flink-1.13.2-rc1/flink-1.13.2-bin-scala_2.11.tgz> Best regards, JING ZHANG Xintong Song 于2021年7月7日周三 上午11:09写道： > H

[jira] [Created] (FLINK-23287) Create user document for Window Join in SQL

JING ZHANG created FLINK-23287: -- Summary: Create user document for Window Join in SQL Key: FLINK-23287 URL: https://issues.apache.org/jira/browse/FLINK-23287 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23286) Create user document for Window Join in SQL

JING ZHANG created FLINK-23286: -- Summary: Create user document for Window Join in SQL Key: FLINK-23286 URL: https://issues.apache.org/jira/browse/FLINK-23286 Project: Flink Issue Type

Re: [ANNOUNCE] New PMC member: Guowei Ma

Congratulations, Guowei Ma! Best regards, JING ZHANG Zakelly Lan 于2021年7月7日周三 上午10:30写道： > Congratulations, Guowei! > > Best, > Zakelly > > On Wed, Jul 7, 2021 at 10:24 AM tison wrote: > > > Congrats! NB. > > > > Best, > > tison

Re: [ANNOUNCE] New Apache Flink Committer - Yang Wang

Congratulations! Yang Wang! Best regards, JING ZHANG Zakelly Lan 于2021年7月7日周三 上午10:31写道： > Congrats & well deserved, Yang Wang! > > Best, > Zakelly > > On Wed, Jul 7, 2021 at 10:30 AM 刘建刚 wrote: > > > Congratulations, Yang Wang. > > > > Best > &

Re: [VOTE] Release 1.13.2, release candidate #1

/log 4. Started cluster and run some e2e sql queries using SQL Client, query result is expected. 5. Repeat Step 3 and 4 with flink-1.13.2-bin-scala_2.11.tgz <https://dist.apache.org/repos/dist/dev/flink/flink-1.13.2-rc1/flink-1.13.2-bin-scala_2.11.tgz> Best regards, JING ZHANG Zakelly Lan 于20

[jira] [Created] (FLINK-23282) Compile error in `Streaming Java` module: MailboxProcessor.java:[217,13]

JING ZHANG created FLINK-23282: -- Summary: Compile error in `Streaming Java` module: MailboxProcessor.java:[217,13] Key: FLINK-23282 URL: https://issues.apache.org/jira/browse/FLINK-23282 Project: Flink

[jira] [Created] (FLINK-23247) Materialize rowtime attribute fields of regular join's inputs

JING ZHANG created FLINK-23247: -- Summary: Materialize rowtime attribute fields of regular join's inputs Key: FLINK-23247 URL: https://issues.apache.org/jira/browse/FLINK-23247 Project:

[jira] [Created] (FLINK-23246) Refactor the time indicator materialization

JING ZHANG created FLINK-23246: -- Summary: Refactor the time indicator materialization Key: FLINK-23246 URL: https://issues.apache.org/jira/browse/FLINK-23246 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23245) Materialize rowtime attribute fields of regular join's inputs

JING ZHANG created FLINK-23245: -- Summary: Materialize rowtime attribute fields of regular join's inputs Key: FLINK-23245 URL: https://issues.apache.org/jira/browse/FLINK-23245 Project:

[jira] [Created] (FLINK-23244) Refactor the time indicator materialization

JING ZHANG created FLINK-23244: -- Summary: Refactor the time indicator materialization Key: FLINK-23244 URL: https://issues.apache.org/jira/browse/FLINK-23244 Project: Flink Issue Type

Re: [VOTE] Release 1.13.2, release candidate #1

Hi yun, Website pull request lists[6] and JIRA release notes[1] both contain unfinished JIRA (such as FLINK-22955). Is it expected? Best regards, JING ZHANG Dawid Wysakowicz 于2021年7月2日周五 下午9:05写道： > +1 (binding) > >- verified signatures and checksums >- reviewed the ann

Re: [VOTE] FLIP-147: Support Checkpoint After Tasks Finished

+1 (binding) Arvid Heise 于2021年7月1日周四 下午3:10写道： > Looks good: +1 (binding) > > On Tue, Jun 29, 2021 at 5:06 AM 刘建刚 wrote: > > > +1 (binding) > > > > Best > > liujiangang > > > > Piotr Nowojski 于2021年6月29日周二 上午2:05写道： > > > > > +1 (binding) > > > > > > Piotrek > > > > > > pon., 28 cze 2021 o 1

[DISCUSS] Better user experience in the WindowAggregate upon Changelog (contains update message)

-fire.delay` to 0s. And in the later version, we deprecate `table.exec.emit.late-fire.delay` and `table.exec.emit.allow-lateness `. Please let me know what you think about the issue. Thank you. [1] https://issues.apache.org/jira/browse/FLINK-22781 Best regards, JING ZHANG

Re: [DISCUSS] Do not merge PRs with "unrelated" test failures.

gt; > > > > > > > > > > > > > > > On Thu, 24 Jun 2021 at 10:04, Xintong Song < > > > > tonysong...@gmail.com> > > > > > > > > wrote: > > > > > > > > > > > > > > > > > > > Thanks all for the feedback. > &g

Re: [Question] Why doesn't Flink use Calcite adapter?

correct me if I'm wrong. Best regards, JING ZHANG [1] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sourcessinks/ Israel Ekpo 于2021年6月28日周一 上午8:28写道： > Maybe this question was better addressed to the DEV list. > > On Fri, Jun 25, 2021 at 11:57 PM

Re: [VOTE] FLIP-169: DataStream API for Fine-Grained Resource Requirements

+1 (binding) Thanks Yangze for driving the issue. Best regards, JING ZHANG Yang Wang 于2021年6月24日周四 下午1:51写道： > +1 (non-binding) > > Best, > Yang > > 刘建刚 于2021年6月24日周四 下午12:17写道： > > > +1 (binding) > > > > Thanks > > liujiangang > >

Re: [DISCUSS] Do not merge PRs with "unrelated" test failures.

uture. Best regards, JING ZHANG Stephan Ewen 于2021年6月23日周三 下午8:16写道： > +1 to Xintong's proposal > > On Wed, Jun 23, 2021 at 1:53 PM Till Rohrmann > wrote: > > > I would first try to not introduce the exception for local builds. It > makes > > it quite hard for oth

Re: [DISCUSS] Feedback Collection Jira Bot

hesnay about not un-assign an issue if a PR is open. Besides, Could assignees remove the "stale-assigned" tag by themself? It seems assignees have no permission to delete the tag if the issue is not created by themselves. Best regards, JING ZHANG Konstantin Knauf 于2021年6月23日周三 下午4:17

[jira] [Created] (FLINK-23079) HiveTableSinkITCase fails

JING ZHANG created FLINK-23079: -- Summary: HiveTableSinkITCase fails Key: FLINK-23079 URL: https://issues.apache.org/jira/browse/FLINK-23079 Project: Flink Issue Type: Bug Components

Re: [VOTE] FLIP-129 Register sources/sinks in Table API

+1 (binding) Best regards, JING ZHANG Jingsong Li 于2021年6月22日周二 上午10:11写道： > +1 (binding) > > Thanks for driving. > > Best, > Jingsong > > On Tue, Jun 22, 2021 at 12:07 AM Jark Wu wrote: > > > +1 (binding) > > > > Best, > > Jark > &

[jira] [Created] (FLINK-23055) Add document for Window TVF offset

JING ZHANG created FLINK-23055: -- Summary: Add document for Window TVF offset Key: FLINK-23055 URL: https://issues.apache.org/jira/browse/FLINK-23055 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23023) Support offset in window TVF

JING ZHANG created FLINK-23023: -- Summary: Support offset in window TVF Key: FLINK-23023 URL: https://issues.apache.org/jira/browse/FLINK-23023 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23015) Implement streaming window Deduplicate operator

JING ZHANG created FLINK-23015: -- Summary: Implement streaming window Deduplicate operator Key: FLINK-23015 URL: https://issues.apache.org/jira/browse/FLINK-23015 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-23014) Support streaming window Deduplicate in planner

JING ZHANG created FLINK-23014: -- Summary: Support streaming window Deduplicate in planner Key: FLINK-23014 URL: https://issues.apache.org/jira/browse/FLINK-23014 Project: Flink Issue Type: Sub

Re: [ANNOUNCE] New PMC member: Arvid Heise

Congratulations, Arvid! Nicholas Jiang 于2021年6月16日周三 下午7:25写道： > Congratulations, Arvid! > > > > -- > Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/ >

Re: [ANNOUNCE] New PMC member: Xintong Song

Congratulations, Xintong! Jiayi Liao 于2021年6月16日周三 下午7:30写道： > > > > > > Congratulations Xintong! > > > > On Wed, Jun 16, 2021 at 7:24 PM Nicholas Jiang > > wrote: > > > >> Congratulations, Xintong! > >> > >> > >> > >> -- > >> S

Re: [DISCUSS] FLIP-129 (Update): Registering sources/sinks on Table API without SQL

Thanks Ingo for starting this discussion. Big +1 for this feature. Looking forward to the feature. Best regards, JING ZHANG Jark Wu 于2021年6月15日周二 下午3:48写道： > Thanks Ingo for picking up this FLIP. > > FLIP-129 is an important piece to have a complete Table SQL story, > and use

Re: Flink TM Heartbeat Timeout

Hi Lu, Xintong has a professional analysis about TM heartbeat timeout in a historical mail[1], please check if it could help. [1] http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Heartbeat-of-TaskManager-timed-out-td36228.html Best regards, JING ZHANG Lu Niu 于2021年6月11日周五 上午

Re: Add control mode for flink

careful design. [ http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Dynamic-configuration-of-Flink-checkpoint-interval-td44059.html ] Best regards, JING ZHANG 刘建刚 于2021年6月8日周二 上午10:01写道： > Thanks Xintong Song for the detailed supplement. Since flink is > long-running,

Re: [Discuss] Planning Flink 1.14

ot support state compatibility yet. Best regards, JING ZHANG Prasanna kumar 于2021年6月4日周五 下午2:27写道： > Hi all, > > We are using Flink for our eventing system. Overall we are very happy with > the tech, documentation and community support and quick replies in mails. > > My last 1 y

Re: [Discuss] Planning Flink 1.14

wing+table-valued+function#FLIP145:SupportSQLwindowingtablevaluedfunction-CumulatingWindows Best regards, JING ZHANG Xintong Song 于2021年6月2日周三 下午6:45写道： > Hi all, > > As 1.13 has been released for a while, I think it is a good time to start > planning for the 1.14 release cycle. > &

Re: [DISCUSS] SQL CTAS Syntax

en/create-table-select.html, the result is a bit unexpected, I wonder What the behavior would be in Flink. [image: image.png] Best, JING ZHANG

[jira] [Created] (FLINK-15077) Support Semi/Anti LookupJoin in Blink planner

Jing Zhang created FLINK-15077: -- Summary: Support Semi/Anti LookupJoin in Blink planner Key: FLINK-15077 URL: https://issues.apache.org/jira/browse/FLINK-15077 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14946) Retraction infer would result in bad plan under corner case in blink planner

Jing Zhang created FLINK-14946: -- Summary: Retraction infer would result in bad plan under corner case in blink planner Key: FLINK-14946 URL: https://issues.apache.org/jira/browse/FLINK-14946 Project

[jira] [Created] (FLINK-14875) Set Unmodifiable collection serializer of Kryo in Flink code

Jing Zhang created FLINK-14875: -- Summary: Set Unmodifiable collection serializer of Kryo in Flink code Key: FLINK-14875 URL: https://issues.apache.org/jira/browse/FLINK-14875 Project: Flink

[jira] [Created] (FLINK-13582) Improve the implementation of LISTAGG in Blink planner to remove delimiter from state

Jing Zhang created FLINK-13582: -- Summary: Improve the implementation of LISTAGG in Blink planner to remove delimiter from state Key: FLINK-13582 URL: https://issues.apache.org/jira/browse/FLINK-13582

[jira] [Created] (FLINK-13529) Verify and correct agg function's semantic for Blink planner

Jing Zhang created FLINK-13529: -- Summary: Verify and correct agg function's semantic for Blink planner Key: FLINK-13529 URL: https://issues.apache.org/jira/browse/FLINK-13529 Project:

[jira] [Created] (FLINK-13509) Support `is not distinct from ` and similar syntax in LookupJoin

Jing Zhang created FLINK-13509: -- Summary: Support `is not distinct from ` and similar syntax in LookupJoin Key: FLINK-13509 URL: https://issues.apache.org/jira/browse/FLINK-13509 Project: Flink

[jira] [Created] (FLINK-13503) Correct the behavior of `JDBCLookupFunction`

Jing Zhang created FLINK-13503: -- Summary: Correct the behavior of `JDBCLookupFunction` Key: FLINK-13503 URL: https://issues.apache.org/jira/browse/FLINK-13503 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-13433) Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value

Jing Zhang created FLINK-13433: -- Summary: Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value Key: FLINK-13433 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-13321) Join a udf with constant arguments or without argument in TableAPI query of Blink Planner does not work now

Jing Zhang created FLINK-13321: -- Summary: Join a udf with constant arguments or without argument in TableAPI query of Blink Planner does not work now Key: FLINK-13321 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-13314) Correct resultType of some PlannerExpression when operands contains DecimalTypeInfo or BigDecimalTypeInfo in Blink planner

Jing Zhang created FLINK-13314: -- Summary: Correct resultType of some PlannerExpression when operands contains DecimalTypeInfo or BigDecimalTypeInfo in Blink planner Key: FLINK-13314 URL: https://issues.apache.org

[jira] [Created] (FLINK-13301) Some PlannerExpression resultType is not consistent with Calcite Type inference

Jing Zhang created FLINK-13301: -- Summary: Some PlannerExpression resultType is not consistent with Calcite Type inference Key: FLINK-13301 URL: https://issues.apache.org/jira/browse/FLINK-13301 Project

[jira] [Created] (FLINK-13218) '*.count not supported in TableApi query

Jing Zhang created FLINK-13218: -- Summary: '*.count not supported in TableApi query Key: FLINK-13218 URL: https://issues.apache.org/jira/browse/FLINK-13218 Project: Flink Issue Type:

[jira] [Created] (FLINK-13213) MinIdleStateRetentionTime/MaxIdleStateRetentionTime in TableConfig will be removed after call toAppendStream/toRetractStream without QueryConfig parameters

Jing Zhang created FLINK-13213: -- Summary: MinIdleStateRetentionTime/MaxIdleStateRetentionTime in TableConfig will be removed after call toAppendStream/toRetractStream without QueryConfig parameters Key: FLINK-13213

[jira] [Created] (FLINK-13107) Port TableApi IT and UT

Jing Zhang created FLINK-13107: -- Summary: Port TableApi IT and UT Key: FLINK-13107 URL: https://issues.apache.org/jira/browse/FLINK-13107 Project: Flink Issue Type: Task Components

[jira] [Created] (FLINK-13071) QueryOperationConverter in Blink planner support add kinds of QueryOperations.

Jing Zhang created FLINK-13071: -- Summary: QueryOperationConverter in Blink planner support add kinds of QueryOperations. Key: FLINK-13071 URL: https://issues.apache.org/jira/browse/FLINK-13071 Project

[jira] [Created] (FLINK-12810) Support to run a TableAPI query like 'table.select('a, 'b, 'c)'

Jing Zhang created FLINK-12810: -- Summary: Support to run a TableAPI query like 'table.select('a, 'b, 'c)' Key: FLINK-12810 URL: https://issues.apache.org/jira/browse/FLINK-12810

[jira] [Created] (FLINK-12496) Support translation from StreamExecGroupWindowAggregate to StreamTransformation.

Jing Zhang created FLINK-12496: -- Summary: Support translation from StreamExecGroupWindowAggregate to StreamTransformation. Key: FLINK-12496 URL: https://issues.apache.org/jira/browse/FLINK-12496 Project

[jira] [Created] (FLINK-12374) Support translation from StreamExecTableSourceScan/BatchExecTableSourceScan to StreamTransformation.

Jing Zhang created FLINK-12374: -- Summary: Support translation from StreamExecTableSourceScan/BatchExecTableSourceScan to StreamTransformation. Key: FLINK-12374 URL: https://issues.apache.org/jira/browse/FLINK-12374

[jira] [Created] (FLINK-12348) Use TableConfig in api module to replace TableConfig in blink-planner module.

Jing Zhang created FLINK-12348: -- Summary: Use TableConfig in api module to replace TableConfig in blink-planner module. Key: FLINK-12348 URL: https://issues.apache.org/jira/browse/FLINK-12348 Project

[jira] [Created] (FLINK-12307) Support translation from StreamExecWindowJoin to StreamTransformation.

Jing Zhang created FLINK-12307: -- Summary: Support translation from StreamExecWindowJoin to StreamTransformation. Key: FLINK-12307 URL: https://issues.apache.org/jira/browse/FLINK-12307 Project: Flink

[jira] [Created] (FLINK-12208) Introduce Sort / TemporalSort / SortLimit/ Limit operators for blink streaming runtime

Jing Zhang created FLINK-12208: -- Summary: Introduce Sort / TemporalSort / SortLimit/ Limit operators for blink streaming runtime Key: FLINK-12208 URL: https://issues.apache.org/jira/browse/FLINK-12208

[jira] [Created] (FLINK-12017) Support to run a sql query : 'SELECT * FROM source'

Jing Zhang created FLINK-12017: -- Summary: Support to run a sql query : 'SELECT * FROM source' Key: FLINK-12017 URL: https://issues.apache.org/jira/browse/FLINK-12017 Project: Flink

[jira] [Created] (FLINK-11993) Introduce partitionable filesystem sink

Jing Zhang created FLINK-11993: -- Summary: Introduce partitionable filesystem sink Key: FLINK-11993 URL: https://issues.apache.org/jira/browse/FLINK-11993 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-11975) Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)'

Jing Zhang created FLINK-11975: -- Summary: Support to run a sql query : 'SELECT * FROM (VALUES (1, 2, 3)) T(a, b, c)' Key: FLINK-11975 URL: https://issues.apache.org/jira/browse/FLINK-11975

[jira] [Created] (FLINK-11946) Introduce Exec nodes

Jing Zhang created FLINK-11946: -- Summary: Introduce Exec nodes Key: FLINK-11946 URL: https://issues.apache.org/jira/browse/FLINK-11946 Project: Flink Issue Type: Task Reporter: Jing

<    1   2