[GitHub] zentol closed pull request #6912: [FLINK-10657] TPCHQuery3 fail with IllegalAccessException

2018-10-24 Thread GitBox
zentol closed pull request #6912: [FLINK-10657] TPCHQuery3 fail with IllegalAccessException URL: https://github.com/apache/flink/pull/6912 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 i

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

2018-10-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10621: - Affects Version/s: 1.7.0 > BootstrapToolsTest.testConcurrentActorSystemCreation hangs fo

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

2018-10-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10621: - Component/s: Tests > BootstrapToolsTest.testConcurrentActorSystemCreation hangs forever

[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&focusedCommentId=16663339#comment-16663339 ] ASF GitHub Bot commented on FLINK-10621: zentol closed pull request #6925: [FLIN

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

2018-10-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler resolved FLINK-10621. -- Resolution: Fixed Fix Version/s: 1.7.0 master: 2fe70a5c1256eed9781c74e48574da54

[GitHub] zentol closed pull request #6925: [FLINK-10621][runtime] Fix unstable unit test case of BootstrapToolsTest

2018-10-24 Thread GitBox
zentol closed pull request #6925: [FLINK-10621][runtime] Fix unstable unit test case of BootstrapToolsTest URL: https://github.com/apache/flink/pull/6925 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 provena

[jira] [Created] (FLINK-10674) DistinctAccumulator.remove lead to NPE

2018-10-24 Thread ambition (JIRA)
ambition created FLINK-10674: Summary: DistinctAccumulator.remove lead to NPE Key: FLINK-10674 URL: https://issues.apache.org/jira/browse/FLINK-10674 Project: Flink Issue Type: Bug Comp

[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 im

[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&focusedCommentId=16663171#comment-16663171 ] ASF GitHub Bot commented on FLINK-10002: zhangxinyu1 commented on issue #6770:

[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 t

[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: ) > BootstrapToolsTest.testConcurrentActorSystemCreati

[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&focusedCommentId=16663160#comment-16663160 ] ASF GitHub Bot commented on FLINK-10621: ifndef-SleePy opened a new pull request

[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&focusedCommentId=16663146#comment-16663146 ] Biao Liu commented on FLINK-10621: -- Thank you for reporting. [~alexeyt820] It's an unst

[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 mode

[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 > r

[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&focusedCommentId=16663133#comment-16663133 ] ASF GitHub Bot commented on FLINK-10656: zhijiangW commented on a change in pull

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reade

[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&focusedCommentId=16663127#comment-16663127 ] ASF GitHub Bot commented on FLINK-10656: zhijiangW commented on a change in pull

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reade

[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 Client

[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 ope

[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&focusedCommentId=16663102#comment-16663102 ] ASF GitHub Bot commented on FLINK-10600: yanghua opened a new pull request #6924

[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 con

[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 C

[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&focusedCommentId=16663093#comment-16663093 ] vinoyang commented on FLINK-5833: - Hi [~clarkyzl] This issue has not been active for a lo

[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 > --- > > K

[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 wi

[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 wi

[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 wi

[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 wi

[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 wi

[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&focusedCommentId=16662937#comment-16662937 ] Ankur Goenka commented on FLINK-10672: -- cc: [~mxm] [~robertwb] > Task stuck while

[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&focusedCommentId=16662923#comment-16662923 ] ASF GitHub Bot commented on FLINK-8354: --- alexeyt820 commented on issue #6615: [FLIN

[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 t

[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 Apache

[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&focusedCommentId=16662721#comment-16662721 ] Xuefu Zhang commented on FLINK-6036: Thank you, [~jinyu.zj]. PR looks good overall, a

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/InMemoryExternalCatalog

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/InMemoryExternalCatalog

[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: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.sc

[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&focusedCommentId=16662592#comment-16662592 ] ASF GitHub Bot commented on FLINK-10656: isunjin commented on a change in pull r

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/

[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&focusedCommentId=16662587#comment-16662587 ] ASF GitHub Bot commented on FLINK-10656: isunjin commented on a change in pull r

[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: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/

[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&focusedCommentId=16662551#comment-16662551 ] Xuefu Zhang commented on FLINK-10556: - The proposal is attached. > Integration with

[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&focusedCommentId=16662539#comment-16662539 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in p

[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: flink-runtime/src/main/java/org/apache/flink/run

[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&focusedCommentId=16662540#comment-16662540 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in p

[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: flink-runtime/src/main/java/org/apache/flink/run

[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&focusedCommentId=16662546#comment-16662546 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in p

[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: flink-runtime/src/main/java/org/apache/flink/run

[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: flink-runtime/src/main/java/org/apache/flink/run

[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: flink-runtime/src/main/java/org/apache/flink/run

[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&focusedCommentId=16662544#comment-16662544 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in p

[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: flink-runtime/src/main/java/org/apache/flink/run

[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&focusedCommentId=16662541#comment-16662541 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in p

[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: flink-runtime/src/main/java/org/apache/flink/run

[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: flink-runtime/src/main/java/org/apache/flink/run

[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&focusedCommentId=16662545#comment-16662545 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in p

[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: flink-runtime/src/main/java/org/apache/flink/run

[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&focusedCommentId=16662547#comment-16662547 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in p

[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&focusedCommentId=16662542#comment-16662542 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in p

[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&focusedCommentId=16662548#comment-16662548 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in p

[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: flink-runtime/src/main/java/org/apache/flink/run

[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&focusedCommentId=16662543#comment-16662543 ] ASF GitHub Bot commented on FLINK-10431: tillrohrmann commented on a change in p

[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&focusedCommentId=16662521#comment-16662521 ] ASF GitHub Bot commented on FLINK-10657: isunjin commented on issue #6912: [FLIN

[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) 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&focusedCommentId=16662491#comment-16662491 ] ASF GitHub Bot commented on FLINK-8995: --- tzulitai commented on a change in pull req

[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: flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/ap

[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&focusedCommentId=16662481#comment-16662481 ] Dawid Wysakowicz commented on FLINK-10570: -- Fixed in master: fa085699ee5a8a9049

[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 unbou

[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&focusedCommentId=16662476#comment-16662476 ] ASF GitHub Bot commented on FLINK-10670: Xpray opened a new pull request #6923:

[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 cha

[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&focusedCommentId=16662466#comment-16662466 ] ASF GitHub Bot commented on FLINK-10603: yanghua commented on issue #6890: [FLIN

[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&focusedCommentId=16662439#comment-16662439 ] ASF GitHub Bot commented on FLINK-10665: TisonKun commented on issue #6917: [FLI

[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 :-) T

[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&focusedCommentId=16662436#comment-16662436 ] Ruidong Li commented on FLINK-8921: --- [~xueyu] thanks for you contribution, I assign thi

[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&focusedCommentId=16662430#comment-16662430 ] ASF GitHub Bot commented on FLINK-10665: zentol commented on issue #6917: [FLINK

[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&focusedCommentId=16662427#comment-16662427 ] ASF GitHub Bot commented on FLINK-10490: zentol commented on issue #6910: [FLINK

  1   2   3   >