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

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

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

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501381#comment-16501381 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

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

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

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

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501379#comment-16501379 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

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

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

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

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

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

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501382#comment-16501382 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

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

2018-06-05 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/6082#discussion_r192768664 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaAvroTableSourceTestBase.java --- @@

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

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501383#comment-16501383 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

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

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

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

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501380#comment-16501380 ] ASF GitHub Bot commented on FLINK-9444: --- Github user twalthr commented on a diff in the pull

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

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501392#comment-16501392 ] 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-05 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5786 @zorro786 That should still work. But you're right that it should also be listed, maybe as a "legacy" option or the separate flip6 option should be removed. ---

[GitHub] flink issue #6101: [FLINK-9458] Unable to recover from job failure on YARN w...

2018-06-05 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/6101 @tillrohrmann OK, closing... ---

[GitHub] flink pull request #6101: [FLINK-9458] Unable to recover from job failure on...

2018-06-05 Thread yanghua
Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/6101 ---

[jira] [Commented] (FLINK-9458) Unable to recover from job failure on YARN with NPE

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

[jira] [Commented] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501403#comment-16501403 ] ASF GitHub Bot commented on FLINK-9458: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #6101: [FLINK-9458] Unable to recover from job failure on YARN w...

2018-06-05 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/6101 Could you please close this PR @yanghua. It is now subsumed by #6119. ---

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

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

[jira] [Commented] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT

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

[jira] [Commented] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT

2018-06-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501449#comment-16501449 ] Timo Walther commented on FLINK-8518: - DOW has been added in 1.6.0:

[GitHub] flink issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail wi...

2018-06-05 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/6103 Hi, Stephan. Thank you for your response. But I would ask, if the issue does not occur by the receiver of a channel starts much faster than the sender. Like RuntimeException cause the task

[jira] [Commented] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501493#comment-16501493 ] ASF GitHub Bot commented on FLINK-9413: --- Github user zhangminglei commented on the issue:

[jira] [Created] (FLINK-9527) Paths initialize with URI are not normalized

2018-06-05 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9527: --- Summary: Paths initialize with URI are not normalized Key: FLINK-9527 URL: https://issues.apache.org/jira/browse/FLINK-9527 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9440) Allow cancelation and reset of timers

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501496#comment-16501496 ] ASF GitHub Bot commented on FLINK-9440: --- Github user aljoscha commented on a diff in the pull

[GitHub] flink pull request #6096: [FLINK-9440][streaming] Expose cancelation of time...

2018-06-05 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/6096#discussion_r192994475 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java --- @@ -114,12 +114,22 @@ public long

[jira] [Updated] (FLINK-9527) Paths initialized with URI are not normalized

2018-06-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9527: Summary: Paths initialized with URI are not normalized (was: Paths initialize with URI

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

2018-06-05 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

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

2018-06-05 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

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

2018-06-05 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

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

2018-06-05 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501397#comment-16501397 ] Nico Kruber commented on FLINK-2032: I checked a few of the mentioned tests and it seems this is

[GitHub] flink pull request #6096: [FLINK-9440][streaming] Expose cancelation of time...

2018-06-05 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6096#discussion_r192976292 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java --- @@ -114,12 +114,22 @@ public long

[jira] [Commented] (FLINK-6469) Configure Memory Sizes with units

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501429#comment-16501429 ] ASF GitHub Bot commented on FLINK-6469: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5448: [FLINK-6469] Configure Memory Sizes with units

2018-06-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5448 There is no problem reusing old keys, if their default unit was "bytes", because the `MemorySize.parse(...)` interprets a number as bytes, if there is no unit attached to it. I did not

[GitHub] flink issue #6103: [FLINK-9413] [distributed coordination] Tasks can fail wi...

2018-06-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/6103 That all depends why the failure happens in the first place. It seems to happen if the receiver of a channel starts much faster than the sender. The longest part of the deployment is library

[jira] [Commented] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501438#comment-16501438 ] ASF GitHub Bot commented on FLINK-9413: --- Github user StephanEwen commented on the issue:

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

2018-06-05 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/6116 Yes I know, but I didn't see those problematic dependencies in > mvn -Dhadoop.version=2.7.0 dependency:tree -pl flink-shaded-hadoop/flink-shaded-hadoop2 thus I why assumed problem is with

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

2018-06-05 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-05 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

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

2018-06-05 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:

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

2018-06-05 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:

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

2018-06-05 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-2032: -- Assignee: Deepak Sharma (was: Pattarawat Chormai) > Migrate integration tests from temp

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

2018-06-05 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16116515#comment-16116515 ] Nico Kruber edited comment on FLINK-2032 at 6/5/18 7:14 AM: Hi [~heytitle],

[jira] [Created] (FLINK-9526) BucketingSink end-to-end test failed on Travis

2018-06-05 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9526: --- Summary: BucketingSink end-to-end test failed on Travis Key: FLINK-9526 URL: https://issues.apache.org/jira/browse/FLINK-9526 Project: Flink Issue

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

2018-06-05 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5786 The section `flip6` is effectively the standalone mode @zorro786. I'll update the documentation accordingly. The reason why the job manager option is now shown under the different

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

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

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

2018-06-05 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501456#comment-16501456 ] Luke Hutchison commented on FLINK-6019: --- Unfortunately I am so unknowledgeable about the

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

2018-06-05 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5786#discussion_r192983985 --- Diff: docs/ops/cli.md --- @@ -287,6 +287,16 @@ Action "run" compiles and runs a program. sub-paths for high

[jira] [Comment Edited] (FLINK-8650) Add tests and documentation for WINDOW clause

2018-06-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501457#comment-16501457 ] Timo Walther edited comment on FLINK-8650 at 6/5/18 8:15 AM: - Thanks for

[jira] [Commented] (FLINK-9448) contribute-code.html references Hadoop 1.x support

2018-06-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501470#comment-16501470 ] Fabian Hueske commented on FLINK-9448: -- Thanks for noticing and reporting this! While we are at it,

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

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

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

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501503#comment-16501503 ] ASF GitHub Bot commented on FLINK-9525: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #6120: [FLINK-7251] [types] Remove the flink-java8 module and im...

2018-06-05 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6120 @twalthr I think you only have to update the java8 docs: https://ci.apache.org/projects/flink/flink-docs-master/dev/java8.html ---

[GitHub] flink issue #6118: [FLINK-9525][filesystem] Add missing `META-INF/services/*...

2018-06-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/6118 I think this is a misdiagnosis, this should not be merged. Flink does not need a file system factory for Hadoop, it uses Hadoop's FS as the general fallback for all schemes that it does

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

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

[GitHub] flink issue #6120: [FLINK-7251] [types] Remove the flink-java8 module and im...

2018-06-05 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/6120 I checked the docs. They do not change with these changes. However, we should verify that the docs about the Eclipse JDT compiler are still correct maybe even with an end-to-end test. ---

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501507#comment-16501507 ] ASF GitHub Bot commented on FLINK-7251: --- Github user twalthr commented on the issue:

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

2018-06-05 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-05 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] [Commented] (FLINK-8790) Improve performance for recovery from incremental checkpoint

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

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

