[GitHub] [flink] yanghua opened a new pull request #7960: [FLINK-9854] Allow passing multi-line input to SQL Client CLI

2019-03-12 Thread GitBox
yanghua opened a new pull request #7960: [FLINK-9854] Allow passing multi-line input to SQL Client CLI URL: https://github.com/apache/flink/pull/7960 ## What is the purpose of the change *This pull request support passing multi-line input to SQL Client CLI* ## Brief change

[jira] [Created] (FLINK-11882) Introduce BytesHashMap to batch hash agg

2019-03-12 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11882: Summary: Introduce BytesHashMap to batch hash agg Key: FLINK-11882 URL: https://issues.apache.org/jira/browse/FLINK-11882 Project: Flink Issue Type: New

[GitHub] [flink] JingsongLi commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-12 Thread GitBox
JingsongLi commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r264556661 ## File path:

[GitHub] [flink] yanghua commented on issue #7960: [FLINK-9854][table] Allow passing multi-line input to SQL Client CLI

2019-03-12 Thread GitBox
yanghua commented on issue #7960: [FLINK-9854][table] Allow passing multi-line input to SQL Client CLI URL: https://github.com/apache/flink/pull/7960#issuecomment-471899887 > Hi @yanghua, could you extend the description with how does the piping multiline support actually works. Why only

[GitHub] [flink] flinkbot commented on issue #7962: [FLINK-11883] Harmonize the version of maven-shade-plugin

2019-03-12 Thread GitBox
flinkbot commented on issue #7962: [FLINK-11883] Harmonize the version of maven-shade-plugin URL: https://github.com/apache/flink/pull/7962#issuecomment-471904554 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] zhijiangW commented on issue #7730: [FLINK-11646][test] Remove legacy MockRecordWriter

2019-03-12 Thread GitBox
zhijiangW commented on issue #7730: [FLINK-11646][test] Remove legacy MockRecordWriter URL: https://github.com/apache/flink/pull/7730#issuecomment-471907125 @pnowojski , could you help review this? I would introduce the `RecordWriterBuilder` to avoid creating `RecordWriter` directly, so

[jira] [Updated] (FLINK-9854) Allow passing multi-line input to SQL Client CLI

2019-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9854: -- Labels: pull-request-available (was: ) > Allow passing multi-line input to SQL Client CLI >

[GitHub] [flink] flinkbot commented on issue #7960: [FLINK-9854] Allow passing multi-line input to SQL Client CLI

2019-03-12 Thread GitBox
flinkbot commented on issue #7960: [FLINK-9854] Allow passing multi-line input to SQL Client CLI URL: https://github.com/apache/flink/pull/7960#issuecomment-471871593 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] JingsongLi opened a new pull request #7961: [FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg

2019-03-12 Thread GitBox
JingsongLi opened a new pull request #7961: [FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg URL: https://github.com/apache/flink/pull/7961 ## What is the purpose of the change Introduce bytes based hash table. It can be used for performing aggregations

[jira] [Updated] (FLINK-11882) Introduce BytesHashMap to batch hash agg

2019-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11882: --- Labels: pull-request-available (was: ) > Introduce BytesHashMap to batch hash agg >

[GitHub] [flink] yanghua commented on issue #7960: [FLINK-9854][table] Allow passing multi-line input to SQL Client CLI

2019-03-12 Thread GitBox
yanghua commented on issue #7960: [FLINK-9854][table] Allow passing multi-line input to SQL Client CLI URL: https://github.com/apache/flink/pull/7960#issuecomment-471910241 @dawidwys Align the information, the issue currently only supports one SQL statement is split into multiple lines,

[jira] [Closed] (FLINK-11420) Serialization of case classes containing a Map[String, Any] sometimes throws ArrayIndexOutOfBoundsException

2019-03-12 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-11420. Resolution: Fixed Additional issue with {{CoGroupedStreams.UnionSerializer}} fixed in:

[jira] [Updated] (FLINK-11883) Harmonize the version of maven-shade-plugin

