[jira] [Created] (FLINK-34403) GHA misc test cannot pass due to OOM

Benchao Li created FLINK-34403: -- Summary: GHA misc test cannot pass due to OOM Key: FLINK-34403 URL: https://issues.apache.org/jira/browse/FLINK-34403 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33533) Add documentation about performance for huge ProtoBuf definations

Benchao Li created FLINK-33533: -- Summary: Add documentation about performance for huge ProtoBuf definations Key: FLINK-33533 URL: https://issues.apache.org/jira/browse/FLINK-33533 Project: Flink

[jira] [Created] (FLINK-32547) Add missing doc for Timestamp support in ProtoBuf format

Benchao Li created FLINK-32547: -- Summary: Add missing doc for Timestamp support in ProtoBuf format Key: FLINK-32547 URL: https://issues.apache.org/jira/browse/FLINK-32547 Project: Flink Issue

[jira] [Created] (FLINK-31673) Add E2E tests for flink jdbc driver

Benchao Li created FLINK-31673: -- Summary: Add E2E tests for flink jdbc driver Key: FLINK-31673 URL: https://issues.apache.org/jira/browse/FLINK-31673 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28676) Update copyright year to 2014-2022 in NOTICE files

Benchao Li created FLINK-28676: -- Summary: Update copyright year to 2014-2022 in NOTICE files Key: FLINK-28676 URL: https://issues.apache.org/jira/browse/FLINK-28676 Project: Flink Issue Type:

[jira] [Created] (FLINK-21573) Support expression reuse in codegen

Benchao Li created FLINK-21573: -- Summary: Support expression reuse in codegen Key: FLINK-21573 URL: https://issues.apache.org/jira/browse/FLINK-21573 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-19449) LEAD/LAG cannot work correctly in streaming mode

Benchao Li created FLINK-19449: -- Summary: LEAD/LAG cannot work correctly in streaming mode Key: FLINK-19449 URL: https://issues.apache.org/jira/browse/FLINK-19449 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19336) EncodingUtils#encodeObjectToString should propagate inner exception

Benchao Li created FLINK-19336: -- Summary: EncodingUtils#encodeObjectToString should propagate inner exception Key: FLINK-19336 URL: https://issues.apache.org/jira/browse/FLINK-19336 Project: Flink

[jira] [Created] (FLINK-19281) LIKE cannot recognize full table path

Benchao Li created FLINK-19281: -- Summary: LIKE cannot recognize full table path Key: FLINK-19281 URL: https://issues.apache.org/jira/browse/FLINK-19281 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19140) Join with Table Function (UDTF) SQL example is incorrect

Benchao Li created FLINK-19140: -- Summary: Join with Table Function (UDTF) SQL example is incorrect Key: FLINK-19140 URL: https://issues.apache.org/jira/browse/FLINK-19140 Project: Flink Issue

[jira] [Created] (FLINK-18996) Avoid disorder for time interval join

Benchao Li created FLINK-18996: -- Summary: Avoid disorder for time interval join Key: FLINK-18996 URL: https://issues.apache.org/jira/browse/FLINK-18996 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18872) Aggregate with mini-batch does not respect state retention

Benchao Li created FLINK-18872: -- Summary: Aggregate with mini-batch does not respect state retention Key: FLINK-18872 URL: https://issues.apache.org/jira/browse/FLINK-18872 Project: Flink Issue

[jira] [Created] (FLINK-18871) Non-deterministic function could break retract mechanism

Benchao Li created FLINK-18871: -- Summary: Non-deterministic function could break retract mechanism Key: FLINK-18871 URL: https://issues.apache.org/jira/browse/FLINK-18871 Project: Flink Issue

[jira] [Created] (FLINK-18850) Add late records dropped metric for row time over windows

Benchao Li created FLINK-18850: -- Summary: Add late records dropped metric for row time over windows Key: FLINK-18850 URL: https://issues.apache.org/jira/browse/FLINK-18850 Project: Flink Issue

