[GitHub] zhangxinyu1 commented on issue #6770: [FLINK-10002] [Webfrontend] WebUI shows jm/tm logs more friendly.

2018-10-24 Thread GitBox
zhangxinyu1 commented on issue #6770: [FLINK-10002] [Webfrontend] WebUI shows jm/tm logs more friendly. URL: https://github.com/apache/flink/pull/6770#issuecomment-432905856 @ifndef-SleePy Thanks for your suggestions. I have modified the code. I removed the legacy part and refactor the

[jira] [Commented] (FLINK-10002) WebUI shows logs unfriendly, especially when the amount of logs is large

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663171#comment-16663171 ] ASF GitHub Bot commented on FLINK-10002: zhangxinyu1 commented on issue #6770: [FLINK-10002]

[jira] [Updated] (FLINK-10621) BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when running locally

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10621: --- Labels: pull-request-available (was: ) >

[GitHub] ifndef-SleePy opened a new pull request #6925: [FLINK-10621][runtime] Fix unstable unit test case of BootstrapToolsTest

2018-10-24 Thread GitBox
ifndef-SleePy opened a new pull request #6925: [FLINK-10621][runtime] Fix unstable unit test case of BootstrapToolsTest URL: https://github.com/apache/flink/pull/6925 ## What is the purpose of the change `BootstrapToolsTest.testConcurrentActorSystemCreation` is unstable. We forgot

[jira] [Commented] (FLINK-10621) BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when running locally

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663160#comment-16663160 ] ASF GitHub Bot commented on FLINK-10621: ifndef-SleePy opened a new pull request #6925:

[jira] [Assigned] (FLINK-10504) Decide actual parallelism based on available resources

2018-10-24 Thread blues zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] blues zheng reassigned FLINK-10504: --- Assignee: blues zheng > Decide actual parallelism based on available resources >

[jira] [Assigned] (FLINK-9957) Rescale job with respect to available slots

2018-10-24 Thread blues zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] blues zheng reassigned FLINK-9957: -- Assignee: blues zheng > Rescale job with respect to available slots >

[jira] [Commented] (FLINK-10621) BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when running locally

2018-10-24 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663146#comment-16663146 ] Biao Liu commented on FLINK-10621: -- Thank you for reporting. [~alexeyt820] It's an unstable case. Would

[jira] [Assigned] (FLINK-10507) Set target parallelism to maximum when using the standalone job cluster mode

2018-10-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10507: Assignee: vinoyang > Set target parallelism to maximum when using the standalone job cluster

[jira] [Assigned] (FLINK-10505) Treat fail signal as scheduling event

2018-10-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10505: Assignee: vinoyang > Treat fail signal as scheduling event >

[jira] [Assigned] (FLINK-10621) BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when running locally

2018-10-24 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-10621: Assignee: Biao Liu > BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever when >

[jira] [Assigned] (FLINK-10503) Periodically check for new resources

2018-10-24 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10503: --- Assignee: Shimin Yang > Periodically check for new resources >

[jira] [Assigned] (FLINK-10501) Obtain resource overview of cluster

2018-10-24 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang reassigned FLINK-10501: --- Assignee: Shimin Yang > Obtain resource overview of cluster >

[jira] [Commented] (FLINK-10656) Refactor org.apache.flink.runtime.io.network.api.reader.ReaderBase

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663133#comment-16663133 ] ASF GitHub Bot commented on FLINK-10656: zhijiangW commented on a change in pull request #6911:

[GitHub] zhijiangW commented on a change in pull request #6911: [FLINK-10656] Refactor org.apache.flink.runtime.io.network.api.reader…

2018-10-24 Thread GitBox
zhijiangW commented on a change in pull request #6911: [FLINK-10656] Refactor org.apache.flink.runtime.io.network.api.reader… URL: https://github.com/apache/flink/pull/6911#discussion_r228020917 ## File path:

[jira] [Commented] (FLINK-10656) Refactor org.apache.flink.runtime.io.network.api.reader.ReaderBase

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663127#comment-16663127 ] ASF GitHub Bot commented on FLINK-10656: zhijiangW commented on a change in pull request #6911:

[GitHub] zhijiangW commented on a change in pull request #6911: [FLINK-10656] Refactor org.apache.flink.runtime.io.network.api.reader…

2018-10-24 Thread GitBox
zhijiangW commented on a change in pull request #6911: [FLINK-10656] Refactor org.apache.flink.runtime.io.network.api.reader… URL: https://github.com/apache/flink/pull/6911#discussion_r228020917 ## File path:

[jira] [Assigned] (FLINK-10673) Table API / SQL UIDs not the only one

2018-10-24 Thread winifredtang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] winifredtang reassigned FLINK-10673: Assignee: winifredtang > Table API / SQL UIDs not the only one >

[jira] [Assigned] (FLINK-10265) Configure checkpointing behavior for SQL Client

2018-10-24 Thread winifredtang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] winifredtang reassigned FLINK-10265: Assignee: winifredtang (was: vinoyang) > Configure checkpointing behavior for SQL

[jira] [Assigned] (FLINK-10448) VALUES clause is translated into a separate operator per value

2018-10-24 Thread winifredtang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] winifredtang reassigned FLINK-10448: Assignee: winifredtang (was: vinoyang) > VALUES clause is translated into a separate

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663102#comment-16663102 ] ASF GitHub Bot commented on FLINK-10600: yanghua opened a new pull request #6924: [FLINK-10600]

[jira] [Updated] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10600: --- Labels: pull-request-available (was: ) > Provide End-to-end test cases for modern Kafka

[GitHub] yanghua opened a new pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-24 Thread GitBox
yanghua opened a new pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924 ## What is the purpose of the change *This pull request provides End-to-end test cases for modern Kafka connectors*

[jira] [Assigned] (FLINK-5832) Support for simple hive UDF

2018-10-24 Thread winifredtang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] winifredtang reassigned FLINK-5832: --- Assignee: winifredtang (was: vinoyang) > Support for simple hive UDF >

[jira] [Assigned] (FLINK-5802) Flink SQL calling Hive User-Defined Functions

2018-10-24 Thread winifredtang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] winifredtang reassigned FLINK-5802: --- Assignee: winifredtang > Flink SQL calling Hive User-Defined Functions >

[jira] [Created] (FLINK-10673) Table API / SQL UIDs not the only one

2018-10-24 Thread Fan weiwen (JIRA)
Fan weiwen created FLINK-10673: -- Summary: Table API / SQL UIDs not the only one Key: FLINK-10673 URL: https://issues.apache.org/jira/browse/FLINK-10673 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5833) Support for Hive GenericUDF

2018-10-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16663093#comment-16663093 ] vinoyang commented on FLINK-5833: - Hi [~clarkyzl] This issue has not been active for a long time. Are you

[jira] [Assigned] (FLINK-5832) Support for simple hive UDF

2018-10-24 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-5832: --- Assignee: vinoyang > Support for simple hive UDF > --- > >

[jira] [Updated] (FLINK-10672) Task stuck while writing output to flink

2018-10-24 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated FLINK-10672: - Description: I am running a fairly complex pipleline with 200+ task. The pipeline works fine

[jira] [Updated] (FLINK-10672) Task stuck while writing output to flink

2018-10-24 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated FLINK-10672: - Description: I am running a fairly complex pipleline with 200+ task. The pipeline works fine

[jira] [Updated] (FLINK-10672) Task stuck while writing output to flink

2018-10-24 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated FLINK-10672: - Description: I am running a fairly complex pipleline with 200+ task. The pipeline works fine

[jira] [Updated] (FLINK-10672) Task stuck while writing output to flink

2018-10-24 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated FLINK-10672: - Description: I am running a fairly complex pipleline with 200+ task. The pipeline works fine

[jira] [Updated] (FLINK-10672) Task stuck while writing output to flink

2018-10-24 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ankur Goenka updated FLINK-10672: - Description: I am running a fairly complex pipleline with 200+ task. The pipeline works fine

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

