[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585019#comment-16585019 ] ASF GitHub Bot commented on FLINK-10145: yanghua commented on a change in pull request #6576:

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585022#comment-16585022 ] ASF GitHub Bot commented on FLINK-10145: yanghua commented on a change in pull request #6576:

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585024#comment-16585024 ] ASF GitHub Bot commented on FLINK-10145: yanghua commented on a change in pull request #6576:

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585023#comment-16585023 ] ASF GitHub Bot commented on FLINK-10145: yanghua commented on a change in pull request #6576:

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585021#comment-16585021 ] ASF GitHub Bot commented on FLINK-10145: yanghua commented on a change in pull request #6576:

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16585020#comment-16585020 ] ASF GitHub Bot commented on FLINK-10145: yanghua commented on a change in pull request #6576:

[GitHub] yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211091915 ## File path:

[GitHub] yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211091900 ## File path: docs/dev/table/functions.md ## @@ -2592,6 +2604,18 @@

[GitHub] yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211091912 ## File path:

[GitHub] yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211091901 ## File path: docs/dev/table/functions.md ## @@ -2784,6 +2808,18 @@

[GitHub] yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211091929 ## File path:

[GitHub] yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

yanghua commented on a change in pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#discussion_r211091930 ## File path:

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584999#comment-16584999 ] ASF GitHub Bot commented on FLINK-10145: Guibo-Pan commented on issue #6576:

[GitHub] Guibo-Pan commented on issue #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

Guibo-Pan commented on issue #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#issuecomment-414101901 cc @yanghua @tillrohrmann a small feature~ This is an

[jira] [Updated] (FLINK-9849) Create hbase connector for hbase version to 2.0.1

[ https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9849: -- Description: Currently hbase 1.4.3 is used for hbase connector. We should create connector for hbase 2.0.1

[jira] [Updated] (FLINK-9924) Upgrade zookeeper to 3.4.13

[ https://issues.apache.org/jira/browse/FLINK-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9924: -- Description: zookeeper 3.4.13 is being released. ZOOKEEPER-2959 fixes data loss when observer is used

[jira] [Updated] (FLINK-10168) support filtering files by modified/created time in StreamExecutionEnvironment.readFile()

[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10168: - Description: support filtering files by modified/created time in

[jira] [Commented] (FLINK-10168) support filtering files by modified/created time in StreamExecutionEnvironment.readFile()

[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584865#comment-16584865 ] Bowen Li commented on FLINK-10168: -- Hi [~wind_ljy] , please see the updated description of what I mean

[jira] [Updated] (FLINK-10168) support filtering files by modified/created time in StreamExecutionEnvironment.readFile()

[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-10168: - Description: support filtering files by modified/created time in

[jira] [Updated] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10145: --- Labels: pull-request-available (was: ) > Add replace supported in TableAPI and SQL >

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584852#comment-16584852 ] ASF GitHub Bot commented on FLINK-10145: Guibo-Pan opened a new pull request #6576:

[GitHub] Guibo-Pan opened a new pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

Guibo-Pan opened a new pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576 ## What is the purpose of the change *This pull request add replace supported in TableAPI and SQL* ## Brief change log

[GitHub] jrthe42 edited a comment on issue #6575: [hotfix][table] Fix bug in RowtimeValidator when getting custom TimestampExtractor

jrthe42 edited a comment on issue #6575: [hotfix][table] Fix bug in RowtimeValidator when getting custom TimestampExtractor URL: https://github.com/apache/flink/pull/6575#issuecomment-414063096 A test has been added for using custom ```TimestampExtractor```. cc @twalthr .

[GitHub] jrthe42 commented on issue #6575: [hotfix][table] Fix bug in RowtimeValidator when getting custom TimestampExtractor

jrthe42 commented on issue #6575: [hotfix][table] Fix bug in RowtimeValidator when getting custom TimestampExtractor URL: https://github.com/apache/flink/pull/6575#issuecomment-414063096 A test has been added for using custom ```TimestampExtractor```.

[jira] [Commented] (FLINK-9116) Introduce getAll and removeAll for MapState

[ https://issues.apache.org/jira/browse/FLINK-9116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584760#comment-16584760 ] ASF GitHub Bot commented on FLINK-9116: --- klion26 commented on issue #6558: [FLINK-9116] Introduce

[GitHub] klion26 commented on issue #6558: [FLINK-9116] Introduce getAll and removeAll for MapState

klion26 commented on issue #6558: [FLINK-9116] Introduce getAll and removeAll for MapState URL: https://github.com/apache/flink/pull/6558#issuecomment-414059575 Hi, @StefanRRichter I have addressed your comments. Please have another review. In my opinion, add getAll/removeAll

[jira] [Commented] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584676#comment-16584676 ] ASF GitHub Bot commented on FLINK-9962: --- kl0u commented on issue #6492: [FLINK-9962] [FS connector]

[GitHub] kl0u commented on issue #6492: [FLINK-9962] [FS connector] allow users to specify TimeZone in DateTimeBucketer

kl0u commented on issue #6492: [FLINK-9962] [FS connector] allow users to specify TimeZone in DateTimeBucketer URL: https://github.com/apache/flink/pull/6492#issuecomment-414036401 Hi @bowenli86 ! Are you planning to continue working on this issue? If not, I could work on that next week

[jira] [Commented] (FLINK-10168) support filtering files by modified/created time in StreamExecutionEnvironment.readFile()

[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584675#comment-16584675 ] buptljy commented on FLINK-10168: - [~phoenixjiangnan] Thanks! I think this will be a good improvement.

[jira] [Commented] (FLINK-10163) Support CREATE VIEW in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-10163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584672#comment-16584672 ] Timo Walther commented on FLINK-10163: -- [~suez1224] Yes, I think the full implementation as

[jira] [Assigned] (FLINK-10168) support filtering files by modified/created time in StreamExecutionEnvironment.readFile()

[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] buptljy reassigned FLINK-10168: --- Assignee: buptljy > support filtering files by modified/created time in >

[jira] [Commented] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584667#comment-16584667 ] ASF GitHub Bot commented on FLINK-9407: --- phenixmzy edited a comment on issue #6075: [FLINK-9407]

[jira] [Commented] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584665#comment-16584665 ] ASF GitHub Bot commented on FLINK-9407: --- phenixmzy edited a comment on issue #6075: [FLINK-9407]

[GitHub] phenixmzy edited a comment on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer

phenixmzy edited a comment on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer URL: https://github.com/apache/flink/pull/6075#issuecomment-414035357 @zhangminglei the OrcFileWriter with BucketingSink can rolling when the batchSize is full? It seems that

[GitHub] phenixmzy edited a comment on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer

phenixmzy edited a comment on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer URL: https://github.com/apache/flink/pull/6075#issuecomment-414035357 @zhangminglei the OrcFileWriter with BucketingSink can rolling when the batchSize is full? It seems that

[jira] [Commented] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584664#comment-16584664 ] ASF GitHub Bot commented on FLINK-9407: --- phenixmzy commented on issue #6075: [FLINK-9407] [hdfs

[GitHub] phenixmzy commented on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer

phenixmzy commented on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer URL: https://github.com/apache/flink/pull/6075#issuecomment-414035357 @zhangminglei the OrcFileWriter with BucketingSink can rolling when the batchSize is full?It seems that one record

[jira] [Commented] (FLINK-10068) Add documentation for async/RocksDB-based timers

[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584658#comment-16584658 ] ASF GitHub Bot commented on FLINK-10068: twalthr commented on issue #6504: [FLINK-10068][docs]

[GitHub] twalthr commented on issue #6504: [FLINK-10068][docs] Add documentation for RocksDB-based timers and st…

twalthr commented on issue #6504: [FLINK-10068][docs] Add documentation for RocksDB-based timers and st… URL: https://github.com/apache/flink/pull/6504#issuecomment-414035015 Thanks for the update @StefanRRichter. LGTM % the single comment. Feel free to merge this.

[jira] [Commented] (FLINK-10068) Add documentation for async/RocksDB-based timers

[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584657#comment-16584657 ] ASF GitHub Bot commented on FLINK-10068: twalthr commented on a change in pull request #6504:

[GitHub] twalthr commented on a change in pull request #6504: [FLINK-10068][docs] Add documentation for RocksDB-based timers and st…

twalthr commented on a change in pull request #6504: [FLINK-10068][docs] Add documentation for RocksDB-based timers and st… URL: https://github.com/apache/flink/pull/6504#discussion_r211066338 ## File path: docs/dev/stream/operators/process_function.md ## @@ -277,19

[jira] [Commented] (FLINK-10068) Add documentation for async/RocksDB-based timers

[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584656#comment-16584656 ] ASF GitHub Bot commented on FLINK-10068: twalthr commented on a change in pull request #6504: