[jira] [Updated] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-21978: --- Fix Version/s: 1.13.0 > Disable cast conversion between Numeric type and TIMESTAMP_LTZ type >

[jira] [Closed] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21978. -- Resolution: Fixed Temporary disabled: cb6b5c1282f2d7ac226fa5c04ff650107382bb6d > Disable cast

[jira] [Closed] (FLINK-21984) Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

[ https://issues.apache.org/jira/browse/FLINK-21984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21984. -- Resolution: Fixed fixed: 1af31a5648f4ecf15bd850a12a41f051ff6c15d2 > Change precision argument from

[jira] [Commented] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

[ https://issues.apache.org/jira/browse/FLINK-20412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309852#comment-17309852 ] Kurt Young commented on FLINK-20412: [~sewen] I will ping Caizhi  > Collect Result Fetching

[jira] [Closed] (FLINK-21947) Support TIMESTAMP_LTZ type in CSV format

[ https://issues.apache.org/jira/browse/FLINK-21947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21947. -- Resolution: Fixed fixed: a5aaa0e605eb4966b5d73c987ea4d9d0bc852c6d > Support TIMESTAMP_LTZ type in

[jira] [Commented] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309842#comment-17309842 ] Kurt Young commented on FLINK-21978: [~hackergin] When you cast timestamp to BIGINT, which precision

[jira] [Commented] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309408#comment-17309408 ] Kurt Young commented on FLINK-21978: We can also explain this a bit more in the description that

[jira] [Commented] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309406#comment-17309406 ] Kurt Young commented on FLINK-21978: IMO being consistent within Flink is more important than

[jira] [Closed] (FLINK-20563) Support built-in functions for Hive versions prior to 1.2.0

[ https://issues.apache.org/jira/browse/FLINK-20563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-20563. -- Assignee: Rui Li Resolution: Fixed fixed via: 2aab2ef8c259ec35231a42571766d480e735f84e >

[jira] [Commented] (FLINK-21978) Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

[ https://issues.apache.org/jira/browse/FLINK-21978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309095#comment-17309095 ] Kurt Young commented on FLINK-21978: cc [~twalthr] , what do you think about this? > Disable cast

[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=17304789#comment-17304789 ] Kurt Young commented on FLINK-21871: +1 > Support watermark for Hive and Filesystem streaming

[jira] [Closed] (FLINK-21622) Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

[ https://issues.apache.org/jira/browse/FLINK-21622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21622. -- Fix Version/s: 1.13.0 Resolution: Fixed fixed via: c2f74dc8a33f7bcd859a71905877b0a9a70bb76a >

[jira] [Closed] (FLINK-21624) Correct FLOOR/CEIL (TIMESTAMP/TIMESTAMP_LTZ/DATE TO WEEK) functions

[ https://issues.apache.org/jira/browse/FLINK-21624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21624. -- Fix Version/s: 1.13.0 Resolution: Fixed fixed with: 615d5d150abdeab89d15f6830177eac238bdc2fc

[jira] [Updated] (FLINK-11894) PagedTypeSerializer.serializeToPages return type should be void

[ https://issues.apache.org/jira/browse/FLINK-11894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11894: --- Priority: Minor (was: Major) > PagedTypeSerializer.serializeToPages return type should be void >

[jira] [Updated] (FLINK-11894) PagedTypeSerializer.serializeToPages return type should be void

[ https://issues.apache.org/jira/browse/FLINK-11894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11894: --- Summary: PagedTypeSerializer.serializeToPages return type should be void (was:

[jira] [Assigned] (FLINK-21191) Support reducing buffer for upsert-kafka sink

[ https://issues.apache.org/jira/browse/FLINK-21191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-21191: -- Assignee: Shengkai Fang > Support reducing buffer for upsert-kafka sink >

[jira] [Commented] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288241#comment-17288241 ] Kurt Young commented on FLINK-21236: +1 from my side as well.  Another option is remove all sub

[jira] [Commented] (FLINK-21375) Refactor HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-21375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288170#comment-17288170 ] Kurt Young commented on FLINK-21375: Please keep this article in mind:

[jira] [Comment Edited] (FLINK-21162) FLINK SQL IF function semantic incorrect

[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288143#comment-17288143 ] Kurt Young edited comment on FLINK-21162 at 2/22/21, 2:54 AM: -- I don't

[jira] [Commented] (FLINK-21162) FLINK SQL IF function semantic incorrect

[ https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17288143#comment-17288143 ] Kurt Young commented on FLINK-21162: I don't we should change this behavior. I checked all the

[jira] [Assigned] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-21236: -- Assignee: Nicholas Jiang > Don't explicitly use HeapMemorySegment in raw format serde >

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278479#comment-17278479 ] Kurt Young commented on FLINK-20663: [~xintongsong] Then I think the result will be even worse.  >

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278469#comment-17278469 ] Kurt Young commented on FLINK-20663: [~xintongsong]  Will it affect all interfaces of MemorySegment

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277896#comment-17277896 ] Kurt Young commented on FLINK-20663: {quote}Which patch did you test and what does it do 

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277577#comment-17277577 ] Kurt Young commented on FLINK-20663: I'm fine to add safety net for WrappedBuffer, read-write lock,

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17277032#comment-17277032 ] Kurt Young commented on FLINK-20663: [~trohrmann] Things are becoming more interesting. If I

[jira] [Assigned] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-21236: -- Assignee: (was: Kurt Young) > Don't explicitly use HeapMemorySegment in raw format serde

[jira] [Assigned] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-21236: -- Assignee: Kurt Young > Don't explicitly use HeapMemorySegment in raw format serde >

[jira] [Updated] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-21236: --- Summary: Don't explicitly use HeapMemorySegment in raw format serde (was: Don't explicitly use

[jira] [Created] (FLINK-21236) Don't explicitly use HeapMemorySegment in row format serde

Kurt Young created FLINK-21236: -- Summary: Don't explicitly use HeapMemorySegment in row format serde Key: FLINK-21236 URL: https://issues.apache.org/jira/browse/FLINK-21236 Project: Flink Issue

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276849#comment-17276849 ] Kurt Young commented on FLINK-20663: One more comment to hint that we are pretty safe when using

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276827#comment-17276827 ] Kurt Young commented on FLINK-20663: [~xintongsong] You are correct.  Regarding to the lock part,

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276801#comment-17276801 ] Kurt Young commented on FLINK-20663: [~xintongsong] It doesn't need to be such complex. We can still

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276776#comment-17276776 ] Kurt Young commented on FLINK-17793: I'm curious about `ResolvedSchema`. What exactly properties

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276298#comment-17276298 ] Kurt Young commented on FLINK-20663: Thanks [~TsReaper] for the testing. [~trohrmann] I see

[jira] [Updated] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-20663: --- Priority: Critical (was: Major) > Managed memory may not be released in time when operators use

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17274107#comment-17274107 ] Kurt Young commented on FLINK-20663: {quote}Before jumping to conclusions, can we verify whether we

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273247#comment-17273247 ] Kurt Young commented on FLINK-20663: IIRC in the past, users of managed memory (operators, data

[jira] [Commented] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272763#comment-17272763 ] Kurt Young commented on FLINK-20663: It's not necessarily be OLAP scenario, but normal batch job

[jira] [Updated] (FLINK-20663) Managed memory may not be released in time when operators use managed memory frequently

[ https://issues.apache.org/jira/browse/FLINK-20663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-20663: --- Fix Version/s: 1.12.2 > Managed memory may not be released in time when operators use managed

[jira] [Commented] (FLINK-21013) Blink planner does not ingest timestamp into StreamRecord

[ https://issues.apache.org/jira/browse/FLINK-21013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271973#comment-17271973 ] Kurt Young commented on FLINK-21013: Yes, I also think this bug deserved to be back ported.

[jira] [Assigned] (FLINK-20961) Flink throws NullPointerException for tables created from DataStream with no assigned timestamps and watermarks

[ https://issues.apache.org/jira/browse/FLINK-20961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-20961: -- Assignee: Yuval Itzchakov > Flink throws NullPointerException for tables created from

[jira] [Commented] (FLINK-17111) Support SHOW VIEWS in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250137#comment-17250137 ] Kurt Young commented on FLINK-17111: [~knaufk] Could you try 1.11 with SQL CLI for this feature? I

[jira] [Closed] (FLINK-19649) In Flink's module flink-sql-parser/sqlCreateTable/unparse, the tables without columns are not supported.

[ https://issues.apache.org/jira/browse/FLINK-19649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-19649. -- Fix Version/s: 1.12.0 Assignee: gsralex Resolution: Fixed fixed in 

[jira] [Commented] (FLINK-19649) In Flink's module flink-sql-parser/sqlCreateTable/unparse, the tables without columns are not supported.

[ https://issues.apache.org/jira/browse/FLINK-19649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214466#comment-17214466 ] Kurt Young commented on FLINK-19649: Good catch, feel free to open a pull request [~gsralex] > In

[jira] [Commented] (FLINK-19063) Support join late event from dimension table side in temporal table join

[ https://issues.apache.org/jira/browse/FLINK-19063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187380#comment-17187380 ] Kurt Young commented on FLINK-19063: We can probably rely on watermark when doing event time

[jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode

[ https://issues.apache.org/jira/browse/FLINK-13735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13735: --- Fix Version/s: 1.12.0 > Support session window with blink planner in batch mode >

[jira] [Commented] (FLINK-18782) Retain the column name when converting a Table to a DataStream

[ https://issues.apache.org/jira/browse/FLINK-18782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185061#comment-17185061 ] Kurt Young commented on FLINK-18782: [~atri] Thanks for your interest. Before going to code details,

[jira] [Commented] (FLINK-17397) FileSystemTableFactory supports LookupableTableSource

[ https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183227#comment-17183227 ] Kurt Young commented on FLINK-17397: {quote}I think this issue is to support the same feature as

[jira] [Commented] (FLINK-17397) Filesystem support lookup table source

[ https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17182978#comment-17182978 ] Kurt Young commented on FLINK-17397: I'm kind of confused what exactly does "support lookup source"

[jira] [Updated] (FLINK-16295) Optimize BinaryString.copy to not materialize if there is javaObject

[ https://issues.apache.org/jira/browse/FLINK-16295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16295: --- Labels: starter (was: ) > Optimize BinaryString.copy to not materialize if there is javaObject >

[jira] [Updated] (FLINK-18607) Give the maven modules human readable names.

[ https://issues.apache.org/jira/browse/FLINK-18607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18607: --- Component/s: Build System > Give the maven modules human readable names. >

[jira] [Closed] (FLINK-18607) Give the maven modules human readable names.

[ https://issues.apache.org/jira/browse/FLINK-18607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-18607. -- Fix Version/s: 1.12.0 Assignee: Niels Basjes Resolution: Fixed master: 

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159797#comment-17159797 ] Kurt Young commented on FLINK-16048: I'm not 100% sure but it looks very likely that the description

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159788#comment-17159788 ] Kurt Young commented on FLINK-16048: Fields declared in DDL should be the ground truth. We also need

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159786#comment-17159786 ] Kurt Young commented on FLINK-16048: [~dwysakowicz] isn't it DDL's job to determine the schema that

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159743#comment-17159743 ] Kurt Young commented on FLINK-16048: I have question about whether *schema-string* is required.

[jira] [Updated] (FLINK-18358) TableEnvironmentITCase.testSqlUpdateAndToDataSetWithTableSource:245 unstable: result mismatch

[ https://issues.apache.org/jira/browse/FLINK-18358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18358: --- Component/s: (was: Table SQL / Planner) Table SQL / Legacy Planner >

[jira] [Assigned] (FLINK-18325) NPE may throw when use SqlDataTypeSpec#getNullable

[ https://issues.apache.org/jira/browse/FLINK-18325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18325: -- Assignee: Jiatao Tao > NPE may throw when use SqlDataTypeSpec#getNullable >

[jira] [Commented] (FLINK-18325) NPE may throw when use SqlDataTypeSpec#getNullable

[ https://issues.apache.org/jira/browse/FLINK-18325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136625#comment-17136625 ] Kurt Young commented on FLINK-18325: Thanks [~Aron.tao], assigning this to you. > NPE may throw

[jira] [Closed] (FLINK-15950) Remove registration of TableSource/TableSink in ConnectTableDescriptor

[ https://issues.apache.org/jira/browse/FLINK-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-15950. -- Resolution: Fixed > Remove registration of TableSource/TableSink in ConnectTableDescriptor >

[jira] [Closed] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16375. -- Resolution: Fixed 1.11.0: c72799933a0d5ac02dfb9437bafa1b5ef38619f9 > Reintroduce

[jira] [Commented] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133139#comment-17133139 ] Kurt Young commented on FLINK-16375: BTW, how about we only revert this in 1.11 branch? I don't see

[jira] [Updated] (FLINK-15950) Remove registration of TableSource/TableSink in ConnectTableDescriptor

[ https://issues.apache.org/jira/browse/FLINK-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15950: --- Description: This ticket would track the removal of direct TableSource/TableSink registration to

[jira] [Updated] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16375: --- Component/s: (was: Documentation) > Reintroduce registerTableSource/Sink methods for table env

[jira] [Assigned] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16375: -- Assignee: Kurt Young > Reintroduce registerTableSource/Sink methods for table env >

[jira] [Updated] (FLINK-16375) Reintroduce registerTableSource/Sink methods for table env

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16375: --- Summary: Reintroduce registerTableSource/Sink methods for table env (was: Remove references to

[jira] [Updated] (FLINK-15950) Remove registration of TableSource/TableSink in ConnectTableDescriptor

[ https://issues.apache.org/jira/browse/FLINK-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15950: --- Summary: Remove registration of TableSource/TableSink in ConnectTableDescriptor (was: Remove

[jira] [Commented] (FLINK-16375) Remove references to registerTableSource/Sink methods from documentation

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133108#comment-17133108 ] Kurt Young commented on FLINK-16375: I'm also ok for reintroduce them, dropping a method without

[jira] [Updated] (FLINK-17521) Remove `com.ibm.icu` dependency from table-common

[ https://issues.apache.org/jira/browse/FLINK-17521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17521: --- Parent: (was: FLINK-16361) Issue Type: Improvement (was: Sub-task) > Remove

[jira] [Commented] (FLINK-18021) [Umbrella] Manually tests for 1.11 SQL features

[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133106#comment-17133106 ] Kurt Young commented on FLINK-18021: Closing this since all planned tests are finished, thanks all!

[jira] [Closed] (FLINK-18021) [Umbrella] Manually tests for 1.11 SQL features

[ https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-18021. -- Resolution: Fixed > [Umbrella] Manually tests for 1.11 SQL features >

[jira] [Closed] (FLINK-17105) FLIP-71: E2E view support for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17105. -- Release Note: Support view operations in both table env and sql client, including: 1. create / drop

[jira] [Updated] (FLINK-17105) FLIP-71: E2E view support for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17105: --- Component/s: (was: Table SQL / Legacy Planner) > FLIP-71: E2E view support for Flink SQL >

[jira] [Closed] (FLINK-18224) Add document about sql client's tableau result mode

[ https://issues.apache.org/jira/browse/FLINK-18224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-18224. -- Release Note: sql client added another result mode called tableau Resolution: Fixed

[jira] [Commented] (FLINK-18232) Fix Hive streaming source bugs

[ https://issues.apache.org/jira/browse/FLINK-18232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132866#comment-17132866 ] Kurt Young commented on FLINK-18232: this kind of Jira title and commit message show too less

[jira] [Updated] (FLINK-17666) Insert into partitioned table can fail with select *

[ https://issues.apache.org/jira/browse/FLINK-17666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17666: --- Priority: Critical (was: Major) > Insert into partitioned table can fail with select * >

[jira] [Assigned] (FLINK-17752) Align the timestamp format with Flink SQL types in JSON format

[ https://issues.apache.org/jira/browse/FLINK-17752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17752: -- Assignee: Shengkai Fang > Align the timestamp format with Flink SQL types in JSON format >

[jira] [Updated] (FLINK-15778) SQL Client end-to-end test for Kafka 0.10 nightly run hung on travis

[ https://issues.apache.org/jira/browse/FLINK-15778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15778: --- Component/s: (was: Table SQL / Client) > SQL Client end-to-end test for Kafka 0.10 nightly run

[jira] [Assigned] (FLINK-18161) Changing parallelism is not possible in sql-client.sh

[ https://issues.apache.org/jira/browse/FLINK-18161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18161: -- Assignee: godfrey he > Changing parallelism is not possible in sql-client.sh >

[jira] [Created] (FLINK-18224) Add document about sql client's tableau result mode

Kurt Young created FLINK-18224: -- Summary: Add document about sql client's tableau result mode Key: FLINK-18224 URL: https://issues.apache.org/jira/browse/FLINK-18224 Project: Flink Issue Type:

[jira] [Commented] (FLINK-16375) Remove references to registerTableSource/Sink methods from documentation

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128942#comment-17128942 ] Kurt Young commented on FLINK-16375: Before we have good replacement for such method, I actually

[jira] [Commented] (FLINK-18164) null <> 'str' should be true

[ https://issues.apache.org/jira/browse/FLINK-18164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127200#comment-17127200 ] Kurt Young commented on FLINK-18164: It's also incorrect to return `true` in this case, I think we

[jira] [Updated] (FLINK-18093) E2E tests manually for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18093: --- Component/s: Connectors / ElasticSearch > E2E tests manually for Elasticsearch Sink >

[jira] [Updated] (FLINK-18093) E2E tests manually for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18093: --- Priority: Blocker (was: Major) > E2E tests manually for Elasticsearch Sink >

[jira] [Updated] (FLINK-18092) E2E tests manually for HBase

[ https://issues.apache.org/jira/browse/FLINK-18092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18092: --- Component/s: Connectors / HBase > E2E tests manually for HBase > > >

[jira] [Updated] (FLINK-18092) E2E tests manually for HBase

[ https://issues.apache.org/jira/browse/FLINK-18092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-18092: --- Priority: Blocker (was: Major) > E2E tests manually for HBase > > >

[jira] [Assigned] (FLINK-17635) Add documentation about view support

[ https://issues.apache.org/jira/browse/FLINK-17635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17635: -- Assignee: Leonard Xu (was: Caizhi Weng) > Add documentation about view support >

[jira] [Assigned] (FLINK-18076) Sql client uses wrong class loader when parsing queries

[ https://issues.apache.org/jira/browse/FLINK-18076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18076: -- Assignee: Leonard Xu (was: Caizhi Weng) > Sql client uses wrong class loader when parsing

[jira] [Updated] (FLINK-17022) Flink SQL ROW_NUMBER() Exception: TableException: This calc has no useful projection and no filter. It should be removed by CalcRemoveRule.

[ https://issues.apache.org/jira/browse/FLINK-17022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17022: --- Fix Version/s: (was: 1.11.0) > Flink SQL ROW_NUMBER() Exception: TableException: This calc has

[jira] [Updated] (FLINK-17948) Sql client lost precision for Timestamp and Decimal Data type

[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17948: --- Fix Version/s: (was: 1.11.0) > Sql client lost precision for Timestamp and Decimal Data type >

[jira] [Updated] (FLINK-17895) Default value of rows-per-second in datagen can be limited

[ https://issues.apache.org/jira/browse/FLINK-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17895: --- Fix Version/s: (was: 1.11.0) > Default value of rows-per-second in datagen can be limited >

[jira] [Assigned] (FLINK-18061) TableResult#collect should return closeable iterator to avoid resource leak

[ https://issues.apache.org/jira/browse/FLINK-18061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18061: -- Assignee: godfrey he > TableResult#collect should return closeable iterator to avoid

[jira] [Assigned] (FLINK-18030) Hive UDF doesn't accept empty string literal parameter

[ https://issues.apache.org/jira/browse/FLINK-18030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18030: -- Assignee: Rui Li > Hive UDF doesn't accept empty string literal parameter >

[jira] [Assigned] (FLINK-18076) Sql client uses wrong class loader when parsing queries

[ https://issues.apache.org/jira/browse/FLINK-18076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18076: -- Assignee: Caizhi Weng > Sql client uses wrong class loader when parsing queries >

[jira] [Updated] (FLINK-16451) listagg with distinct for over window codegen error

[ https://issues.apache.org/jira/browse/FLINK-16451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16451: --- Priority: Critical (was: Major) > listagg with distinct for over window codegen error >

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17553: --- Priority: Critical (was: Major) > Constant exists in group window key leads to error:

[jira] [Updated] (FLINK-16743) [Umbrella] Introduce datagen, print, blackhole connectors

[ https://issues.apache.org/jira/browse/FLINK-16743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16743: --- Summary: [Umbrella] Introduce datagen, print, blackhole connectors (was: Introduce datagen, print,

[jira] [Updated] (FLINK-15609) Add blink built-in functions from FlinkSqlOperatorTable to BuiltInFunctionDefinitions

[ https://issues.apache.org/jira/browse/FLINK-15609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15609: --- Fix Version/s: (was: 1.11.0) > Add blink built-in functions from FlinkSqlOperatorTable to >

[jira] [Updated] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17625: --- Priority: Critical (was: Major) > Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction >

<    1   2   3   4   5   6   7   8   9   10   >