[jira] [Commented] (FLINK-9853) add hex support in table api and sql

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551516#comment-16551516 ] ASF GitHub Bot commented on FLINK-9853: --- Github user hequn8128 commented on the issue:

[GitHub] flink issue #6337: [FLINK-9853][Tabel API & SQL] add HEX support

2018-07-20 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/6337 Thanks for your PR. +1 to merge. ---

[jira] [Commented] (FLINK-9714) Support versioned joins with processing time

2018-07-20 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551507#comment-16551507 ] Hequn Cheng commented on FLINK-9714: Rates(o.rowtime) => Rates(o.proctime) ? > Support versioned

[jira] [Commented] (FLINK-9236) Use Apache Parent POM 19

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551506#comment-16551506 ] ASF GitHub Bot commented on FLINK-9236: --- Github user YCjia commented on the issue:

[GitHub] flink issue #6378: [FLINK-9236] [pom] upgrade the version of apache parent p...

2018-07-20 Thread YCjia
Github user YCjia commented on the issue: https://github.com/apache/flink/pull/6378 @TisonShadowsong @zhangminglei I ran these tests locally, but they all succeeded, and the Travis CI build for my fork repository passed too. https://travis-ci.com/YCjia/flink/builds ---

[jira] [Commented] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

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

[GitHub] flink issue #6336: [FLINK-9630] [connector] Kafka09PartitionDiscoverer cause...

2018-07-20 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/6336 Hi, @ubyyj Thanks for your contribution! It looks good to me. ---

[jira] [Assigned] (FLINK-9391) Support UNNEST in Table API

2018-07-20 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-9391: -- Assignee: (was: Hequn Cheng) > Support UNNEST in Table API > ---

[jira] [Updated] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

2018-07-20 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei updated FLINK-9900: Affects Version/s: 1.5.1 > Failed to testRestoreBehaviourWithFaultyStateHandles >

[jira] [Commented] (FLINK-9236) Use Apache Parent POM 19

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

[GitHub] flink issue #6378: [FLINK-9236] [pom] upgrade the version of apache parent p...

2018-07-20 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/6378 @TisonShadowsong is right. You can verify that and i think it might be a bug. ---

[jira] [Assigned] (FLINK-9391) Support UNNEST in Table API

2018-07-20 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-9391: -- Assignee: Hequn Cheng > Support UNNEST in Table API > --- > >

[jira] [Commented] (FLINK-9720) Introduce ResourceTag class for tag support in scheduling

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551477#comment-16551477 ] ASF GitHub Bot commented on FLINK-9720: --- Github user liurenjie1024 commented on the issue:

[GitHub] flink issue #6357: [FLINK-9720] [Scheduler] Add ResourceAttribute and MesosR...

2018-07-20 Thread liurenjie1024
Github user liurenjie1024 commented on the issue: https://github.com/apache/flink/pull/6357 @tillrohrmann Can you help to review this? ---

[jira] [Commented] (FLINK-9061) add entropy to s3 path for better scalability

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551464#comment-16551464 ] ASF GitHub Bot commented on FLINK-9061: --- Github user indrc commented on the issue:

[GitHub] flink issue #6302: [FLINK-9061][checkpointing] add entropy to s3 path for be...

2018-07-20 Thread indrc
Github user indrc commented on the issue: https://github.com/apache/flink/pull/6302 @mdaxini i don't think we have to validate the public api; with the 4 char alphanumeric there is more than enough entropy to cover all filewrites in a conceivable TM cluster. And to add to that, this

[jira] [Commented] (FLINK-9630) Kafka09PartitionDiscoverer cause connection leak on TopicAuthorizationException

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551463#comment-16551463 ] ASF GitHub Bot commented on FLINK-9630: --- Github user ubyyj commented on the issue:

[GitHub] flink issue #6336: [FLINK-9630] [connector] Kafka09PartitionDiscoverer cause...

2018-07-20 Thread ubyyj
Github user ubyyj commented on the issue: https://github.com/apache/flink/pull/6336 @zhangminglei @tzulitai would you please take a look? ---

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

2018-07-20 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}}*,

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

2018-07-20 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}}*,

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

2018-07-20 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}}*,

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