2018-06-05 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

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

2018-06-05 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6116 The actual issue here is that these dependencies aren't shaded. ---

[jira] [Commented] (FLINK-9458) Unable to recover from job failure on YARN with NPE

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

[jira] [Commented] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-06-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501405#comment-16501405 ] ASF GitHub Bot commented on FLINK-9458: --- Github user yanghua closed the pull request at:

[GitHub] flink pull request #6007: [FLINK-8518][Table API & SQL] Support DOW for EXTR...

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

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

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

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

2018-06-05 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

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

2018-06-05 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

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

2018-06-05 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 >

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

2018-06-05 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-05 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501359#comment-16501359 ] Hai Zhou commented on FLINK-9525: - After adding this missing file in the {{flink-hadoop-fs}} module, and

[GitHub] flink issue #5798: [FLINK-7917] The return of taskInformationOrBlobKey shoul...

2018-06-05 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5798 cc @tzulitai ---

[GitHub] flink issue #5448: [FLINK-6469] Configure Memory Sizes with units

2018-06-05 Thread yanghua
Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5448 @StephanEwen for the `taskmanager.memory.segment-size` because of it's default unit is `byte`, so whether there is a unit or not, the behavior is consistent. So we just need to handle

[jira] [Commented] (FLINK-8650) Add tests and documentation for WINDOW clause

2018-06-05 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501457#comment-16501457 ] Timo Walther commented on FLINK-8650: - Thanks for working on this [~Sergey Nuyanzin]. I think we

[jira] [Commented] (FLINK-9448) contribute-code.html references Hadoop 1.x support

2018-06-05 Thread Andrew Janke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501479#comment-16501479 ] Andrew Janke commented on FLINK-9448: - Does it also require Java 1.8 to run? I remember seeing a

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

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

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

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

[jira] [Commented] (FLINK-9440) Allow cancelation and reset of timers

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

[jira] [Assigned] (FLINK-9448) contribute-code.html references Hadoop 1.x support

2018-06-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9448: --- Assignee: (was: vinoyang) > contribute-code.html references Hadoop 1.x support >

[jira] [Updated] (FLINK-9527) Paths initialize with URI are not normalized

2018-06-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9527: Description: The {{Path}} class has a lot of logic to normalize paths, like removing

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

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

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

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

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

2018-06-05 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

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

2018-06-05 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

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

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

[GitHub] flink pull request #6119: [FLINK-9458] Ignore SharedSlot in CoLocationConstr...

2018-06-05 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/6119 [FLINK-9458] Ignore SharedSlot in CoLocationConstraint when not using legacy mode ## What is the purpose of the change The SharedSlot in CoLocationConstraint is only set when using

[GitHub] flink pull request #:

2018-06-05 Thread roycao-xhs
Github user roycao-xhs commented on the pull request: https://github.com/apache/flink/commit/f391957f3e226e302288dc177b538ce7672b3d91#commitcomment-29244185 明爷 ---

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

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

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

2018-06-05 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5786 I've updated the PR @zorro786 and @zentol. ---

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

2018-06-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501435#comment-16501435 ] Stephan Ewen commented on FLINK-6019: - Glad to hear that this solved the issue, happy to help. I

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

2018-06-05 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/6116 Or can not you converge dependencies in your hadoop? It seems like it's causing convergence errors with itself. Disabling convergence checking would be a step back and asking ourself for

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

2018-06-05 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/6116 Well it's not really _their_ hadoop, we explicitly allow and intend users to set different hadoop version for `flink-shaded-hadoop`. For the default version in master we're hiding all dependencies,

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

2018-06-05 Thread Luke Hutchison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501463#comment-16501463 ] Luke Hutchison commented on FLINK-6019: --- PS this is especially confusing because the current

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

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

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

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

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

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

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

2018-06-05 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-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6114 ---

[GitHub] flink pull request #6118: [FLINK-9525][filesystem] Add missing `META-INF/ser...

2018-06-05 Thread yew1eb
GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/6118 [FLINK-9525][filesystem] Add missing `META-INF/services/*FileSystemFactory` file for flink-hadoop-fs ## What is the purpose of the change more details, see

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

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

  1   2   3   >