[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

2019-07-09 Thread GitBox
danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r301445920 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

2019-07-09 Thread GitBox
danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r301446506 ## File path:

[jira] [Commented] (FLINK-13162) Default value of slot.idle.timeout is too large for batch job

2019-07-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881031#comment-16881031 ] Till Rohrmann commented on FLINK-13162: --- I don't fully understand the problem [~zjffdu]. Is the

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

2019-07-09 Thread GitBox
danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r301446761 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

2019-07-09 Thread GitBox
danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r301446663 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

2019-07-09 Thread GitBox
danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r301446410 ## File path:

[GitHub] [flink] ye-lun commented on a change in pull request #8995: [FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

2019-07-09 Thread GitBox
ye-lun commented on a change in pull request #8995: [FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r301446109 ## File path: docs/dev/parallel.zh.md ## @@ -22,29 +22,20 @@ specific language

[GitHub] [flink] StephanEwen commented on issue #8914: [FLINK-12929] Pass TypeInformation in addSource

2019-07-09 Thread GitBox
StephanEwen commented on issue #8914: [FLINK-12929] Pass TypeInformation in addSource URL: https://github.com/apache/flink/pull/8914#issuecomment-509537604 @lombarde Are you interested in picking this up, following @aljoscha's suggestion?

[GitHub] [flink] TsReaper opened a new pull request #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source

2019-07-09 Thread GitBox
TsReaper opened a new pull request #9029: [FLINK-13118][jdbc] Introduce JDBC table factory and bridge JDBC table source with streaming table source URL: https://github.com/apache/flink/pull/9029 ## What is the purpose of the change Currently `JDBCTableSource` only implements the

[jira] [Updated] (FLINK-13118) Introduce JDBC table factory

2019-07-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13118: --- Labels: pull-request-available (was: ) > Introduce JDBC table factory >

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

2019-07-09 Thread GitBox
danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r301448561 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

2019-07-09 Thread GitBox
danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r301450989 ## File path:

[jira] [Updated] (FLINK-13162) Default value of slot.idle.timeout is too large for batch job

2019-07-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13162: -- Issue Type: Improvement (was: Bug) > Default value of slot.idle.timeout is too large for

[GitHub] [flink] flinkbot commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis

2019-07-09 Thread GitBox
flinkbot commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to Travis URL: https://github.com/apache/flink/pull/8911#issuecomment-509540526 CI report for commit 6a46e32116156ed5291ba80bdb367a6af15ef2a7: SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/118391756)

[GitHub] [flink] flinkbot commented on issue #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

2019-07-09 Thread GitBox
flinkbot commented on issue #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#issuecomment-509540449 CI report for commit 481ff9057a420e923cbf38bb2094c11875144c8a: FAILURE

[GitHub] [flink] flinkbot commented on issue #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
flinkbot commented on issue #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#issuecomment-509542535 CI report for commit ea5b9fc9b374fa895cefe921a3d4e99f8e12d3f2: FAILURE

[GitHub] [flink] flinkbot commented on issue #9030: [FLINK-13123] Align Stop/Cancel Commands in CLI and REST Interface and Improve Documentation

2019-07-09 Thread GitBox
flinkbot commented on issue #9030: [FLINK-13123] Align Stop/Cancel Commands in CLI and REST Interface and Improve Documentation URL: https://github.com/apache/flink/pull/9030#issuecomment-509546108 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] flinkbot commented on issue #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner

2019-07-09 Thread GitBox
flinkbot commented on issue #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner URL: https://github.com/apache/flink/pull/8962#issuecomment-509546534 CI report for commit a1376f5b783fe9387c6201263382ad117c5283fe: FAILURE

[jira] [Updated] (FLINK-13163) Support execution of batch jobs with fewer slots than requested

2019-07-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-13163: -- Description: Flink should be able to execute batch jobs with fewer slots than requested in a

[jira] [Assigned] (FLINK-12998) Document Plugins mechanism

2019-07-09 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-12998: -- Assignee: Alex > Document Plugins mechanism > -- > >

[jira] [Updated] (FLINK-13124) Stop fails with Universal Kafka Consumer

2019-07-09 Thread Konstantin Knauf (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-13124: - Description: When running the {{StateMachineExample}} (with the universal Kafka

[jira] [Assigned] (FLINK-11116) Overwrite outdated in-progress files in StreamingFileSink.

2019-07-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-6: Assignee: (was: Kostas Kloudas) > Overwrite outdated in-progress files in

[GitHub] [flink] flinkbot commented on issue #9014: [FLINK-12754][table-api]alterTableColumnStatistics() in GenericInMemo…

2019-07-09 Thread GitBox
flinkbot commented on issue #9014: [FLINK-12754][table-api]alterTableColumnStatistics() in GenericInMemo… URL: https://github.com/apache/flink/pull/9014#issuecomment-509567205 CI report for commit 40d39b91f95d79232236093b5fb638e43b4a65cc: SUCCESS

[GitHub] [flink] c4emmmm opened a new pull request #9033: [FLINK-13167] Introduce FlinkML import/export framework

2019-07-09 Thread GitBox
c4e opened a new pull request #9033: [FLINK-13167] Introduce FlinkML import/export framework URL: https://github.com/apache/flink/pull/9033 ## What is the purpose of the change Importing/exporting a trained model is an important part in machine learning lifecycle, especially

[GitHub] [flink] ye-lun commented on a change in pull request #8995: [FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese

2019-07-09 Thread GitBox
ye-lun commented on a change in pull request #8995: [FLINK-13106][doc-zh]Translate Parallel Execution page into Chinese URL: https://github.com/apache/flink/pull/8995#discussion_r301497488 ## File path: docs/dev/parallel.zh.md ## @@ -80,17 +71,11 @@ env.execute("Word

[jira] [Assigned] (FLINK-13165) Complete requested slots in request order

2019-07-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13165: - Assignee: Till Rohrmann > Complete requested slots in request order >

[jira] [Assigned] (FLINK-13163) Support execution of batch jobs with fewer slots than requested

2019-07-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13163: - Assignee: Till Rohrmann > Support execution of batch jobs with fewer slots than

[jira] [Created] (FLINK-13169) IT test for fine-grained recovery (task executor failures)

2019-07-09 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-13169: --- Summary: IT test for fine-grained recovery (task executor failures) Key: FLINK-13169 URL: https://issues.apache.org/jira/browse/FLINK-13169 Project: Flink

[GitHub] [flink] flinkbot commented on issue #9024: [FLINK-13119] add blink table config to documentation

2019-07-09 Thread GitBox
flinkbot commented on issue #9024: [FLINK-13119] add blink table config to documentation URL: https://github.com/apache/flink/pull/9024#issuecomment-509581062 CI report for commit 1e4a2e9a584232fd8f5b441567190e1149b6f72f: FAILURE

[jira] [Updated] (FLINK-13168) clarify isBatch/isStreaming/isBounded flag in flink planner and blink planner

2019-07-09 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-13168: --- Description: in blink planner & flink planner, there are many {{isBatch}} and {{isStreaming}}

[jira] [Assigned] (FLINK-13166) Support batch slot requests

2019-07-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-13166: - Assignee: Till Rohrmann > Support batch slot requests > --- >

[GitHub] [flink] tillrohrmann opened a new pull request #9043: [FLINK-13165] Complete slot requests in request order

2019-07-09 Thread GitBox
tillrohrmann opened a new pull request #9043: [FLINK-13165] Complete slot requests in request order URL: https://github.com/apache/flink/pull/9043 ## What is the purpose of the change This commit makes sure that slot requests enqueued at the SlotPoolImpl will get completed in

[GitHub] [flink] pnowojski opened a new pull request #9044: [hotfix] Clean up NettyShuffleEnvironmentTest and extract MINIMAL_CHECKPOINT_TIME magic constant

2019-07-09 Thread GitBox
pnowojski opened a new pull request #9044: [hotfix] Clean up NettyShuffleEnvironmentTest and extract MINIMAL_CHECKPOINT_TIME magic constant URL: https://github.com/apache/flink/pull/9044 This PR contains two simple hotfixes that clean up the code a bit. They are cosmetic changes that do

[jira] [Updated] (FLINK-13165) Complete requested slots in request order

2019-07-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13165: --- Labels: pull-request-available (was: ) > Complete requested slots in request order >

[GitHub] [flink] flinkbot commented on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

2019-07-09 Thread GitBox
flinkbot commented on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#issuecomment-509639383 CI report for commit 98f0cec3deff65ebe316b8d3c13b51470d079b65: SUCCESS

[GitHub] [flink] flinkbot commented on issue #9044: [hotfix] Clean up NettyShuffleEnvironmentTest and extract MINIMAL_CHECKPOINT_TIME magic constant

2019-07-09 Thread GitBox
flinkbot commented on issue #9044: [hotfix] Clean up NettyShuffleEnvironmentTest and extract MINIMAL_CHECKPOINT_TIME magic constant URL: https://github.com/apache/flink/pull/9044#issuecomment-509640166 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot commented on issue #9043: [FLINK-13165] Complete slot requests in request order

2019-07-09 Thread GitBox
flinkbot commented on issue #9043: [FLINK-13165] Complete slot requests in request order URL: https://github.com/apache/flink/pull/9043#issuecomment-509640186 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] wuchong opened a new pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
wuchong opened a new pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045 ## What is the purpose of the change Support LookupableTableSource for HBase. ## Brief change log -

[GitHub] [flink] wuchong commented on issue #8930: [FLINK-12955] HBase LookupableTableSource

2019-07-09 Thread GitBox
wuchong commented on issue #8930: [FLINK-12955] HBase LookupableTableSource URL: https://github.com/apache/flink/pull/8930#issuecomment-509642291 Thanks @chancelq for the great effort. With discussed with @chancelq , we will continue the work in #9045 .

[GitHub] [flink] wuchong closed pull request #8930: [FLINK-12955] HBase LookupableTableSource

2019-07-09 Thread GitBox
wuchong closed pull request #8930: [FLINK-12955] HBase LookupableTableSource URL: https://github.com/apache/flink/pull/8930 This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot commented on issue #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
flinkbot commented on issue #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#issuecomment-509642844 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] flinkbot commented on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource

2019-07-09 Thread GitBox
flinkbot commented on issue #9032: [FLINK-13160]HiveTaleSource should implement PartitionableTableSource URL: https://github.com/apache/flink/pull/9032#issuecomment-509644023 CI report for commit eecc93fcfd21e0be24aca13b2bb82359429f592a: FAILURE

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301589731 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301591024 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301591532 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301589468 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301592842 ## File path:

[GitHub] [flink] flinkbot commented on issue #8914: [FLINK-12929] Pass TypeInformation in addSource

2019-07-09 Thread GitBox
flinkbot commented on issue #8914: [FLINK-12929] Pass TypeInformation in addSource URL: https://github.com/apache/flink/pull/8914#issuecomment-509653025 CI report for commit e0a83f5e75ad6778ed59bbd4611b29d6e0011223: FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/118414506)

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301599058 ## File path:

[GitHub] [flink] hehuiyuan opened a new pull request #9046: [Table]Add a PrintTableSink

2019-07-09 Thread GitBox
hehuiyuan opened a new pull request #9046: [Table]Add a PrintTableSink URL: https://github.com/apache/flink/pull/9046 ## What is the purpose of the change This is very convenient for local mode and it is convenient for learning the Table & SQL Api ## Brief change

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301601958 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301601141 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301601419 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase

2019-07-09 Thread GitBox
carp84 commented on a change in pull request #9045: [FLINK-12955][hbase] Support LookupableTableSource for HBase URL: https://github.com/apache/flink/pull/9045#discussion_r301602137 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #9021: [hostfix][runtime] Make checkpoints injection ordered with stop-with-savepoint

2019-07-09 Thread GitBox
pnowojski commented on a change in pull request #9021: [hostfix][runtime] Make checkpoints injection ordered with stop-with-savepoint URL: https://github.com/apache/flink/pull/9021#discussion_r301593676 ## File path:

[GitHub] [flink] YngwieWang opened a new pull request #9047: [FLINK-13109][docs-zh]Translate "Restart Strategies" page into Chinese

2019-07-09 Thread GitBox
YngwieWang opened a new pull request #9047: [FLINK-13109][docs-zh]Translate "Restart Strategies" page into Chinese URL: https://github.com/apache/flink/pull/9047 初次翻译,请多指教。 This is an automated message from the Apache Git

[jira] [Updated] (FLINK-13109) Translate "Restart Strategies" page into Chinese

2019-07-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13109: --- Labels: pull-request-available (was: ) > Translate "Restart Strategies" page into Chinese

[GitHub] [flink] flinkbot commented on issue #9046: [Table]Add a PrintTableSink

2019-07-09 Thread GitBox
flinkbot commented on issue #9046: [Table]Add a PrintTableSink URL: https://github.com/apache/flink/pull/9046#issuecomment-509655763 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this

[GitHub] [flink] flinkbot commented on issue #9047: [FLINK-13109][docs-zh]Translate "Restart Strategies" page into Chinese

2019-07-09 Thread GitBox
flinkbot commented on issue #9047: [FLINK-13109][docs-zh]Translate "Restart Strategies" page into Chinese URL: https://github.com/apache/flink/pull/9047#issuecomment-509656897 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Commented] (FLINK-13159) java.lang.ClassNotFoundException when restore job

2019-07-09 Thread Yun Tang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880972#comment-16880972 ] Yun Tang commented on FLINK-13159: -- [~kring] would you please give more details. From your description,

[GitHub] [flink] WeiZhong94 commented on issue #9018: [hotfix][python][docs]Fix wrong example code in Python REPL and wrong table plan in table/common page

2019-07-09 Thread GitBox
WeiZhong94 commented on issue #9018: [hotfix][python][docs]Fix wrong example code in Python REPL and wrong table plan in table/common page URL: https://github.com/apache/flink/pull/9018#issuecomment-509510671 @HuangXingBo Thanks for your pull request! LGTM and +1 from my side.

[GitHub] [flink] sunjincheng121 merged pull request #9018: [hotfix][python][docs]Fix wrong example code in Python REPL and wrong table plan in table/common page

2019-07-09 Thread GitBox
sunjincheng121 merged pull request #9018: [hotfix][python][docs]Fix wrong example code in Python REPL and wrong table plan in table/common page URL: https://github.com/apache/flink/pull/9018 This is an automated message

[jira] [Created] (FLINK-13163) Default value of slot.request.timeout is too small for batch job

2019-07-09 Thread Jeff Zhang (JIRA)
Jeff Zhang created FLINK-13163: -- Summary: Default value of slot.request.timeout is too small for batch job Key: FLINK-13163 URL: https://issues.apache.org/jira/browse/FLINK-13163 Project: Flink

[GitHub] [flink] flinkbot commented on issue #9028: [hotfix][python] Update the package name from pyflink to apache-flink

2019-07-09 Thread GitBox
flinkbot commented on issue #9028: [hotfix][python] Update the package name from pyflink to apache-flink URL: https://github.com/apache/flink/pull/9028#issuecomment-509513963 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] godfreyhe commented on a change in pull request #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner

2019-07-09 Thread GitBox
godfreyhe commented on a change in pull request #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner URL: https://github.com/apache/flink/pull/8962#discussion_r301423012 ## File path:

[jira] [Commented] (FLINK-13100) Fix the unexpected IOException during FileBufferReader#nextBuffer

2019-07-09 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880999#comment-16880999 ] zhijiang commented on FLINK-13100: -- In netty internal implementation of writeAndFlush(), the write

[jira] [Comment Edited] (FLINK-13100) Fix the unexpected IOException during FileBufferReader#nextBuffer

2019-07-09 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881009#comment-16881009 ] Piotr Nowojski edited comment on FLINK-13100 at 7/9/19 7:28 AM:

[GitHub] [flink] vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301437253 ## File path:

[GitHub] [flink] StephanEwen commented on issue #8957: [hotfix][docs] fix broken links

2019-07-09 Thread GitBox
StephanEwen commented on issue #8957: [hotfix][docs] fix broken links URL: https://github.com/apache/flink/pull/8957#issuecomment-509528154 Thanks for fixing this. Merging... This is an automated message from the Apache Git

[GitHub] [flink] StephanEwen commented on issue #8994: [FLINK-13057][state] Correct comments in ListState class

2019-07-09 Thread GitBox
StephanEwen commented on issue #8994: [FLINK-13057][state] Correct comments in ListState class URL: https://github.com/apache/flink/pull/8994#issuecomment-509533497 Good fix, thank you! Merging this... This is an

[GitHub] [flink] lirui-apache commented on issue #8965: [FLINK-13068][hive] HiveTableSink should implement PartitionableTable…

2019-07-09 Thread GitBox
lirui-apache commented on issue #8965: [FLINK-13068][hive] HiveTableSink should implement PartitionableTable… URL: https://github.com/apache/flink/pull/8965#issuecomment-509501919 The test failure cannot be reproduced locally. Travis build of my own repo passed at:

[jira] [Closed] (FLINK-12693) Store state per key-group in CopyOnWriteStateTable

2019-07-09 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-12693. -- Resolution: Implemented Merged in: master: 8f47b38 > Store state per key-group in

[GitHub] [flink] sunjincheng121 merged pull request #9016: [hotfix][python]Fix the install failure of pyflink used previous version of python 2.7

2019-07-09 Thread GitBox
sunjincheng121 merged pull request #9016: [hotfix][python]Fix the install failure of pyflink used previous version of python 2.7 URL: https://github.com/apache/flink/pull/9016 This is an automated message from the Apache

[GitHub] [flink] flinkbot commented on issue #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload.

2019-07-09 Thread GitBox
flinkbot commented on issue #8885: [FLINK-12855] [streaming-java][window-assigners] Add functionality that staggers panes on partitions to distribute workload. URL: https://github.com/apache/flink/pull/8885#issuecomment-509505532 CI report for commit

[GitHub] [flink] flinkbot commented on issue #9014: [FLINK-12754][table-api]alterTableColumnStatistics() in GenericInMemo…

2019-07-09 Thread GitBox
flinkbot commented on issue #9014: [FLINK-12754][table-api]alterTableColumnStatistics() in GenericInMemo… URL: https://github.com/apache/flink/pull/9014#issuecomment-509506967 CI report for commit 36c2c6a362ca3693d5dcf1fcbd08ef8c915da178: FAILURE

[GitHub] [flink] vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301415192 ## File path:

[GitHub] [flink] dianfu opened a new pull request #9028: [hotfix][python] Update the package name from pyflink to apache-flink

2019-07-09 Thread GitBox
dianfu opened a new pull request #9028: [hotfix][python] Update the package name from pyflink to apache-flink URL: https://github.com/apache/flink/pull/9028 ## What is the purpose of the change *As discussed in the mail list, we want to add pip support for pyflink. As the name

[GitHub] [flink] godfreyhe commented on a change in pull request #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner

2019-07-09 Thread GitBox
godfreyhe commented on a change in pull request #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner URL: https://github.com/apache/flink/pull/8962#discussion_r301423012 ## File path:

[GitHub] [flink] drummerwolli commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
drummerwolli commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301422994 ## File path:

[jira] [Comment Edited] (FLINK-13100) Fix the unexpected IOException during FileBufferReader#nextBuffer

2019-07-09 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880988#comment-16880988 ] Piotr Nowojski edited comment on FLINK-13100 at 7/9/19 6:55 AM: I'm

[GitHub] [flink] drummerwolli commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
drummerwolli commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301423570 ## File path:

[GitHub] [flink] vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301429146 ## File path:

[jira] [Commented] (FLINK-13100) Fix the unexpected IOException during FileBufferReader#nextBuffer

2019-07-09 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881003#comment-16881003 ] zhijiang commented on FLINK-13100: -- [~pnowojski] the previous deadlock was ever happened on our side

[GitHub] [flink] vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301428436 ## File path:

[jira] [Commented] (FLINK-13149) improve flink ui to make it easier to be used by other projects

2019-07-09 Thread Yadong Xie (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881005#comment-16881005 ] Yadong Xie commented on FLINK-13149: great job! [~simplejason] I will review this > improve flink

[GitHub] [flink] drummerwolli commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
drummerwolli commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301430296 ## File path:

[GitHub] [flink] flinkbot commented on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

2019-07-09 Thread GitBox
flinkbot commented on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-509522294 CI report for commit 903d6827b5f5c056265716a5a7e533ea81634855: SUCCESS

[GitHub] [flink] StefanRRichter merged pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable

2019-07-09 Thread GitBox
StefanRRichter merged pull request #8611: [FLINK-12693][state] Store state per key-group in CopyOnWriteStateTable URL: https://github.com/apache/flink/pull/8611 This is an automated message from the Apache Git Service. To

[GitHub] [flink] vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301414862 ## File path:

[GitHub] [flink] sunjincheng121 commented on issue #8563: [FLINK-12602][travis] Correct the flink pom `artifactId` config and s…

2019-07-09 Thread GitBox
sunjincheng121 commented on issue #8563: [FLINK-12602][travis] Correct the flink pom `artifactId` config and s… URL: https://github.com/apache/flink/pull/8563#issuecomment-509507811 @zentol I have added the check of Scala suffix for all groupId, I appreciate if you have time to have look

[GitHub] [flink] lirui-apache commented on a change in pull request #8987: [FLINK-13090][hive] Test Hive connector with hive runner

2019-07-09 Thread GitBox
lirui-apache commented on a change in pull request #8987: [FLINK-13090][hive] Test Hive connector with hive runner URL: https://github.com/apache/flink/pull/8987#discussion_r301415547 ## File path:

[GitHub] [flink] lirui-apache commented on issue #8987: [FLINK-13090][hive] Test Hive connector with hive runner

2019-07-09 Thread GitBox
lirui-apache commented on issue #8987: [FLINK-13090][hive] Test Hive connector with hive runner URL: https://github.com/apache/flink/pull/8987#issuecomment-509508883 Rebased and addressed comments. @bowenli86 please take another look, thanks.

[GitHub] [flink] vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301418305 ## File path:

[GitHub] [flink] drummerwolli commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
drummerwolli commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301420055 ## File path:

[GitHub] [flink] vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301419500 ## File path:

[GitHub] [flink] vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301414862 ## File path:

[GitHub] [flink] vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements

2019-07-09 Thread GitBox
vthinkxie commented on a change in pull request #8542: [FLINK-10707][web-dashboard] flink cluster overview dashboard improvements URL: https://github.com/apache/flink/pull/8542#discussion_r301419685 ## File path:

[jira] [Commented] (FLINK-13100) Fix the unexpected IOException during FileBufferReader#nextBuffer

2019-07-09 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880988#comment-16880988 ] Piotr Nowojski commented on FLINK-13100: I'm missing something here. Why the previous deadlock

[jira] [Comment Edited] (FLINK-13159) java.lang.ClassNotFoundException when restore job

2019-07-09 Thread kring (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880987#comment-16880987 ] kring edited comment on FLINK-13159 at 7/9/19 6:54 AM: --- [~yunta],thank you.My

[jira] [Commented] (FLINK-13159) java.lang.ClassNotFoundException when restore job

2019-07-09 Thread kring (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880987#comment-16880987 ] kring commented on FLINK-13159: --- My taskManager and JobManager are on the same machine, using local files

<    1   2   3   4   5   6   >