2018-07-20 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}}*,

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

2018-07-20 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}}*,

[jira] [Comment Edited] (FLINK-4319) Rework Cluster Management (FLIP-6)

2018-07-20 Thread Yinan Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551321#comment-16551321 ] Yinan Li edited comment on FLINK-4319 at 7/20/18 9:40 PM: -- Interested in FLIP-6

[jira] [Commented] (FLINK-4319) Rework Cluster Management (FLIP-6)

2018-07-20 Thread Yinan Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551321#comment-16551321 ] Yinan Li commented on FLINK-4319: - Interested in bring FLIP-6 for Flink on Kubernetes. Wondering why the

[jira] [Closed] (FLINK-9753) Support Parquet for StreamingFileSink

2018-07-20 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9753. - Resolution: Fixed Merged on master with 66b1f854a0250bdd048808d40f93aa2990476841 > Support

[jira] [Closed] (FLINK-9903) Add support for bulk writers.

2018-07-20 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9903. - Resolution: Fixed Merged to master with b56c75ca375049b1d2c80d2d0945ae1ae04eb39e > Add support

[jira] [Created] (FLINK-9905) ClassCastException: org.apache.flink.streaming.runtime.streamrecord.LatencyMarker

2018-07-20 Thread Gregory Fee (JIRA)
Gregory Fee created FLINK-9905: -- Summary: ClassCastException: org.apache.flink.streaming.runtime.streamrecord.LatencyMarker Key: FLINK-9905 URL: https://issues.apache.org/jira/browse/FLINK-9905 Project:

[jira] [Commented] (FLINK-9236) Use Apache Parent POM 19

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551103#comment-16551103 ] ASF GitHub Bot commented on FLINK-9236: --- Github user TisonShadowsong commented on the issue:

[GitHub] flink issue #6378: [FLINK-9236] [pom] upgrade the version of apache parent p...

2018-07-20 Thread TisonShadowsong
Github user TisonShadowsong commented on the issue: https://github.com/apache/flink/pull/6378 The test that fails is `WindowCheckpointingITCase`, not sure but @YCjia you can run it locally to figure out what happened. ---

[jira] [Commented] (FLINK-9904) Allow users to control MaxDirectMemorySize

2018-07-20 Thread Himanshu Roongta (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16551020#comment-16551020 ] Himanshu Roongta commented on FLINK-9904: - I can fix this if people agree. > Allow users to

[jira] [Created] (FLINK-9904) Allow users to control MaxDirectMemorySize

2018-07-20 Thread Himanshu Roongta (JIRA)
Himanshu Roongta created FLINK-9904: --- Summary: Allow users to control MaxDirectMemorySize Key: FLINK-9904 URL: https://issues.apache.org/jira/browse/FLINK-9904 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550972#comment-16550972 ] ASF GitHub Bot commented on FLINK-8981: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #6377: [FLINK-8981] Add end-to-end test for running on YARN with...

2018-07-20 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/6377 I also ran the new version on `flink-ci`: https://travis-ci.org/aljoscha/flink-ci/builds/406269018 ---

[jira] [Commented] (FLINK-9849) Upgrade hbase version to 2.0.1 for hbase connector

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550960#comment-16550960 ] ASF GitHub Bot commented on FLINK-9849: --- Github user tedyu commented on the issue:

[GitHub] flink issue #6365: [FLINK-9849] [hbase] Hbase upgrade to 2.0.1

2018-07-20 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/6365 That would be ideal - a new connector for hbase 2.x considering that: hbase 1.x is stable hbase 2.y is newly released. ---

[GitHub] flink issue #6378: [FLINK-9236] [pom] upgrade the version of apache parent p...

2018-07-20 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/6378 No particular reason - considering the date when JIRA was first logged :-) ---

[jira] [Commented] (FLINK-9236) Use Apache Parent POM 19

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550958#comment-16550958 ] ASF GitHub Bot commented on FLINK-9236: --- Github user tedyu commented on the issue:

[jira] [Commented] (FLINK-9849) Upgrade hbase version to 2.0.1 for hbase connector

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550957#comment-16550957 ] ASF GitHub Bot commented on FLINK-9849: --- Github user greghogan commented on the issue:

[GitHub] flink issue #6365: [FLINK-9849] [hbase] Hbase upgrade to 2.0.1

2018-07-20 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/6365 Should this be a separate connector for HBase 2.x where we would also keep a connector for HBase 1.x? ---

[jira] [Commented] (FLINK-9236) Use Apache Parent POM 19

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550940#comment-16550940 ] ASF GitHub Bot commented on FLINK-9236: --- Github user greghogan commented on the issue:

[GitHub] flink issue #6378: [FLINK-9236] [pom] upgrade the version of apache parent p...

2018-07-20 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/6378 Any reason not to use version 20 or are we just being conservative? ---

[jira] [Commented] (FLINK-9236) Use Apache Parent POM 19

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550934#comment-16550934 ] ASF GitHub Bot commented on FLINK-9236: --- Github user tedyu commented on the issue:

[GitHub] flink issue #6378: [FLINK-9236] [pom] upgrade the version of apache parent p...

2018-07-20 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/6378 lgtm Pending QA bot ---

[jira] [Commented] (FLINK-9637) Add public user documentation for TTL feature

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550922#comment-16550922 ] ASF GitHub Bot commented on FLINK-9637: --- GitHub user azagrebin opened a pull request:

[jira] [Updated] (FLINK-9637) Add public user documentation for TTL feature

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9637: -- Labels: pull-request-available (was: ) > Add public user documentation for TTL feature >

[GitHub] flink pull request #6379: [FLINK-9637] Add public user documentation for sta...

2018-07-20 Thread azagrebin
GitHub user azagrebin opened a pull request: https://github.com/apache/flink/pull/6379 [FLINK-9637] Add public user documentation for state TTL feature ## What is the purpose of the change Public user documentation for first iteration of state TTL feature ## Brief

[jira] [Commented] (FLINK-9813) Build xTableSource from Avro schemas

2018-07-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550884#comment-16550884 ] François Lacombe commented on FLINK-9813: - Hi [~twalthr] I've no problem to deal with

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550824#comment-16550824 ] ASF GitHub Bot commented on FLINK-8981: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #6377: [FLINK-8981] Add end-to-end test for running on YARN with...

2018-07-20 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/6377 @zentol I addressed most of your comments. I now added a test in there that verifies the job fails if we don't set a keytab. I'm not running with different Hadoop. It might work but I'm basically

[jira] [Closed] (FLINK-9902) Improve and refactor window checkpointing IT cases

2018-07-20 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9902. - Resolution: Implemented Merged in: master: d309e61 release-1.6: f19337a > Improve and refactor

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r204057806 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/docker-compose.yml --- @@ -0,0 +1,87 @@

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r204057939 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/docker-compose.yml --- @@ -0,0 +1,87 @@

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r204057245 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/bootstrap.sh --- @@ -0,0 +1,121 @@ +#!/bin/bash

[jira] [Assigned] (FLINK-9714) Support versioned joins with processing time

2018-07-20 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-9714: - Assignee: Piotr Nowojski > Support versioned joins with processing time >

[jira] [Commented] (FLINK-9902) Improve and refactor window checkpointing IT cases

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

[GitHub] flink pull request #6376: [FLINK-9902][tests] Improve and refactor window ch...

2018-07-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6376 ---

[GitHub] flink issue #6376: [FLINK-9902][tests] Improve and refactor window checkpoin...

2018-07-20 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/6376 Thanks for the fast review @aljoscha . Addressed the comment about the `while`-loop and will merge now. ---

[jira] [Commented] (FLINK-9902) Improve and refactor window checkpointing IT cases

2018-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550785#comment-16550785 ] ASF GitHub Bot commented on FLINK-9902: --- Github user StefanRRichter commented on the issue:

[jira] [Commented] (FLINK-9391) Support UNNEST in Table API

