[jira] [Commented] (FLINK-9885) End-to-end test: Elasticsearch 6.x connector

[ https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564773#comment-16564773 ] ASF GitHub Bot commented on FLINK-9885: --- tzulitai commented on a change in pull request #6391:

[GitHub] tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x

tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x URL: https://github.com/apache/flink/pull/6391#discussion_r206761263 ## File path: docs/dev/connectors/elasticsearch.md ## @@ -198,10 +198,6 @@ List httpHost = new

[jira] [Commented] (FLINK-9885) End-to-end test: Elasticsearch 6.x connector

[ https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564768#comment-16564768 ] ASF GitHub Bot commented on FLINK-9885: --- tzulitai commented on a change in pull request #6391:

[GitHub] tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x

tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x URL: https://github.com/apache/flink/pull/6391#discussion_r206760736 ## File path:

[jira] [Commented] (FLINK-9885) End-to-end test: Elasticsearch 6.x connector

[ https://issues.apache.org/jira/browse/FLINK-9885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564765#comment-16564765 ] ASF GitHub Bot commented on FLINK-9885: --- tzulitai commented on a change in pull request #6391:

[GitHub] tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x

tzulitai commented on a change in pull request #6391: [FLINK-9885] [FLINK-8101] Finalize Elasticsearch 6.x URL: https://github.com/apache/flink/pull/6391#discussion_r206760543 ## File path:

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564761#comment-16564761 ] ASF GitHub Bot commented on FLINK-7205: --- buptljy commented on a change in pull request #6381:

[GitHub] buptljy commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

buptljy commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#discussion_r206759487 ## File path: docs/dev/table/tableApi.md ## @@ -2311,6 +2311,17 @@ randInteger(seed

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564753#comment-16564753 ] Zhenqiu Huang commented on FLINK-7243: -- [~najman] I am adding some ITTest tonight. Will create the

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564742#comment-16564742 ] ASF GitHub Bot commented on FLINK-7205: --- yanghua commented on a change in pull request #6381:

[GitHub] yanghua commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

yanghua commented on a change in pull request #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#discussion_r206756114 ## File path: docs/dev/table/tableApi.md ## @@ -2311,6 +2311,17 @@ randInteger(seed

[jira] [Comment Edited] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564741#comment-16564741 ] Kostas Kloudas edited comment on FLINK-10005 at 8/1/18 5:03 AM: Is it

[jira] [Commented] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564741#comment-16564741 ] Kostas Kloudas commented on FLINK-10005: Is it that the

[jira] [Commented] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564738#comment-16564738 ] Kostas Kloudas commented on FLINK-10005: [~Zentol] Do you have an example of that? >

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564735#comment-16564735 ] ASF GitHub Bot commented on FLINK-7205: --- buptljy commented on issue #6381: [FLINK-7205] [table] Add

[GitHub] buptljy commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

buptljy commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#issuecomment-409449274 @yanghua fix. This is an automated message from the Apache

[jira] [Commented] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

[ https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564727#comment-16564727 ] ASF GitHub Bot commented on FLINK-10008: Xpray opened a new pull request #6465:

[jira] [Updated] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

[ https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10008: --- Labels: pull-request-available (was: ) > Improve the LOG function in Table to support

[GitHub] Xpray opened a new pull request #6465: [FLINK-10008][TableAPI & SQL]Improve the LOG function in Table to support bases less than 1

Xpray opened a new pull request #6465: [FLINK-10008][TableAPI & SQL]Improve the LOG function in Table to support bases less than 1 URL: https://github.com/apache/flink/pull/6465 ## What is the purpose of the change Improve the LOG function in Table to support bases less than 1

[jira] [Created] (FLINK-10012) Support setStreamTimeCharacteristic for Python API

vinoyang created FLINK-10012: Summary: Support setStreamTimeCharacteristic for Python API Key: FLINK-10012 URL: https://issues.apache.org/jira/browse/FLINK-10012 Project: Flink Issue Type:

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564659#comment-16564659 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on a change in pull request #6432:

[GitHub] yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r206741741 ## File path:

[jira] [Commented] (FLINK-10000) There's a mistake in the comments of CoGroupedStreams.java

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564626#comment-16564626 ] ASF GitHub Bot commented on FLINK-1: Clark commented on issue #6463:

[GitHub] Clarkkkkk commented on issue #6463: [FLINK-10000][streaming]Fix the example of CoGroupedStreams

Clark commented on issue #6463: [FLINK-1][streaming]Fix the example of CoGroupedStreams URL: https://github.com/apache/flink/pull/6463#issuecomment-409424518 It's just kind of misleading, I was tried to correlate the keyselector with the input stream, which didn't mean two

[jira] [Assigned] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

[ https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li reassigned FLINK-10008: -- Assignee: Ruidong Li > Improve the LOG function in Table to support bases less than 1 >

[jira] [Assigned] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

[ https://issues.apache.org/jira/browse/FLINK-10009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruidong Li reassigned FLINK-10009: -- Assignee: Ruidong Li > Fix the casting problem for function TIMESTAMPADD in Table >

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564573#comment-16564573 ] Elias Levy commented on FLINK-10011: [~trohrm...@apache.org] what do you think? > Old job

[jira] [Comment Edited] (FLINK-10011) Old job resurrected during HA failover

[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564569#comment-16564569 ] Elias Levy edited comment on FLINK-10011 at 8/1/18 12:48 AM: - It appears

[jira] [Commented] (FLINK-10011) Old job resurrected during HA failover

[ https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564569#comment-16564569 ] Elias Levy commented on FLINK-10011: It appears that it may not be necessary to replace the

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564503#comment-16564503 ] ASF GitHub Bot commented on FLINK-9970: --- suez1224 commented on a change in pull request #6432:

[GitHub] suez1224 commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

suez1224 commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r206716042 ## File path:

[jira] [Created] (FLINK-10011) Old job resurrected during HA failover

Elias Levy created FLINK-10011: -- Summary: Old job resurrected during HA failover Key: FLINK-10011 URL: https://issues.apache.org/jira/browse/FLINK-10011 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9962) allow users to specify TimeZone in DateTimeBucketer

[ https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564337#comment-16564337 ] Bowen Li commented on FLINK-9962: - [~fhueske] Sounds good Besides, after reading code, it also seems to

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564307#comment-16564307 ] ASF GitHub Bot commented on FLINK-9936: --- GJL opened a new pull request #6464: [FLINK-9936][mesos]

[GitHub] GJL opened a new pull request #6464: [FLINK-9936][mesos] WIP

GJL opened a new pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464 WIP cc: @tillrohrmann This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-9833) End-to-end test: SQL Client with unified source/sink/format

[ https://issues.apache.org/jira/browse/FLINK-9833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564150#comment-16564150 ] ASF GitHub Bot commented on FLINK-9833: --- zentol commented on a change in pull request #6422:

[GitHub] zentol commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format

zentol commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format URL: https://github.com/apache/flink/pull/6422#discussion_r206637758 ## File path: flink-end-to-end-tests/test-scripts/test_sql_client.sh

[jira] [Closed] (FLINK-9986) Remove unnecessary information from .version.properties file

[ https://issues.apache.org/jira/browse/FLINK-9986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9986. --- Resolution: Fixed Fix Version/s: 1.5.3 master:

[jira] [Commented] (FLINK-9986) Remove unnecessary information from .version.properties file

[ https://issues.apache.org/jira/browse/FLINK-9986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564122#comment-16564122 ] ASF GitHub Bot commented on FLINK-9986: --- zentol closed pull request #6443: [FLINK-9986][build]

[GitHub] zentol closed pull request #6443: [FLINK-9986][build] Only include commit info in .version.properties file

zentol closed pull request #6443: [FLINK-9986][build] Only include commit info in .version.properties file URL: https://github.com/apache/flink/pull/6443 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Created] (FLINK-10010) Deprecate unused BaseAlignedWindowAssigner related components

Rong Rong created FLINK-10010: - Summary: Deprecate unused BaseAlignedWindowAssigner related components Key: FLINK-10010 URL: https://issues.apache.org/jira/browse/FLINK-10010 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-9905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563901#comment-16563901 ] Gregory Fee commented on FLINK-9905: Thanks, Aljoscha! Yes, since I moved around the synchronization

[jira] [Updated] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

[ https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-10008: Description: Currently, the {{LOG}} function in SQL/Table API restricts the base to be greater

[jira] [Created] (FLINK-10009) Fix the casting problem for function TIMESTAMPADD in Table

Xingcan Cui created FLINK-10009: --- Summary: Fix the casting problem for function TIMESTAMPADD in Table Key: FLINK-10009 URL: https://issues.apache.org/jira/browse/FLINK-10009 Project: Flink

[jira] [Created] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

Xingcan Cui created FLINK-10008: --- Summary: Improve the LOG function in Table to support bases less than 1 Key: FLINK-10008 URL: https://issues.apache.org/jira/browse/FLINK-10008 Project: Flink

[jira] [Comment Edited] (FLINK-10000) There's a mistake in the comments of CoGroupedStreams.java

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563827#comment-16563827 ] Hequn Cheng edited comment on FLINK-1 at 7/31/18 3:21 PM: -- Coool,

[jira] [Commented] (FLINK-10000) There's a mistake in the comments of CoGroupedStreams.java

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563827#comment-16563827 ] Hequn Cheng commented on FLINK-1: - Coool, 1. Thanks for [~dangdangdang]. One big step

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563825#comment-16563825 ] ASF GitHub Bot commented on FLINK-7205: --- yanghua commented on issue #6381: [FLINK-7205] [table] Add

[GitHub] yanghua commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

yanghua commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#issuecomment-409259529 @buptljy conflicts, please update and rebase this PR~ This

[jira] [Commented] (FLINK-9664) FlinkML Quickstart Loading Data section example doesn't work as described

[ https://issues.apache.org/jira/browse/FLINK-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563816#comment-16563816 ] ASF GitHub Bot commented on FLINK-9664: --- yanghua commented on issue #6425: [FLINK-9664][Doc] fixing

[GitHub] yanghua commented on issue #6425: [FLINK-9664][Doc] fixing documentation in ML quick start

yanghua commented on issue #6425: [FLINK-9664][Doc] fixing documentation in ML quick start URL: https://github.com/apache/flink/pull/6425#issuecomment-409258317 +1 This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-9975) Netty dependency of Hadoop >= 2.7 is not relocated

[ https://issues.apache.org/jira/browse/FLINK-9975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563811#comment-16563811 ] ASF GitHub Bot commented on FLINK-9975: --- yanghua commented on issue #6461: [FLINK-9975][hadoop]

[GitHub] yanghua commented on issue #6461: [FLINK-9975][hadoop] also shade Hadoop's io.netty dependency

yanghua commented on issue #6461: [FLINK-9975][hadoop] also shade Hadoop's io.netty dependency URL: https://github.com/apache/flink/pull/6461#issuecomment-409256918 +1 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563807#comment-16563807 ] Fabian Hueske commented on FLINK-5315: -- Good points! I agree. Let's go with {code}

[GitHub] xccui commented on issue #6003: [FLINK-9289][Dataset] Parallelism of generated operators should have max parallelism of input

xccui commented on issue #6003: [FLINK-9289][Dataset] Parallelism of generated operators should have max parallelism of input URL: https://github.com/apache/flink/pull/6003#issuecomment-409256314 Hi @fhueske, I wonder if you could take a look at this PR when it's convenient for you.

[jira] [Commented] (FLINK-9289) Parallelism of generated operators should have max parallism of input

[ https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563806#comment-16563806 ] ASF GitHub Bot commented on FLINK-9289: --- xccui commented on issue #6003: [FLINK-9289][Dataset]

[jira] [Assigned] (FLINK-9948) JSON format does not convert timestamps correctly

[ https://issues.apache.org/jira/browse/FLINK-9948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-9948: - Assignee: (was: Renjie Liu) > JSON format does not convert timestamps correctly >

[jira] [Assigned] (FLINK-9948) JSON format does not convert timestamps correctly

[ https://issues.apache.org/jira/browse/FLINK-9948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-9948: - Assignee: Renjie Liu > JSON format does not convert timestamps correctly >

[jira] [Assigned] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-9740: - Assignee: Renjie Liu > Support group windows over intervals of months >

[jira] [Assigned] (FLINK-8865) Add CLI query code completion in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Renjie Liu reassigned FLINK-8865: - Assignee: (was: Renjie Liu) > Add CLI query code completion in SQL Client >

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563766#comment-16563766 ] Rong Rong commented on FLINK-5315: -- Actually I agree with [~hequn8128] that these are two kinds of

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563758#comment-16563758 ] Hequn Cheng commented on FLINK-5315: Hi [~fhueske] hmm, I think these are two kinds of distinct. One

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563752#comment-16563752 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull request #6456:

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563753#comment-16563753 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull request #6456:

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563751#comment-16563751 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull request #6456:

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563749#comment-16563749 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull request #6456:

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563750#comment-16563750 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull request #6456:

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563748#comment-16563748 ] ASF GitHub Bot commented on FLINK-9947: --- fhueske commented on a change in pull request #6456:

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206546769 ## File path: docs/dev/table/sourceSinks.md ## @@ -1,5 +1,5 @@ --- -title: "Table

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206536297 ## File path: docs/dev/table/connect.md ## @@ -0,0 +1,1033 @@ +--- +title: "Connect

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206546032 ## File path: docs/dev/table/connect.md ## @@ -0,0 +1,1033 @@ +--- +title: "Connect

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206535155 ## File path: docs/dev/table/connect.md ## @@ -0,0 +1,1033 @@ +--- +title: "Connect

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206534039 ## File path: docs/dev/table/connect.md ## @@ -0,0 +1,1033 @@ +--- +title: "Connect

[GitHub] fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

fhueske commented on a change in pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456#discussion_r206540657 ## File path: docs/dev/table/connect.md ## @@ -0,0 +1,1033 @@ +--- +title: "Connect

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563719#comment-16563719 ] ASF GitHub Bot commented on FLINK-9936: --- liurenjie1024 commented on issue #6451: [FLINK-9936]

[GitHub] liurenjie1024 commented on issue #6451: [FLINK-9936] Resource manager connect to mesos after leadership granted. .

liurenjie1024 commented on issue #6451: [FLINK-9936] Resource manager connect to mesos after leadership granted. . URL: https://github.com/apache/flink/pull/6451#issuecomment-409232804 @GJL Thanks for the review. It's ok for you to take over it.

[jira] [Closed] (FLINK-9950) Handle migration to Gitbox

[ https://issues.apache.org/jira/browse/FLINK-9950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9950. --- Resolution: Fixed Core issues appear to be resolved. > Handle migration to Gitbox >

[jira] [Commented] (FLINK-9981) Tune performance of RocksDB implementation

[ https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563688#comment-16563688 ] ASF GitHub Bot commented on FLINK-9981: --- azagrebin commented on a change in pull request #6438:

[jira] [Commented] (FLINK-9981) Tune performance of RocksDB implementation

[ https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563686#comment-16563686 ] ASF GitHub Bot commented on FLINK-9981: --- azagrebin commented on a change in pull request #6438:

[jira] [Commented] (FLINK-9981) Tune performance of RocksDB implementation

[ https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563687#comment-16563687 ] ASF GitHub Bot commented on FLINK-9981: --- azagrebin commented on a change in pull request #6438:

[GitHub] azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune performance of RocksDB implementation

azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune performance of RocksDB implementation URL: https://github.com/apache/flink/pull/6438#discussion_r206506427 ## File path:

[GitHub] azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune performance of RocksDB implementation

azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune performance of RocksDB implementation URL: https://github.com/apache/flink/pull/6438#discussion_r206467281 ## File path:

[GitHub] azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune performance of RocksDB implementation

azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune performance of RocksDB implementation URL: https://github.com/apache/flink/pull/6438#discussion_r206523056 ## File path:

[jira] [Commented] (FLINK-10007) Security vulnerability in website build infrastructure

[ https://issues.apache.org/jira/browse/FLINK-10007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563663#comment-16563663 ] Fabian Hueske commented on FLINK-10007: --- This is the same issue as FLINK-8308 which was solved for

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563658#comment-16563658 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request #6451:

[GitHub] GJL commented on a change in pull request #6451: [FLINK-9936] Resource manager connect to mesos after leadership granted. .

GJL commented on a change in pull request #6451: [FLINK-9936] Resource manager connect to mesos after leadership granted. . URL: https://github.com/apache/flink/pull/6451#discussion_r206522513 ## File path:

[jira] [Commented] (FLINK-9833) End-to-end test: SQL Client with unified source/sink/format

[ https://issues.apache.org/jira/browse/FLINK-9833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563656#comment-16563656 ] ASF GitHub Bot commented on FLINK-9833: --- twalthr commented on a change in pull request #6422:

[jira] [Created] (FLINK-10007) Security vulnerability in website build infrastructure

Fabian Hueske created FLINK-10007: - Summary: Security vulnerability in website build infrastructure Key: FLINK-10007 URL: https://issues.apache.org/jira/browse/FLINK-10007 Project: Flink

[GitHub] twalthr commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format

twalthr commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format URL: https://github.com/apache/flink/pull/6422#discussion_r206524360 ## File path: flink-end-to-end-tests/test-scripts/test_sql_client.sh

[jira] [Commented] (FLINK-9833) End-to-end test: SQL Client with unified source/sink/format

[ https://issues.apache.org/jira/browse/FLINK-9833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563653#comment-16563653 ] ASF GitHub Bot commented on FLINK-9833: --- twalthr commented on a change in pull request #6422:

[jira] [Commented] (FLINK-9833) End-to-end test: SQL Client with unified source/sink/format

[ https://issues.apache.org/jira/browse/FLINK-9833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563652#comment-16563652 ] ASF GitHub Bot commented on FLINK-9833: --- twalthr commented on a change in pull request #6422:

[GitHub] twalthr commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format

twalthr commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format URL: https://github.com/apache/flink/pull/6422#discussion_r206523127 ## File path: flink-end-to-end-tests/test-scripts/test_sql_client.sh

[jira] [Assigned] (FLINK-9936) Mesos resource manager unable to connect to master after failover

[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-9936: --- Assignee: Gary Yao (was: Renjie Liu) > Mesos resource manager unable to connect to master after

[GitHub] twalthr commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format

twalthr commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format URL: https://github.com/apache/flink/pull/6422#discussion_r206522883 ## File path: flink-end-to-end-tests/test-scripts/test_sql_client.sh

[jira] [Assigned] (FLINK-9982) NPE in EnumValueSerializer#copy

[ https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei reassigned FLINK-9982: --- Assignee: dalongliu (was: zhangminglei) > NPE in EnumValueSerializer#copy >

[jira] [Commented] (FLINK-9982) NPE in EnumValueSerializer#copy

[ https://issues.apache.org/jira/browse/FLINK-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563648#comment-16563648 ] zhangminglei commented on FLINK-9982: - [~lsy] Could you tell [~Zentol] what the enum field in your

[jira] [Updated] (FLINK-6810) Add Some built-in Scalar Function supported

[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-6810: - Description: In this JIRA, will create some sub-task for add specific scalar function, such as

[jira] [Commented] (FLINK-6810) Add Some built-in Scalar Function supported

[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563646#comment-16563646 ] Fabian Hueske commented on FLINK-6810: -- Hi [~hequn8128], thanks for adding contribution

[jira] [Comment Edited] (FLINK-10005) StreamingFileSink ignores checkpoint/processing time rolling policies

[ https://issues.apache.org/jira/browse/FLINK-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563643#comment-16563643 ] Chesnay Schepler edited comment on FLINK-10005 at 7/31/18 1:13 PM: ---

[GitHub] twalthr commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format

twalthr commented on a change in pull request #6422: [FLINK-9833] [e2e] Add a SQL Client end-to-end test with unified source/sink/format URL: https://github.com/apache/flink/pull/6422#discussion_r206521137 ## File path: flink-end-to-end-tests/flink-sql-client-test/pom.xml

  1   2   3   >