[GitHub] flink pull request #4507: [FLINK-7404] [table] Generate code for non-equi jo...

2017-08-09 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/4507 [FLINK-7404] [table] Generate code for non-equi join conditions only. ## What is the purpose of the change Generate code only for non-equi join conditions for Table API / SQL batch joins.

[jira] [Updated] (FLINK-7395) NumBytesOut metric in RecordWriter call synchronized method

2017-08-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7395: Priority: Major (was: Blocker) > NumBytesOut metric in RecordWriter call synchronized

[jira] [Commented] (FLINK-7372) Remove ActorGateway from JobGraph

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120143#comment-16120143 ] ASF GitHub Bot commented on FLINK-7372: --- Github user zentol commented on the issue:

[jira] [Created] (FLINK-7404) Table API batch join code-gen's equi-join conditions

2017-08-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7404: Summary: Table API batch join code-gen's equi-join conditions Key: FLINK-7404 URL: https://issues.apache.org/jira/browse/FLINK-7404 Project: Flink Issue

[jira] [Commented] (FLINK-7404) Table API batch join code-gen's equi-join conditions

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120102#comment-16120102 ] ASF GitHub Bot commented on FLINK-7404: --- GitHub user fhueske opened a pull request:

[GitHub] flink issue #4239: [FLINK-6988] flink-connector-kafka-0.11 with exactly-once...

2017-08-09 Thread rangadi
Github user rangadi commented on the issue: https://github.com/apache/flink/pull/4239 May be an extra shuffle to make small batches could help. Another option is to buffer all the records in state and write them all inside commit(). But not sure how costly it is to save all the

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-08-09 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4473 @tzulitai @aljoscha Let me know if this PR looks good. Thanks! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

2017-08-09 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120483#comment-16120483 ] Rong Rong commented on FLINK-7357: -- Seems like the logical plan generated from Having inserts another

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121106#comment-16121106 ] ASF GitHub Bot commented on FLINK-7406: --- GitHub user zhijiangW opened a pull request:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

2017-08-09 Thread zhijiangW
GitHub user zhijiangW opened a pull request: https://github.com/apache/flink/pull/4509 [FLINK-7406][network] Implement Netty receiver incoming pipeline for credit-based ## What is the purpose of the change Currently `PartitionRequestClientHandler` receives and reads

[jira] [Commented] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

2017-08-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121094#comment-16121094 ] Aljoscha Krettek commented on FLINK-7407: - [~tzulitai] Should we make this a blocker, because it

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121011#comment-16121011 ] ASF GitHub Bot commented on FLINK-7368: --- Github user asdf2014 commented on a diff in the pull

[jira] [Created] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

2017-08-09 Thread zhijiang (JIRA)
zhijiang created FLINK-7406: --- Summary: Implement Netty receiver incoming pipeline for credit-based Key: FLINK-7406 URL: https://issues.apache.org/jira/browse/FLINK-7406 Project: Flink Issue Type:

[GitHub] flink pull request #4472: FLINK-7368: MetricStore makes cpu spin at 100%

2017-08-09 Thread asdf2014
Github user asdf2014 commented on a diff in the pull request: https://github.com/apache/flink/pull/4472#discussion_r132358492 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricStore.java --- @@ -24,8 +24,8 @@ import org.slf4j.Logger;

[jira] [Updated] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

2017-08-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7407: --- Priority: Critical (was: Major) > Assumption of partition id strict contiguity is

[jira] [Updated] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

2017-08-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7407: --- Affects Version/s: 1.4.0 > Assumption of partition id strict contiguity is too naive

[jira] [Updated] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

2017-08-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7407: --- Description: In the Kafka Consumer's {{AbstractPartitionDiscoverer}}, for partition

[jira] [Assigned] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

2017-08-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-7407: -- Assignee: Tzu-Li (Gordon) Tai > Assumption of partition id strict contiguity

[jira] [Created] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

2017-08-09 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7407: -- Summary: Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer Key: FLINK-7407 URL:

[jira] [Updated] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

2017-08-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7407: --- Priority: Blocker (was: Critical) > Assumption of partition id strict contiguity is

[jira] [Commented] (FLINK-7407) Assumption of partition id strict contiguity is too naive in Kafka consumer's AbstractPartitionDiscoverer

2017-08-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121099#comment-16121099 ] Tzu-Li (Gordon) Tai commented on FLINK-7407: [~aljoscha] this information isn't independently

[jira] [Commented] (FLINK-7394) Implement basic InputChannel for credit-based logic

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119498#comment-16119498 ] ASF GitHub Bot commented on FLINK-7394: --- GitHub user zhijiangW opened a pull request:

[GitHub] flink pull request #4500: [FLINK-6787] Fix Job-/StoppingException extend Fli...