2018-07-20 Thread Alina Ipatina (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550781#comment-16550781 ] Alina Ipatina commented on FLINK-9391: -- Hello [~twalthr], I would like to work on this issue. Could

[jira] [Closed] (FLINK-5611) Add QueryableStateException type

2018-07-20 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-5611. - Resolution: Won't Fix > Add QueryableStateException type > > >

[jira] [Commented] (FLINK-5611) Add QueryableStateException type

2018-07-20 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550772#comment-16550772 ] Kostas Kloudas commented on FLINK-5611: --- Hi [~klion26]. Probably not! I will close it. Thanks for

[jira] [Commented] (FLINK-5611) Add QueryableStateException type

2018-07-20 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550767#comment-16550767 ] Congxian Qiu commented on FLINK-5611: - Hi, [~kkl0u] is this issue still needed? I could take over it,

[jira] [Commented] (FLINK-9236) Use Apache Parent POM 19

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

[GitHub] flink issue #6378: [FLINK-9236] [pom] upgrade the version of apache parent p...

2018-07-20 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/6378 @YCjia The travis test failed. Could you take a look on what is happening ? ---

[GitHub] flink pull request #6372: [Flink 9353] Tests running per job standalone clus...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6372#discussion_r204022195 --- Diff: flink-end-to-end-tests/run-pre-commit-tests.sh --- @@ -51,6 +51,7 @@ run_test "Shaded Hadoop S3A end-to-end test"

[GitHub] flink pull request #6372: [Flink 9353] Tests running per job standalone clus...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6372#discussion_r204021806 --- Diff: flink-end-to-end-tests/run-pre-commit-tests.sh --- @@ -51,6 +51,7 @@ run_test "Shaded Hadoop S3A end-to-end test"

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r204020995 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/bootstrap.sh --- @@ -0,0 +1,121 @@ +#!/bin/bash

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r204020749 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/README.md --- @@ -0,0 +1,118 @@ +# Apache Hadoop Docker image with Kerberos

[jira] [Comment Edited] (FLINK-9813) Build xTableSource from Avro schemas

2018-07-20 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550695#comment-16550695 ] Timo Walther edited comment on FLINK-9813 at 7/20/18 11:52 AM: --- Hi

[jira] [Commented] (FLINK-9813) Build xTableSource from Avro schemas

2018-07-20 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550695#comment-16550695 ] Timo Walther commented on FLINK-9813: - Hi François, the last and the upcoming Flink version 1.6 have

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r204019505 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/Dockerfile --- @@ -0,0 +1,159 @@

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r204018916 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/Dockerfile --- @@ -0,0 +1,159 @@

[GitHub] flink pull request #6372: [Flink 9353] Tests running per job standalone clus...

2018-07-20 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6372#discussion_r204018623 --- Diff: flink-end-to-end-tests/run-pre-commit-tests.sh --- @@ -51,6 +51,7 @@ run_test "Shaded Hadoop S3A end-to-end test"

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r204017957 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/Dockerfile --- @@ -0,0 +1,159 @@

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r204017611 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/Dockerfile --- @@ -0,0 +1,159 @@

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r204017355 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/Dockerfile --- @@ -0,0 +1,159 @@

[jira] [Commented] (FLINK-9236) Use Apache Parent POM 19

2018-07-20 Thread jiayichao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550638#comment-16550638 ] jiayichao commented on FLINK-9236: -- [~yuzhih...@gmail.com]  Are you available to review my code? > Use

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r203982453 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/docker-compose.yml --- @@ -0,0 +1,87 @@

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r203983391 --- Diff: flink-end-to-end-tests/test-scripts/test_yarn_kerberos_docker.sh --- @@ -0,0 +1,104 @@ +#!/usr/bin/env bash

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r203981196 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/Dockerfile --- @@ -0,0 +1,159 @@

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r203998139 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/Dockerfile --- @@ -0,0 +1,159 @@

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[jira] [Commented] (FLINK-8981) Add end-to-end test for running on YARN with Kerberos

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

[GitHub] flink pull request #6377: [FLINK-8981] Add end-to-end test for running on YA...

2018-07-20 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/6377#discussion_r203997764 --- Diff: flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/bootstrap.sh --- @@ -0,0 +1,121 @@ +#!/bin/bash

[jira] [Commented] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

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

[GitHub] flink pull request #6375: [FLINK-9609] [connectors] Add bucket ready mechani...

2018-07-20 Thread zhangminglei
Github user zhangminglei commented on a diff in the pull request: https://github.com/apache/flink/pull/6375#discussion_r203997376 --- Diff: flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java --- @@

  1   2   >