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

2018-08-09 Thread Sampath Bhat (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sampath Bhat reassigned FLINK-9739: --- Assignee: Sampath Bhat > Regression in supported filesystems for RocksDB > -

[jira] [Commented] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575789#comment-16575789 ] ASF GitHub Bot commented on FLINK-9900: --- yanghua commented on issue #6468: [FLINK-9

[GitHub] yanghua commented on issue #6468: [FLINK-9900][tests] Include more information on timeout in Zookeeper HA ITCase

2018-08-09 Thread GitBox
yanghua commented on issue #6468: [FLINK-9900][tests] Include more information on timeout in Zookeeper HA ITCase URL: https://github.com/apache/flink/pull/6468#issuecomment-411985618 hi @zentol , checkstyle error : ``` src/test/java/org/apache/flink/test/checkpointing/ZooKeeperH

[GitHub] bowenli86 closed pull request #5301: [FLINK-8267] [Kinesis Connector] update Kinesis Producer example for setting Region key

2018-08-09 Thread GitBox
bowenli86 closed pull request #5301: [FLINK-8267] [Kinesis Connector] update Kinesis Producer example for setting Region key URL: https://github.com/apache/flink/pull/5301 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for t

[jira] [Commented] (FLINK-8267) update Kinesis Producer example for setting Region key

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575776#comment-16575776 ] ASF GitHub Bot commented on FLINK-8267: --- bowenli86 closed pull request #5301: [FLIN

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575760#comment-16575760 ] ASF GitHub Bot commented on FLINK-10107: zentol commented on issue #6534: [FLINK

[GitHub] zentol commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs

2018-08-09 Thread GitBox
zentol commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs URL: https://github.com/apache/flink/pull/6534#issuecomment-411978270 I don't understand the goal here. Are we actually trying to support multiple different kafka connector versions bei

[jira] [Assigned] (FLINK-10118) Queryable state MapState entry query

2018-08-09 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10118: Assignee: vinoyang > Queryable state MapState entry query >

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575732#comment-16575732 ] ASF GitHub Bot commented on FLINK-8290: --- maqingxiang commented on a change in pull

[GitHub] maqingxiang commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-09 Thread GitBox
maqingxiang commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8 URL: https://github.com/apache/flink/pull/5304#discussion_r209138484 ## File path: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/

[jira] [Updated] (FLINK-10119) JsonRowDeserializationSchema deserialize kafka message

2018-08-09 Thread sean.miao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sean.miao updated FLINK-10119: -- Description: Recently, we are using Kafka010JsonTableSource to process kafka's json messages.We turne

[jira] [Updated] (FLINK-10119) JsonRowDeserializationSchema deserialize kafka message

2018-08-09 Thread sean.miao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sean.miao updated FLINK-10119: -- Description: enable checkpoint and  use RestartStrategies.fixedDelayRestart 。 Recently, we are using

[jira] [Comment Edited] (FLINK-10119) 存在数据非json格式,使用KafkaJsonTableSource的话,job无法拉起。

2018-08-09 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575703#comment-16575703 ] 陈梓立 edited comment on FLINK-10119 at 8/10/18 3:03 AM: -- [~CrestOfWav

[jira] [Commented] (FLINK-10119) 存在数据非json格式,使用KafkaJsonTableSource的话,job无法拉起。

2018-08-09 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575703#comment-16575703 ] 陈梓立 commented on FLINK-10119: - [~CrestOfWave] I think it is good to add Chinese version as i

[jira] [Commented] (FLINK-10119) 存在数据非json格式,使用KafkaJsonTableSource的话,job无法拉起。

2018-08-09 Thread Jeff Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575696#comment-16575696 ] Jeff Zhang commented on FLINK-10119: [~CrestOfWave] Please use English to create tic

[jira] [Created] (FLINK-10119) 存在数据非json格式,使用KafkaJsonTableSource的话,job无法拉起。

2018-08-09 Thread sean.miao (JIRA)
sean.miao created FLINK-10119: - Summary: 存在数据非json格式,使用KafkaJsonTableSource的话,job无法拉起。 Key: FLINK-10119 URL: https://issues.apache.org/jira/browse/FLINK-10119 Project: Flink Issue Type: Bug

[GitHub] Aitozi commented on issue #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process

2018-08-09 Thread GitBox
Aitozi commented on issue #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process URL: https://github.com/apache/flink/pull/6205#issuecomment-411923422 Thanks a lot for your review👍. I have chaned as your mentioned, please take a look then, thx @dawidwys

[jira] [Commented] (FLINK-9642) Reduce the count to deal with state during a CEP process

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575524#comment-16575524 ] ASF GitHub Bot commented on FLINK-9642: --- Aitozi commented on issue #6205: [FLINK-96

[jira] [Created] (FLINK-10118) Queryable state MapState entry query

2018-08-09 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10118: -- Summary: Queryable state MapState entry query Key: FLINK-10118 URL: https://issues.apache.org/jira/browse/FLINK-10118 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10117) REST API for Queryable State

2018-08-09 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10117: -- Summary: REST API for Queryable State Key: FLINK-10117 URL: https://issues.apache.org/jira/browse/FLINK-10117 Project: Flink Issue Type: Improvement Co

[jira] [Updated] (FLINK-10116) createComparator fails on case class with Unit type fields prior to the join-key

2018-08-09 Thread Will (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Will updated FLINK-10116: - Component/s: DataSet API > createComparator fails on case class with Unit type fields prior to the > join-key >

[jira] [Updated] (FLINK-10116) createComparator fails on case class with Unit type fields prior to the join-key

2018-08-09 Thread Will (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Will updated FLINK-10116: - Description: h1. Overview When joining between case classes, if the attribute representing the join-key comes

[jira] [Updated] (FLINK-10116) createComparator fails on case class with Unit type fields prior to the join-key

2018-08-09 Thread Will (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Will updated FLINK-10116: - Description: h1. Overview When joining between case classes, if the attribute representing the join-key comes

[jira] [Updated] (FLINK-10116) createComparator fails on case class with Unit type fields prior to the join-key

2018-08-09 Thread Will (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Will updated FLINK-10116: - Summary: createComparator fails on case class with Unit type fields prior to the join-key (was: createComparato

[jira] [Created] (FLINK-10116) createComparator fails on case class with Unit type fields prior to the join-keyl

2018-08-09 Thread Will (JIRA)
Will created FLINK-10116: Summary: createComparator fails on case class with Unit type fields prior to the join-keyl Key: FLINK-10116 URL: https://issues.apache.org/jira/browse/FLINK-10116 Project: Flink

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9977: -- Labels: pull-request-available (was: ) > Refine the docs for Table/SQL built-in functions > --

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575084#comment-16575084 ] ASF GitHub Bot commented on FLINK-10107: twalthr commented on issue #6534: [FLIN

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575087#comment-16575087 ] ASF GitHub Bot commented on FLINK-9977: --- xccui opened a new pull request #6535: [FL

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575086#comment-16575086 ] ASF GitHub Bot commented on FLINK-10107: twalthr commented on issue #6534: [FLIN

[GitHub] xccui opened a new pull request #6535: [FLINK-9977] [table][doc] Refine the SQL/Table built-in function docs

2018-08-09 Thread GitBox
xccui opened a new pull request #6535: [FLINK-9977] [table][doc] Refine the SQL/Table built-in function docs URL: https://github.com/apache/flink/pull/6535 ## What is the purpose of the change This PR refines the documentation for all the SQL/Table built-in functions. ## Brief

[GitHub] twalthr commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs

2018-08-09 Thread GitBox
twalthr commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs URL: https://github.com/apache/flink/pull/6534#issuecomment-411815618 CC @fhueske This is an automated message from th

[GitHub] twalthr commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs

2018-08-09 Thread GitBox
twalthr commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs URL: https://github.com/apache/flink/pull/6534#issuecomment-411815540 CC @zentol This is an automated message from the

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575083#comment-16575083 ] ASF GitHub Bot commented on FLINK-10107: twalthr opened a new pull request #6534

[GitHub] twalthr opened a new pull request #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs

2018-08-09 Thread GitBox
twalthr opened a new pull request #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs URL: https://github.com/apache/flink/pull/6534 ## What is the purpose of the change This PR enforces even more shading for SQL JARs than before. In the past, we only shad

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575077#comment-16575077 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on issue #6432: [FLINK-9

[GitHub] yanghua commented on issue #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-08-09 Thread GitBox
yanghua commented on issue #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#issuecomment-411813890 @suez1224 and @xccui Does this PR look good to you? This is

[GitHub] StefanRRichter commented on issue #6493: [FLINK-10058] Add getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment

2018-08-09 Thread GitBox
StefanRRichter commented on issue #6493: [FLINK-10058] Add getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment URL: https://github.com/apache/flink/pull/6493#issuecomment-411812170 @yanghua I did not forget about this, unfortunately just did not find the time yet. Sorr

[jira] [Commented] (FLINK-10058) Add getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575073#comment-16575073 ] ASF GitHub Bot commented on FLINK-10058: StefanRRichter commented on issue #6493

[GitHub] yanghua commented on issue #6493: [FLINK-10058] Add getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment

2018-08-09 Thread GitBox
yanghua commented on issue #6493: [FLINK-10058] Add getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment URL: https://github.com/apache/flink/pull/6493#issuecomment-411811231 cc @StefanRRichter This is an

[jira] [Commented] (FLINK-10058) Add getStateBackend/setStateBackend API for PythonStreamExecutionEnvironment

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575069#comment-16575069 ] ASF GitHub Bot commented on FLINK-10058: yanghua commented on issue #6493: [FLIN

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575055#comment-16575055 ] ASF GitHub Bot commented on FLINK-9013: --- GJL commented on a change in pull request

[jira] [Commented] (FLINK-10109) Add documentation for StreamingFileSink

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575052#comment-16575052 ] ASF GitHub Bot commented on FLINK-10109: twalthr commented on a change in pull r

[jira] [Commented] (FLINK-10109) Add documentation for StreamingFileSink

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575054#comment-16575054 ] ASF GitHub Bot commented on FLINK-10109: twalthr commented on a change in pull r

[GitHub] twalthr commented on a change in pull request #6532: [FLINK-10109] Add documentation for StreamingFileSink

2018-08-09 Thread GitBox
twalthr commented on a change in pull request #6532: [FLINK-10109] Add documentation for StreamingFileSink URL: https://github.com/apache/flink/pull/6532#discussion_r208985527 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -0,0 +1,95 @@ +--- +title: "Streaming

[GitHub] GJL commented on a change in pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe…

2018-08-09 Thread GitBox
GJL commented on a change in pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe… URL: https://github.com/apache/flink/pull/6294#discussion_r208986466 ## File path: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlF

[GitHub] twalthr commented on a change in pull request #6532: [FLINK-10109] Add documentation for StreamingFileSink

2018-08-09 Thread GitBox
twalthr commented on a change in pull request #6532: [FLINK-10109] Add documentation for StreamingFileSink URL: https://github.com/apache/flink/pull/6532#discussion_r208986029 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -0,0 +1,95 @@ +--- +title: "Streaming

[jira] [Commented] (FLINK-6847) Add TIMESTAMPDIFF supported in TableAPI

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575048#comment-16575048 ] ASF GitHub Bot commented on FLINK-6847: --- xueyumusic commented on a change in pull r

[GitHub] xueyumusic commented on a change in pull request #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support

2018-08-09 Thread GitBox
xueyumusic commented on a change in pull request #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support URL: https://github.com/apache/flink/pull/6282#discussion_r208985576 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expr

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575042#comment-16575042 ] ASF GitHub Bot commented on FLINK-9682: --- yanghua commented on issue #6266: [FLINK-9

[GitHub] yanghua commented on issue #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

2018-08-09 Thread GitBox
yanghua commented on issue #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#issuecomment-411806613 cc @tillrohrmann

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575041#comment-16575041 ] ASF GitHub Bot commented on FLINK-9850: --- yanghua commented on issue #6367: [FLINK-9

[GitHub] yanghua commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

2018-08-09 Thread GitBox
yanghua commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#issuecomment-411806291 cc @tillrohrmann This is an automated me

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-08-09 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575038#comment-16575038 ] vinoyang commented on FLINK-10074: -- [~till.rohrmann] yes, I agree with you. If we focus

[jira] [Created] (FLINK-10115) Upload Project to WEB UI has issue

2018-08-09 Thread Yazdan Shirvany (JIRA)
Yazdan Shirvany created FLINK-10115: --- Summary: Upload Project to WEB UI has issue Key: FLINK-10115 URL: https://issues.apache.org/jira/browse/FLINK-10115 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9825) Upgrade checkstyle version to 8.6

2018-08-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575017#comment-16575017 ] Ted Yu commented on FLINK-9825: --- Thanks, Dalong. > Upgrade checkstyle version to 8.6 > ---

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575007#comment-16575007 ] ASF GitHub Bot commented on FLINK-9013: --- GJL commented on a change in pull request

[GitHub] GJL commented on a change in pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe…

2018-08-09 Thread GitBox
GJL commented on a change in pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe… URL: https://github.com/apache/flink/pull/6294#discussion_r208976465 ## File path: flink-core/src/main/java/org/apache/flink/configuration/description/HtmlF

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

2018-08-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16575001#comment-16575001 ] Till Rohrmann commented on FLINK-10074: --- I like the idea of having a maximum time

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574982#comment-16574982 ] ASF GitHub Bot commented on FLINK-9013: --- dawidwys commented on a change in pull req

[GitHub] dawidwys commented on a change in pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe…

2018-08-09 Thread GitBox
dawidwys commented on a change in pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe… URL: https://github.com/apache/flink/pull/6294#discussion_r208969123 ## File path: flink-core/src/main/java/org/apache/flink/configuration/description/

[jira] [Created] (FLINK-10114) Support Orc for StreamingFileSink

2018-08-09 Thread zhangminglei (JIRA)
zhangminglei created FLINK-10114: Summary: Support Orc for StreamingFileSink Key: FLINK-10114 URL: https://issues.apache.org/jira/browse/FLINK-10114 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-9795) Update Mesos documentation for flip6

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9795: -- Labels: pull-request-available (was: ) > Update Mesos documentation for flip6 > --

[jira] [Commented] (FLINK-9795) Update Mesos documentation for flip6

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574971#comment-16574971 ] ASF GitHub Bot commented on FLINK-9795: --- GJL opened a new pull request #6533: [FLIN

[GitHub] GJL opened a new pull request #6533: [FLINK-9795][mesos, docs] Update Mesos documentation for FLIP-6

2018-08-09 Thread GitBox
GJL opened a new pull request #6533: [FLINK-9795][mesos, docs] Update Mesos documentation for FLIP-6 URL: https://github.com/apache/flink/pull/6533 ## What is the purpose of the change *Update Mesos documentation to reflect changes that were introduced with FLIP-6.* cc: @till

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574968#comment-16574968 ] ASF GitHub Bot commented on FLINK-8290: --- azagrebin commented on a change in pull re

[GitHub] azagrebin commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-09 Thread GitBox
azagrebin commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8 URL: https://github.com/apache/flink/pull/5304#discussion_r208965558 ## File path: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/st

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574960#comment-16574960 ] ASF GitHub Bot commented on FLINK-9013: --- NicoK commented on a change in pull reques

[GitHub] NicoK commented on a change in pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe…

2018-08-09 Thread GitBox
NicoK commented on a change in pull request #6294: [FLINK-9013][docs] Document yarn.containers.vcores only being effective whe… URL: https://github.com/apache/flink/pull/6294#discussion_r208962025 ## File path: flink-core/src/main/java/org/apache/flink/configuration/description/Htm

[jira] [Commented] (FLINK-9642) Reduce the count to deal with state during a CEP process

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574958#comment-16574958 ] ASF GitHub Bot commented on FLINK-9642: --- dawidwys commented on issue #6205: [FLINK-

[GitHub] dawidwys commented on issue #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process

2018-08-09 Thread GitBox
dawidwys commented on issue #6205: [FLINK-9642]Reduce the count to deal with state during a CEP process URL: https://github.com/apache/flink/pull/6205#issuecomment-411788642 Hi @Aitozi I found the dependencies between accessor and shared buffer a bit too much both sided. Please have a

[jira] [Created] (FLINK-10113) Drop support for pre 1.6 shared buffer state

2018-08-09 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10113: Summary: Drop support for pre 1.6 shared buffer state Key: FLINK-10113 URL: https://issues.apache.org/jira/browse/FLINK-10113 Project: Flink Issue Ty

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574930#comment-16574930 ] ASF GitHub Bot commented on FLINK-8290: --- aljoscha commented on a change in pull req

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574924#comment-16574924 ] ASF GitHub Bot commented on FLINK-10068: twalthr commented on a change in pull r

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574923#comment-16574923 ] ASF GitHub Bot commented on FLINK-10068: twalthr commented on a change in pull r

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574922#comment-16574922 ] ASF GitHub Bot commented on FLINK-10068: twalthr commented on a change in pull r

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574927#comment-16574927 ] ASF GitHub Bot commented on FLINK-10068: twalthr commented on a change in pull r

[GitHub] aljoscha commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-09 Thread GitBox
aljoscha commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8 URL: https://github.com/apache/flink/pull/5304#discussion_r208955188 ## File path: flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/str

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574925#comment-16574925 ] ASF GitHub Bot commented on FLINK-10068: twalthr commented on a change in pull r

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574928#comment-16574928 ] ASF GitHub Bot commented on FLINK-10068: twalthr commented on a change in pull r

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574926#comment-16574926 ] ASF GitHub Bot commented on FLINK-10068: twalthr commented on a change in pull r

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

2018-08-09 Thread GitBox
twalthr commented on a change in pull request #6504: [FLINK-10068][docs] Add documentation for RocksDB-based timers and st… URL: https://github.com/apache/flink/pull/6504#discussion_r208952984 ## File path: docs/ops/state/large_state_tuning.md ## @@ -142,6 +142,17 @@ by de

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

2018-08-09 Thread GitBox
twalthr commented on a change in pull request #6504: [FLINK-10068][docs] Add documentation for RocksDB-based timers and st… URL: https://github.com/apache/flink/pull/6504#discussion_r208950851 ## File path: docs/dev/stream/operators/process_function.md ## @@ -333,3 +332,43

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

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

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

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

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

2018-08-09 Thread GitBox
twalthr commented on a change in pull request #6504: [FLINK-10068][docs] Add documentation for RocksDB-based timers and st… URL: https://github.com/apache/flink/pull/6504#discussion_r208952554 ## File path: docs/ops/state/large_state_tuning.md ## @@ -142,6 +142,17 @@ by de

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

2018-08-09 Thread GitBox
twalthr commented on a change in pull request #6504: [FLINK-10068][docs] Add documentation for RocksDB-based timers and st… URL: https://github.com/apache/flink/pull/6504#discussion_r208951393 ## File path: docs/ops/state/large_state_tuning.md ## @@ -142,6 +142,17 @@ by de

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

2018-08-09 Thread GitBox
twalthr commented on a change in pull request #6504: [FLINK-10068][docs] Add documentation for RocksDB-based timers and st… URL: https://github.com/apache/flink/pull/6504#discussion_r208950482 ## File path: docs/dev/stream/operators/process_function.md ## @@ -333,3 +332,43

[jira] [Commented] (FLINK-9343) Add Async Example with External Rest API call

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574918#comment-16574918 ] ASF GitHub Bot commented on FLINK-9343: --- medcv commented on issue #5996: [FLINK-934

[GitHub] medcv commented on issue #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call

2018-08-09 Thread GitBox
medcv commented on issue #5996: [FLINK-9343] [Example] Add Async Example with External Rest API call URL: https://github.com/apache/flink/pull/5996#issuecomment-411780022 @azagrebin Thanks for the review. I will go through them and update the PR accordingly --

[jira] [Commented] (FLINK-10099) Rework YarnResourceManagerTest

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574901#comment-16574901 ] ASF GitHub Bot commented on FLINK-10099: tillrohrmann commented on issue #6499:

[GitHub] tillrohrmann commented on issue #6499: [FLINK-10099] [test] Rework YarnResourceManagerTest

2018-08-09 Thread GitBox
tillrohrmann commented on issue #6499: [FLINK-10099] [test] Rework YarnResourceManagerTest URL: https://github.com/apache/flink/pull/6499#issuecomment-411775562 Thanks for addressing our comments @TisonKun. Merging this PR. T

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

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574882#comment-16574882 ] ASF GitHub Bot commented on FLINK-9637: --- asfgit closed pull request #6379: [FLINK-9

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

2018-08-09 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-9637. - Resolution: Fixed Fix Version/s: (was: 1.6.0) 1.7.0

[GitHub] asfgit closed pull request #6379: [FLINK-9637] Add public user documentation for state TTL feature

2018-08-09 Thread GitBox
asfgit closed pull request #6379: [FLINK-9637] Add public user documentation for state TTL feature URL: https://github.com/apache/flink/pull/6379 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As

[jira] [Resolved] (FLINK-9411) Support parquet rolling sink writer

2018-08-09 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei resolved FLINK-9411. - Resolution: Won't Fix > Support parquet rolling sink writer > ---

[jira] [Updated] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv

2018-08-09 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei updated FLINK-7829: Description: These methods are seductive for users but they should never actually use them in a pro

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

2018-08-09 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574846#comment-16574846 ] Timo Walther commented on FLINK-10107: -- A temporary fix has been merged which avoid

[jira] [Commented] (FLINK-10107) SQL Client end-to-end test fails for releases

2018-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574845#comment-16574845 ] ASF GitHub Bot commented on FLINK-10107: asfgit closed pull request #6528: [FLIN

[GitHub] asfgit closed pull request #6528: [FLINK-10107] [e2e] Exclude conflicting SQL JARs from test

2018-08-09 Thread GitBox
asfgit closed pull request #6528: [FLINK-10107] [e2e] Exclude conflicting SQL JARs from test URL: https://github.com/apache/flink/pull/6528 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this

[GitHub] twalthr commented on issue #6379: [FLINK-9637] Add public user documentation for state TTL feature

2018-08-09 Thread GitBox
twalthr commented on issue #6379: [FLINK-9637] Add public user documentation for state TTL feature URL: https://github.com/apache/flink/pull/6379#issuecomment-411756912 Thank you @azagrebin. I will go through the text a last time and merge this... -

  1   2   3   >