[jira] [Closed] (FLINK-9518) SSL setup Docs config example has wrong keys password

2018-06-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9518. --- Resolution: Fixed master: 8372e2d3e6d08cf75ddcee974156cd4126c8c22a 1.5: ff46843715c95f4f2ca3e

[jira] [Closed] (FLINK-9517) Fixing broken links on CLI and Upgrade Docs

2018-06-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9517. --- Resolution: Fixed master: 58233ef6734609a876fb8c446c18a06f3cb6f099 1.5: 0728795d0eaf6e1558ed5

[jira] [Updated] (FLINK-9518) SSL setup Docs config example has wrong keys password

2018-06-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9518: Affects Version/s: (was: 1.4.1) 1.6.0 > SSL setup Docs config ex

[jira] [Updated] (FLINK-9518) SSL setup Docs config example has wrong keys password

2018-06-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9518: Fix Version/s: 1.5.1 1.4.3 1.6.0 > SSL setup Docs con

[jira] [Commented] (FLINK-8790) Improve performance for recovery from incremental checkpoint

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501368#comment-16501368 ] ASF GitHub Bot commented on FLINK-8790: --- Github user sihuazhou commented on the iss

[GitHub] flink issue #5582: [FLINK-8790][State] Improve performance for recovery from...

2018-06-04 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5582 Hi @StefanRRichter I updated the PR according to the previous discussions, could you please have a look when you have time? The travis failed is unrelated, it's a checkstyle error introduced by the

[jira] [Commented] (FLINK-9518) SSL setup Docs config example has wrong keys password

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501366#comment-16501366 ] ASF GitHub Bot commented on FLINK-9518: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-9517) Fixing broken links on CLI and Upgrade Docs

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501365#comment-16501365 ] ASF GitHub Bot commented on FLINK-9517: --- Github user asfgit closed the pull request

[GitHub] flink pull request #6113: [FLINK-9517][Docs]Fixing broken links on CLI and U...

2018-06-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6113 ---

[GitHub] flink pull request #6114: [FLINK-9518][Docs] SSL setup Docs config example h...

2018-06-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6114 ---

[jira] [Updated] (FLINK-9517) Fixing broken links on CLI and Upgrade Docs

2018-06-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9517: Affects Version/s: 1.6.0 1.5.0 1.4.2 > Fixing

[jira] [Updated] (FLINK-9517) Fixing broken links on CLI and Upgrade Docs