2017-08-09 Thread zjureel
GitHub user zjureel opened a pull request: https://github.com/apache/flink/pull/4500 [FLINK-6787] Fix Job-/StoppingException extend FlinkException ## What is the purpose of the change Fix Job-/StoppingException extend FlinkException ## Brief change log -

[jira] [Assigned] (FLINK-6787) Job-/StoppableException should extend FlinkException

2017-08-09 Thread Fang Yong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-6787: Assignee: Fang Yong > Job-/StoppableException should extend FlinkException >

[jira] [Created] (FLINK-7395) NumBytesOut metric in RecordWriter call synchronized method

2017-08-09 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7395: --- Summary: NumBytesOut metric in RecordWriter call synchronized method Key: FLINK-7395 URL: https://issues.apache.org/jira/browse/FLINK-7395 Project: Flink

[jira] [Commented] (FLINK-6988) Add Apache Kafka 0.11 connector

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119556#comment-16119556 ] ASF GitHub Bot commented on FLINK-6988: --- Github user pnowojski commented on the issue:

[GitHub] flink issue #4239: [FLINK-6988] flink-connector-kafka-0.11 with exactly-once...

2017-08-09 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4239 I think there is no way we can to handle it in any different way then to increase the timeout to some very large value. Or is it? --- If your project is set up for it, you can reply to this email

[GitHub] flink issue #4404: [FLINK-4565] [table] Support for SQL IN operator

2017-08-09 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/4404 @fhueske Can you take a look at #4493 ? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-7367) Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime, MaxConnections, RequestTimeout, etc)

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119575#comment-16119575 ] ASF GitHub Bot commented on FLINK-7367: --- Github user tzulitai commented on the issue:

[GitHub] flink pull request #4499: [FLINK-7394][core] Implement basic InputChannel fo...

2017-08-09 Thread zhijiangW
GitHub user zhijiangW opened a pull request: https://github.com/apache/flink/pull/4499 [FLINK-7394][core] Implement basic InputChannel for credit-based logic ## What is the purpose of the change This pull request prepares the basic works for credit-based interaction with

[GitHub] flink pull request #4501: [FLINK-7352] [tests] Stabilize ExecutionGraphResta...

2017-08-09 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4501 [FLINK-7352] [tests] Stabilize ExecutionGraphRestartTest ## What is the purpose of the change Introduce an explicit waiting for the deployment of tasks. This replaces the loose

[GitHub] flink issue #4473: [FLINK-7367][kinesis connector] Parameterize more configs...

2017-08-09 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4473 @bowenli86 no, they're provided via a `Properties` when creating a `FlinkKinesisProducer` --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-7352) ExecutionGraphRestartTest timeouts

2017-08-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119492#comment-16119492 ] Till Rohrmann commented on FLINK-7352: -- I think [~StephanEwen] is right and the problem is

[jira] [Commented] (FLINK-6787) Job-/StoppableException should extend FlinkException

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119510#comment-16119510 ] ASF GitHub Bot commented on FLINK-6787: --- GitHub user zjureel opened a pull request:

[GitHub] flink pull request #4454: [hotfix][docs] Add section in docs about writing u...

2017-08-09 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4454#discussion_r132112682 --- Diff: docs/dev/testing.md --- @@ -0,0 +1,189 @@ +--- +title: "Testing" +nav-parent_id: dev +nav-id: testing +nav-pos: 99 +---

[jira] [Assigned] (FLINK-7352) ExecutionGraphRestartTest timeouts

2017-08-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7352: Assignee: Till Rohrmann > ExecutionGraphRestartTest timeouts >

[jira] [Commented] (FLINK-7352) ExecutionGraphRestartTest timeouts

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119545#comment-16119545 ] ASF GitHub Bot commented on FLINK-7352: --- GitHub user tillrohrmann opened a pull request:

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119576#comment-16119576 ] ASF GitHub Bot commented on FLINK-4565: --- Github user tedyu commented on the issue:

[GitHub] flink issue #4493: [FLINK-4565] [table] Support for SQL IN operator - move c...

2017-08-09 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4493 Thanks @tedyu. I will merge this in my next batch. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119582#comment-16119582 ] ASF GitHub Bot commented on FLINK-4565: --- Github user twalthr commented on the issue:

[jira] [Resolved] (FLINK-7363) add hashes and signatures to the download page

2017-08-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-7363. Resolution: Fixed Fixed by

[GitHub] flink issue #4494: [FLINK-7026] Introduce flink-shaded-asm-5

2017-08-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4494 Thank your for the review @greghogan . I made 2 more changes to the kinesis/shaded-curator poms; they were including/relocating asm in their shade-plugin configuration even though neither appears to

