Frank Wong created FLINK-35598:
--
Summary: Fix error comparison type
ExtendedSqlRowTypeNameSpec#equalsDeep
Key: FLINK-35598
URL: https://issues.apache.org/jira/browse/FLINK-35598
Project: Flink
Daren Wong created FLINK-32317:
--
Summary: Enrich metadata in CR error field
Key: FLINK-32317
URL: https://issues.apache.org/jira/browse/FLINK-32317
Project: Flink
Issue Type: Improvement
Daren Wong created FLINK-31857:
--
Summary: Support pluginable observers mechanism
Key: FLINK-31857
URL: https://issues.apache.org/jira/browse/FLINK-31857
Project: Flink
Issue Type: Improvement
Daren Wong created FLINK-31845:
--
Summary: Make KubernetesStepDecorator Pluggable
Key: FLINK-31845
URL: https://issues.apache.org/jira/browse/FLINK-31845
Project: Flink
Issue Type: Improvement
Daren Wong created FLINK-31798:
--
Summary: Add config to enable/disable Kubernetes Events
Key: FLINK-31798
URL: https://issues.apache.org/jira/browse/FLINK-31798
Project: Flink
Issue Type:
Daren Wong created FLINK-31795:
--
Summary: Add Config to enable/disable savepoint cleanup
Key: FLINK-31795
URL: https://issues.apache.org/jira/browse/FLINK-31795
Project: Flink
Issue Type:
Daren Wong created FLINK-31794:
--
Summary: Ignore unknown CRD fields
Key: FLINK-31794
URL: https://issues.apache.org/jira/browse/FLINK-31794
Project: Flink
Issue Type: Improvement
Daren Wong created FLINK-30418:
--
Summary: Implement synchronous KinesisClient in EFO
Key: FLINK-30418
URL: https://issues.apache.org/jira/browse/FLINK-30418
Project: Flink
Issue Type:
Daren Wong created FLINK-30216:
--
Summary: Address tabs/spaces in checkstyle/spotless
Key: FLINK-30216
URL: https://issues.apache.org/jira/browse/FLINK-30216
Project: Flink
Issue Type:
Daren Wong created FLINK-30118:
--
Summary: Move DDB connector Integration Tests/ITCase to E2E test
Key: FLINK-30118
URL: https://issues.apache.org/jira/browse/FLINK-30118
Project: Flink
Issue
Daren Wong created FLINK-29847:
--
Summary: Store/cache JarUploadResponseBody
Key: FLINK-29847
URL: https://issues.apache.org/jira/browse/FLINK-29847
Project: Flink
Issue Type: Improvement
Daren Wong created FLINK-29708:
--
Summary: Enrich Flink Kubernetes Operator CRD error field
Key: FLINK-29708
URL: https://issues.apache.org/jira/browse/FLINK-29708
Project: Flink
Issue Type:
Daren Wong created FLINK-29667:
--
Summary: Upgrade DynamoDB Connector dependencies from SNAPSHOT to
release 1.16
Key: FLINK-29667
URL: https://issues.apache.org/jira/browse/FLINK-29667
Project: Flink
Clive Wong created FLINK-28613:
--
Summary: PyFlink 1.15 unable to start in Application Mode in k8s
Key: FLINK-28613
URL: https://issues.apache.org/jira/browse/FLINK-28613
Project: Flink
Issue
Daren Wong created FLINK-28494:
--
Summary: Add new job status states to CRD
Key: FLINK-28494
URL: https://issues.apache.org/jira/browse/FLINK-28494
Project: Flink
Issue Type: Improvement
Daren Wong created FLINK-28411:
--
Summary: OperatorCoordinator exception may fail Session Cluster
Key: FLINK-28411
URL: https://issues.apache.org/jira/browse/FLINK-28411
Project: Flink
Issue
Small Wong created FLINK-2:
--
Summary: Can not get the parquet.compression when using native
parquet writer to sink hive
Key: FLINK-2
URL: https://issues.apache.org/jira/browse/FLINK-2
Ada Wong created FLINK-25834:
Summary: 'flink run' command can not use 'pipeline.classpaths' in
flink-conf.yaml
Key: FLINK-25834
URL: https://issues.apache.org/jira/browse/FLINK-25834
Project: Flink
Ada Wong created FLINK-25804:
Summary: Loading and running connector code use separated
ClassLoader.
Key: FLINK-25804
URL: https://issues.apache.org/jira/browse/FLINK-25804
Project: Flink
Issue
Ada Wong created FLINK-25795:
Summary: Support Pulsar sink connector in Python DataStream API.
Key: FLINK-25795
URL: https://issues.apache.org/jira/browse/FLINK-25795
Project: Flink
Issue Type:
Ada Wong created FLINK-25601:
Summary: Update 'state.backend' in flink-conf.yaml
Key: FLINK-25601
URL: https://issues.apache.org/jira/browse/FLINK-25601
Project: Flink
Issue Type: Improvement
Bruce Wong created FLINK-25560:
--
Summary: Add
Key: FLINK-25560
URL: https://issues.apache.org/jira/browse/FLINK-25560
Project: Flink
Issue Type: Improvement
Reporter: Bruce Wong
Ada Wong created FLINK-25530:
Summary: Support Pulsar source connector in Python DataStream API.
Key: FLINK-25530
URL: https://issues.apache.org/jira/browse/FLINK-25530
Project: Flink
Issue
Ada Wong created FLINK-25485:
Summary: JDBC connector implicitly add options when use mysql
Key: FLINK-25485
URL: https://issues.apache.org/jira/browse/FLINK-25485
Project: Flink
Issue Type:
Ada Wong created FLINK-25434:
Summary: Throw an error when BigDecimal precision overflows.
Key: FLINK-25434
URL: https://issues.apache.org/jira/browse/FLINK-25434
Project: Flink
Issue Type: Bug
Bruce Wong created FLINK-25330:
--
Summary: Flink SQL doesn't retract all versions of Hbase data
Key: FLINK-25330
URL: https://issues.apache.org/jira/browse/FLINK-25330
Project: Flink
Issue Type:
Ada Wong created FLINK-25240:
Summary: Update log4j2 version to 2.15.0
Key: FLINK-25240
URL: https://issues.apache.org/jira/browse/FLINK-25240
Project: Flink
Issue Type: Bug
Ada Wong created FLINK-25239:
Summary: Delete useless variables
Key: FLINK-25239
URL: https://issues.apache.org/jira/browse/FLINK-25239
Project: Flink
Issue Type: Improvement
Ada Wong created FLINK-25188:
Summary: Cannot install PyFlink in M1 CPU
Key: FLINK-25188
URL: https://issues.apache.org/jira/browse/FLINK-25188
Project: Flink
Issue Type: Bug
Ada Wong created FLINK-25141:
Summary: Elasticsearch connector customize sink parallelism
Key: FLINK-25141
URL: https://issues.apache.org/jira/browse/FLINK-25141
Project: Flink
Issue Type:
Ada Wong created FLINK-24661:
Summary: ConfigOption add isSecret method to judge sensitive
options
Key: FLINK-24661
URL: https://issues.apache.org/jira/browse/FLINK-24661
Project: Flink
Issue
Ada Wong created FLINK-24381:
Summary: Hidden password value when Flink SQL connector throw
exception.
Key: FLINK-24381
URL: https://issues.apache.org/jira/browse/FLINK-24381
Project: Flink
Ada Wong created FLINK-23324:
Summary: Postgres of JDBC Connector enable case-sensitive.
Key: FLINK-23324
URL: https://issues.apache.org/jira/browse/FLINK-23324
Project: Flink
Issue Type: Bug
Ada Wong created FLINK-23263:
Summary: LocalBufferPool can not request memory.
Key: FLINK-23263
URL: https://issues.apache.org/jira/browse/FLINK-23263
Project: Flink
Issue Type: Improvement
Ada Wong created FLINK-23074:
Summary: There is a class conflict between flink-connector-hive
and flink-parquet
Key: FLINK-23074
URL: https://issues.apache.org/jira/browse/FLINK-23074
Project: Flink
Ada Wong created FLINK-22776:
Summary: Delete casting to byte[]
Key: FLINK-22776
URL: https://issues.apache.org/jira/browse/FLINK-22776
Project: Flink
Issue Type: Improvement
Frost Wong created FLINK-21268:
--
Summary: Logs view can't scoll in Firefox
Key: FLINK-21268
URL: https://issues.apache.org/jira/browse/FLINK-21268
Project: Flink
Issue Type: Bug
Mulan Wong created FLINK-20696:
--
Summary: Yarn Session Blob Directory is not deleted.
Key: FLINK-20696
URL: https://issues.apache.org/jira/browse/FLINK-20696
Project: Flink
Issue Type: Bug
Victor Wong created FLINK-16884:
---
Summary: The "rest.port" configuration is always "0" with
flink-yarn jobs
Key: FLINK-16884
URL: https://issues.apache.org/jira/browse/FLINK-16884
Project: Flink
Jimmy Wong created FLINK-16868:
--
Summary: Table/SQL doesn't support custom trigger
Key: FLINK-16868
URL: https://issues.apache.org/jira/browse/FLINK-16868
Project: Flink
Issue Type: New Feature
mayne wong created FLINK-16687:
--
Summary: PyFlink Cannot determine simple type name
"PythonScalarFunction$0"
Key: FLINK-16687
URL: https://issues.apache.org/jira/browse/FLINK-16687
Project: Flink
Victor Wong created FLINK-16376:
---
Summary: Using consistent method to get Yarn application directory
Key: FLINK-16376
URL: https://issues.apache.org/jira/browse/FLINK-16376
Project: Flink
Victor Wong created FLINK-15992:
---
Summary: Incorrect classloader when finding TableFactory
Key: FLINK-15992
URL: https://issues.apache.org/jira/browse/FLINK-15992
Project: Flink
Issue Type:
Wong created FLINK-15876:
Summary: The alternative code for
GroupedProcessingTimeWindowExample don't compile pass current version
Key: FLINK-15876
URL: https://issues.apache.org/jira/browse/FLINK-15876
Victor Wong created FLINK-15450:
---
Summary: Add kafka topic information to Kafka source
Key: FLINK-15450
URL: https://issues.apache.org/jira/browse/FLINK-15450
Project: Flink
Issue Type:
Victor Wong created FLINK-15449:
---
Summary: Retain lost task managers on Flink UI
Key: FLINK-15449
URL: https://issues.apache.org/jira/browse/FLINK-15449
Project: Flink
Issue Type: Improvement
Victor Wong created FLINK-15448:
---
Summary: Make "ResourceID#toString" more descriptive
Key: FLINK-15448
URL: https://issues.apache.org/jira/browse/FLINK-15448
Project: Flink
Issue Type:
Victor Wong created FLINK-15447:
---
Summary: Change "java.io.tmpdir" of JM/TM on Yarn to
"{{PWD}}/tmp"
Key: FLINK-15447
URL: https://issues.apache.org/jira/browse/FLINK-15447
Project: Flink
Victor Wong created FLINK-14835:
---
Summary: Make `org.apache.flink.configuration.Configuration`
support method chaining
Key: FLINK-14835
URL: https://issues.apache.org/jira/browse/FLINK-14835
Project:
Victor Wong created FLINK-14817:
---
Summary: "Streaming Aggregation" document contains misleading code
examples
Key: FLINK-14817
URL: https://issues.apache.org/jira/browse/FLINK-14817
Project: Flink
Victor Wong created FLINK-14642:
---
Summary: Flink TupleSerializer and CaseClassSerializer shoud
support copy NULL values
Key: FLINK-14642
URL: https://issues.apache.org/jira/browse/FLINK-14642
Project:
Victor Wong created FLINK-14626:
---
Summary: User jar packaged with hadoop dependencies may cause
class conflit with hadoop jars on yarn
Key: FLINK-14626
URL: https://issues.apache.org/jira/browse/FLINK-14626
Jimmy Wong created FLINK-14031:
--
Summary: flink-examples should add blink dependency on
flink-examples-table
Key: FLINK-14031
URL: https://issues.apache.org/jira/browse/FLINK-14031
Project: Flink
Wong created FLINK-13035:
Summary: LocalStreamEnvironment shall launch actuall task solts
Key: FLINK-13035
URL: https://issues.apache.org/jira/browse/FLINK-13035
Project: Flink
Issue Type: Wish
Wong created FLINK-12759:
Summary: FLInk localmode IN MINICluster can't drow DAG visualizer
plan
Key: FLINK-12759
URL: https://issues.apache.org/jira/browse/FLINK-12759
Project: Flink
Issue Type:
Victor Wong created FLINK-12648:
---
Summary: Load Hadoop file system via FileSystem.get()
Key: FLINK-12648
URL: https://issues.apache.org/jira/browse/FLINK-12648
Project: Flink
Issue Type:
Victor Wong created FLINK-12646:
---
Summary: Fix broken tests of RestClientTest
Key: FLINK-12646
URL: https://issues.apache.org/jira/browse/FLINK-12646
Project: Flink
Issue Type: Bug
Victor Wong created FLINK-12472:
---
Summary: Support setting attemptFailuresValidityInterval of jobs
on Yarn
Key: FLINK-12472
URL: https://issues.apache.org/jira/browse/FLINK-12472
Project: Flink
Victor Wong created FLINK-12468:
---
Summary: Unregister application from the YARN Resource Manager
with a valid appTrackingUrl
Key: FLINK-12468
URL: https://issues.apache.org/jira/browse/FLINK-12468
Victor Wong created FLINK-12459:
---
Summary: YarnConfigOptions#CLASSPATH_INCLUDE_USER_JAR should
affect the order of classpath between user jars and flink jar
Key: FLINK-12459
URL:
Victor Wong created FLINK-12130:
---
Summary: Apply command line options to configuration before
install security modules
Key: FLINK-12130
URL: https://issues.apache.org/jira/browse/FLINK-12130
Project:
Wong created FLINK-11016:
Summary: flink chain have a bug？？？
Key: FLINK-11016
URL: https://issues.apache.org/jira/browse/FLINK-11016
Project: Flink
Issue Type: Bug
Components: Core
Michael Wong created FLINK-4506:
---
Summary: CsvOutputFormat defaults allowNullValues to false, even
though doc and declaration says true
Key: FLINK-4506
URL: https://issues.apache.org/jira/browse/FLINK-4506
63 matches
Mail list logo