[jira] [Created] (FLINK-18837) Allow retract message for StreamSelectTableSink

Benchao Li created FLINK-18837: -- Summary: Allow retract message for StreamSelectTableSink Key: FLINK-18837 URL: https://issues.apache.org/jira/browse/FLINK-18837 Project: Flink Issue Type:

[jira] [Created] (FLINK-18781) Example in table/sql/queries.md Exists section is not correct

Benchao Li created FLINK-18781: -- Summary: Example in table/sql/queries.md Exists section is not correct Key: FLINK-18781 URL: https://issues.apache.org/jira/browse/FLINK-18781 Project: Flink

[jira] [Created] (FLINK-18590) Support json array explode to multi messages

Benchao Li created FLINK-18590: -- Summary: Support json array explode to multi messages Key: FLINK-18590 URL: https://issues.apache.org/jira/browse/FLINK-18590 Project: Flink Issue Type:

[jira] [Created] (FLINK-18520) New Table Function type inference fails

Benchao Li created FLINK-18520: -- Summary: New Table Function type inference fails Key: FLINK-18520 URL: https://issues.apache.org/jira/browse/FLINK-18520 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18487) New table source factory omits unrecognized properties silently

Benchao Li created FLINK-18487: -- Summary: New table source factory omits unrecognized properties silently Key: FLINK-18487 URL: https://issues.apache.org/jira/browse/FLINK-18487 Project: Flink

[jira] [Created] (FLINK-18379) Introduce asynchronous UDF/UDTF

Benchao Li created FLINK-18379: -- Summary: Introduce asynchronous UDF/UDTF Key: FLINK-18379 URL: https://issues.apache.org/jira/browse/FLINK-18379 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-18202) Introduce PB format

Benchao Li created FLINK-18202: -- Summary: Introduce PB format Key: FLINK-18202 URL: https://issues.apache.org/jira/browse/FLINK-18202 Project: Flink Issue Type: New Feature

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

Benchao Li created FLINK-18164: -- Summary: null <> 'str' should be true Key: FLINK-18164 URL: https://issues.apache.org/jira/browse/FLINK-18164 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18027) ROW value constructor cannot deal with complex expressions

Benchao Li created FLINK-18027: -- Summary: ROW value constructor cannot deal with complex expressions Key: FLINK-18027 URL: https://issues.apache.org/jira/browse/FLINK-18027 Project: Flink Issue

[jira] [Created] (FLINK-18002) Support forcing varchar type in Json format

Benchao Li created FLINK-18002: -- Summary: Support forcing varchar type in Json format Key: FLINK-18002 URL: https://issues.apache.org/jira/browse/FLINK-18002 Project: Flink Issue Type:

[jira] [Created] (FLINK-17942) Count distinct could not clean state in WindowOperator

Benchao Li created FLINK-17942: -- Summary: Count distinct could not clean state in WindowOperator Key: FLINK-17942 URL: https://issues.apache.org/jira/browse/FLINK-17942 Project: Flink Issue

[jira] [Created] (FLINK-17381) travis_controller prints wrong mvn version

Benchao Li created FLINK-17381: -- Summary: travis_controller prints wrong mvn version Key: FLINK-17381 URL: https://issues.apache.org/jira/browse/FLINK-17381 Project: Flink Issue Type:

[jira] [Created] (FLINK-17354) Introduce range sort for batch sort operator in blink

Benchao Li created FLINK-17354: -- Summary: Introduce range sort for batch sort operator in blink Key: FLINK-17354 URL: https://issues.apache.org/jira/browse/FLINK-17354 Project: Flink Issue

[jira] [Created] (FLINK-17343) Add doc for retraction behavior for all operators

Benchao Li created FLINK-17343: -- Summary: Add doc for retraction behavior for all operators Key: FLINK-17343 URL: https://issues.apache.org/jira/browse/FLINK-17343 Project: Flink Issue Type:

[jira] [Created] (FLINK-17199) Use NeverReturnExpired strategy for states in blink streaming join.

