[jira] [Updated] (FLINK-11310) Convert predicates to IN or NOT_IN for Project

2019-01-12 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11310: Description: In FLINK-10474, we force translate IN into a predicate to avoid translating to a JOI

[jira] [Created] (FLINK-11310) Convert predicates to IN or NOT_IN for Project

2019-01-12 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-11310: --- Summary: Convert predicates to IN or NOT_IN for Project Key: FLINK-11310 URL: https://issues.apache.org/jira/browse/FLINK-11310 Project: Flink Issue Type: Impr

[jira] [Updated] (FLINK-11309) Batch Job Failover Using RestartPipelinedRegionStrategy Fails in Some Scenes

2019-01-12 Thread BoWang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BoWang updated FLINK-11309: --- Description: Hi all, When running the batch WordCount example,  I configured the job execution mode as *BA

[jira] [Updated] (FLINK-11309) Batch Job Failover Using RestartPipelinedRegionStrategy Fails in Some Scenes

2019-01-12 Thread BoWang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BoWang updated FLINK-11309: --- Description: Hi all, When running the batch WordCount example,  I configured the job execution mode as *BA

[jira] [Created] (FLINK-11309) Batch Job Failover Using RestartPipelinedRegionStrategy Fails in Some Scenes

2019-01-12 Thread BoWang (JIRA)
BoWang created FLINK-11309: -- Summary: Batch Job Failover Using RestartPipelinedRegionStrategy Fails in Some Scenes Key: FLINK-11309 URL: https://issues.apache.org/jira/browse/FLINK-11309 Project: Flink

[jira] [Commented] (FLINK-11228) Flink web UI can not read stdout logs

2019-01-12 Thread leesf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741446#comment-16741446 ] leesf commented on FLINK-11228: --- [~wxmimperio], hi, may be you could see std out in TaskMa

[GitHub] eaglewatcherwb opened a new pull request #7474: [FLINK-11295][configuration] Rename configuration options of queryable-state from query.x to queryable-state.x

2019-01-12 Thread GitBox
eaglewatcherwb opened a new pull request #7474: [FLINK-11295][configuration] Rename configuration options of queryable-state from query.x to queryable-state.x URL: https://github.com/apache/flink/pull/7474 Change-Id: Idb561da3982de07e77a05ffef9ad227094f527b0 ## What is t

[GitHub] eaglewatcherwb closed pull request #7461: [FLINK-11295][configuration] Rename configuration options of queryable-state from query.x to queryable-state.x

2019-01-12 Thread GitBox
eaglewatcherwb closed pull request #7461: [FLINK-11295][configuration] Rename configuration options of queryable-state from query.x to queryable-state.x URL: https://github.com/apache/flink/pull/7461 This is a PR merged from a forked repository. As GitHub hides the original diff on merge

[GitHub] eaglewatcherwb commented on issue #7461: [FLINK-11295][configuration] Rename configuration options of queryable-state from query.x to queryable-state.x

2019-01-12 Thread GitBox
eaglewatcherwb commented on issue #7461: [FLINK-11295][configuration] Rename configuration options of queryable-state from query.x to queryable-state.x URL: https://github.com/apache/flink/pull/7461#issuecomment-453796292 > @eaglewatcherwb Thank you for your contribution, overall it is goo

[jira] [Updated] (FLINK-11295) Rename configuration options of queryable state from query.x to queryable-state.x

2019-01-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11295: --- Labels: pull-request-available (was: ) > Rename configuration options of queryable state fr

[GitHub] eaglewatcherwb opened a new pull request #7473: [FLINK-11295][test] add retry test

2019-01-12 Thread GitBox
eaglewatcherwb opened a new pull request #7473: [FLINK-11295][test] add retry test URL: https://github.com/apache/flink/pull/7473 Change-Id: I052158e3b3f23f288c1270c43f19bb7441e250d1 ## What is the purpose of the change *(For example: This pull request makes task deplo

[GitHub] eaglewatcherwb closed pull request #7473: [FLINK-11295][test] add retry test

2019-01-12 Thread GitBox
eaglewatcherwb closed pull request #7473: [FLINK-11295][test] add retry test URL: https://github.com/apache/flink/pull/7473 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 is a foreign pull

[jira] [Updated] (FLINK-11296) Support truncate in TableAPI & SQL

2019-01-12 Thread xuqianjin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-11296: -- Summary: Support truncate in TableAPI & SQL (was: Support truncate in TableAPI) > Support truncate i

[GitHub] caosuwenwu closed pull request #7472: hh

2019-01-12 Thread GitBox
caosuwenwu closed pull request #7472: hh URL: https://github.com/apache/flink/pull/7472 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 is a foreign pull request (from a fork), the diff is

[GitHub] caosuwenwu closed pull request #7472: hh

2019-01-12 Thread GitBox
caosuwenwu closed pull request #7472: hh URL: https://github.com/apache/flink/pull/7472 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 is a foreign pull request (from a fork), the diff is

[GitHub] caosuwenwu opened a new pull request #7472: hh

2019-01-12 Thread GitBox
caosuwenwu opened a new pull request #7472: hh URL: https://github.com/apache/flink/pull/7472 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring the

[GitHub] bmeriaux commented on issue #6715: [FLINK-8424] update cassandra and driver version to latest

2019-01-12 Thread GitBox
bmeriaux commented on issue #6715: [FLINK-8424] update cassandra and driver version to latest URL: https://github.com/apache/flink/pull/6715#issuecomment-453761361 I updated the Notice file without jnr because they are optional and i did a rebase on master

[GitHub] bmeriaux commented on a change in pull request #6715: [FLINK-8424] update cassandra and driver version to latest

2019-01-12 Thread GitBox
bmeriaux commented on a change in pull request #6715: [FLINK-8424] update cassandra and driver version to latest URL: https://github.com/apache/flink/pull/6715#discussion_r247317683 ## File path: flink-connectors/flink-connector-cassandra/src/test/resources/cassandra.yaml

[GitHub] JaryZhen commented on a change in pull request #7466: [FLINK-11304][docs][table] Fix typo in time attributes doc

2019-01-12 Thread GitBox
JaryZhen commented on a change in pull request #7466: [FLINK-11304][docs][table] Fix typo in time attributes doc URL: https://github.com/apache/flink/pull/7466#discussion_r247315350 ## File path: docs/dev/table/streaming/time_attributes.md ## @@ -317,9 +323,15 @@ class Use

[GitHub] KarmaGYZ closed pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-12 Thread GitBox
KarmaGYZ closed pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469 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 is a foreig

[GitHub] KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-12 Thread GitBox
KarmaGYZ commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469#discussion_r247309351 ## File path: docs/monitoring/logging.md ## @@ -93,7 +93,7 @@ Placeholders can also be used in conjuncti

[GitHub] klion26 commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error

2019-01-12 Thread GitBox
klion26 commented on a change in pull request #7469: [hotfix][docs] Correct the usage of LOG.error URL: https://github.com/apache/flink/pull/7469#discussion_r247307241 ## File path: docs/monitoring/logging.md ## @@ -93,7 +93,7 @@ Placeholders can also be used in conjunctio