2018-06-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9517: Fix Version/s: (was: 1.4.2) (was: 1.4.1) (

[jira] [Commented] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-04 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501359#comment-16501359 ] Hai Zhou commented on FLINK-9525: - After adding this missing file in the {{flink-hadoop-f

[GitHub] flink pull request #6117: [hotfix][checkstyle] fix checkstyle of CEPOperator...

2018-06-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6117 ---

[jira] [Commented] (FLINK-9518) SSL setup Docs config example has wrong keys password

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501358#comment-16501358 ] ASF GitHub Bot commented on FLINK-9518: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-9517) Fixing broken links on CLI and Upgrade Docs

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501357#comment-16501357 ] ASF GitHub Bot commented on FLINK-9517: --- Github user zentol commented on the issue:

[GitHub] flink issue #6114: [FLINK-9518][Docs] SSL setup Docs config example has wron...

2018-06-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6114 merging, ---

[GitHub] flink issue #6113: [FLINK-9517][Docs]Fixing broken links on CLI and Upgrade ...

2018-06-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6113 merging. ---

[GitHub] flink issue #6117: [hotfix][checkstyle] fix checkstyle of CEPOperatorTest

2018-06-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6117 Thanks for fixing it, merging. ---

[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9525: Priority: Blocker (was: Major) > Missing META-INF/services/*FileSystemFactory in flink-had

[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9525: Affects Version/s: 1.6.0 > Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs

[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9525: Fix Version/s: 1.6.0 > Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs modu

[GitHub] flink issue #6117: [hotfix][checkstyle] fix checkstyle of CEPOperatorTest

2018-06-04 Thread sihuazhou
Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/6117 cc @zentol ---

[GitHub] flink pull request #6117: [hotfix][checkstyle] fix checkstyle of CEPOperator...

2018-06-04 Thread sihuazhou
GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/6117 [hotfix][checkstyle] fix checkstyle of CEPOperatorTest ## What is the purpose of the change *fixes checkstyle error introduced by the previous PR.* ## Brief change log

[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-04 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-9525: Description: if flink job dependencies includes `hadoop-common` and `hadoop-hdfs`, will throw runtime erro

[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-04 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-9525: Description: if flink job dependencies includes `hadoop-common` and `hadoop-hdfs`, will throw runtime erro

[jira] [Created] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

2018-06-04 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-9525: --- Summary: Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module Key: FLINK-9525 URL: https://issues.apache.org/jira/browse/FLINK-9525 Project: Flink I

[jira] [Commented] (FLINK-9444) KafkaAvroTableSource failed to work for map and array fields

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501331#comment-16501331 ] ASF GitHub Bot commented on FLINK-9444: --- Github user suez1224 commented on a diff i

[GitHub] flink pull request #6082: [FLINK-9444][table] KafkaAvroTableSource failed to...

2018-06-04 Thread suez1224
Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r192955182 --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroRecordClassConverter.java --- @@ -73,9 +75,37 @@ private AvroR

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

2018-06-04 Thread Sihua Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501312#comment-16501312 ] Sihua Zhou commented on FLINK-9043: --- Okay, I see it is quite tricky to provide a comple

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501231#comment-16501231 ] ASF GitHub Bot commented on FLINK-8946: --- Github user yanghua commented on the issue

[GitHub] flink issue #6060: [FLINK-8946] TaskManager stop sending metrics after JobMa...

2018-06-04 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6060 cc @zentol @tillrohrmann ---

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2018-06-04 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501158#comment-16501158 ] Luke Hutchison commented on FLINK-6019: --- [~StephanEwen] It looks like I don't have

[jira] [Commented] (FLINK-6019) Some log4j messages do not have a loglevel field set, so they can't be suppressed

2018-06-04 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501151#comment-16501151 ] Luke Hutchison commented on FLINK-6019: --- Yes, that was the problem, thank you. I ha

[jira] [Commented] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests"

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501120#comment-16501120 ] ASF GitHub Bot commented on FLINK-9498: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #6116: [FLINK-9498][build] Disable dependency convergence for fl...

2018-06-04 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/6116 when I build flink with our maintained hadoop version, the command like this `mvn clean install -DskipTests -Dhadoop.version=2.7.0-xxx`, it will `BUILD FAILURE`. Some Enforcer rules have failed.

[jira] [Updated] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex

2018-06-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7917: -- Description: Currently in ExecutionJobVertex#getTaskInformationOrBlobKey: {code} } return taskInformat

[jira] [Updated] (FLINK-9363) Bump up the Jackson version

2018-06-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9363: -- Description: CVE's for Jackson: CVE-2017-17485 CVE-2018-5968 CVE-2018-7489 We can upgrade to 2.9.5 was: C

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-06-04 Thread Nikolas Davis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501068#comment-16501068 ] Nikolas Davis commented on FLINK-8946: -- I think we are seeing a similar issue. We ar

[jira] [Comment Edited] (FLINK-2032) Migrate integration tests from temp output files to collect()

2018-06-04 Thread Deepak Sharma (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16498511#comment-16498511 ] Deepak Sharma edited comment on FLINK-2032 at 6/5/18 12:16 AM:

[jira] [Commented] (FLINK-9447) "sensible" vs. "sensitive" in Code Contribution Process

2018-06-04 Thread Andrew Janke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501060#comment-16501060 ] Andrew Janke commented on FLINK-9447: - Sure! https://github.com/apache/flink-web/pul

[jira] [Comment Edited] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-04 Thread yan zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501026#comment-16501026 ] yan zhou edited comment on FLINK-9524 at 6/4/18 11:31 PM: -- I wou

[jira] [Comment Edited] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-04 Thread yan zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501026#comment-16501026 ] yan zhou edited comment on FLINK-9524 at 6/4/18 11:29 PM: -- I wou

[jira] [Commented] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-04 Thread yan zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501029#comment-16501029 ] yan zhou commented on FLINK-9524: - I have added some trace log in ProcTimeBoundedRangeOve

[jira] [Commented] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-04 Thread yan zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501026#comment-16501026 ] yan zhou commented on FLINK-9524: - Here is the trace log I added into ProcTimeBoundedRang

[jira] [Updated] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-04 Thread yan zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yan zhou updated FLINK-9524: Description: The class _ProcTimeBoundedRangeOver_ would throws NPE if _minRetentionTime_ and  _maxRetention

[jira] [Updated] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-04 Thread yan zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yan zhou updated FLINK-9524: Description: The class _ProcTimeBoundedRangeOver_ would throws NPE if _minRetentionTime_ and  _maxRetention

[jira] [Created] (FLINK-9524) NPE from ProcTimeBoundedRangeOver.scala

2018-06-04 Thread yan zhou (JIRA)
yan zhou created FLINK-9524: --- Summary: NPE from ProcTimeBoundedRangeOver.scala Key: FLINK-9524 URL: https://issues.apache.org/jira/browse/FLINK-9524 Project: Flink Issue Type: Bug Compone

[jira] [Created] (FLINK-9523) Add Kafka examples for Flink Table/SQL API

2018-06-04 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-9523: - Summary: Add Kafka examples for Flink Table/SQL API Key: FLINK-9523 URL: https://issues.apache.org/jira/browse/FLINK-9523 Project: Flink Issue Type: Task

[GitHub] flink issue #5786: [FLINK-9109] [doc] Update documentation for CLI

2018-06-04 Thread zorro786
Github user zorro786 commented on the issue: https://github.com/apache/flink/pull/5786 @zentol What if I want to pass jobmanager option in non flip6 mode? ---

[jira] [Commented] (FLINK-9109) Add flink modify command to documentation

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500835#comment-16500835 ] ASF GitHub Bot commented on FLINK-9109: --- Github user zorro786 commented on the issu

[jira] [Commented] (FLINK-9109) Add flink modify command to documentation

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500829#comment-16500829 ] ASF GitHub Bot commented on FLINK-9109: --- Github user zentol commented on the issue:

[GitHub] flink issue #5786: [FLINK-9109] [doc] Update documentation for CLI

2018-06-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5786 it is listed separately under the flip6 options in the version of this PR. ---

[jira] [Created] (FLINK-9522) Rework Flink website

2018-06-04 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-9522: Summary: Rework Flink website Key: FLINK-9522 URL: https://issues.apache.org/jira/browse/FLINK-9522 Project: Flink Issue Type: Improvement Componen

[jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500778#comment-16500778 ] ASF GitHub Bot commented on FLINK-9374: --- Github user fmthoma commented on a diff in

[jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500780#comment-16500780 ] ASF GitHub Bot commented on FLINK-9374: --- Github user fmthoma commented on a diff in

[GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer...

2018-06-04 Thread fmthoma
Github user fmthoma commented on a diff in the pull request: https://github.com/apache/flink/pull/6021#discussion_r192861304 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -180,9 +204,

[jira] [Commented] (FLINK-9447) "sensible" vs. "sensitive" in Code Contribution Process

2018-06-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500777#comment-16500777 ] Fabian Hueske commented on FLINK-9447: -- Hi Andrew, thank for the question! You are

[GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer...

2018-06-04 Thread fmthoma
Github user fmthoma commented on a diff in the pull request: https://github.com/apache/flink/pull/6021#discussion_r192861127 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/TimeoutLatch.java --- @@ -0,0 +1,41 @@

[jira] [Commented] (FLINK-9451) End-to-end test: Scala Quickstarts

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500763#comment-16500763 ] ASF GitHub Bot commented on FLINK-9451: --- Github user medcv commented on the issue:

[GitHub] flink issue #6089: [FLINK-9451]End-to-end test: Scala Quickstarts

2018-06-04 Thread medcv
Github user medcv commented on the issue: https://github.com/apache/flink/pull/6089 @zentol PR has been updated and usage also changed to `test_quickstarts.sh ` ---

[jira] [Commented] (FLINK-9109) Add flink modify command to documentation

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500760#comment-16500760 ] ASF GitHub Bot commented on FLINK-9109: --- Github user zorro786 commented on the issu

[GitHub] flink issue #5786: [FLINK-9109] [doc] Update documentation for CLI

2018-06-04 Thread zorro786
Github user zorro786 commented on the issue: https://github.com/apache/flink/pull/5786 @tillrohrmann Why is passing job-manager option in standalone mode not supported now? ---

[jira] [Commented] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500677#comment-16500677 ] ASF GitHub Bot commented on FLINK-9398: --- Github user zentol commented on a diff in

[jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500678#comment-16500678 ] ASF GitHub Bot commented on FLINK-9374: --- Github user bowenli86 commented on a diff

[jira] [Commented] (FLINK-9374) Flink Kinesis Producer does not backpressure

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500679#comment-16500679 ] ASF GitHub Bot commented on FLINK-9374: --- Github user bowenli86 commented on a diff

[GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer...

2018-06-04 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6021#discussion_r192834879 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/TimeoutLatch.java --- @@ -0,0 +1,41 @@

[GitHub] flink pull request #6049: [FLINK-9398][Client] Fix CLI list running job retu...

2018-06-04 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6049#discussion_r192837393 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java --- @@ -474,6 +482,19 @@ protected void list(String[] args) throws Exceptio

[GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer...

2018-06-04 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6021#discussion_r192837000 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -180,9 +20

[jira] [Commented] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests"

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500520#comment-16500520 ] ASF GitHub Bot commented on FLINK-9498: --- Github user zentol commented on the issue:

[GitHub] flink issue #6116: [FLINK-9498][build] Disable dependency convergence for fl...

2018-06-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6116 Why make this change? I don't see a build failure; i guess this is just another instance of FLINK-9091 in which case the PR is already subsumed by #6102. ---

[jira] [Commented] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests"

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500485#comment-16500485 ] ASF GitHub Bot commented on FLINK-9498: --- Github user bowenli86 commented on the iss

[GitHub] flink issue #6116: [FLINK-9498][build] Disable dependency convergence for fl...

2018-06-04 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/6116 Will it lower the possibility of detecting lib version conflicts of Flink's dependencies? ---

[jira] [Commented] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests"

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500435#comment-16500435 ] ASF GitHub Bot commented on FLINK-9498: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #6116: [FLINK-9498][build] Disable dependency convergence for fl...

2018-06-04 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/6116 CC @pnowojski ---

[jira] [Commented] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests"

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500433#comment-16500433 ] ASF GitHub Bot commented on FLINK-9498: --- GitHub user yew1eb opened a pull request:

[GitHub] flink pull request #6116: [FLINK-9498][build] Disable dependency convergence...

2018-06-04 Thread yew1eb
GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/6116 [FLINK-9498][build] Disable dependency convergence for flink-end-to-end-tests ## What is the purpose of the change *deactivate that enforce dependency convergence for `flink-end-to-end-tes

[jira] [Created] (FLINK-9521) Add build plugin to package table example jar

2018-06-04 Thread vinoyang (JIRA)
vinoyang created FLINK-9521: --- Summary: Add build plugin to package table example jar Key: FLINK-9521 URL: https://issues.apache.org/jira/browse/FLINK-9521 Project: Flink Issue Type: Bug Affects

[jira] [Closed] (FLINK-7866) Weigh list of preferred locations for scheduling

2018-06-04 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-7866. - Resolution: Fixed Merged in: master: 8868ff5b05 > Weigh list of preferred locations for scheduli

[jira] [Commented] (FLINK-7866) Weigh list of preferred locations for scheduling

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500379#comment-16500379 ] ASF GitHub Bot commented on FLINK-7866: --- Github user asfgit closed the pull request

[GitHub] flink pull request #4949: [FLINK-7866] [runtime] Weigh list of preferred loc...

2018-06-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4949 ---

[jira] [Commented] (FLINK-7866) Weigh list of preferred locations for scheduling

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500371#comment-16500371 ] ASF GitHub Bot commented on FLINK-7866: --- Github user StefanRRichter commented on th

[GitHub] flink issue #4949: [FLINK-7866] [runtime] Weigh list of preferred locations ...

2018-06-04 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4949 LTGM 👍 Will merge this. ---

[jira] [Commented] (FLINK-9398) Flink CLI list running job returns all jobs except in CREATE state

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500362#comment-16500362 ] ASF GitHub Bot commented on FLINK-9398: --- Github user walterddr commented on a diff

[GitHub] flink pull request #6049: [FLINK-9398][Client] Fix CLI list running job retu...

2018-06-04 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/6049#discussion_r192778560 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java --- @@ -474,6 +482,19 @@ protected void list(String[] args) throws Excep

[jira] [Commented] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500312#comment-16500312 ] ASF GitHub Bot commented on FLINK-9476: --- Github user asfgit closed the pull request

[jira] [Resolved] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator

2018-06-04 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-9476. - Resolution: Fixed > Lost sideOutPut Late Elements in CEP Operator > -

[GitHub] flink pull request #6104: [FLINK-9476]Emit late elements in CEP as sideOutPu...

2018-06-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6104 ---

[jira] [Closed] (FLINK-6538) Emit late elements as Side Outputs

2018-06-04 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-6538. --- Resolution: Duplicate > Emit late elements as Side Outputs >

[jira] [Updated] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator

2018-06-04 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-9476: Fix Version/s: 1.6.0 > Lost sideOutPut Late Elements in CEP Operator >

[jira] [Updated] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator

2018-06-04 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-9476: Affects Version/s: (was: 1.4.2) > Lost sideOutPut Late Elements in CEP Operator > -

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-06-04 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong updated FLINK-9294: - Description: Most of the UDF function signatures that includes composite types such as *{{MAP}}*, *{{ARR

[jira] [Commented] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

2018-06-04 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500307#comment-16500307 ] Rong Rong commented on FLINK-9294: -- Yes you are absolutely right, sorry for the typo. >

[jira] [Commented] (FLINK-9476) Lost sideOutPut Late Elements in CEP Operator

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500296#comment-16500296 ] ASF GitHub Bot commented on FLINK-9476: --- Github user Aitozi commented on the issue:

[GitHub] flink issue #6104: [FLINK-9476]Emit late elements in CEP as sideOutPut

2018-06-04 Thread Aitozi
Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/6104 @dawidwys fix the flaw according to your suggestion ;-) ---

[jira] [Updated] (FLINK-9520) JarFileCreator does not support Java MethodReferences

2018-06-04 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9520: Component/s: (was: Local Runtime) Core > JarFileCreator does not support Java

[jira] [Commented] (FLINK-9435) Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector

2018-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16500281#comment-16500281 ] ASF GitHub Bot commented on FLINK-9435: --- GitHub user NicoK opened a pull request:

[jira] [Created] (FLINK-9520) JarFileCreator does not support Java MethodReferences

2018-06-04 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9520: --- Summary: JarFileCreator does not support Java MethodReferences Key: FLINK-9520 URL: https://issues.apache.org/jira/browse/FLINK-9520 Project: Flink Issue Type:

[GitHub] flink pull request #6115: [FLINK-9435][java] Remove per-key selection Tuple ...

2018-06-04 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/6115 [FLINK-9435][java] Remove per-key selection Tuple instantiation via reflection in ComparableKeySelector and ArrayKeySelector ## What is the purpose of the change Inside `KeySelectorUtil`, eve

[GitHub] flink issue #6111: [FLINK-9504]Change the log level of checkpoint duration t...

2018-06-04 Thread Aitozi
Github user Aitozi commented on the issue: https://github.com/apache/flink/pull/6111 thanks @StephanEwen for review. As you mentioned, I only set the log level in state backends to `debug` , is there something wrong with my pull request or misunderstand what your meaning ? ---

  1   2   3   >