Benchao Li created FLINK-17199: -- Summary: Use NeverReturnExpired strategy for states in blink streaming join. Key: FLINK-17199 URL: https://issues.apache.org/jira/browse/FLINK-17199 Project: Flink

[jira] [Created] (FLINK-17137) Support mini batch for WindowOperator in blink planner

Benchao Li created FLINK-17137: -- Summary: Support mini batch for WindowOperator in blink planner Key: FLINK-17137 URL: https://issues.apache.org/jira/browse/FLINK-17137 Project: Flink Issue

[jira] [Created] (FLINK-16844) Support retract message for StreamExecGroupWindowAggregate in blink planner

Benchao Li created FLINK-16844: -- Summary: Support retract message for StreamExecGroupWindowAggregate in blink planner Key: FLINK-16844 URL: https://issues.apache.org/jira/browse/FLINK-16844 Project:

[jira] [Created] (FLINK-16401) Support map type for JsonRowSerializationSchema

Benchao Li created FLINK-16401: -- Summary: Support map type for JsonRowSerializationSchema Key: FLINK-16401 URL: https://issues.apache.org/jira/browse/FLINK-16401 Project: Flink Issue Type:

[jira] [Created] (FLINK-16354) Add PrintSink for Table API

Benchao Li created FLINK-16354: -- Summary: Add PrintSink for Table API Key: FLINK-16354 URL: https://issues.apache.org/jira/browse/FLINK-16354 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16266) es6 & 7 table sql connector conflicts each other

Benchao Li created FLINK-16266: -- Summary: es6 & 7 table sql connector conflicts each other Key: FLINK-16266 URL: https://issues.apache.org/jira/browse/FLINK-16266 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16220) JsonRowSerializationSchema throws cast exception : NullNode cannot be cast to ArrayNode

Benchao Li created FLINK-16220: -- Summary: JsonRowSerializationSchema throws cast exception : NullNode cannot be cast to ArrayNode Key: FLINK-16220 URL: https://issues.apache.org/jira/browse/FLINK-16220

[jira] [Created] (FLINK-16181) IfCallGen will throw NPE for primitive types in blink

Benchao Li created FLINK-16181: -- Summary: IfCallGen will throw NPE for primitive types in blink Key: FLINK-16181 URL: https://issues.apache.org/jira/browse/FLINK-16181 Project: Flink Issue

[jira] [Created] (FLINK-16043) Support non-BMP Unicode for JsonRowSerializationSchema

Benchao Li created FLINK-16043: -- Summary: Support non-BMP Unicode for JsonRowSerializationSchema Key: FLINK-16043 URL: https://issues.apache.org/jira/browse/FLINK-16043 Project: Flink Issue

[jira] [Created] (FLINK-16038) Expose hitRate metric for JDBCLookupFunction

Benchao Li created FLINK-16038: -- Summary: Expose hitRate metric for JDBCLookupFunction Key: FLINK-16038 URL: https://issues.apache.org/jira/browse/FLINK-16038 Project: Flink Issue Type:

[jira] [Created] (FLINK-15988) Make JsonRowSerializationSchema's constructor private

Benchao Li created FLINK-15988: -- Summary: Make JsonRowSerializationSchema's constructor private Key: FLINK-15988 URL: https://issues.apache.org/jira/browse/FLINK-15988 Project: Flink Issue

[jira] [Created] (FLINK-15938) Idle state not cleaned in StreamingJoinOperator and StreamingSemiAntiJoinOperator

Benchao Li created FLINK-15938: -- Summary: Idle state not cleaned in StreamingJoinOperator and StreamingSemiAntiJoinOperator Key: FLINK-15938 URL: https://issues.apache.org/jira/browse/FLINK-15938

[jira] [Created] (FLINK-15580) Add baseurl to docs/build_docs.sh

Benchao Li created FLINK-15580: -- Summary: Add baseurl to docs/build_docs.sh Key: FLINK-15580 URL: https://issues.apache.org/jira/browse/FLINK-15580 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15559) Missing {{site.baseurl}} in some docs

