[jira] [Updated] (FLINK-33426) If the directory does not have the read permission, an exception cannot be thrown, when read this path.
[ https://issues.apache.org/jira/browse/FLINK-33426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wenhao.yu updated FLINK-33426: -- Issue Type: Improvement (was: Bug) > If the directory does not have the read permission, an exception cannot be > thrown, when read this path. > --- > > Key: FLINK-33426 > URL: https://issues.apache.org/jira/browse/FLINK-33426 > Project: Flink > Issue Type: Improvement > Components: API / DataStream >Affects Versions: 1.13.5, 1.17.1 >Reporter: wenhao.yu >Priority: Major > Fix For: 1.17.1 > > Original Estimate: 1h > Remaining Estimate: 1h > > When I use StreamExecutionEnvironment.ReadFile () this API, found that while > reading on HDFS directory if the directory does not give permission to read, > then this exception is not thrown, task would have been run, the outside > world will not perceive the task status. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-33426) If the directory does not have the read permission, an exception cannot be thrown, when read this path.
wenhao.yu created FLINK-33426: - Summary: If the directory does not have the read permission, an exception cannot be thrown, when read this path. Key: FLINK-33426 URL: https://issues.apache.org/jira/browse/FLINK-33426 Project: Flink Issue Type: Bug Components: API / DataStream Affects Versions: 1.17.1, 1.13.5 Reporter: wenhao.yu Fix For: 1.17.1 When I use StreamExecutionEnvironment.ReadFile () this API, found that while reading on HDFS directory if the directory does not give permission to read, then this exception is not thrown, task would have been run, the outside world will not perceive the task status. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-33145) Exposes the FileLifeCycleListener interface
[ https://issues.apache.org/jira/browse/FLINK-33145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wenhao.yu updated FLINK-33145: -- Affects Version/s: 1.17.1 (was: 1.15.4) > Exposes the FileLifeCycleListener interface > --- > > Key: FLINK-33145 > URL: https://issues.apache.org/jira/browse/FLINK-33145 > Project: Flink > Issue Type: New Feature > Components: Connectors / FileSystem >Affects Versions: 1.17.1 >Reporter: wenhao.yu >Priority: Minor > Fix For: 1.15.4 > > > Monitors the life cycle of written files. Users can customize operations > after the file is > committed. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-33150) add the processing logic for the long type
wenhao.yu created FLINK-33150: - Summary: add the processing logic for the long type Key: FLINK-33150 URL: https://issues.apache.org/jira/browse/FLINK-33150 Project: Flink Issue Type: New Feature Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile) Affects Versions: 1.15.4 Reporter: wenhao.yu Fix For: 1.15.4 The AvroToRowDataConverters class has a convertToDate method that will report an error when it encounters time data represented by the long type, so add a code to handle the long type. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-33145) Exposes the FileLifeCycleListener interface
wenhao.yu created FLINK-33145: - Summary: Exposes the FileLifeCycleListener interface Key: FLINK-33145 URL: https://issues.apache.org/jira/browse/FLINK-33145 Project: Flink Issue Type: New Feature Components: Connectors / FileSystem Affects Versions: 1.15.4 Reporter: wenhao.yu Fix For: 1.15.4 Monitors the life cycle of written files. Users can customize operations after the file is committed. -- This message was sent by Atlassian Jira (v8.20.10#820010)
