[jira] [Commented] (FLINK-11004) Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction

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

[GitHub] yuanyangwu commented on a change in pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document

yuanyangwu commented on a change in pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document URL: https://github.com/apache/flink/pull/7175#discussion_r236551419 ## File path: docs/dev/stream/operators/windows.md ##

[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks

[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16700024#comment-16700024 ] Jiayi Liao commented on FLINK-5601: --- [~icshuo] I've fixed the problem. It took me a while to

[jira] [Commented] (FLINK-10958) Add overload support for user defined function

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

[GitHub] dianfu commented on a change in pull request #7152: [FLINK-10958] [table] Add overload support for user defined function

dianfu commented on a change in pull request #7152: [FLINK-10958] [table] Add overload support for user defined function URL: https://github.com/apache/flink/pull/7152#discussion_r236540135 ## File path:

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

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

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699989#comment-16699989 ] ASF GitHub Bot commented on FLINK-10134: XuQianJin-Stars commented on issue #7157: [FLINK-10134]

[GitHub] dianfu opened a new pull request #7179: [hotfix] [table][tests] (follow up) Moves the overload test case to UserDefinedScalarFunctionTest

dianfu opened a new pull request #7179: [hotfix] [table][tests] (follow up) Moves the overload test case to UserDefinedScalarFunctionTest URL: https://github.com/apache/flink/pull/7179 ## What is the purpose of the change *This is a follow up of FLINK-10958 which moves the it cases

[jira] [Commented] (FLINK-11004) Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction

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

[GitHub] yuanyangwu commented on a change in pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document

yuanyangwu commented on a change in pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document URL: https://github.com/apache/flink/pull/7175#discussion_r236537954 ## File path: docs/dev/stream/operators/windows.md ##

[GitHub] hequn8128 commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

hequn8128 commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r236537434 ## File path:

[GitHub] XuQianJin-Stars commented on issue #7157: [FLINK-10134] UTF-16 support for TextInputFormat bug

XuQianJin-Stars commented on issue #7157: [FLINK-10134] UTF-16 support for TextInputFormat bug URL: https://github.com/apache/flink/pull/7157#issuecomment-441947433 hi @fhueske Thank you very much for your help. If you can spare some time, I would like to continue asking you to review

[jira] [Commented] (FLINK-11004) Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction

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

[GitHub] sunjincheng121 commented on a change in pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document

sunjincheng121 commented on a change in pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document URL: https://github.com/apache/flink/pull/7175#discussion_r236533158 ## File path: docs/dev/stream/operators/windows.md

[jira] [Updated] (FLINK-11009) Add support for FILTER clause for non-windowed aggregation in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-11009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11009: --- Labels: pull-request-available (was: ) > Add support for FILTER clause for non-windowed

[jira] [Commented] (FLINK-11009) Add support for FILTER clause for non-windowed aggregation in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-11009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699969#comment-16699969 ] ASF GitHub Bot commented on FLINK-11009: dianfu opened a new pull request #7178: [FLINK-11009]

[GitHub] dianfu opened a new pull request #7178: [FLINK-11009] [table] Add support for FILTER clause for non-windowed aggregation in Table API and SQL

dianfu opened a new pull request #7178: [FLINK-11009] [table] Add support for FILTER clause for non-windowed aggregation in Table API and SQL URL: https://github.com/apache/flink/pull/7178 ## What is the purpose of the change *This pull request add the support of FILTER clause for

[jira] [Closed] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

[ https://issues.apache.org/jira/browse/FLINK-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-10009. --- Resolution: Fixed Fixed in master: cd09fbf606c9f508b7d6879247b3a371ed7a1920 > Fix the casting

[jira] [Commented] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

[ https://issues.apache.org/jira/browse/FLINK-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699962#comment-16699962 ] ASF GitHub Bot commented on FLINK-10009: asfgit closed pull request #7155: [FLINK-10009] [table]

[GitHub] asfgit closed pull request #7155: [FLINK-10009] [table] Fix the casting problem for function TIMESTAMPADD in Table

asfgit closed pull request #7155: [FLINK-10009] [table] Fix the casting problem for function TIMESTAMPADD in Table URL: https://github.com/apache/flink/pull/7155 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[jira] [Commented] (FLINK-11004) Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction

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

[jira] [Created] (FLINK-11009) Add support for FILTER clause for non-windowed aggregation in Table API and SQL

Dian Fu created FLINK-11009: --- Summary: Add support for FILTER clause for non-windowed aggregation in Table API and SQL Key: FLINK-11009 URL: https://issues.apache.org/jira/browse/FLINK-11009 Project: Flink

[GitHub] yuanyangwu commented on a change in pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document

yuanyangwu commented on a change in pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document URL: https://github.com/apache/flink/pull/7175#discussion_r236528195 ## File path: docs/dev/stream/operators/windows.md ##

[jira] [Updated] (FLINK-11008) Speed up upload checkpoint files using multi-thread

[ https://issues.apache.org/jira/browse/FLINK-11008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-11008: - Component/s: State Backends, Checkpointing > Speed up upload checkpoint files using

[jira] [Created] (FLINK-11008) Speed up upload checkpoint files using multi-thread

Congxian Qiu created FLINK-11008: Summary: Speed up upload checkpoint files using multi-thread Key: FLINK-11008 URL: https://issues.apache.org/jira/browse/FLINK-11008 Project: Flink Issue

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699934#comment-16699934 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on issue #6483:

[GitHub] HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format

HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-441920259 @fhueske I removed timestamp override, and also update the failure recovery test case to test recovery reading file with 10

[GitHub] yanghua commented on issue #5641: [WIP] Introduce ElasticBloomFilter for Approximate calculation and other situations of performance optimization

yanghua commented on issue #5641: [WIP] Introduce ElasticBloomFilter for Approximate calculation and other situations of performance optimization URL: https://github.com/apache/flink/pull/5641#issuecomment-441912153 @sihuazhou This PR has conflicts, can you rebase and fix it?

[jira] [Commented] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows

[ https://issues.apache.org/jira/browse/FLINK-10918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699914#comment-16699914 ] ASF GitHub Bot commented on FLINK-10918: imamitsehgal removed a comment on issue #7171:

[GitHub] imamitsehgal removed a comment on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock …

imamitsehgal removed a comment on issue #7171: FLINK-10918 Fix error while checkpointing on window keyed state rock … URL: https://github.com/apache/flink/pull/7171#issuecomment-441378109 What is the purpose of the change? To fix the issue with creating directory while running on

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

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

[GitHub] sunjincheng121 commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

sunjincheng121 commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r236513562 ## File path:

[GitHub] shuiqiangchen commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

shuiqiangchen commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r236513423 ## File path: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ## @@

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[GitHub] zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r236512499 ## File path: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ## @@ -139,7

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699856#comment-16699856 ] ASF GitHub Bot commented on FLINK-9555: --- zjffdu commented on issue #7121: [FLINK-9555]Support table

[GitHub] zjffdu commented on issue #7121: [FLINK-9555]Support table api in scala shell

zjffdu commented on issue #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#issuecomment-441880219 Thanks @shuiqiangchen , I left a few comments. And agree with @sunjincheng121 , we need to add test

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[GitHub] zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r236504524 ## File path: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ## @@ -243,22

[GitHub] zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r236504513 ## File path: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ## @@ -243,22

[GitHub] zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r236504436 ## File path: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ## @@ -243,22

[GitHub] zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

zjffdu commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r236504392 ## File path: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ## @@ -243,22

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[GitHub] shuiqiangchen commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

shuiqiangchen commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r236503717 ## File path: flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ## @@

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[GitHub] shuiqiangchen commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell

shuiqiangchen commented on a change in pull request #7121: [FLINK-9555]Support table api in scala shell URL: https://github.com/apache/flink/pull/7121#discussion_r236503478 ## File path: flink-dist/pom.xml ## @@ -319,7 +319,6 @@ under the License.

[jira] [Commented] (FLINK-9555) Support table api in scala shell

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

[jira] [Commented] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

[ https://issues.apache.org/jira/browse/FLINK-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699824#comment-16699824 ] ASF GitHub Bot commented on FLINK-10009: sunjincheng121 commented on issue #7155: [FLINK-10009]

[GitHub] sunjincheng121 commented on issue #7155: [FLINK-10009] [table] Fix the casting problem for function TIMESTAMPADD in Table

sunjincheng121 commented on issue #7155: [FLINK-10009] [table] Fix the casting problem for function TIMESTAMPADD in Table URL: https://github.com/apache/flink/pull/7155#issuecomment-441875172 Merging ... This is an automated

[jira] [Commented] (FLINK-11004) Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction

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

[GitHub] sunjincheng121 commented on a change in pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document

sunjincheng121 commented on a change in pull request #7175: [FLINK-11004][Documentation] wrong ProcessWindowFunction.process argument in window document URL: https://github.com/apache/flink/pull/7175#discussion_r236496272 ## File path: docs/dev/stream/operators/windows.md

[jira] [Commented] (FLINK-10997) Avro-confluent-registry does not bundle any dependency

[ https://issues.apache.org/jira/browse/FLINK-10997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699589#comment-16699589 ] ASF GitHub Bot commented on FLINK-10997: dawidwys commented on issue #7170:

[GitHub] dawidwys commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client

dawidwys commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client URL: https://github.com/apache/flink/pull/7170#issuecomment-441799465 How about if we include just what we need for the confluent schema-registry in the uber-jar:

[jira] [Commented] (FLINK-10997) Avro-confluent-registry does not bundle any dependency

[ https://issues.apache.org/jira/browse/FLINK-10997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699548#comment-16699548 ] ASF GitHub Bot commented on FLINK-10997: dawidwys commented on issue #7170:

[GitHub] dawidwys commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client

dawidwys commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client URL: https://github.com/apache/flink/pull/7170#issuecomment-441788027 My understanding/plan when I first worked on it was as @zentol described that the only dependency user should specify is

[jira] [Created] (FLINK-11007) Update documentation to describe new checkpoint metadata file behavior

Josh Lemer created FLINK-11007: -- Summary: Update documentation to describe new checkpoint metadata file behavior Key: FLINK-11007 URL: https://issues.apache.org/jira/browse/FLINK-11007 Project: Flink

[jira] [Commented] (FLINK-10471) State TTL cleanup using RocksDb compaction filter

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

[GitHub] azagrebin commented on a change in pull request #7163: [FLINK-10471][State TTL] State TTL cleanup using RocksDb compaction filter

azagrebin commented on a change in pull request #7163: [FLINK-10471][State TTL] State TTL cleanup using RocksDb compaction filter URL: https://github.com/apache/flink/pull/7163#discussion_r236383506 ## File path:

[jira] [Commented] (FLINK-10471) State TTL cleanup using RocksDb compaction filter

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

[GitHub] azagrebin commented on a change in pull request #7163: [FLINK-10471][State TTL] State TTL cleanup using RocksDb compaction filter

azagrebin commented on a change in pull request #7163: [FLINK-10471][State TTL] State TTL cleanup using RocksDb compaction filter URL: https://github.com/apache/flink/pull/7163#discussion_r236381761 ## File path:

[jira] [Closed] (FLINK-11006) Update Calcite dependency to 1.18

[ https://issues.apache.org/jira/browse/FLINK-11006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen closed FLINK-11006. -- Resolution: Duplicate > Update Calcite dependency to 1.18 > - > >

[jira] [Commented] (FLINK-11006) Update Calcite dependency to 1.18

[ https://issues.apache.org/jira/browse/FLINK-11006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699379#comment-16699379 ] Shuyi Chen commented on FLINK-11006: This is a duplicate of

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

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

[GitHub] StefanRRichter edited a comment on issue #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter edited a comment on issue #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#issuecomment-441723504 Thank you for this contribution. I think overall it looks good to me, in particular I like how

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

[ https://issues.apache.org/jira/browse/FLINK-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699327#comment-16699327 ] ASF GitHub Bot commented on FLINK-10865: StefanRRichter commented on issue #7123: [FLINK-10865]

[GitHub] StefanRRichter commented on issue #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter commented on issue #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#issuecomment-441723504 Thank you for this contribution. I think overall it looks good to me, in particular I like how detailed your

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

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

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

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

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

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

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

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

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

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

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

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

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

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

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

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

[GitHub] StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#discussion_r236347738 ## File path: docs/ops/deployment/oss.md ## @@ -0,0 +1,233 @@ +---

[GitHub] StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#discussion_r236348352 ## File path: docs/ops/deployment/oss.md ## @@ -0,0 +1,233 @@ +---

[GitHub] StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#discussion_r236344254 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#discussion_r236348730 ## File path: docs/ops/deployment/oss.md ## @@ -0,0 +1,233 @@ +---

[GitHub] StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#discussion_r236345238 ## File path: docs/ops/deployment/oss.md ## @@ -0,0 +1,233 @@ +---

[GitHub] StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#discussion_r236348045 ## File path: docs/ops/deployment/oss.md ## @@ -0,0 +1,233 @@ +---

[GitHub] StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#discussion_r236345803 ## File path: docs/ops/deployment/oss.md ## @@ -0,0 +1,233 @@ +---

[GitHub] StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

StefanRRichter commented on a change in pull request #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#discussion_r236345508 ## File path: docs/ops/deployment/oss.md ## @@ -0,0 +1,233 @@ +---

[jira] [Commented] (FLINK-10997) Avro-confluent-registry does not bundle any dependency

[ https://issues.apache.org/jira/browse/FLINK-10997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699216#comment-16699216 ] ASF GitHub Bot commented on FLINK-10997: zentol commented on issue #7170: [FLINK-10997][formats]

[GitHub] zentol commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client

zentol commented on issue #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client URL: https://github.com/apache/flink/pull/7170#issuecomment-441699554 My understanding was that users would define a dependency on `flink-avro-confluent-registry` and pull avro into the user-jar.

[jira] [Commented] (FLINK-11005) Define flink-sql-client uber-jar dependencies via artifactSet

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

[GitHub] zentol commented on a change in pull request #7176: [FLINK-11005] Define flink-sql-client uber-jar dependencies via artifactSet

zentol commented on a change in pull request #7176: [FLINK-11005] Define flink-sql-client uber-jar dependencies via artifactSet URL: https://github.com/apache/flink/pull/7176#discussion_r236319075 ## File path: flink-libraries/flink-sql-client/pom.xml ## @@ -144,30

[jira] [Commented] (FLINK-10929) Add support for Apache Arrow

[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699173#comment-16699173 ] Pedro Cardoso Silva commented on FLINK-10929: - {noformat} Pedro Cardoso Silva, what was the

[jira] [Created] (FLINK-11006) Update Calcite dependency to 1.18

Rong Rong created FLINK-11006: - Summary: Update Calcite dependency to 1.18 Key: FLINK-11006 URL: https://issues.apache.org/jira/browse/FLINK-11006 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699166#comment-16699166 ] ASF GitHub Bot commented on FLINK-7599: --- dawidwys opened a new pull request #7177: [FLINK-7599]

[GitHub] dawidwys opened a new pull request #7177: [FLINK-7599] Support for aggregates in MATCH_RECOGNIZE

dawidwys opened a new pull request #7177: [FLINK-7599] Support for aggregates in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7177 ## What is the purpose of the change This change allows using aggregates in MEASURES and DEFINE clauses of MATCH_RECOGNIZE in sql.

[jira] [Updated] (FLINK-7599) Support aggregation functions in the define and measures clause of MatchRecognize

[ https://issues.apache.org/jira/browse/FLINK-7599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7599: -- Labels: pull-request-available (was: ) > Support aggregation functions in the define and

[GitHub] kl0u commented on issue #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

kl0u commented on issue #6871: [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator. URL: https://github.com/apache/flink/pull/6871#issuecomment-441673911 Thanks @twalthr ! So I will rebase the PR and have another look and if travis gives green light, I will go on and

[jira] [Commented] (FLINK-10583) Add support for state retention to the Processing Time versioned joins.

[ https://issues.apache.org/jira/browse/FLINK-10583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699124#comment-16699124 ] ASF GitHub Bot commented on FLINK-10583: kl0u commented on issue #6871: [FLINK-10583][table] Add

[jira] [Commented] (FLINK-8159) Pattern(Flat)SelectFunctions should support RichFunction interface

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

[jira] [Commented] (FLINK-11005) Define flink-sql-client uber-jar dependencies via artifactSet

[ https://issues.apache.org/jira/browse/FLINK-11005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699115#comment-16699115 ] ASF GitHub Bot commented on FLINK-11005: tillrohrmann commented on issue #7176: [FLINK-11005]

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

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

[jira] [Commented] (FLINK-11005) Define flink-sql-client uber-jar dependencies via artifactSet

[ https://issues.apache.org/jira/browse/FLINK-11005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16699100#comment-16699100 ] ASF GitHub Bot commented on FLINK-11005: tillrohrmann opened a new pull request #7176:

  1   2   3   >