Shengnan YU created FLINK-32562:
---
Summary: FileSink Compactor Service should not use FileWriter from
Sink for OutputStreamBasedFileCompactor
Key: FLINK-32562
URL: https://issues.apache.org/jira/browse/FLINK-32562
Shengnan YU created FLINK-24391:
---
Summary: flink-json formats should support an option to extract
the raw message into a column
Key: FLINK-24391
URL: https://issues.apache.org/jira/browse/FLINK-24391
Pr
Shengnan YU created FLINK-23933:
---
Summary: flink-json formats support a option to parse nested json
as a String
Key: FLINK-23933
URL: https://issues.apache.org/jira/browse/FLINK-23933
Project: Flink
Shengnan YU created FLINK-18939:
---
Summary: Sort-partition result is incorrect when use Bigdecimal as
Key
Key: FLINK-18939
URL: https://issues.apache.org/jira/browse/FLINK-18939
Project: Flink
Shengnan YU created FLINK-14938:
---
Summary: Flink elasticsearch failure handler re-add indexrequest
causes ConcurrentModificationException
Key: FLINK-14938
URL: https://issues.apache.org/jira/browse/FLINK-14938
Shengnan YU created FLINK-13701:
---
Summary: KafkaTableSourceSink doesn't support topic pattern
Key: FLINK-13701
URL: https://issues.apache.org/jira/browse/FLINK-13701
Project: Flink
Issue Type:
Shengnan YU created FLINK-11928:
---
Summary: Create a Compression string writer for
flink-connectors-filesystem
Key: FLINK-11928
URL: https://issues.apache.org/jira/browse/FLINK-11928
Project: Flink
Shengnan YU created FLINK-11848:
---
Summary: Delete outdated kafka topics caused
UNKNOWN_TOPIC_EXCEPTIION
Key: FLINK-11848
URL: https://issues.apache.org/jira/browse/FLINK-11848
Project: Flink
I
