[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563195#comment-16563195 ] ASF GitHub Bot commented on FLINK-9739: --- sampathBhat commented on issue #6452: [FLI

[GitHub] sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-409112411 So what would be the resolution for this bug/PR? @zentol @StephanEwen --

[jira] [Commented] (FLINK-9697) Provide connector for Kafka 2.0.0

[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563187#comment-16563187 ] vinoyang commented on FLINK-9697: - hi [~yuzhih...@gmail.com] and [~tzulitai] ， Kafka 2.0

[jira] [Commented] (FLINK-9637) Add public user documentation for TTL feature

[ https://issues.apache.org/jira/browse/FLINK-9637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563163#comment-16563163 ] ASF GitHub Bot commented on FLINK-9637: --- bowenli86 commented on a change in pull re

[GitHub] bowenli86 commented on a change in pull request #6379: [FLINK-9637] Add public user documentation for state TTL feature

bowenli86 commented on a change in pull request #6379: [FLINK-9637] Add public user documentation for state TTL feature URL: https://github.com/apache/flink/pull/6379#discussion_r206399972 ## File path: docs/dev/stream/state/state.md ## @@ -266,6 +266,92 @@ a `ValueState`.

[jira] [Commented] (FLINK-9926) Allow for ShardConsumer override in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-9926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563161#comment-16563161 ] ASF GitHub Bot commented on FLINK-9926: --- tzulitai commented on issue #6427: [FLINK-

[GitHub] tzulitai commented on issue #6427: [FLINK-9926][Kinesis Connector] Allow for ShardConsumer override in Kinesis consumer.

tzulitai commented on issue #6427: [FLINK-9926][Kinesis Connector] Allow for ShardConsumer override in Kinesis consumer. URL: https://github.com/apache/flink/pull/6427#issuecomment-409101923 Thanks all for the PR and reviews. +1, merging this .. -

[jira] [Commented] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563155#comment-16563155 ] ASF GitHub Bot commented on FLINK-9897: --- tzulitai commented on issue #6408: [FLINK-

[GitHub] tzulitai commented on issue #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis

tzulitai commented on issue #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis URL: https://github.com/apache/flink/pull/6408#issuecomment-409101468 +1, thanks for the work @glaksh100 and @tweise for the help on the reviews.

[jira] [Commented] (FLINK-9926) Allow for ShardConsumer override in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-9926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16563112#comment-16563112 ] ASF GitHub Bot commented on FLINK-9926: --- tweise commented on issue #6427: [FLINK-99

[GitHub] tweise commented on issue #6427: [FLINK-9926][Kinesis Connector] Allow for ShardConsumer override in Kinesis consumer.

tweise commented on issue #6427: [FLINK-9926][Kinesis Connector] Allow for ShardConsumer override in Kinesis consumer. URL: https://github.com/apache/flink/pull/6427#issuecomment-409083557 @tzulitai it would be great if you could merge this PR. We also need it for https://issues.apache.

[jira] [Updated] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort

[ https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8037: -- Labels: kafka kafka-connect (was: kafka-connect) > Missing cast in integer arithmetic in > TransactionalIdsGe

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562994#comment-16562994 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on a change in pull requ

[GitHub] yanghua commented on a change in pull request #6432: [FLINK-9970] Add ASCII/CHR function for table/sql API

yanghua commented on a change in pull request #6432: [FLINK-9970] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r206376636 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/FunctionGene

[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&focusedCommentId=16562980#comment-16562980 ] ASF GitHub Bot commented on FLINK-9407: --- zhangminglei commented on a change in pull

[GitHub] zhangminglei commented on a change in pull request #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer

zhangminglei commented on a change in pull request #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer URL: https://github.com/apache/flink/pull/6075#discussion_r206374395 ## File path: flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.jav

[jira] [Comment Edited] (FLINK-9150) Prepare for Java 10

[ https://issues.apache.org/jira/browse/FLINK-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16473198#comment-16473198 ] Ted Yu edited comment on FLINK-9150 at 7/31/18 1:49 AM: Similar e

[jira] [Commented] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562745#comment-16562745 ] ASF GitHub Bot commented on FLINK-9897: --- glaksh100 edited a comment on issue #6408:

[GitHub] glaksh100 edited a comment on issue #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis

glaksh100 edited a comment on issue #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis URL: https://github.com/apache/flink/pull/6408#issuecomment-409059048 @tzulitai Thanks for reviewing and apologies for the delay. I have addr

[jira] [Commented] (FLINK-9926) Allow for ShardConsumer override in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-9926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562737#comment-16562737 ] ASF GitHub Bot commented on FLINK-9926: --- yxu-valleytider commented on a change in p

[GitHub] yxu-valleytider commented on a change in pull request #6427: [FLINK-9926][Kinesis Connector] Allow for ShardConsumer override in Kinesis consumer.

yxu-valleytider commented on a change in pull request #6427: [FLINK-9926][Kinesis Connector] Allow for ShardConsumer override in Kinesis consumer. URL: https://github.com/apache/flink/pull/6427#discussion_r206369575 ## File path: flink-connectors/flink-connector-kinesis/src/main/j

[GitHub] glaksh100 commented on issue #6427: [FLINK-9926][Kinesis Connector] Allow for ShardConsumer override in Kinesis consumer.

glaksh100 commented on issue #6427: [FLINK-9926][Kinesis Connector] Allow for ShardConsumer override in Kinesis consumer. URL: https://github.com/apache/flink/pull/6427#issuecomment-409059743 +1 from my side. LGTM. This is an

[jira] [Commented] (FLINK-9926) Allow for ShardConsumer override in Kinesis consumer

[ https://issues.apache.org/jira/browse/FLINK-9926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562725#comment-16562725 ] ASF GitHub Bot commented on FLINK-9926: --- glaksh100 commented on issue #6427: [FLINK

[jira] [Commented] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562723#comment-16562723 ] ASF GitHub Bot commented on FLINK-9897: --- glaksh100 commented on issue #6408: [FLINK

[GitHub] glaksh100 commented on issue #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis

glaksh100 commented on issue #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis URL: https://github.com/apache/flink/pull/6408#issuecomment-409059048 @tzulitai Thanks for reviewing and apologies for the delay. I have addressed

[jira] [Commented] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562699#comment-16562699 ] ASF GitHub Bot commented on FLINK-9897: --- glaksh100 commented on a change in pull re

[jira] [Commented] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562698#comment-16562698 ] ASF GitHub Bot commented on FLINK-9897: --- glaksh100 commented on a change in pull re

[GitHub] glaksh100 commented on a change in pull request #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis

glaksh100 commented on a change in pull request #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis URL: https://github.com/apache/flink/pull/6408#discussion_r206363113 ## File path: flink-connectors/flink-connector-kin

[GitHub] glaksh100 commented on a change in pull request #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis

glaksh100 commented on a change in pull request #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis URL: https://github.com/apache/flink/pull/6408#discussion_r206363100 ## File path: flink-connectors/flink-connector-kin

[jira] [Commented] (FLINK-9897) Further enhance adaptive reads in Kinesis Connector to depend on run loop time

[ https://issues.apache.org/jira/browse/FLINK-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562695#comment-16562695 ] ASF GitHub Bot commented on FLINK-9897: --- glaksh100 commented on a change in pull re

[GitHub] glaksh100 commented on a change in pull request #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis

glaksh100 commented on a change in pull request #6408: [FLINK-9897][Kinesis Connector] Make adaptive reads depend on run loop time instead of fetchintervalmillis URL: https://github.com/apache/flink/pull/6408#discussion_r206362309 ## File path: flink-connectors/flink-connector-kin

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562628#comment-16562628 ] ASF GitHub Bot commented on FLINK-9970: --- suez1224 commented on a change in pull req

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562630#comment-16562630 ] ASF GitHub Bot commented on FLINK-9970: --- suez1224 commented on a change in pull req

[GitHub] suez1224 commented on a change in pull request #6432: [FLINK-9970] Add ASCII/CHR function for table/sql API

suez1224 commented on a change in pull request #6432: [FLINK-9970] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r206346433 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/FunctionGen

[GitHub] suez1224 commented on a change in pull request #6432: [FLINK-9970] Add ASCII/CHR function for table/sql API

suez1224 commented on a change in pull request #6432: [FLINK-9970] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r206346433 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/FunctionGen

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562210#comment-16562210 ] Xingcan Cui commented on FLINK-9977: Hi [~twalthr], I've refined the documents for SQ

[jira] [Commented] (FLINK-9875) Add concurrent creation of execution job vertex

[ https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562203#comment-16562203 ] ASF GitHub Bot commented on FLINK-9875: --- StephanEwen commented on issue #6353: [FLI

[GitHub] StephanEwen commented on issue #6353: [FLINK-9875][runtime] Add concurrent creation of execution job vertex

StephanEwen commented on issue #6353: [FLINK-9875][runtime] Add concurrent creation of execution job vertex URL: https://github.com/apache/flink/pull/6353#issuecomment-408947775 I would suggest to first drive a discussion about what the interface for the creation of input splits would be.

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562202#comment-16562202 ] ASF GitHub Bot commented on FLINK-9739: --- sampathBhat commented on issue #6452: [FLI

[GitHub] sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-408947692 This works fine state.backend.rocksdb.localdir = /some/file/path. At least there is no (relative path)exception thrown if

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562186#comment-16562186 ] ASF GitHub Bot commented on FLINK-9739: --- StephanEwen commented on issue #6452: [FLI

[GitHub] StephanEwen commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

StephanEwen commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-408945091 The character `:` is actually the standard UNIX path separator. Not supporting this would be kind of strange and break ex

[jira] [Closed] (FLINK-3930) Implement Service-Level Authorization

[ https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-3930. --- Resolution: Won't Fix _This issue relates to the obsolete plan to use a 'shared secret' for client a

[jira] [Closed] (FLINK-4919) Add secure cookie support for the cluster deployed in Mesos environment

[ https://issues.apache.org/jira/browse/FLINK-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-4919. --- Resolution: Won't Fix _This issue relates to the obsolete plan to use a 'shared secret' for client a

[jira] [Closed] (FLINK-4637) Address Yarn proxy incompatibility with Flink Web UI when service level authorization is enabled

[ https://issues.apache.org/jira/browse/FLINK-4637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-4637. --- Resolution: Won't Fix _This issue relates to the obsolete plan to use a 'shared secret' for client a

[jira] [Updated] (FLINK-4919) Add secure cookie support for the cluster deployed in Mesos environment

[ https://issues.apache.org/jira/browse/FLINK-4919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-4919: Issue Type: Sub-task (was: Task) Parent: FLINK-3930 > Add secure cookie support for the cl

[jira] [Closed] (FLINK-4635) Implement Data Transfer Authentication using shared secret configuration

[ https://issues.apache.org/jira/browse/FLINK-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-4635. --- Resolution: Won't Fix _This issue relates to the obsolete plan to use a 'shared secret' for client a

[jira] [Assigned] (FLINK-4635) Implement Data Transfer Authentication using shared secret configuration

[ https://issues.apache.org/jira/browse/FLINK-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright reassigned FLINK-4635: --- Assignee: (was: Vijay Srinivasaraghavan) > Implement Data Transfer Authentication using

[jira] [Created] (FLINK-9998) FlinkKafkaConsumer produces lag -Inf when the pipeline lags

Julio Biason created FLINK-9998: --- Summary: FlinkKafkaConsumer produces lag -Inf when the pipeline lags Key: FLINK-9998 URL: https://issues.apache.org/jira/browse/FLINK-9998 Project: Flink Issu

[jira] [Comment Edited] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562125#comment-16562125 ] Adam Najman edited comment on FLINK-7243 at 7/30/18 4:46 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562125#comment-16562125 ] Adam Najman commented on FLINK-7243: Is there an open PR for this I can look at? I'd

[jira] [Commented] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562076#comment-16562076 ] ASF GitHub Bot commented on FLINK-9874: --- florianschmidt1994 edited a comment on iss

[GitHub] florianschmidt1994 edited a comment on issue #6453: [FLINK-9874][E2E Tests] Fix set_ssl_conf for macOS

florianschmidt1994 edited a comment on issue #6453: [FLINK-9874][E2E Tests] Fix set_ssl_conf for macOS URL: https://github.com/apache/flink/pull/6453#issuecomment-408921235 According to [1]`ifconfig` is not part of coreutils, but more like "a wrapper to the IPConfiguration agent"[2]. IDK i

[jira] [Commented] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562075#comment-16562075 ] ASF GitHub Bot commented on FLINK-9874: --- florianschmidt1994 commented on issue #645

[GitHub] florianschmidt1994 commented on issue #6453: [FLINK-9874][E2E Tests] Fix set_ssl_conf for macOS

florianschmidt1994 commented on issue #6453: [FLINK-9874][E2E Tests] Fix set_ssl_conf for macOS URL: https://github.com/apache/flink/pull/6453#issuecomment-408921235 According to [1]`ifconfig` is not part of coreutils, but more like "a wrapper to the IPConfiguration agent". IDK if there is

[jira] [Commented] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562067#comment-16562067 ] ASF GitHub Bot commented on FLINK-9874: --- NicoK commented on issue #6453: [FLINK-987

[GitHub] NicoK commented on issue #6453: [FLINK-9874][E2E Tests] Fix set_ssl_conf for macOS

NicoK commented on issue #6453: [FLINK-9874][E2E Tests] Fix set_ssl_conf for macOS URL: https://github.com/apache/flink/pull/6453#issuecomment-408918418 just out of curiosity (and I don't know the details there): Does this still work with the gnu versions of these tools installed, e.g.

[jira] [Commented] (FLINK-9985) Incorrect parameter order in document

[ https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562043#comment-16562043 ] ASF GitHub Bot commented on FLINK-9985: --- zhangminglei commented on issue #6457: [FL

[GitHub] zhangminglei commented on issue #6457: [FLINK-9985] Incorrect parameter order in document

zhangminglei commented on issue #6457: [FLINK-9985] Incorrect parameter order in document URL: https://github.com/apache/flink/pull/6457#issuecomment-408911173 Thanks for your contribution! Change looks good to me. This is an

[jira] [Commented] (FLINK-9995) Jepsen: Clean up Mesos Logs and Working Directory

[ https://issues.apache.org/jira/browse/FLINK-9995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562029#comment-16562029 ] ASF GitHub Bot commented on FLINK-9995: --- GJL opened a new pull request #6458: [FLIN

[jira] [Updated] (FLINK-9995) Jepsen: Clean up Mesos Logs and Working Directory

[ https://issues.apache.org/jira/browse/FLINK-9995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9995: -- Labels: pull-request-available (was: ) > Jepsen: Clean up Mesos Logs and Working Directory > -

[GitHub] GJL opened a new pull request #6458: [FLINK-9995][tests] Improve tearing down Mesos.

GJL opened a new pull request #6458: [FLINK-9995][tests] Improve tearing down Mesos. URL: https://github.com/apache/flink/pull/6458 ## What is the purpose of the change *Clean up Mesos logs and working directory so that we do not run out of disk space on the DB nodes while running t

[jira] [Commented] (FLINK-9985) Incorrect parameter order in document

[ https://issues.apache.org/jira/browse/FLINK-9985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562019#comment-16562019 ] ASF GitHub Bot commented on FLINK-9985: --- lsyldliu opened a new pull request #6457:

[jira] [Updated] (FLINK-9985) Incorrect parameter order in document

[GitHub] lsyldliu opened a new pull request #6457: [FLINK-9985] Incorrect parameter order in document

lsyldliu opened a new pull request #6457: [FLINK-9985] Incorrect parameter order in document URL: https://github.com/apache/flink/pull/6457 ## What is the purpose of the change *(This pull request is aim to fix incorrect parameter order in document about windows)* ## Brief ch

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562009#comment-16562009 ] ASF GitHub Bot commented on FLINK-9947: --- twalthr commented on a change in pull requ

[GitHub] twalthr commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

twalthr commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206185390 ## File path: docs/dev/table/sourceSinks.md ## @@ -22,751 +22,17 @@ specific language

[jira] [Updated] (FLINK-9947) Document unified table sources/sinks/formats

[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9947: -- Labels: pull-request-available (was: ) > Document unified table sources/sinks/formats > --

[GitHub] twalthr opened a new pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

twalthr opened a new pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456 ## What is the purpose of the change Documentation for unified table sources, sinks, and formats both for Table API & SQL and SQL

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16562004#comment-16562004 ] ASF GitHub Bot commented on FLINK-9947: --- twalthr opened a new pull request #6456: [

[jira] [Updated] (FLINK-9997) Improve Expression Reduce

[ https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9997: -- Labels: pull-request-available (was: ) > Improve Expression Reduce > -

[jira] [Commented] (FLINK-9997) Improve Expression Reduce

[ https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561997#comment-16561997 ] ASF GitHub Bot commented on FLINK-9997: --- Xpray opened a new pull request #6455: [FL

[GitHub] Xpray opened a new pull request #6455: [FLINK-9997][TableAPI & SQL] Improve Expression Reduce

Xpray opened a new pull request #6455: [FLINK-9997][TableAPI & SQL] Improve Expression Reduce URL: https://github.com/apache/flink/pull/6455 ## What is the purpose of the change Improve Expression Reduce ## Brief change log make Project and Filter to Calc and let ReduceExpressi

[jira] [Updated] (FLINK-9997) Improve Expression Reduce

[ https://issues.apache.org/jira/browse/FLINK-9997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li updated FLINK-9997: -- Summary: Improve Expression Reduce (was: Improve ExpressionReduce) > Improve Expression Reduce > -

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561897#comment-16561897 ] ASF GitHub Bot commented on FLINK-9739: --- sampathBhat commented on issue #6452: [FLI

[GitHub] sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-408855934 @zentol Could you assign this bug to me. So there are few more changes that can be done, such as 1. enhancing the

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561884#comment-16561884 ] ASF GitHub Bot commented on FLINK-9739: --- zentol commented on issue #6452: [FLINK-97

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561885#comment-16561885 ] ASF GitHub Bot commented on FLINK-9739: --- zentol edited a comment on issue #6452: [F

[GitHub] zentol edited a comment on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

zentol edited a comment on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-408851714 Note that this of course could break setups where people actually use `:` as a separator :/ --

[GitHub] zentol commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

zentol commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-408851714 Note that this of course could break setups where people actually use `:` as a separate :/ --

[GitHub] zentol commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

zentol commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-408851475 yes that would be my suggestion. This is an automated message

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561883#comment-16561883 ] ASF GitHub Bot commented on FLINK-9739: --- zentol commented on issue #6452: [FLINK-97

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561875#comment-16561875 ] ASF GitHub Bot commented on FLINK-9739: --- sampathBhat commented on issue #6452: [FLI

[GitHub] sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-408850327 @zentol So you are suggesting to remove file.pathSeperator from the split options? I agree with you that the solution

[jira] [Commented] (FLINK-9996) PrestoS3FileSystemITCase#testConfigKeysForwarding fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561869#comment-16561869 ] ASF GitHub Bot commented on FLINK-9996: --- zentol commented on issue #6454: [FLINK-99

[GitHub] zentol commented on issue #6454: [FLINK-9996][fs] Wrap exceptions during FS creation

zentol commented on issue #6454: [FLINK-9996][fs] Wrap exceptions during FS creation URL: https://github.com/apache/flink/pull/6454#issuecomment-408849850 Naturally the alternative is to update the `FileSystem` docs and update the linked test to catch all exceptions. -

[jira] [Commented] (FLINK-9996) PrestoS3FileSystemITCase#testConfigKeysForwarding fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561867#comment-16561867 ] ASF GitHub Bot commented on FLINK-9996: --- zentol opened a new pull request #6454: [F

[jira] [Updated] (FLINK-9996) PrestoS3FileSystemITCase#testConfigKeysForwarding fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9996: -- Labels: pull-request-available (was: ) > PrestoS3FileSystemITCase#testConfigKeysForwarding fai

[GitHub] zentol opened a new pull request #6454: [FLINK-9996][fs] Wrap exceptions during FS creation

zentol opened a new pull request #6454: [FLINK-9996][fs] Wrap exceptions during FS creation URL: https://github.com/apache/flink/pull/6454 ## What is the purpose of the change This PR is a small modification to the hadoop `AbstractFileSystemFactory` too wrap all exceptions that occu

[jira] [Created] (FLINK-9997) Improve ExpressionReduce

Ruidong Li created FLINK-9997: - Summary: Improve ExpressionReduce Key: FLINK-9997 URL: https://issues.apache.org/jira/browse/FLINK-9997 Project: Flink Issue Type: Improvement Components

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561856#comment-16561856 ] ASF GitHub Bot commented on FLINK-9739: --- zentol edited a comment on issue #6452: [F

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561855#comment-16561855 ] ASF GitHub Bot commented on FLINK-9739: --- zentol commented on issue #6452: [FLINK-97

[GitHub] zentol edited a comment on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

zentol edited a comment on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-408846731 I'm well aware that `:` was explicitly introduced to support multiple file paths, my point is that it (in hindsight) wa

[GitHub] zentol commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

zentol commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-408846731 I'm well aware that `:` was explicitly introduced to support multiple file paths, my point is that it (in hindsight) wasn't a

[jira] [Commented] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561845#comment-16561845 ] ASF GitHub Bot commented on FLINK-9874: --- florianschmidt1994 commented on issue #645

[jira] [Commented] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561844#comment-16561844 ] ASF GitHub Bot commented on FLINK-9874: --- florianschmidt1994 opened a new pull reque

[jira] [Updated] (FLINK-9874) set_conf_ssl in E2E tests fails on macOS

[ https://issues.apache.org/jira/browse/FLINK-9874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9874: -- Labels: pull-request-available test-stability (was: test-stability) > set_conf_ssl in E2E test

[GitHub] florianschmidt1994 commented on issue #6453: [FLINK-9874][E2E Tests] Fix set_ssl_conf for macOS

florianschmidt1994 commented on issue #6453: [FLINK-9874][E2E Tests] Fix set_ssl_conf for macOS URL: https://github.com/apache/flink/pull/6453#issuecomment-408844189 @NicoK here we go 🙌 This is an automated message from the A

[GitHub] florianschmidt1994 opened a new pull request #6453: [FLINK-9874][E2E Tests] Fix set_ssl_conf for macOS

florianschmidt1994 opened a new pull request #6453: [FLINK-9874][E2E Tests] Fix set_ssl_conf for macOS URL: https://github.com/apache/flink/pull/6453 ## What is the purpose of the change This fixes the set_ssl_conf utility function under macOS. The previous version was using `host

[jira] [Commented] (FLINK-9739) Regression in supported filesystems for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16561825#comment-16561825 ] ASF GitHub Bot commented on FLINK-9739: --- sampathBhat commented on issue #6452: [FLI

  1   2   3   >