2019-03-12 Thread Fokko Driesprong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fokko Driesprong updated FLINK-11883: - Summary: Harmonize the version of maven-shade-plugin (was: Harmonize the versions of

[jira] [Updated] (FLINK-11883) Harmonize the version of maven-shade-plugin

2019-03-12 Thread Fokko Driesprong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fokko Driesprong updated FLINK-11883: - Affects Version/s: 1.7.2 > Harmonize the version of maven-shade-plugin >

[jira] [Updated] (FLINK-11883) Harmonize the version of maven-shade-plugin

2019-03-12 Thread Fokko Driesprong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fokko Driesprong updated FLINK-11883: - Component/s: Build System > Harmonize the version of maven-shade-plugin >

[GitHub] [flink] klion26 commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-12 Thread GitBox
klion26 commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r264533487 ## File path:

[GitHub] [flink] dawidwys commented on issue #7960: [FLINK-9854][table] Allow passing multi-line input to SQL Client CLI

2019-03-12 Thread GitBox
dawidwys commented on issue #7960: [FLINK-9854][table] Allow passing multi-line input to SQL Client CLI URL: https://github.com/apache/flink/pull/7960#issuecomment-471896256 Hi @yanghua, could you extend the description with how does the piping multiline support actually works. Why only

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

2019-03-12 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790352#comment-16790352 ] Dawid Wysakowicz commented on FLINK-11068: -- Hi [~hequn8128] thanks for working on this issue.

[GitHub] [flink] Fokko opened a new pull request #7962: [FLINK-11883] Harmonize the version of maven-shade-plugin

2019-03-12 Thread GitBox
Fokko opened a new pull request #7962: [FLINK-11883] Harmonize the version of maven-shade-plugin URL: https://github.com/apache/flink/pull/7962 ## What is the purpose of the change Currently we're using two version of the maven-shade-plugin which might lead to confusion/collisions.

[jira] [Updated] (FLINK-11883) Harmonize the version of maven-shade-plugin

2019-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11883: --- Labels: pull-request-available (was: ) > Harmonize the version of maven-shade-plugin >

[jira] [Created] (FLINK-11883) Harmonize the versions of the

2019-03-12 Thread Fokko Driesprong (JIRA)
Fokko Driesprong created FLINK-11883: Summary: Harmonize the versions of the Key: FLINK-11883 URL: https://issues.apache.org/jira/browse/FLINK-11883 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-11883) Harmonize the version of maven-shade-plugin

2019-03-12 Thread Fokko Driesprong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fokko Driesprong reassigned FLINK-11883: Assignee: Fokko Driesprong > Harmonize the version of maven-shade-plugin >

[GitHub] [flink] klion26 commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-12 Thread GitBox
klion26 commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r264567432 ## File path:

[jira] [Created] (FLINK-11884) Port Table to flink-api-java

2019-03-12 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-11884: Summary: Port Table to flink-api-java Key: FLINK-11884 URL: https://issues.apache.org/jira/browse/FLINK-11884 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-11068) Convert the API classes *Table, *Window to interfaces

2019-03-12 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790378#comment-16790378 ] Hequn Cheng commented on FLINK-11068: - [~dawidwys] Thanks for your valuable suggestions. I think you

[GitHub] [flink] flinkbot commented on issue #7961: [FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg

2019-03-12 Thread GitBox
flinkbot commented on issue #7961: [FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg URL: https://github.com/apache/flink/pull/7961#issuecomment-471895102 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] dawidwys commented on issue #7956: fix Environment.java catalogs lose

2019-03-12 Thread GitBox
dawidwys commented on issue #7956: fix Environment.java catalogs lose URL: https://github.com/apache/flink/pull/7956#issuecomment-471896714 Hi @ssyue , could you please improve the description of this PR? Also could you please edit the title of this PR to match our guidelines (included in

[GitHub] [flink] klion26 commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-12 Thread GitBox
klion26 commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r264568021 ## File path:

[GitHub] [flink] dawidwys commented on issue #7960: [FLINK-9854][table] Allow passing multi-line input to SQL Client CLI

2019-03-12 Thread GitBox
dawidwys commented on issue #7960: [FLINK-9854][table] Allow passing multi-line input to SQL Client CLI URL: https://github.com/apache/flink/pull/7960#issuecomment-471906653 Yes, I induced that from the tests. Then I think that's still a problem, cause afaik we require a sql statement to

[GitHub] [flink] JingsongLi commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-12 Thread GitBox
JingsongLi commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r264572260 ## File path:

[jira] [Commented] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-12 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791268#comment-16791268 ] Yu Li commented on FLINK-11892: --- +1, nice analysis on the root cause! I encountered the same issue on my

[jira] [Updated] (FLINK-11893) Update ecosystem page and add it to the navigation bar

2019-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11893: --- Labels: pull-request-available (was: ) > Update ecosystem page and add it to the

[jira] [Created] (FLINK-11895) Allow FileSystem Configs to be altered at Runtime

2019-03-12 Thread Luka Jurukovski (JIRA)
Luka Jurukovski created FLINK-11895: --- Summary: Allow FileSystem Configs to be altered at Runtime Key: FLINK-11895 URL: https://issues.apache.org/jira/browse/FLINK-11895 Project: Flink

[jira] [Commented] (FLINK-11894) AbstractRowSerializer.serializeToPages return type should be void

2019-03-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791273#comment-16791273 ] Kurt Young commented on FLINK-11894: maybe we should move this issue under 

[GitHub] [flink] KurtYoung commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-12 Thread GitBox
KurtYoung commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r264971399 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-12 Thread GitBox
KurtYoung commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r264971007 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-12 Thread GitBox
KurtYoung commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r264970786 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #7961: [FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg

2019-03-12 Thread GitBox
KurtYoung commented on a change in pull request #7961: [FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg URL: https://github.com/apache/flink/pull/7961#discussion_r264982223 ## File path:

[jira] [Updated] (FLINK-11896) Introduce stream physical nodes

2019-03-12 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-11896: --- Description: This issues aims to introduce flink stream physical RelNode, such as

[jira] [Updated] (FLINK-11896) Introduce stream physical nodes

2019-03-12 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-11896: --- Description: This issues aims to introduce flink stream physical RelNode, such as

[jira] [Commented] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-12 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791183#comment-16791183 ] sunjincheng commented on FLINK-11892: - Just now I try to use

[jira] [Created] (FLINK-11894) AbstractRowSerializer.serializeToPages return type should be void

2019-03-12 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11894: Summary: AbstractRowSerializer.serializeToPages return type should be void Key: FLINK-11894 URL: https://issues.apache.org/jira/browse/FLINK-11894 Project: Flink

[GitHub] [flink] klion26 commented on issue #7965: make JDBCOutputFormat ClassCastException more helpful

2019-03-12 Thread GitBox
klion26 commented on issue #7965: make JDBCOutputFormat ClassCastException more helpful URL: https://github.com/apache/flink/pull/7965#issuecomment-472238898 @FaxianZhao could you please edit the title of this PR to match our guidelines (included in the PR template)

[jira] [Commented] (FLINK-6131) Add side inputs for DataStream API

2019-03-12 Thread Ashish Pokharel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791175#comment-16791175 ] Ashish Pokharel commented on FLINK-6131: All, looping back again on this. This feature seems very

[GitHub] [flink] link3280 commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

2019-03-12 Thread GitBox
link3280 commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7895#discussion_r264971776 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/UtilsTest.java

[jira] [Commented] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-12 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791286#comment-16791286 ] sunjincheng commented on FLINK-11892: - Hi Thanks for your nice check [~carp84] ! Of course, I am

[jira] [Commented] (FLINK-11888) Refine document of how to run end-to-end tests

2019-03-12 Thread Yu Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791288#comment-16791288 ] Yu Li commented on FLINK-11888: --- [~sunjincheng121] has located the root cause of the port conflict issue

[jira] [Created] (FLINK-11896) Introduce stream physical nodes

2019-03-12 Thread godfrey he (JIRA)
godfrey he created FLINK-11896: -- Summary: Introduce stream physical nodes Key: FLINK-11896 URL: https://issues.apache.org/jira/browse/FLINK-11896 Project: Flink Issue Type: New Feature

[GitHub] [flink] godfreyhe opened a new pull request #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes

2019-03-12 Thread GitBox
godfreyhe opened a new pull request #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes URL: https://github.com/apache/flink/pull/7969 ## What is the purpose of the change *Introduce stream physical RelNode* ## Brief change log - *adds all

[jira] [Updated] (FLINK-11896) Introduce stream physical nodes

2019-03-12 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-11896: --- Description: This issues aims to introduce flink stream physical RelNode, such as

[jira] [Created] (FLINK-11891) Fix some script or test case bug in 1.8 RC

2019-03-12 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11891: --- Summary: Fix some script or test case bug in 1.8 RC Key: FLINK-11891 URL: https://issues.apache.org/jira/browse/FLINK-11891 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-12 Thread sunjincheng (JIRA)
sunjincheng created FLINK-11892: --- Summary: Port conflict problem when do the end-to-end nightly-tests. Key: FLINK-11892 URL: https://issues.apache.org/jira/browse/FLINK-11892 Project: Flink

[jira] [Updated] (FLINK-11892) Port conflict problem when do the end-to-end nightly-tests.

2019-03-12 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-11892: Description: When I do the end-to-end check according to

[jira] [Created] (FLINK-11893) Update ecosystem page and add it to the navigation bar

2019-03-12 Thread Jiangjie Qin (JIRA)
Jiangjie Qin created FLINK-11893: Summary: Update ecosystem page and add it to the navigation bar Key: FLINK-11893 URL: https://issues.apache.org/jira/browse/FLINK-11893 Project: Flink Issue

[jira] [Updated] (FLINK-11886) update the output of cluster management script in jobmanager_high_availability doc

2019-03-12 Thread chunpinghe (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11886: --- Attachment: ha_doc.png > update the output of cluster management script in >

[GitHub] [flink] becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-03-12 Thread GitBox
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r264622246 ## File path:

[GitHub] [flink] KurtYoung commented on issue #3511: [Flink-5734] code generation for normalizedkey sorter

2019-03-12 Thread GitBox
KurtYoung commented on issue #3511: [Flink-5734] code generation for normalizedkey sorter URL: https://github.com/apache/flink/pull/3511#issuecomment-471922611 As you may want to know, we have opened a PR to introduce code generated sorter, check out #7958 if you are interested. @ggevay

[jira] [Updated] (FLINK-11886) update the output of cluster management script in jobmanager_high_availability doc

2019-03-12 Thread chunpinghe (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11886: --- Attachment: ha_doc_updated.png > update the output of cluster management script in >

[jira] [Updated] (FLINK-11886) update the output of cluster management script in jobmanager_high_availability doc

2019-03-12 Thread chunpinghe (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chunpinghe updated FLINK-11886: --- Attachment: (was: jira_cluster.sh.png) > update the output of cluster management script in >

[GitHub] [flink] becketqin commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-03-12 Thread GitBox
becketqin commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-471952495 > Hello @rmetzger > > Let me address them point by point: > > > I

[GitHub] [flink] tweise commented on issue #7896: [FLINK-9007] [kinesis] [e2e] Add Kinesis end-to-end test

2019-03-12 Thread GitBox
tweise commented on issue #7896: [FLINK-9007] [kinesis] [e2e] Add Kinesis end-to-end test URL: https://github.com/apache/flink/pull/7896#issuecomment-471992102 @StefanRRichter could you approve the PR or let me know if anything else should be done here?

[GitHub] [flink] JingsongLi commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

2019-03-12 Thread GitBox
JingsongLi commented on a change in pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#discussion_r264587151 ## File path:

[GitHub] [flink] chummyhe89 opened a new pull request #7964: [FLINK-11886] [doc] update the output of start/stop_cluster.sh in job…

2019-03-12 Thread GitBox
chummyhe89 opened a new pull request #7964: [FLINK-11886] [doc] update the output of start/stop_cluster.sh in job… URL: https://github.com/apache/flink/pull/7964 ## What is the purpose of the change Update the output of the cluster management script in

[GitHub] [flink] becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-03-12 Thread GitBox
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r264624917 ## File path:

[GitHub] [flink] GJL commented on issue #7922: [FLINK-10756][runtime][tests] Wait for TM processes to shutdown

2019-03-12 Thread GitBox
GJL commented on issue #7922: [FLINK-10756][runtime][tests] Wait for TM processes to shutdown URL: https://github.com/apache/flink/pull/7922#issuecomment-471974410 @flinkbot approve all This is an automated message from the

[jira] [Updated] (FLINK-11881) Introduce code generated typed sort to blink table

2019-03-12 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-11881: - Description: Introduce SortCodeGenerator (CodeGen efficient computation and comparison of 

[GitHub] [flink] pnowojski commented on a change in pull request #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode

2019-03-12 Thread GitBox
pnowojski commented on a change in pull request #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r264634735 ## File path:

[jira] [Created] (FLINK-11887) Operator's Latency Metrics continues to increase

2019-03-12 Thread Suxing Lee (JIRA)
Suxing Lee created FLINK-11887: -- Summary: Operator's Latency Metrics continues to increase Key: FLINK-11887 URL: https://issues.apache.org/jira/browse/FLINK-11887 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11888) Refine document of how to run end-to-end tests

2019-03-12 Thread Yu Li (JIRA)
Yu Li created FLINK-11888: - Summary: Refine document of how to run end-to-end tests Key: FLINK-11888 URL: https://issues.apache.org/jira/browse/FLINK-11888 Project: Flink Issue Type: Improvement

[GitHub] [flink] becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-03-12 Thread GitBox
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r264614405 ## File path:

[GitHub] [flink] flinkbot commented on issue #7964: [FLINK-11886] [doc] update the output of start/stop_cluster.sh in job…

2019-03-12 Thread GitBox
flinkbot commented on issue #7964: [FLINK-11886] [doc] update the output of start/stop_cluster.sh in job… URL: https://github.com/apache/flink/pull/7964#issuecomment-471946845 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] leesf commented on issue #7940: [hotfix][docs] fix error in functions example

2019-03-12 Thread GitBox
leesf commented on issue #7940: [hotfix][docs] fix error in functions example URL: https://github.com/apache/flink/pull/7940#issuecomment-471980702 cc @twalthr @zentol This is an automated message from the Apache Git

[jira] [Updated] (FLINK-11692) Add Proxy for DataDog Metric Reporter

2019-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11692: --- Labels: pull-request-available (was: ) > Add Proxy for DataDog Metric Reporter >

[GitHub] [flink] scott-mitchell opened a new pull request #7968: [FLINK-11692] [Datadog Reporter] added proxy to datadog reporter

2019-03-12 Thread GitBox
scott-mitchell opened a new pull request #7968: [FLINK-11692] [Datadog Reporter] added proxy to datadog reporter URL: https://github.com/apache/flink/pull/7968 ## What is the purpose of the change This pull request adds a configurable proxy to the Datadog metric reporter.

[GitHub] [flink] flinkbot commented on issue #7968: [FLINK-11692] [Datadog Reporter] added proxy to datadog reporter

2019-03-12 Thread GitBox
flinkbot commented on issue #7968: [FLINK-11692] [Datadog Reporter] added proxy to datadog reporter URL: https://github.com/apache/flink/pull/7968#issuecomment-472096718 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-03-12 Thread GitBox
Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r264810803 ## File path:

[jira] [Created] (FLINK-11885) Introduce RecordWriterBuilder for creating RecordWriter instance

2019-03-12 Thread zhijiang (JIRA)
zhijiang created FLINK-11885: Summary: Introduce RecordWriterBuilder for creating RecordWriter instance Key: FLINK-11885 URL: https://issues.apache.org/jira/browse/FLINK-11885 Project: Flink

[GitHub] [flink] zhijiangW commented on issue #7963: [FLINK-11885][network] Introduce RecordWriterBuilder for creating RecordWriter instance

2019-03-12 Thread GitBox
zhijiangW commented on issue #7963: [FLINK-11885][network] Introduce RecordWriterBuilder for creating RecordWriter instance URL: https://github.com/apache/flink/pull/7963#issuecomment-471935488 @pnowojski , this is the preparation work for #7713

[jira] [Closed] (FLINK-11856) Introduce BinaryHashTable to batch table runtime

2019-03-12 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11856. -- Resolution: Implemented Fix Version/s: 1.9.0 fixed in 5968206f843a58e10e3db58cde3407bb3608d085

[GitHub] [flink] KurtYoung merged pull request #7949: [FLINK-11856][table-runtime-blink] Introduce BinaryHashTable to batch table runtime

2019-03-12 Thread GitBox
KurtYoung merged pull request #7949: [FLINK-11856][table-runtime-blink] Introduce BinaryHashTable to batch table runtime URL: https://github.com/apache/flink/pull/7949 This is an automated message from the Apache Git

[jira] [Updated] (FLINK-11885) Introduce RecordWriterBuilder for creating RecordWriter instance

2019-03-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11885: --- Labels: pull-request-available (was: ) > Introduce RecordWriterBuilder for creating

[GitHub] [flink] pnowojski commented on a change in pull request #7963: [FLINK-11885][network] Introduce RecordWriterBuilder for creating RecordWriter instance

2019-03-12 Thread GitBox
pnowojski commented on a change in pull request #7963: [FLINK-11885][network] Introduce RecordWriterBuilder for creating RecordWriter instance URL: https://github.com/apache/flink/pull/7963#discussion_r264631813 ## File path:

[GitHub] [flink] becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-03-12 Thread GitBox
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r264638629 ## File path:

[GitHub] [flink] flinkbot commented on issue #7965: make JDBCOutputFormat ClassCastException more helpful

2019-03-12 Thread GitBox
flinkbot commented on issue #7965: make JDBCOutputFormat ClassCastException more helpful URL: https://github.com/apache/flink/pull/7965#issuecomment-471968284 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

2019-03-12 Thread GitBox
becketqin commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#discussion_r264635101 ## File path:

[GitHub] [flink] GJL commented on issue #7922: [FLINK-10756][runtime][tests] Wait for TM processes to shutdown

2019-03-12 Thread GitBox
GJL commented on issue #7922: [FLINK-10756][runtime][tests] Wait for TM processes to shutdown URL: https://github.com/apache/flink/pull/7922#issuecomment-471968212 @flinkbot approve description This is an automated message

[GitHub] [flink] FaxianZhao opened a new pull request #7965: make JDBCOutputFormat ClassCastException more helpful

2019-03-12 Thread GitBox
FaxianZhao opened a new pull request #7965: make JDBCOutputFormat ClassCastException more helpful URL: https://github.com/apache/flink/pull/7965 ## What is the purpose of the change This PR makes JDBCOutputFormat's ClassCastException more readable. Current exception make me confused

[GitHub] [flink] dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes

2019-03-12 Thread GitBox
dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes URL: https://github.com/apache/flink/pull/7967#discussion_r264751565 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes

2019-03-12 Thread GitBox
dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes URL: https://github.com/apache/flink/pull/7967#discussion_r264703739 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes

2019-03-12 Thread GitBox
dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes URL: https://github.com/apache/flink/pull/7967#discussion_r264710350 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes

2019-03-12 Thread GitBox
dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes URL: https://github.com/apache/flink/pull/7967#discussion_r264742946 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes

2019-03-12 Thread GitBox
dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes URL: https://github.com/apache/flink/pull/7967#discussion_r264703419 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes

2019-03-12 Thread GitBox
dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes URL: https://github.com/apache/flink/pull/7967#discussion_r264723067 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes

2019-03-12 Thread GitBox
dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes URL: https://github.com/apache/flink/pull/7967#discussion_r264711540 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes

2019-03-12 Thread GitBox
dawidwys commented on a change in pull request #7967: [FLINK-11449][table] Uncouple the Expression class from RexNodes URL: https://github.com/apache/flink/pull/7967#discussion_r264742116 ## File path:

[GitHub] [flink] zhijiangW commented on issue #7963: [FLINK-11885][network] Introduce RecordWriterBuilder for creating RecordWriter instance

2019-03-12 Thread GitBox
zhijiangW commented on issue #7963: [FLINK-11885][network] Introduce RecordWriterBuilder for creating RecordWriter instance URL: https://github.com/apache/flink/pull/7963#issuecomment-472059561 @pnowojski , I have updated the codes for only fixing `StreamTask` class compared with first

[jira] [Created] (FLINK-11890) Replace Table API string-based expressions by a Java DSL

2019-03-12 Thread Timo Walther (JIRA)
Timo Walther created FLINK-11890: Summary: Replace Table API string-based expressions by a Java DSL Key: FLINK-11890 URL: https://issues.apache.org/jira/browse/FLINK-11890 Project: Flink

[GitHub] [flink] aljoscha commented on issue #7957: [FLINK-11865] Improve code generation speed in TraversableSerializer

2019-03-12 Thread GitBox
aljoscha commented on issue #7957: [FLINK-11865] Improve code generation speed in TraversableSerializer URL: https://github.com/apache/flink/pull/7957#issuecomment-472069699 Merged This is an automated message from the

[jira] [Closed] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow

2019-03-12 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11865. Resolution: Fixed > Code generation in TraversableSerializer is prohibitively slow >

[GitHub] [flink] aljoscha closed pull request #7957: [FLINK-11865] Improve code generation speed in TraversableSerializer

2019-03-12 Thread GitBox
aljoscha closed pull request #7957: [FLINK-11865] Improve code generation speed in TraversableSerializer URL: https://github.com/apache/flink/pull/7957 This is an automated message from the Apache Git Service. To respond to

  1   2   >