Benchao Li created FLINK-15559: -- Summary: Missing {{site.baseurl}} in some docs Key: FLINK-15559 URL: https://issues.apache.org/jira/browse/FLINK-15559 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15494) time field index wrong in LogicalWindowAggregateRuleBase

Benchao Li created FLINK-15494: -- Summary: time field index wrong in LogicalWindowAggregateRuleBase Key: FLINK-15494 URL: https://issues.apache.org/jira/browse/FLINK-15494 Project: Flink Issue

[jira] [Created] (FLINK-15478) FROM_BASE64 code gen type wrong

Benchao Li created FLINK-15478: -- Summary: FROM_BASE64 code gen type wrong Key: FLINK-15478 URL: https://issues.apache.org/jira/browse/FLINK-15478 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15435) ExecutionConfigTests.test_equals_and_hash in pyFlink fails when cpu core numbers is 6

Benchao Li created FLINK-15435: -- Summary: ExecutionConfigTests.test_equals_and_hash in pyFlink fails when cpu core numbers is 6 Key: FLINK-15435 URL: https://issues.apache.org/jira/browse/FLINK-15435

[jira] [Created] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

Benchao Li created FLINK-15431: -- Summary: Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator Key: FLINK-15431 URL: https://issues.apache.org/jira/browse/FLINK-15431

[jira] [Created] (FLINK-15430) Fix Java 64K method compiling limitation for blink planner.

Benchao Li created FLINK-15430: -- Summary: Fix Java 64K method compiling limitation for blink planner. Key: FLINK-15430 URL: https://issues.apache.org/jira/browse/FLINK-15430 Project: Flink

[jira] [Created] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

Benchao Li created FLINK-15421: -- Summary: GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp Key: FLINK-15421 URL: https://issues.apache.org/jira/browse/FLINK-15421

[jira] [Created] (FLINK-15418) StreamExecMatchRule not set FlinkRelDistribution

Benchao Li created FLINK-15418: -- Summary: StreamExecMatchRule not set FlinkRelDistribution Key: FLINK-15418 URL: https://issues.apache.org/jira/browse/FLINK-15418 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15266) NPE in blink planner code gen

Benchao Li created FLINK-15266: -- Summary: NPE in blink planner code gen Key: FLINK-15266 URL: https://issues.apache.org/jira/browse/FLINK-15266 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14546) Support map type in flink-json

Benchao Li created FLINK-14546: -- Summary: Support map type in flink-json Key: FLINK-14546 URL: https://issues.apache.org/jira/browse/FLINK-14546 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11722) Fix the outdated java doc in AkkaRpcServiceUtils

Benchao Li created FLINK-11722: -- Summary: Fix the outdated java doc in AkkaRpcServiceUtils Key: FLINK-11722 URL: https://issues.apache.org/jira/browse/FLINK-11722 Project: Flink Issue Type:

[jira] [Created] (FLINK-11699) Should use `String.equals()` instead of `==` for String compares in AbstractDispatcherResourceManagerComponentFactory.getHostname()

Benchao Li created FLINK-11699: -- Summary: Should use `String.equals()` instead of `==` for String compares in AbstractDispatcherResourceManagerComponentFactory.getHostname() Key: FLINK-11699 URL:

[jira] [Created] (FLINK-11655) runnable field should be transient in RunAsync from RPC messages

Benchao Li created FLINK-11655: -- Summary: runnable field should be transient in RunAsync from RPC messages Key: FLINK-11655 URL: https://issues.apache.org/jira/browse/FLINK-11655 Project: Flink

[jira] [Created] (FLINK-11311) StreamSource implements StreamOperator interface multiple times.

Benchao Li created FLINK-11311: -- Summary: StreamSource implements StreamOperator interface multiple times. Key: FLINK-11311 URL: https://issues.apache.org/jira/browse/FLINK-11311 Project: Flink