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

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

[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

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

[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-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 #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] [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] [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] [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

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

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

[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=16119576#comment-16119576 ] ASF GitHub Bot commented on FLINK-4565: --- Github user tedyu commented on the issue:

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

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

[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

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

[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] [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-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:

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

[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] [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 #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

[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

<    1   2   3