dalongliu created FLINK-10144:
-
Summary: No unused import "import akka.actor.ActorRef" in class
"org.apache.flink.runtime.messages.TaskManagerMessages"
Key: FLINK-10144
URL:
dalongliu created FLINK-10636:
-
Summary: ERROR
org.apache.flink.shaded.curator.org.apache.curator.ConnectionState -
Authentication failed
Key: FLINK-10636
URL: https://issues.apache.org/jira/browse/FLINK-10636
dalongliu created FLINK-12623:
-
Summary: Flink on yarn encountered AMRMClientImpl does not update
AMRM token properly
Key: FLINK-12623
URL: https://issues.apache.org/jira/browse/FLINK-12623
Project:
dalongliu created FLINK-17099:
-
Summary: Refactoring State TTL solution in Group Agg、TopN
operator, etc replace Timer with StateTtlConfig
Key: FLINK-17099
URL: https://issues.apache.org/jira/browse/FLINK-17099
dalongliu created FLINK-17096:
-
Summary: Minibatch Group Agg support state ttl
Key: FLINK-17096
URL: https://issues.apache.org/jira/browse/FLINK-17096
Project: Flink
Issue Type: New Feature
dalongliu created FLINK-19207:
-
Summary: TtlListState#IteratorWithCleanup support remove method
Key: FLINK-19207
URL: https://issues.apache.org/jira/browse/FLINK-19207
Project: Flink
Issue Type:
dalongliu created FLINK-19633:
-
Summary: Fix ArrayIndexOutOfBoundsException in
RetractableTopNFunction
Key: FLINK-19633
URL: https://issues.apache.org/jira/browse/FLINK-19633
Project: Flink
dalongliu created FLINK-18410:
-
Summary: Flink SQL filesystem connector class name correct
Key: FLINK-18410
URL: https://issues.apache.org/jira/browse/FLINK-18410
Project: Flink
Issue Type:
dalongliu created FLINK-19905:
-
Summary: The Jdbc-connector's 'lookup.max-retries' option initial
value is 1 in JdbcLookupFunction
Key: FLINK-19905
URL: https://issues.apache.org/jira/browse/FLINK-19905
dalongliu created FLINK-24822:
-
Summary: Improve CatalogTableSpecBase and its subclass method
parameter
Key: FLINK-24822
URL: https://issues.apache.org/jira/browse/FLINK-24822
Project: Flink
dalongliu created FLINK-25635:
-
Summary: Using sql client create hive catalog throw exception
Key: FLINK-25635
URL: https://issues.apache.org/jira/browse/FLINK-25635
Project: Flink
Issue Type:
dalongliu created FLINK-26813:
-
Summary: Supports ADD/MODIFY column/watermark/constraint syntax
parse for ALTER TABLE
Key: FLINK-26813
URL: https://issues.apache.org/jira/browse/FLINK-26813
Project:
dalongliu created FLINK-26929:
-
Summary: Introduce adaptive hash join for batch sql optimization
Key: FLINK-26929
URL: https://issues.apache.org/jira/browse/FLINK-26929
Project: Flink
Issue
dalongliu created FLINK-26951:
-
Summary: Add HASH supported in SQL & Table API
Key: FLINK-26951
URL: https://issues.apache.org/jira/browse/FLINK-26951
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26939:
-
Summary: Add TRANSLATE supported in SQL & Table API
Key: FLINK-26939
URL: https://issues.apache.org/jira/browse/FLINK-26939
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26945:
-
Summary: Add DATE_SUB supported in SQL & Table API
Key: FLINK-26945
URL: https://issues.apache.org/jira/browse/FLINK-26945
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26944:
-
Summary: Add ADD_MONTHS supported in SQL and Table API
Key: FLINK-26944
URL: https://issues.apache.org/jira/browse/FLINK-26944
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26946:
-
Summary: Add SHIFTRIGHT supported in SQL & Table API
Key: FLINK-26946
URL: https://issues.apache.org/jira/browse/FLINK-26946
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26947:
-
Summary: Add ARRAY_CONTAINS supported in SQL & Table API
Key: FLINK-26947
URL: https://issues.apache.org/jira/browse/FLINK-26947
Project: Flink
Issue Type:
dalongliu created FLINK-26943:
-
Summary: Add DATE_ADD supported in SQL & Table API
Key: FLINK-26943
URL: https://issues.apache.org/jira/browse/FLINK-26943
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26940:
-
Summary: Add SUBSTRING_INDEX supported in SQL & Table API
Key: FLINK-26940
URL: https://issues.apache.org/jira/browse/FLINK-26940
Project: Flink
Issue Type:
dalongliu created FLINK-26949:
-
Summary: Add NVL supported in SQL & Table API
Key: FLINK-26949
URL: https://issues.apache.org/jira/browse/FLINK-26949
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-26948:
-
Summary: Add SORT_ARRAY supported in SQL & Table API
Key: FLINK-26948
URL: https://issues.apache.org/jira/browse/FLINK-26948
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-33004:
-
Summary: Decoupling topology and network memory to support complex
job topologies
Key: FLINK-33004
URL: https://issues.apache.org/jira/browse/FLINK-33004
Project: Flink
dalongliu created FLINK-33229:
-
Summary: Moving Java FlinkRecomputeStatisticsProgram from scala
package to java package
Key: FLINK-33229
URL: https://issues.apache.org/jira/browse/FLINK-33229
Project:
dalongliu created FLINK-32865:
-
Summary: DynamicFilteringDataCollectorOperator can't chain with
the upstream operator when the parallelism is inconsistent
Key: FLINK-32865
URL:
dalongliu created FLINK-32905:
-
Summary: Fix the bug of broadcast hash join doesn't support spill
to disk when enable operator fusion codegn
Key: FLINK-32905
URL: https://issues.apache.org/jira/browse/FLINK-32905
dalongliu created FLINK-27363:
-
Summary: Support EXCHANGE PARTITION statement for partitioned table
Key: FLINK-27363
URL: https://issues.apache.org/jira/browse/FLINK-27363
Project: Flink
Issue
dalongliu created FLINK-27364:
-
Summary: Support DESC EXTENDED partition statement for partitioned
table
Key: FLINK-27364
URL: https://issues.apache.org/jira/browse/FLINK-27364
Project: Flink
dalongliu created FLINK-27658:
-
Summary: Introduce MutableURLClassLoader allow to register and
remove user jar dynamically
Key: FLINK-27658
URL: https://issues.apache.org/jira/browse/FLINK-27658
Project:
dalongliu created FLINK-27659:
-
Summary: Planner support to use jar which is registered by "USING
JAR" syntax
Key: FLINK-27659
URL: https://issues.apache.org/jira/browse/FLINK-27659
Project: Flink
dalongliu created FLINK-27660:
-
Summary: Table API support create function using customed jar
Key: FLINK-27660
URL: https://issues.apache.org/jira/browse/FLINK-27660
Project: Flink
Issue Type:
dalongliu created FLINK-27790:
-
Summary: Move ADD/Remove Jar syntax code implementation from
SqlClient to TableEnvironment side
Key: FLINK-27790
URL: https://issues.apache.org/jira/browse/FLINK-27790
dalongliu created FLINK-27861:
-
Summary: Introduce UserResourceManager to manage user defined
resource
Key: FLINK-27861
URL: https://issues.apache.org/jira/browse/FLINK-27861
Project: Flink
dalongliu created FLINK-27606:
-
Summary: Fix code generator exception when using imperative udaf
that is introduced for planner scala-free
Key: FLINK-27606
URL: https://issues.apache.org/jira/browse/FLINK-27606
dalongliu created FLINK-27593:
-
Summary: Parquet/Orc format reader optimization
Key: FLINK-27593
URL: https://issues.apache.org/jira/browse/FLINK-27593
Project: Flink
Issue Type: Bug
dalongliu created FLINK-27651:
-
Summary: Support CREATE FUNCTION USING JAR syntax
Key: FLINK-27651
URL: https://issues.apache.org/jira/browse/FLINK-27651
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-28451:
-
Summary: HiveFunctionDefinitionFactory load udf using user
classloader instead of thread context classloader
Key: FLINK-28451
URL: https://issues.apache.org/jira/browse/FLINK-28451
dalongliu created FLINK-28213:
-
Summary: StreamExecutionEnvironment configure method support
override pipeline.jars option
Key: FLINK-28213
URL: https://issues.apache.org/jira/browse/FLINK-28213
Project:
dalongliu created FLINK-28080:
-
Summary: Introduce MutableURLClassLoader as parent class of
FlinkUserClassLoader and SafetyNetWrapperClassLoader
Key: FLINK-28080
URL: https://issues.apache.org/jira/browse/FLINK-28080
dalongliu created FLINK-28101:
-
Summary: YARNHighAvailabilityITCase failed on azure
Key: FLINK-28101
URL: https://issues.apache.org/jira/browse/FLINK-28101
Project: Flink
Issue Type: Bug
dalongliu created FLINK-27240:
-
Summary: Support ADD PARTITION statement
Key: FLINK-27240
URL: https://issues.apache.org/jira/browse/FLINK-27240
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-27237:
-
Summary: Partition table statement enhancement
Key: FLINK-27237
URL: https://issues.apache.org/jira/browse/FLINK-27237
Project: Flink
Issue Type: New Feature
dalongliu created FLINK-27241:
-
Summary: Support DROP PARTITION statement
Key: FLINK-27241
URL: https://issues.apache.org/jira/browse/FLINK-27241
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-27243:
-
Summary: Support SHOW PARTITIONS statement for partitioned table
Key: FLINK-27243
URL: https://issues.apache.org/jira/browse/FLINK-27243
Project: Flink
Issue
dalongliu created FLINK-27242:
-
Summary: Support RENAME PARTITION statement for partitioned table
Key: FLINK-27242
URL: https://issues.apache.org/jira/browse/FLINK-27242
Project: Flink
Issue
dalongliu created FLINK-29087:
-
Summary: Jdbc connector sql ITCase failed when run in idea
Key: FLINK-29087
URL: https://issues.apache.org/jira/browse/FLINK-29087
Project: Flink
Issue Type: Bug
dalongliu created FLINK-29068:
-
Summary: Release Testing: Verify FLIP-214 Create function using
jar syntax
Key: FLINK-29068
URL: https://issues.apache.org/jira/browse/FLINK-29068
Project: Flink
dalongliu created FLINK-29069:
-
Summary: Release Testing: Verify FLIP-218 Create table as select
syntax
Key: FLINK-29069
URL: https://issues.apache.org/jira/browse/FLINK-29069
Project: Flink
dalongliu created FLINK-29451:
-
Summary: Push down group by partition column for Aggregate
(Min/Max/Count) for Parquet and Orc
Key: FLINK-29451
URL: https://issues.apache.org/jira/browse/FLINK-29451
dalongliu created FLINK-29449:
-
Summary: Aggregate (Min/Max/Count) push down for Parquet
Key: FLINK-29449
URL: https://issues.apache.org/jira/browse/FLINK-29449
Project: Flink
Issue Type:
dalongliu created FLINK-29448:
-
Summary: Aggregate (Min/Max/Count) push down for ORC
Key: FLINK-29448
URL: https://issues.apache.org/jira/browse/FLINK-29448
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-29450:
-
Summary: Push down filter by partition column for Aggregate
(Min/Max/Count) for Parquet
Key: FLINK-29450
URL: https://issues.apache.org/jira/browse/FLINK-29450
Project:
dalongliu created FLINK-29718:
-
Summary: Supports hive sum function by native implementation
Key: FLINK-29718
URL: https://issues.apache.org/jira/browse/FLINK-29718
Project: Flink
Issue Type:
dalongliu created FLINK-29717:
-
Summary: Supports hive udaf such as sum/count by native
implementation
Key: FLINK-29717
URL: https://issues.apache.org/jira/browse/FLINK-29717
Project: Flink
dalongliu created FLINK-29722:
-
Summary: Supports hive max function by native implementation
Key: FLINK-29722
URL: https://issues.apache.org/jira/browse/FLINK-29722
Project: Flink
Issue Type:
dalongliu created FLINK-29720:
-
Summary: Supports hive average function by native implemetatoin
Key: FLINK-29720
URL: https://issues.apache.org/jira/browse/FLINK-29720
Project: Flink
Issue Type:
dalongliu created FLINK-29721:
-
Summary: Supports hive min function by native implementation
Key: FLINK-29721
URL: https://issues.apache.org/jira/browse/FLINK-29721
Project: Flink
Issue Type:
dalongliu created FLINK-29723:
-
Summary: Supports hive first_value function by native
implementation
Key: FLINK-29723
URL: https://issues.apache.org/jira/browse/FLINK-29723
Project: Flink
Issue
dalongliu created FLINK-29719:
-
Summary: Supports hive count function by native implementation
Key: FLINK-29719
URL: https://issues.apache.org/jira/browse/FLINK-29719
Project: Flink
Issue Type:
dalongliu created FLINK-29724:
-
Summary: Supports hive last_value function by native implementation
Key: FLINK-29724
URL: https://issues.apache.org/jira/browse/FLINK-29724
Project: Flink
Issue
dalongliu created FLINK-29725:
-
Summary: Supports hive std function by native implementation
Key: FLINK-29725
URL: https://issues.apache.org/jira/browse/FLINK-29725
Project: Flink
Issue Type:
dalongliu created FLINK-29726:
-
Summary: Supports hive stddev_samp function by native
implementation
Key: FLINK-29726
URL: https://issues.apache.org/jira/browse/FLINK-29726
Project: Flink
Issue
dalongliu created FLINK-29240:
-
Summary: Unify the ClassLoader in StreamExecutionEnvironment and
TableEnvironment
Key: FLINK-29240
URL: https://issues.apache.org/jira/browse/FLINK-29240
Project: Flink
dalongliu created FLINK-29551:
-
Summary: Improving adaptive hash join by using sort merge join
strategy per partition instead of all partitions
Key: FLINK-29551
URL: https://issues.apache.org/jira/browse/FLINK-29551
dalongliu created FLINK-29547:
-
Summary: Select a[1] which is array type for parquet complex type
throw ClassCastException
Key: FLINK-29547
URL: https://issues.apache.org/jira/browse/FLINK-29547
dalongliu created FLINK-29162:
-
Summary: missCounter and loadCount metrics also increase even if
cache hint
Key: FLINK-29162
URL: https://issues.apache.org/jira/browse/FLINK-29162
Project: Flink
dalongliu created FLINK-28917:
-
Summary: Add sql test for adaptive hash join
Key: FLINK-28917
URL: https://issues.apache.org/jira/browse/FLINK-28917
Project: Flink
Issue Type: Bug
dalongliu created FLINK-28916:
-
Summary: Add e2e test for create function using jar syntax
Key: FLINK-28916
URL: https://issues.apache.org/jira/browse/FLINK-28916
Project: Flink
Issue Type: Bug
dalongliu created FLINK-28867:
-
Summary: Parquet reader support nested type in array/map type
Key: FLINK-28867
URL: https://issues.apache.org/jira/browse/FLINK-28867
Project: Flink
Issue Type:
dalongliu created FLINK-29005:
-
Summary: Parquet row type reader should not return null value when
some child fields is null
Key: FLINK-29005
URL: https://issues.apache.org/jira/browse/FLINK-29005
dalongliu created FLINK-29023:
-
Summary: Updating Jar statement document
Key: FLINK-29023
URL: https://issues.apache.org/jira/browse/FLINK-29023
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-29019:
-
Summary: Updating parquet format document that support complex type
Key: FLINK-29019
URL: https://issues.apache.org/jira/browse/FLINK-29019
Project: Flink
Issue
dalongliu created FLINK-29020:
-
Summary: Add document for CTAS feature
Key: FLINK-29020
URL: https://issues.apache.org/jira/browse/FLINK-29020
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-29022:
-
Summary: Add document for CREATE FUNCTIOn USING JAR feature
Key: FLINK-29022
URL: https://issues.apache.org/jira/browse/FLINK-29022
Project: Flink
Issue Type:
dalongliu created FLINK-30491:
-
Summary: Hive table partition supports to deserialize later during
runtime
Key: FLINK-30491
URL: https://issues.apache.org/jira/browse/FLINK-30491
Project: Flink
dalongliu created FLINK-30579:
-
Summary: Introducing cofigurable option to enable hive native
function
Key: FLINK-30579
URL: https://issues.apache.org/jira/browse/FLINK-30579
Project: Flink
dalongliu created FLINK-30221:
-
Summary: Fix the bug of sum(try_cast(string as bigint)) return
null when partial elements can't convert to bigint
Key: FLINK-30221
URL:
dalongliu created FLINK-30824:
-
Summary: Add document for new introduced hive agg option
Key: FLINK-30824
URL: https://issues.apache.org/jira/browse/FLINK-30824
Project: Flink
Issue Type:
dalongliu created FLINK-31239:
-
Summary: Fix sum function can't get the corrected value when the
argument type is string
Key: FLINK-31239
URL: https://issues.apache.org/jira/browse/FLINK-31239
Project:
dalongliu created FLINK-31193:
-
Summary: The option `table.exec.hive.native-agg-function.enabled`
should work at job level when using it in SqlClient side
Key: FLINK-31193
URL:
dalongliu created FLINK-31059:
-
Summary: Release Testing: Verify FLINK-29717 Supports hive udaf
such as sum/count by native implementation
Key: FLINK-31059
URL: https://issues.apache.org/jira/browse/FLINK-31059
dalongliu created FLINK-32608:
-
Summary: Improve source reusing with projection push down
Key: FLINK-32608
URL: https://issues.apache.org/jira/browse/FLINK-32608
Project: Flink
Issue Type:
dalongliu created FLINK-32607:
-
Summary: Kafka table source support projection pushdown
Key: FLINK-32607
URL: https://issues.apache.org/jira/browse/FLINK-32607
Project: Flink
Issue Type:
dalongliu created FLINK-32610:
-
Summary: JSON format supports projection push down
Key: FLINK-32610
URL: https://issues.apache.org/jira/browse/FLINK-32610
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-32609:
-
Summary: Kafka table source supports projection push down
Key: FLINK-32609
URL: https://issues.apache.org/jira/browse/FLINK-32609
Project: Flink
Issue Type:
dalongliu created FLINK-32220:
-
Summary: Improving the adaptive local hash agg code to avoid get
value from RowData repeatedly
Key: FLINK-32220
URL: https://issues.apache.org/jira/browse/FLINK-32220
dalongliu created FLINK-32280:
-
Summary: HashAgg support operator fusion codegen
Key: FLINK-32280
URL: https://issues.apache.org/jira/browse/FLINK-32280
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-32281:
-
Summary: Enable two-phase agg default when agg function support
adaptive local hashagg
Key: FLINK-32281
URL: https://issues.apache.org/jira/browse/FLINK-32281
Project:
dalongliu created FLINK-32279:
-
Summary: Shuffle HashJoin support spill to disk when enable
operator fusion codegen
Key: FLINK-32279
URL: https://issues.apache.org/jira/browse/FLINK-32279
Project: Flink
dalongliu created FLINK-32277:
-
Summary: Introduce operator fusion codegen framework
Key: FLINK-32277
URL: https://issues.apache.org/jira/browse/FLINK-32277
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-32278:
-
Summary: HashJoin support operator fusion codegen
Key: FLINK-32278
URL: https://issues.apache.org/jira/browse/FLINK-32278
Project: Flink
Issue Type: Sub-task
dalongliu created FLINK-32646:
-
Summary: The snapshot is null in CatalogTable when query specify
the time snapshot
Key: FLINK-32646
URL: https://issues.apache.org/jira/browse/FLINK-32646
Project: Flink
dalongliu created FLINK-32426:
-
Summary: Fix adaptive local hash can't work when auxGrouping exist
Key: FLINK-32426
URL: https://issues.apache.org/jira/browse/FLINK-32426
Project: Flink
Issue
dalongliu created FLINK-32489:
-
Summary: Support serialize and merge BloomFilter for runtime filter
Key: FLINK-32489
URL: https://issues.apache.org/jira/browse/FLINK-32489
Project: Flink
Issue
dalongliu created FLINK-32491:
-
Summary: Introduce RuntimeFilterOperator to support runtime filter
which can reduce the shuffle data size before shuffle join
Key: FLINK-32491
URL:
dalongliu created FLINK-32493:
-
Summary: Introduce RuntimeFilterBuilderOperator to build a
BloomFilter from build side data of shuffle join
Key: FLINK-32493
URL: https://issues.apache.org/jira/browse/FLINK-32493
dalongliu created FLINK-32510:
-
Summary: Reusing the LongHashJoinGenerator and
HashJoinFusionCodegenSpec code as soon as possible to avoid too high maintain
cost
Key: FLINK-32510
URL:
dalongliu created FLINK-33593:
-
Summary: Left title bar of the official documentation for the
master branch is misaligned
Key: FLINK-33593
URL: https://issues.apache.org/jira/browse/FLINK-33593
Project:
dalongliu created FLINK-35191:
-
Summary: Support alter materialized table related syntaxes:
suspend, resume, refresh, set and reset
Key: FLINK-35191
URL: https://issues.apache.org/jira/browse/FLINK-35191
1 - 100 of 122 matches
Mail list logo
