Hi:
i think flink integrate atlas also need add catalog information such as
spark atlas project
.https://github.com/hortonworks-spark/spark-atlas-connector
when user use catalog such as JDBCCatalog/HiveCatalog, flink atlas project
will sync this information to atlas.
But i don't find any Event
Hi Márton Balassi:
I am very glad to look at it and where to find .
And it is my issue , which you can see
https://issues.apache.org/jira/browse/FLINK-16774
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
jackylau created FLINK-14053:
Summary: blink planner dense_rank corner case bug
Key: FLINK-14053
URL: https://issues.apache.org/jira/browse/FLINK-14053
Project: Flink
Issue Type: Bug
jackylau created FLINK-31902:
Summary: cast expr to type with not null should throw exception
like calcite
Key: FLINK-31902
URL: https://issues.apache.org/jira/browse/FLINK-31902
Project: Flink
jackylau created FLINK-31904:
Summary: fix current serveral flink nullable type handle
Key: FLINK-31904
URL: https://issues.apache.org/jira/browse/FLINK-31904
Project: Flink
Issue Type
jackylau created FLINK-31906:
Summary: typeof should only return type exclude nullable
Key: FLINK-31906
URL: https://issues.apache.org/jira/browse/FLINK-31906
Project: Flink
Issue Type
jackylau created FLINK-31908:
Summary: cast expr to type with not null should not change
nullable of expr
Key: FLINK-31908
URL: https://issues.apache.org/jira/browse/FLINK-31908
Project: Flink
jackylau created FLINK-32363:
Summary: calcite 1.21 supports type coercion but flink don't
enable it in validate
Key: FLINK-32363
URL: https://issues.apache.org/jira/browse/FLINK-32363
Project:
jackylau created FLINK-16692:
Summary: flink joblistener can register from config
Key: FLINK-16692
URL: https://issues.apache.org/jira/browse/FLINK-16692
Project: Flink
Issue Type: Improvement
jackylau created FLINK-16698:
Summary: fllink need catalog listener to do such as
preCreate/PreDrop* afterCreate/AfterDrop* things
Key: FLINK-16698
URL: https://issues.apache.org/jira/browse/FLINK-16698
jackylau created FLINK-16774:
Summary: expose HBaseUpsertSinkFunction hTableName and schema for
other system
Key: FLINK-16774
URL: https://issues.apache.org/jira/browse/FLINK-16774
Project: Flink
jackylau created FLINK-16775:
Summary: expose FlinkKafkaConsumer/FlinkKafkaProducer Properties
for other system
Key: FLINK-16775
URL: https://issues.apache.org/jira/browse/FLINK-16775
Project: Flink
jackylau created FLINK-16777:
Summary: expose Pipeline in JobClient
Key: FLINK-16777
URL: https://issues.apache.org/jira/browse/FLINK-16777
Project: Flink
Issue Type: Improvement
jackylau created FLINK-17155:
Summary: flink in memory catalog can not support hive udf
Key: FLINK-17155
URL: https://issues.apache.org/jira/browse/FLINK-17155
Project: Flink
Issue Type: Bug
jackylau created FLINK-17326:
Summary: flink sql gateway should support persist meta
information such as SessionContext in order to recover
Key: FLINK-17326
URL: https://issues.apache.org/jira/browse/FLINK-17326
jackylau created FLINK-17384:
Summary: support read hbase conf dir from flink.conf just like
hadoop_conf
Key: FLINK-17384
URL: https://issues.apache.org/jira/browse/FLINK-17384
Project: Flink
jackylau created FLINK-14159:
Summary: flink rocksdb StreamCompressionDecorator not right
Key: FLINK-14159
URL: https://issues.apache.org/jira/browse/FLINK-14159
Project: Flink
Issue Type: Bug
jackylau created FLINK-14243:
Summary: flink hiveudf need some check whether it is using cache
Key: FLINK-14243
URL: https://issues.apache.org/jira/browse/FLINK-14243
Project: Flink
Issue Type
jackylau created FLINK-15625:
Summary: flink sql multiple statements syntatic validation supports
Key: FLINK-15625
URL: https://issues.apache.org/jira/browse/FLINK-15625
Project: Flink
Issue
jackylau created FLINK-19755:
Summary: flink cep
Key: FLINK-19755
URL: https://issues.apache.org/jira/browse/FLINK-19755
Project: Flink
Issue Type: Bug
Components: Library / CEP
jackylau created FLINK-19765:
Summary: flink SqlUseCatalog.getCatalogName is not unified with
SqlCreateCatalog and SqlDropCatalog
Key: FLINK-19765
URL: https://issues.apache.org/jira/browse/FLINK-19765
jackylau created FLINK-19848:
Summary: flink docs of Building Flink from Source bug
Key: FLINK-19848
URL: https://issues.apache.org/jira/browse/FLINK-19848
Project: Flink
Issue Type: Bug
jackylau created FLINK-19915:
Summary: wrong comments of cep test
Key: FLINK-19915
URL: https://issues.apache.org/jira/browse/FLINK-19915
Project: Flink
Issue Type: Bug
Components
jackylau created FLINK-19950:
Summary: LookupJoin can not support view or subquery and so on. o
Key: FLINK-19950
URL: https://issues.apache.org/jira/browse/FLINK-19950
Project: Flink
Issue Type
jackylau created FLINK-19952:
Summary: flink SecurityOptions.class use depracted method so mant
times
Key: FLINK-19952
URL: https://issues.apache.org/jira/browse/FLINK-19952
Project: Flink
jackylau created FLINK-20474:
Summary: flink cep results of doc is not right
Key: FLINK-20474
URL: https://issues.apache.org/jira/browse/FLINK-20474
Project: Flink
Issue Type: Bug
jackylau created FLINK-31006:
Summary: job is not finished when using pipeline mode to run
bounded source like kafka/pulsar
Key: FLINK-31006
URL: https://issues.apache.org/jira/browse/FLINK-31006
Project
jackylau created FLINK-31098:
Summary: Add ARRAY_SIZE supported in SQL & Table API
Key: FLINK-31098
URL: https://issues.apache.org/jira/browse/FLINK-31098
Project: Flink
Issue Type: New Fea
jackylau created FLINK-31102:
Summary: Add ARRAY_REMOVE supported in SQL & Table API
Key: FLINK-31102
URL: https://issues.apache.org/jira/browse/FLINK-31102
Project: Flink
Issue Type: Sub-
jackylau created FLINK-31118:
Summary: Add ARRAY_UNION supported in SQL & Table API
Key: FLINK-31118
URL: https://issues.apache.org/jira/browse/FLINK-31118
Project: Flink
Issue Type: Sub-
jackylau created FLINK-31161:
Summary: upgrade MojoHaus Versions Maven Plugin to 2.14.2
Key: FLINK-31161
URL: https://issues.apache.org/jira/browse/FLINK-31161
Project: Flink
Issue Type: Bug
jackylau created FLINK-31166:
Summary: array_contains element type error
Key: FLINK-31166
URL: https://issues.apache.org/jira/browse/FLINK-31166
Project: Flink
Issue Type: Bug
jackylau created FLINK-31199:
Summary: Add MAP_KEYS supported in SQL & Table API
Key: FLINK-31199
URL: https://issues.apache.org/jira/browse/FLINK-31199
Project: Flink
Issue Type:
jackylau created FLINK-31200:
Summary: Add MAP_VALUES supported in SQL & Table API
Key: FLINK-31200
URL: https://issues.apache.org/jira/browse/FLINK-31200
Project: Flink
Issue Type: Sub-
jackylau created FLINK-31207:
Summary: supports high order function like other engine
Key: FLINK-31207
URL: https://issues.apache.org/jira/browse/FLINK-31207
Project: Flink
Issue Type: Sub-task
jackylau created FLINK-31237:
Summary: Fix possible bug of array_distinct
Key: FLINK-31237
URL: https://issues.apache.org/jira/browse/FLINK-31237
Project: Flink
Issue Type: Bug
Affects
jackylau created FLINK-31279:
Summary: fix times using number and interval type bug
Key: FLINK-31279
URL: https://issues.apache.org/jira/browse/FLINK-31279
Project: Flink
Issue Type: Bug
jackylau created FLINK-31336:
Summary: interval type process has problem in table api and sql
Key: FLINK-31336
URL: https://issues.apache.org/jira/browse/FLINK-31336
Project: Flink
Issue Type
jackylau created FLINK-31377:
Summary: BinaryArrayData getArray/getMap should Handle null
correctly AssertionError: valueArraySize (-6) should >= 0
Key: FLINK-31377
URL: https://issues.apache.org/jira/browse/FL
jackylau created FLINK-31381:
Summary: UnsupportedOperationException: Unsupported type when
convertTypeToSpec: MAP
Key: FLINK-31381
URL: https://issues.apache.org/jira/browse/FLINK-31381
Project: Flink
jackylau created FLINK-31602:
Summary: Add ARRAY_POSITION supported in SQL & Table API
Key: FLINK-31602
URL: https://issues.apache.org/jira/browse/FLINK-31602
Project: Flink
Issue
jackylau created FLINK-31621:
Summary: Add ARRAY_REVERSE supported in SQL & Table API
Key: FLINK-31621
URL: https://issues.apache.org/jira/browse/FLINK-31621
Project: Flink
Issue
jackylau created FLINK-31622:
Summary: Add ARRAY_APPEND supported in SQL & Table API
Key: FLINK-31622
URL: https://issues.apache.org/jira/browse/FLINK-31622
Project: Flink
Issue
jackylau created FLINK-31664:
Summary: Add ARRAY_INTERSECT supported in SQL & Table API
Key: FLINK-31664
URL: https://issues.apache.org/jira/browse/FLINK-31664
Project: Flink
Issue
jackylau created FLINK-31665:
Summary: Add ARRAY_CONCAT supported in SQL & Table API
Key: FLINK-31665
URL: https://issues.apache.org/jira/browse/FLINK-31665
Project: Flink
Issue
jackylau created FLINK-31666:
Summary: Add ARRAY_OVERLAP supported in SQL & Table API
Key: FLINK-31666
URL: https://issues.apache.org/jira/browse/FLINK-31666
Project: Flink
Issue
jackylau created FLINK-31677:
Summary: Add MAP_ENTRIES supported in SQL & Table API
Key: FLINK-31677
URL: https://issues.apache.org/jira/browse/FLINK-31677
Project: Flink
Issue Type: Improve
jackylau created FLINK-31682:
Summary: map_from_arrays should take whether allow duplicate keys
and null key into consideration
Key: FLINK-31682
URL: https://issues.apache.org/jira/browse/FLINK-31682
jackylau created FLINK-31691:
Summary: Add MAP_FROM_ENTRIES supported in SQL & Table API
Key: FLINK-31691
URL: https://issues.apache.org/jira/browse/FLINK-31691
Project: Flink
Issue
jackylau created FLINK-31751:
Summary: array return type SpecificTypeStrategies.ARRAY and
ifThenElse return type is not correct
Key: FLINK-31751
URL: https://issues.apache.org/jira/browse/FLINK-31751
jackylau created FLINK-26678:
Summary: make flink-console.sh script clean
Key: FLINK-26678
URL: https://issues.apache.org/jira/browse/FLINK-26678
Project: Flink
Issue Type: Improvement
jackylau created FLINK-26732:
Summary: DefaultResourceAllocationStrategy need more log info to
troubleshoot
Key: FLINK-26732
URL: https://issues.apache.org/jira/browse/FLINK-26732
Project: Flink
jackylau created FLINK-27621:
Summary: expose SafetyNetWrapperClassLoader from private to public
and add addUrl method for flink client
Key: FLINK-27621
URL: https://issues.apache.org/jira/browse/FLINK-27621
jackylau created FLINK-27630:
Summary: maven-source-plugin for table planner values connector
for debug
Key: FLINK-27630
URL: https://issues.apache.org/jira/browse/FLINK-27630
Project: Flink
jackylau created FLINK-27899:
Summary: deactivate the shade plugin doesn't take effect
Key: FLINK-27899
URL: https://issues.apache.org/jira/browse/FLINK-27899
Project: Flink
Issue
jackylau created FLINK-27992:
Summary: cep StreamExecMatch need check the parallelism and
maxParallelism of the two transformation in it
Key: FLINK-27992
URL: https://issues.apache.org/jira/browse/FLINK-27992
jackylau created FLINK-26145:
Summary: k8s docs jobmanager-pod-template
artifacts-fetcher:latest image is not exist, we can use busybox to replace it
Key: FLINK-26145
URL: https://issues.apache.org/jira/browse
jackylau created FLINK-21512:
Summary: flink MemorySize.parseBytes bug if users use it by
setting dynamic properties like
Key: FLINK-21512
URL: https://issues.apache.org/jira/browse/FLINK-21512
Project
jackylau created FLINK-21991:
Summary: flink varchar which exposes to users it not unified
Key: FLINK-21991
URL: https://issues.apache.org/jira/browse/FLINK-21991
Project: Flink
Issue Type: Bug
jackylau created FLINK-23697:
Summary: flink standalone Isolation is poor, why not do as spark
does
Key: FLINK-23697
URL: https://issues.apache.org/jira/browse/FLINK-23697
Project: Flink
Issue
jackylau created FLINK-24884:
Summary: flink flame graph webui bug
Key: FLINK-24884
URL: https://issues.apache.org/jira/browse/FLINK-24884
Project: Flink
Issue Type: Bug
Affects Versions
jackylau created FLINK-24886:
Summary: flink flame args bug, may we need to modify TimeUtils to
supports m
Key: FLINK-24886
URL: https://issues.apache.org/jira/browse/FLINK-24886
Project: Flink
jackylau created FLINK-28507:
Summary: supports set hadoop mount path in pod
Key: FLINK-28507
URL: https://issues.apache.org/jira/browse/FLINK-28507
Project: Flink
Issue Type: Improvement
jackylau created FLINK-28583:
Summary: make flink dist log4j dependency simple and clear
Key: FLINK-28583
URL: https://issues.apache.org/jira/browse/FLINK-28583
Project: Flink
Issue Type
jackylau created FLINK-28776:
Summary: RowTimeMiniBatchAssginerOperator doesn't need separate
chain with upstream WatermarkAssignerOperator
Key: FLINK-28776
URL: https://issues.apache.org/jira/browse/FLINK-
jackylau created FLINK-28780:
Summary: function docs of dayofmonth is not correct
Key: FLINK-28780
URL: https://issues.apache.org/jira/browse/FLINK-28780
Project: Flink
Issue Type: Improvement
jackylau created FLINK-28813:
Summary: new stach builtinfunction validateClassForRuntime it not
correct
Key: FLINK-28813
URL: https://issues.apache.org/jira/browse/FLINK-28813
Project: Flink
jackylau created FLINK-28830:
Summary: new stack udtf doesn't support atomic type
Key: FLINK-28830
URL: https://issues.apache.org/jira/browse/FLINK-28830
Project: Flink
Issue Type: Improv
jackylau created FLINK-28893:
Summary: Add conv function supported in SQL & Table API
Key: FLINK-28893
URL: https://issues.apache.org/jira/browse/FLINK-28893
Project: Flink
Issue
jackylau created FLINK-28919:
Summary: Add built-in generate_series function.
Key: FLINK-28919
URL: https://issues.apache.org/jira/browse/FLINK-28919
Project: Flink
Issue Type: Improvement
jackylau created FLINK-28929:
Summary: Add built-in datediff function.
Key: FLINK-28929
URL: https://issues.apache.org/jira/browse/FLINK-28929
Project: Flink
Issue Type: Improvement
jackylau created FLINK-29010:
Summary: flink planner test is not correct
Key: FLINK-29010
URL: https://issues.apache.org/jira/browse/FLINK-29010
Project: Flink
Issue Type: Bug
jackylau created FLINK-29012:
Summary: flink function doc is not correct
Key: FLINK-29012
URL: https://issues.apache.org/jira/browse/FLINK-29012
Project: Flink
Issue Type: Bug
jackylau created FLINK-29096:
Summary: json_value when the path has blank, the result is not
right
Key: FLINK-29096
URL: https://issues.apache.org/jira/browse/FLINK-29096
Project: Flink
Issue
jackylau created FLINK-29150:
Summary: TIMESTAMPDIFF microsecond unit for table api
Key: FLINK-29150
URL: https://issues.apache.org/jira/browse/FLINK-29150
Project: Flink
Issue Type: Bug
jackylau created FLINK-29182:
Summary: SumAggFunction redundant computations
Key: FLINK-29182
URL: https://issues.apache.org/jira/browse/FLINK-29182
Project: Flink
Issue Type: Bug
jackylau created FLINK-29227:
Summary: shoud package disruptor(com.lmax) to flink lib for aync
logger when xxconnector using it.
Key: FLINK-29227
URL: https://issues.apache.org/jira/browse/FLINK-29227
jackylau created FLINK-29479:
Summary: support whether using system env for pythonpath
Key: FLINK-29479
URL: https://issues.apache.org/jira/browse/FLINK-29479
Project: Flink
Issue Type: Bug
jackylau created FLINK-29483:
Summary: flink python udf arrow in thread model bug
Key: FLINK-29483
URL: https://issues.apache.org/jira/browse/FLINK-29483
Project: Flink
Issue Type: Bug
jackylau created FLINK-29749:
Summary: flink info command support dynamic properties
Key: FLINK-29749
URL: https://issues.apache.org/jira/browse/FLINK-29749
Project: Flink
Issue Type: Bug
jackylau created FLINK-29934:
Summary: maven-assembly-plugin 2.4 make assemble plugin could find
xml in flink clients module
Key: FLINK-29934
URL: https://issues.apache.org/jira/browse/FLINK-29934
jackylau created FLINK-18208:
Summary: flink es connector exists 2 Spelling mistakes
Key: FLINK-18208
URL: https://issues.apache.org/jira/browse/FLINK-18208
Project: Flink
Issue Type
jackylau created FLINK-18213:
Summary: refactor kafka sql connector to use just one shade to
compatible 0.10.0.2 +
Key: FLINK-18213
URL: https://issues.apache.org/jira/browse/FLINK-18213
Project: Flink
jackylau created FLINK-18231:
Summary: flink kafka connector exists same qualified class name,
whch will cause conflicts when user has all the versions of
flink-kafka-connector
Key: FLINK-18231
URL: https
jackylau created FLINK-18236:
Summary: flink elasticsearch IT test
ElasticsearchSinkTestBase.runElasticsearchSink* verify it not right
Key: FLINK-18236
URL: https://issues.apache.org/jira/browse/FLINK-18236
jackylau created FLINK-18495:
Summary: flink filterpushdown can not take effect in blink planner
Key: FLINK-18495
URL: https://issues.apache.org/jira/browse/FLINK-18495
Project: Flink
Issue Type
86 matches
Mail list logo