2018-10-24 Thread Ankur Goenka (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662937#comment-16662937 ] Ankur Goenka commented on FLINK-10672: -- cc: [~mxm] [~robertwb] > Task stuck while writing output

[jira] [Created] (FLINK-10672) Task stuck while writing output to flink

2018-10-24 Thread Ankur Goenka (JIRA)
Ankur Goenka created FLINK-10672: Summary: Task stuck while writing output to flink Key: FLINK-10672 URL: https://issues.apache.org/jira/browse/FLINK-10672 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8354) Flink Kafka connector ignores Kafka message headers

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662923#comment-16662923 ] ASF GitHub Bot commented on FLINK-8354: --- alexeyt820 commented on issue #6615: [FLINK-8354]

[GitHub] alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

2018-10-24 Thread GitBox
alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#issuecomment-432846236 @yanghua, @aljoscha is anything else need to be done with this PR ?

[jira] [Updated] (FLINK-10542) Register Hive metastore as an external catalog in TableEnvironment

2018-10-24 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10542: Description: Similar to FLINK-2167 but rather register Hive metastore as an external catalog in

[jira] [Updated] (FLINK-10556) Integration with Apache Hive

2018-10-24 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10556: Attachment: (was: Proposal_ Integrate Flink with Hive Ecosystem.pdf) > Integration with

[jira] [Updated] (FLINK-10556) Integration with Apache Hive

2018-10-24 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10556: Attachment: Proposal_ Integrate Flink with Hive Ecosystem.pdf > Integration with Apache Hive >

[jira] [Created] (FLINK-10671) rest monitoring api Savepoint status call fails if akka.ask.timeout < checkpoint duration

2018-10-24 Thread Cliff Resnick (JIRA)
Cliff Resnick created FLINK-10671: - Summary: rest monitoring api Savepoint status call fails if akka.ask.timeout < checkpoint duration Key: FLINK-10671 URL: https://issues.apache.org/jira/browse/FLINK-10671

[jira] [Commented] (FLINK-6036) Let catalog support partition

2018-10-24 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662721#comment-16662721 ] Xuefu Zhang commented on FLINK-6036: Thank you, [~jinyu.zj]. PR looks good overall, and I left some

[GitHub] xuefuz commented on a change in pull request #6906: [Flink-6036][table]Let catalog support partition.

2018-10-24 Thread GitBox
xuefuz commented on a change in pull request #6906: [Flink-6036][table]Let catalog support partition. URL: https://github.com/apache/flink/pull/6906#discussion_r227924642 ## File path:

[GitHub] xuefuz commented on a change in pull request #6906: [Flink-6036][table]Let catalog support partition.

2018-10-24 Thread GitBox
xuefuz commented on a change in pull request #6906: [Flink-6036][table]Let catalog support partition. URL: https://github.com/apache/flink/pull/6906#discussion_r227920287 ## File path:

[GitHub] xuefuz commented on a change in pull request #6906: [Flink-6036][table]Let catalog support partition.

2018-10-24 Thread GitBox
xuefuz commented on a change in pull request #6906: [Flink-6036][table]Let catalog support partition. URL: https://github.com/apache/flink/pull/6906#discussion_r227915200 ## File path:

[GitHub] xuefuz commented on a change in pull request #6906: [Flink-6036][table]Let catalog support partition.

2018-10-24 Thread GitBox
xuefuz commented on a change in pull request #6906: [Flink-6036][table]Let catalog support partition. URL: https://github.com/apache/flink/pull/6906#discussion_r227908967 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalog.scala

[GitHub] xuefuz commented on a change in pull request #6906: [Flink-6036][table]Let catalog support partition.

2018-10-24 Thread GitBox
xuefuz commented on a change in pull request #6906: [Flink-6036][table]Let catalog support partition. URL: https://github.com/apache/flink/pull/6906#discussion_r227908967 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalog.scala

[jira] [Commented] (FLINK-10656) Refactor org.apache.flink.runtime.io.network.api.reader.ReaderBase

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662592#comment-16662592 ] ASF GitHub Bot commented on FLINK-10656: isunjin commented on a change in pull request #6911:

[GitHub] isunjin commented on a change in pull request #6911: [FLINK-10656] Refactor org.apache.flink.runtime.io.network.api.reader…

2018-10-24 Thread GitBox
isunjin commented on a change in pull request #6911: [FLINK-10656] Refactor org.apache.flink.runtime.io.network.api.reader… URL: https://github.com/apache/flink/pull/6911#discussion_r227888205 ## File path:

[jira] [Commented] (FLINK-10656) Refactor org.apache.flink.runtime.io.network.api.reader.ReaderBase

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662587#comment-16662587 ] ASF GitHub Bot commented on FLINK-10656: isunjin commented on a change in pull request #6911:

[GitHub] isunjin commented on a change in pull request #6911: [FLINK-10656] Refactor org.apache.flink.runtime.io.network.api.reader…

2018-10-24 Thread GitBox
isunjin commented on a change in pull request #6911: [FLINK-10656] Refactor org.apache.flink.runtime.io.network.api.reader… URL: https://github.com/apache/flink/pull/6911#discussion_r227887183 ## File path:

[jira] [Commented] (FLINK-10556) Integration with Apache Hive

2018-10-24 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662551#comment-16662551 ] Xuefu Zhang commented on FLINK-10556: - The proposal is attached. > Integration with Apache Hive >

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662539#comment-16662539 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in pull request

[jira] [Updated] (FLINK-10556) Integration with Apache Hive

2018-10-24 Thread Xuefu Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-10556: Attachment: Proposal_ Integrate Flink with Hive Ecosystem.pdf > Integration with Apache Hive >

[GitHub] tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

2018-10-24 Thread GitBox
tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#discussion_r227849935 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

2018-10-24 Thread GitBox
tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#discussion_r227877459 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

2018-10-24 Thread GitBox
tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#discussion_r227872341 ## File path:

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662544#comment-16662544 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

2018-10-24 Thread GitBox
tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#discussion_r227871624 ## File path:

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662540#comment-16662540 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

2018-10-24 Thread GitBox
tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#discussion_r227872749 ## File path:

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662546#comment-16662546 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662547#comment-16662547 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662542#comment-16662542 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662548#comment-16662548 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

2018-10-24 Thread GitBox
tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#discussion_r227870899 ## File path:

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662543#comment-16662543 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

2018-10-24 Thread GitBox
tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#discussion_r227848647 ## File path:

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662541#comment-16662541 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

2018-10-24 Thread GitBox
tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#discussion_r227872948 ## File path:

[GitHub] tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

2018-10-24 Thread GitBox
tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#discussion_r227872252 ## File path:

[jira] [Commented] (FLINK-10431) Extract scheduling-related code from SlotPool

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662545#comment-16662545 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler

2018-10-24 Thread GitBox
tillrohrmann commented on a change in pull request #6898: [FLINK-10431] Extraction of scheduling-related code from SlotPool into preliminary Scheduler URL: https://github.com/apache/flink/pull/6898#discussion_r227872881 ## File path:

[jira] [Commented] (FLINK-10657) TPCHQuery3 fail with IllegalAccessException

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662521#comment-16662521 ] ASF GitHub Bot commented on FLINK-10657: isunjin commented on issue #6912: [FLINK-10657]

[GitHub] isunjin commented on issue #6912: [FLINK-10657] TPCHQuery3 fail with IllegalAccessException

2018-10-24 Thread GitBox
isunjin commented on issue #6912: [FLINK-10657] TPCHQuery3 fail with IllegalAccessException URL: https://github.com/apache/flink/pull/6912#issuecomment-432735636 > ``` > 00:58:26.666 [ERROR] src/main/java/org/apache/flink/examples/java/relational/TPCHQuery3.java:[241] (javadoc)

[jira] [Commented] (FLINK-8995) Add a test operator with keyed state that uses custom, stateful serializer

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662491#comment-16662491 ] ASF GitHub Bot commented on FLINK-8995: --- tzulitai commented on a change in pull request #6909:

[GitHub] tzulitai commented on a change in pull request #6909: [FLINK-8995][tests] Add keyed state that uses custom stateful seriali…

2018-10-24 Thread GitBox
tzulitai commented on a change in pull request #6909: [FLINK-8995][tests] Add keyed state that uses custom stateful seriali… URL: https://github.com/apache/flink/pull/6909#discussion_r227863415 ## File path:

[jira] [Commented] (FLINK-10570) State grows unbounded when "within" constraint not applied

2018-10-24 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662481#comment-16662481 ] Dawid Wysakowicz commented on FLINK-10570: -- Fixed in master:

[jira] [Closed] (FLINK-10570) State grows unbounded when "within" constraint not applied

2018-10-24 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10570. Resolution: Fixed Fix Version/s: 1.7.0 1.6.3 > State grows

[jira] [Updated] (FLINK-10670) Fix Correlate codegen error

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10670: --- Labels: pull-request-available (was: ) > Fix Correlate codegen error >

[jira] [Commented] (FLINK-10670) Fix Correlate codegen error

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662476#comment-16662476 ] ASF GitHub Bot commented on FLINK-10670: Xpray opened a new pull request #6923: [FLINK-10670]

[GitHub] Xpray opened a new pull request #6923: [FLINK-10670] [table] Fix Correlate codegen error

2018-10-24 Thread GitBox
Xpray opened a new pull request #6923: [FLINK-10670] [table] Fix Correlate codegen error URL: https://github.com/apache/flink/pull/6923 ## What is the purpose of the change TableFunctionCollector should handle reuseInitStatements and reuseMemberStatements ## Brief

[jira] [Closed] (FLINK-10669) Exceptions & errors are not properly checked in logs in e2e tests

2018-10-24 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10669. Resolution: Fixed > Exceptions & errors are not properly checked in logs in e2e tests >

[jira] [Resolved] (FLINK-10220) StreamSQL E2E test fails on travis

2018-10-24 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-10220. -- Resolution: Fixed > StreamSQL E2E test fails on travis >

[GitHub] yanghua commented on issue #6890: [FLINK-10603] Reduce kafka test duration

2018-10-24 Thread GitBox
yanghua commented on issue #6890: [FLINK-10603] Reduce kafka test duration URL: https://github.com/apache/flink/pull/6890#issuecomment-432718022 excluded all but `FlinkKafkaProducer011ITCase`, test result : ``` 15:41:23.815 [INFO] flink-connector-kafka-0.8

[jira] [Commented] (FLINK-10603) Reduce kafka test duration

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662466#comment-16662466 ] ASF GitHub Bot commented on FLINK-10603: yanghua commented on issue #6890: [FLINK-10603] Reduce

[jira] [Commented] (FLINK-10665) Port YARNSessionFIFOITCase#testJavaAPI to new codebase

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662439#comment-16662439 ] ASF GitHub Bot commented on FLINK-10665: TisonKun commented on issue #6917: [FLINK-10665]

[GitHub] TisonKun commented on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c…

2018-10-24 Thread GitBox
TisonKun commented on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c… URL: https://github.com/apache/flink/pull/6917#issuecomment-432711697 @zentol thanks for the review, add a hotfix :-)

[jira] [Assigned] (FLINK-8921) Split code generated call expression

2018-10-24 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li reassigned FLINK-8921: - Assignee: xueyu (was: Ruidong Li) > Split code generated call expression >

[jira] [Commented] (FLINK-8921) Split code generated call expression

2018-10-24 Thread Ruidong Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662436#comment-16662436 ] Ruidong Li commented on FLINK-8921: --- [~xueyu] thanks for you contribution, I assign this issue to you

[jira] [Commented] (FLINK-10665) Port YARNSessionFIFOITCase#testJavaAPI to new codebase

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662430#comment-16662430 ] ASF GitHub Bot commented on FLINK-10665: zentol commented on issue #6917: [FLINK-10665] [tests]

[GitHub] zentol commented on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c…

2018-10-24 Thread GitBox
zentol commented on issue #6917: [FLINK-10665] [tests] Port YARNSessionFIFOITCase#testJavaAPI to new c… URL: https://github.com/apache/flink/pull/6917#issuecomment-432709017 ``` 14:45:49.851 [INFO] There are 3 errors reported by Checkstyle 8.9 with /tools/maven/checkstyle.xml ruleset.

[jira] [Commented] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662427#comment-16662427 ] ASF GitHub Bot commented on FLINK-10490: zentol commented on issue #6910: [FLINK-10490][tests]

[GitHub] zentol commented on issue #6910: [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Seria…

2018-10-24 Thread GitBox
zentol commented on issue #6910: [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Seria… URL: https://github.com/apache/flink/pull/6910#issuecomment-432708555 The code loading the savepoint is aware of previous versions and starts a migration routine if a v1 savepoint is

[jira] [Commented] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662422#comment-16662422 ] ASF GitHub Bot commented on FLINK-8274: --- xueyumusic commented on issue #5613: [FLINK-8274] [table]

[jira] [Updated] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8274: -- Labels: pull-request-available (was: ) > Fix Java 64K method compiling limitation for

[GitHub] xueyumusic commented on issue #5613: [FLINK-8274] [table] Split generated methods for preventing compiler exceptions

2018-10-24 Thread GitBox
xueyumusic commented on issue #5613: [FLINK-8274] [table] Split generated methods for preventing compiler exceptions URL: https://github.com/apache/flink/pull/5613#issuecomment-432705919 > Hi @twalthr > Current implementation will reach the limits if a field becomes too large. This can

[jira] [Commented] (FLINK-10613) Remove logger casts in HBaseConnectorITCase

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16662421#comment-16662421 ] ASF GitHub Bot commented on FLINK-10613: zentol opened a new pull request #6922:

[jira] [Assigned] (FLINK-10613) Remove logger casts in HBaseConnectorITCase

2018-10-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-10613: Assignee: Chesnay Schepler > Remove logger casts in HBaseConnectorITCase >

[jira] [Updated] (FLINK-10613) Remove logger casts in HBaseConnectorITCase

2018-10-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10613: --- Labels: pull-request-available (was: ) > Remove logger casts in HBaseConnectorITCase >

  1   2   3   >