[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979749#comment-15979749 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979756#comment-15979756 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979757#comment-15979757 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979751#comment-15979751 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979758#comment-15979758 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979750#comment-15979750 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979754#comment-15979754 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979755#comment-15979755 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112802060 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -194,26

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112802220 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -267,38

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112802168 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -267,38

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112801654 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -91,6

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979748#comment-15979748 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979753#comment-15979753 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112802072 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -194,26

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979752#comment-15979752 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112802181 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -267,38

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112802258 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -267,38

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112802121 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -194,26

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112802386 --- Diff: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java ---

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112802344 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java --- @@

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3001#discussion_r112802078 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -194,26

[jira] [Commented] (FLINK-6351) Refactor YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979745#comment-15979745 ] ASF GitHub Bot commented on FLINK-6351: --- GitHub user zhangminglei opened a pull request:

[GitHub] flink pull request #3755: [FLINK-6351] [YARN] Refactoring YarnFlinkApplicati...

GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/3755 [FLINK-6351] [YARN] Refactoring YarnFlinkApplicationMasterRunner by c… …ombining AbstractYarnFlinkApplicationMasterRunner in one class. Thanks for contributing to Apache Flink.

[jira] [Commented] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979723#comment-15979723 ] Kaibo Zhou commented on FLINK-6355: --- Hi, [~fhueske] The previous version of the example code did not

[jira] [Updated] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-6355: -- Description: Currently {{TableEnvironment}} only supports register ScalarFunction, the Java users

[jira] [Closed] (FLINK-6193) Flink dist directory normalize

[ https://issues.apache.org/jira/browse/FLINK-6193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui closed FLINK-6193. Resolution: Fixed > Flink dist directory normalize > -- > >

[jira] [Updated] (FLINK-6351) Refactor YarnFlinkApplicationMasterRunner by combining AbstractYarnFlinkApplicationMasterRunner in one class

[ https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-6351: Summary: Refactor YarnFlinkApplicationMasterRunner by combining

[jira] [Updated] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-6355: -- Description: Currently {{TableEnvironment}} only supports register ScalarFunction, the Java users

[GitHub] flink issue #2460: [FLINK-4562] table examples make an divided module in fli...

Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2460 @fhueske Thanks : ) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[jira] [Commented] (FLINK-4562) table examples make an divided module in flink-examples

[ https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979683#comment-15979683 ] ASF GitHub Bot commented on FLINK-4562: --- Github user shijinkui commented on the issue:

[jira] [Commented] (FLINK-6217) ContaineredTaskManagerParameters sets off heap memory size incorrectly

[ https://issues.apache.org/jira/browse/FLINK-6217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979671#comment-15979671 ] ASF GitHub Bot commented on FLINK-6217: --- Github user haohui commented on the issue:

[GitHub] flink issue #3648: [FLINK-6217] ContaineredTaskManagerParameters sets off-he...

Github user haohui commented on the issue: https://github.com/apache/flink/pull/3648 Totally Agree :-) @StephanEwen please take another look. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

[ https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979665#comment-15979665 ] ASF GitHub Bot commented on FLINK-6281: --- Github user haohui commented on the issue:

[GitHub] flink issue #3712: [FLINK-6281] Create TableSink for JDBC.

Github user haohui commented on the issue: https://github.com/apache/flink/pull/3712 Thanks for the review. I'm not aware of the fact that OutputFormats are not integrated with Flink's checkpointing mechanism. To address this problem, maybe we can do something similar to the

[jira] [Closed] (FLINK-6242) codeGen DataSet Goupingwindow Aggregates

[ https://issues.apache.org/jira/browse/FLINK-6242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6242. Resolution: Implemented Fix Version/s: 1.3.0 Implemented with

[jira] [Closed] (FLINK-6326) add ProjectMergeRule at logical optimization stage

[ https://issues.apache.org/jira/browse/FLINK-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6326. Resolution: Fixed Fix Version/s: 1.3.0 Fixed with 4024afffcd5a3f011e8ba2a3a1053e8bae6cec4f

[jira] [Closed] (FLINK-4562) table examples make an divided module in flink-examples

[ https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4562. Resolution: Done Fix Version/s: (was: 1.2.1) 1.3.0 Done with

[jira] [Commented] (FLINK-6242) codeGen DataSet Goupingwindow Aggregates

[ https://issues.apache.org/jira/browse/FLINK-6242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979375#comment-15979375 ] ASF GitHub Bot commented on FLINK-6242: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6326) add ProjectMergeRule at logical optimization stage

[ https://issues.apache.org/jira/browse/FLINK-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979373#comment-15979373 ] ASF GitHub Bot commented on FLINK-6326: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3735: [FLINK-6242] [table] Add code generation for DataS...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3735 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3739: [FLINK-6326] [table] add ProjectMergeRule at logic...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3739 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3754: update Table API Java examples

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3754 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4562) table examples make an divided module in flink-examples

[ https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979374#comment-15979374 ] ASF GitHub Bot commented on FLINK-4562: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #2460: [FLINK-4562] table examples make an divided module...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2460 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6326) add ProjectMergeRule at logical optimization stage

[ https://issues.apache.org/jira/browse/FLINK-6326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979262#comment-15979262 ] ASF GitHub Bot commented on FLINK-6326: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-4562) table examples make an divided module in flink-examples

[ https://issues.apache.org/jira/browse/FLINK-4562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979264#comment-15979264 ] ASF GitHub Bot commented on FLINK-4562: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-6242) codeGen DataSet Goupingwindow Aggregates

[ https://issues.apache.org/jira/browse/FLINK-6242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979261#comment-15979261 ] ASF GitHub Bot commented on FLINK-6242: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2460: [FLINK-4562] table examples make an divided module in fli...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2460 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[GitHub] flink issue #3739: [FLINK-6326] [table] add ProjectMergeRule at logical opti...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3739 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[GitHub] flink issue #3735: [FLINK-6242] [table] Add code generation for DataSet Aggr...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3735 Thanks @shaoxuan-wang! Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[GitHub] flink issue #3754: update Table API Java examples

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3754 Thanks for the fixes! Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Created] (FLINK-6356) Make times() eager and enable allowing combinations.

Kostas Kloudas created FLINK-6356: - Summary: Make times() eager and enable allowing combinations. Key: FLINK-6356 URL: https://issues.apache.org/jira/browse/FLINK-6356 Project: Flink Issue

[jira] [Commented] (FLINK-4898) Refactor HTTP handlers and Netty server/client

[ https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979184#comment-15979184 ] ASF GitHub Bot commented on FLINK-4898: --- Github user EronWright commented on the issue:

[jira] [Commented] (FLINK-4898) Refactor HTTP handlers and Netty server/client

[ https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979185#comment-15979185 ] ASF GitHub Bot commented on FLINK-4898: --- Github user EronWright closed the pull request at:

[GitHub] flink issue #2766: [FLINK-4898] Refactor HTTP handlers and Netty server/clie...

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/2766 @uce thanks for the feedback. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[GitHub] flink pull request #2766: [FLINK-4898] Refactor HTTP handlers and Netty serv...

Github user EronWright closed the pull request at: https://github.com/apache/flink/pull/2766 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979182#comment-15979182 ] Fabian Hueske commented on FLINK-6355: -- You could also define {{tableEnv}} as

[jira] [Assigned] (FLINK-5182) Implement SSL file-shipping

[ https://issues.apache.org/jira/browse/FLINK-5182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright reassigned FLINK-5182: --- Assignee: (was: Eron Wright ) > Implement SSL file-shipping >

[jira] [Commented] (FLINK-5030) Support hostname verification

[ https://issues.apache.org/jira/browse/FLINK-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979175#comment-15979175 ] ASF GitHub Bot commented on FLINK-5030: --- Github user EronWright closed the pull request at:

[jira] [Commented] (FLINK-5030) Support hostname verification

[ https://issues.apache.org/jira/browse/FLINK-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979174#comment-15979174 ] ASF GitHub Bot commented on FLINK-5030: --- Github user EronWright commented on the issue:

[GitHub] flink issue #3061: [FLINK-5030] Support hostname verification

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3061 @tillrohrmann I'm closing this PR because it is quite old, in favor of a successor. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request #3061: [FLINK-5030] Support hostname verification

Github user EronWright closed the pull request at: https://github.com/apache/flink/pull/3061 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-5815) Add resource files configuration for Yarn Mode

[ https://issues.apache.org/jira/browse/FLINK-5815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979160#comment-15979160 ] ASF GitHub Bot commented on FLINK-5815: --- Github user EronWright commented on the issue:

[GitHub] flink issue #3388: [FLINK-5815] Add resource files configuration for Yarn Mo...

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3388 Just a note: For Mesos, inevitably we'll add support for arbitrary URLs to be downloaded by the container. The Mesos fetcher deals with HTTP URLs primarily but actually supports HDFS URLs too

[GitHub] flink pull request #3754: update Table API Java examples

GitHub user kgeis opened a pull request: https://github.com/apache/flink/pull/3754 update Table API Java examples add trailing semicolons to Java examples in table_api.md for correct syntax You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979153#comment-15979153 ] Kaibo Zhou commented on FLINK-6355: --- Thanks [~fhueske] I have updated the description and add some

[jira] [Updated] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-6355: -- Description: Currently {{TableEnvironment}} only supports register ScalarFunction, the Java users

[jira] [Commented] (FLINK-6302) Documentation build error on ruby 2.4

[ https://issues.apache.org/jira/browse/FLINK-6302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979137#comment-15979137 ] ASF GitHub Bot commented on FLINK-6302: --- Github user haohui commented on the issue:

[GitHub] flink issue #3720: [FLINK-6302] Documentation build error on ruby 2.4

Github user haohui commented on the issue: https://github.com/apache/flink/pull/3720 I hit the same problem on my Mac. Let me try it out later today. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-5476) Fail fast if trying to submit a job to a non-existing Flink cluster

[ https://issues.apache.org/jira/browse/FLINK-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979121#comment-15979121 ] ASF GitHub Bot commented on FLINK-5476: --- GitHub user DmytroShkvyra opened a pull request:

[GitHub] flink pull request #3753: [FLINK-5476] Fail fast if trying to submit a job t...

GitHub user DmytroShkvyra opened a pull request: https://github.com/apache/flink/pull/3753 [FLINK-5476] Fail fast if trying to submit a job to a non-existing Fl… …ink cluster Thanks for contributing to Apache Flink. Before you open your pull request, please take the

[jira] [Updated] (FLINK-6355) TableEnvironment support register TableFunction

[ https://issues.apache.org/jira/browse/FLINK-6355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kaibo Zhou updated FLINK-6355: -- Description: Currently {{TableEnvironment}} only supports register ScalarFunction, the Java users

[jira] [Commented] (FLINK-6333) Utilize Bloomfilters in RocksDb

[ https://issues.apache.org/jira/browse/FLINK-6333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979076#comment-15979076 ] Ted Yu commented on FLINK-6333: --- I found this issue which was resolved:

[jira] [Commented] (FLINK-6336) Placement Constraints for Mesos

[ https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979056#comment-15979056 ] ASF GitHub Bot commented on FLINK-6336: --- Github user sgran closed the pull request at:

[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...

Github user sgran closed the pull request at: https://github.com/apache/flink/pull/3744 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6336) Placement Constraints for Mesos

[ https://issues.apache.org/jira/browse/FLINK-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979057#comment-15979057 ] ASF GitHub Bot commented on FLINK-6336: --- GitHub user sgran reopened a pull request:

[GitHub] flink pull request #3744: [FLINK-6336] Initial commit of mesos placement con...

GitHub user sgran reopened a pull request: https://github.com/apache/flink/pull/3744 [FLINK-6336] Initial commit of mesos placement constraints This adds a HostAttrValueConstraint evaluator for fenzo, allowing tasks to be placed on agents with matching attributes.

[jira] [Commented] (FLINK-5974) Support Mesos DNS

[ https://issues.apache.org/jira/browse/FLINK-5974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979052#comment-15979052 ] ASF GitHub Bot commented on FLINK-5974: --- Github user EronWright commented on the issue:

[GitHub] flink issue #3692: FLINK-5974 Added configurations to support mesos-dns host...

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3692 @StephanEwen in this case, the

[jira] [Comment Edited] (FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2

[ https://issues.apache.org/jira/browse/FLINK-6353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979042#comment-15979042 ] Stefan Richter edited comment on FLINK-6353 at 4/21/17 4:42 PM: Just a

[jira] [Comment Edited] (FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2

[ https://issues.apache.org/jira/browse/FLINK-6353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979042#comment-15979042 ] Stefan Richter edited comment on FLINK-6353 at 4/21/17 4:40 PM: Just a

[jira] [Commented] (FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2

[ https://issues.apache.org/jira/browse/FLINK-6353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979042#comment-15979042 ] Stefan Richter commented on FLINK-6353: --- Just a small idea: do you think that from a users

[jira] [Commented] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15978996#comment-15978996 ] ASF GitHub Bot commented on FLINK-6250: --- Github user stefanobortoli commented on a diff in the pull

[GitHub] flink pull request #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics rep...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3736#discussion_r112729232 --- Diff: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java --- @@ -0,0 +1,97 @@ +/* + *

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979038#comment-15979038 ] ASF GitHub Bot commented on FLINK-6013: --- Github user bowenli86 commented on a diff in the pull

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979034#comment-15979034 ] ASF GitHub Bot commented on FLINK-6013: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink pull request #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics rep...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3736#discussion_r112729036 --- Diff: flink-dist/src/main/assemblies/opt.xml --- @@ -95,5 +95,12 @@ flink-metrics-statsd-${project.version}.jar

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979022#comment-15979022 ] ASF GitHub Bot commented on FLINK-6013: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink pull request #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics rep...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3736#discussion_r112728271 --- Diff: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DMetric.java --- @@ -0,0 +1,65 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979013#comment-15979013 ] ASF GitHub Bot commented on FLINK-6013: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink pull request #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics rep...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3736#discussion_r112727162 --- Diff: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java --- @@ -0,0 +1,197 @@ +/* +

[GitHub] flink pull request #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics rep...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3736#discussion_r112727098 --- Diff: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpClient.java --- @@ -0,0 +1,97 @@ +/* + *

[GitHub] flink pull request #3736: [FLINK-6013][metrics] Add Datadog HTTP metrics rep...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/3736#discussion_r112727145 --- Diff: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java --- @@ -0,0 +1,197 @@ +/* +

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979012#comment-15979012 ] ASF GitHub Bot commented on FLINK-6013: --- Github user bowenli86 commented on a diff in the pull

[jira] [Commented] (FLINK-6013) Add Datadog HTTP metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979011#comment-15979011 ] ASF GitHub Bot commented on FLINK-6013: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink issue #3732: [FLINK-6250] Distinct procTime with Rows boundaries

Github user stefanobortoli commented on the issue: https://github.com/apache/flink/pull/3732 @fhueske I have just pushed a version working with code generation (without modifying the code generation) There will be the need for some refactoring in the AggregateUtil function, but if

[GitHub] flink pull request #3732: [FLINK-6250] Distinct procTime with Rows boundarie...

Github user stefanobortoli commented on a diff in the pull request: https://github.com/apache/flink/pull/3732#discussion_r112725482 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/UnsupportedOperatorsIndicatorFunctions.scala --- @@ -0,0 +1,46

[GitHub] flink pull request #3732: [FLINK-6250] Distinct procTime with Rows boundarie...

Github user stefanobortoli commented on a diff in the pull request: https://github.com/apache/flink/pull/3732#discussion_r112725820 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala --- @@ -91,6 +93,22

[jira] [Commented] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15979007#comment-15979007 ] ASF GitHub Bot commented on FLINK-6250: --- Github user stefanobortoli commented on the issue:

  1   2   3   4   >