[jira] [Created] (FLINK-7396) Don't put multiple directories in HADOOP_CONF_DIR in config.sh

2017-08-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7396: --- Summary: Don't put multiple directories in HADOOP_CONF_DIR in config.sh Key: FLINK-7396 URL: https://issues.apache.org/jira/browse/FLINK-7396 Project: Flink

[jira] [Updated] (FLINK-7396) Don't put multiple directories in HADOOP_CONF_DIR in config.sh

2017-08-09 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7396: Priority: Blocker (was: Major) > Don't put multiple directories in HADOOP_CONF_DIR in

[jira] [Commented] (FLINK-7107) Start Yarn session via start-up script

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119640#comment-16119640 ] ASF GitHub Bot commented on FLINK-7107: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4489: [FLINK-7383] Remove ConfigurationUtil

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4489 Thanks for the review @aljoscha. Merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-7375) Remove ActorGateway from JobClient

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119656#comment-16119656 ] ASF GitHub Bot commented on FLINK-7375: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119662#comment-16119662 ] ASF GitHub Bot commented on FLINK-7381: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119660#comment-16119660 ] ASF GitHub Bot commented on FLINK-7381: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132141995 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java --- @@ -101,127 +98,112 @@ public void

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119668#comment-16119668 ] ASF GitHub Bot commented on FLINK-7381: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7026) Add shaded asm dependency

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119633#comment-16119633 ] ASF GitHub Bot commented on FLINK-7026: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #4494: [FLINK-7026] Introduce flink-shaded-asm-5

2017-08-09 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4494 @zentol I think it should be safe to remove that asm relocation (for Kinesis, as far as I'm aware of). --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink issue #4465: [FLINK-7107] [flip6] Add option to start a Flip-6 Yarn se...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4465 Thanks for the review @zentol. Merging this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-7383) Remove ConfigurationUtil

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119642#comment-16119642 ] ASF GitHub Bot commented on FLINK-7383: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-7372) Remove ActorGateway from JobGraph

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119653#comment-16119653 ] ASF GitHub Bot commented on FLINK-7372: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4486: [FLINK-7375] Replace ActorGateway with JobManagerGateway ...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4486 Rebased onto the latest master. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132141613 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/WebMonitorOptions.java --- @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119659#comment-16119659 ] ASF GitHub Bot commented on FLINK-7381: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132141830 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/WebMonitorOptions.java --- @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119667#comment-16119667 ] ASF GitHub Bot commented on FLINK-7381: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119666#comment-16119666 ] ASF GitHub Bot commented on FLINK-7381: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132142466 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerGateway.java --- @@ -63,4 +70,103 @@ * @return Future

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132142385 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java --- @@ -101,127 +98,112 @@ public void

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132142562 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java --- @@ -247,6 +262,8 @@ public static Path

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119682#comment-16119682 ] ASF GitHub Bot commented on FLINK-7381: --- Github user tillrohrmann commented on the issue:

[jira] [Commented] (FLINK-7026) Add shaded asm dependency

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119631#comment-16119631 ] ASF GitHub Bot commented on FLINK-7026: --- Github user zentol commented on the issue:

[GitHub] flink pull request #4489: [FLINK-7383] Remove ConfigurationUtil

2017-08-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4489 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Closed] (FLINK-7107) Start Yarn session via start-up script

2017-08-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7107. Resolution: Fixed Fix Version/s: 1.4.0 Added via a570aa5c0c7d9a18e6cdcb689dcad9ff173dc2ac >

[jira] [Commented] (FLINK-7107) Start Yarn session via start-up script

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119648#comment-16119648 ] ASF GitHub Bot commented on FLINK-7107: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7383) Remove ConfigurationUtil

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119649#comment-16119649 ] ASF GitHub Bot commented on FLINK-7383: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-7383) Remove ConfigurationUtil

2017-08-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7383. Resolution: Fixed Fix Version/s: 1.4.0 Removed via ff70cc3afd004aad4016f94485b95a3ced1639c9

[GitHub] flink pull request #4465: [FLINK-7107] [flip6] Add option to start a Flip-6 ...

2017-08-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4465 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-7372) Remove ActorGateway from JobGraph

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119651#comment-16119651 ] ASF GitHub Bot commented on FLINK-7372: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink issue #4483: [FLINK-7372] [JobGraph] Remove ActorGateway from JobGraph

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4483 Rebased this PR onto the latest master. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] flink pull request #4483: [FLINK-7372] [JobGraph] Remove ActorGateway from J...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4483#discussion_r132140409 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/client/JobClientActorTest.java --- @@ -388,7 +391,9 @@ else if (message instanceof

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119657#comment-16119657 ] ASF GitHub Bot commented on FLINK-7381: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132141346 --- Diff: docs/setup/config.md --- @@ -389,6 +389,10 @@ These parameters allow for advanced tuning. The default values are sufficient wh -

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119675#comment-16119675 ] ASF GitHub Bot commented on FLINK-7381: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132143993 --- Diff: docs/setup/config.md --- @@ -389,6 +389,10 @@ These parameters allow for advanced tuning. The default values are sufficient wh -

[GitHub] flink issue #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from ActorG...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4492 Thanks for the review @zentol. I've addressed most of your comments modulo the web frontend configuration options and rebased the PR onto the latest master. I've tested the web

[jira] [Closed] (FLINK-7397) Which scheduling mechanism and algorithm used for scheduling Jobs

2017-08-09 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7397. --- Resolution: Not A Problem Please ask questions on the {{u...@flink.apache.org}} or

[jira] [Commented] (FLINK-7397) Which scheduling mechanism and algorithm used for scheduling Jobs

2017-08-09 Thread saif.aljumaili (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119722#comment-16119722 ] saif.aljumaili commented on FLINK-7397: --- iam send it > Which scheduling mechanism and algorithm

[jira] [Commented] (FLINK-7062) Support the basic functionality of MATCH_RECOGNIZE

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119728#comment-16119728 ] ASF GitHub Bot commented on FLINK-7062: --- GitHub user dianfu opened a pull request:

[jira] [Commented] (FLINK-7381) Decouple WebRuntimeMonitor from ActorGateway

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119732#comment-16119732 ] ASF GitHub Bot commented on FLINK-7381: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-6982) Replace guava dependencies

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119741#comment-16119741 ] ASF GitHub Bot commented on FLINK-6982: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #4503: [FLINK-6982] [guava] Integrate flink-shaded-guava-...

2017-08-09 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4503 [FLINK-6982] [guava] Integrate flink-shaded-guava-18 ## What is the purpose of the change This PR integrates the shaded guava dependency from flink-shaded. Basically, replace all usages of

[GitHub] flink issue #4477: [FLINK-7370][docs] rework the operator documentation stru...

2017-08-09 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4477 Thanks @NicoK. I will relocate the files according to the new structure and merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-7021) Flink Task Manager hangs on startup if one Zookeeper node is unresolvable

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119760#comment-16119760 ] ASF GitHub Bot commented on FLINK-7021: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4214: [FLINK-7021] Flink Task Manager hangs on startup i...

2017-08-09 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4214#discussion_r132162054 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java --- @@ -196,4 +198,12 @@ protected

[GitHub] flink pull request #4477: [FLINK-7370][docs] rework the operator documentati...

2017-08-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4477 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-7370) rework operator documentation

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119764#comment-16119764 ] ASF GitHub Bot commented on FLINK-7370: --- Github user asfgit closed the pull request at:

[jira] [Created] (FLINK-7397) Which scheduling mechanism and algorithm used for scheduling Jobs

2017-08-09 Thread saif.aljumaili (JIRA)
saif.aljumaili created FLINK-7397: - Summary: Which scheduling mechanism and algorithm used for scheduling Jobs Key: FLINK-7397 URL: https://issues.apache.org/jira/browse/FLINK-7397 Project: Flink

[GitHub] flink pull request #4502: [FLINK-7062] [table, cep] Support the basic functi...

2017-08-09 Thread dianfu
GitHub user dianfu opened a pull request: https://github.com/apache/flink/pull/4502 [FLINK-7062] [table, cep] Support the basic functionality of MATCH_RECOGNIZE ## What is the purpose of the change *This pull request adds the basic support of MATCH_RECOGNIZE.*

[GitHub] flink pull request #4492: [FLINK-7381] [web] Decouple WebRuntimeMonitor from...

2017-08-09 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4492#discussion_r132155748 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricFetcher.java --- @@ -101,127 +98,112 @@ public void update() {

[GitHub] flink issue #4494: [FLINK-7026] Introduce flink-shaded-asm-5

2017-08-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4494 merging. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-7026) Add shaded asm dependency

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119747#comment-16119747 ] ASF GitHub Bot commented on FLINK-7026: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-7370) rework operator documentation

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119757#comment-16119757 ] ASF GitHub Bot commented on FLINK-7370: --- Github user twalthr commented on the issue:

[GitHub] flink issue #4488: [FLINK-7337] [table] Refactor internal handling of time i...

2017-08-09 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4488 @wuchong No problem. Thursday is fine. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (FLINK-7337) Refactor handling of time indicator attributes

2017-08-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119770#comment-16119770 ] ASF GitHub Bot commented on FLINK-7337: --- Github user twalthr commented on the issue:

  1   2   3   >