[jira] [Created] (FLINK-10146) numBuffersOut not updated properly

Nico Kruber created FLINK-10146: --- Summary: numBuffersOut not updated properly Key: FLINK-10146 URL: https://issues.apache.org/jira/browse/FLINK-10146 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9913) Improve output serialization only once in RecordWriter

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

[jira] [Updated] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so.

[ https://issues.apache.org/jira/browse/FLINK-10149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10149: --- Labels: pull-request-available (was: ) > Fink Mesos allocates extra port when not

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

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

[jira] [Commented] (FLINK-9913) Improve output serialization only once in RecordWriter

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

[jira] [Created] (FLINK-10150) Inconsistent number of "Records received" / "Records sent"

Helmut Zechmann created FLINK-10150: --- Summary: Inconsistent number of "Records received" / "Records sent" Key: FLINK-10150 URL: https://issues.apache.org/jira/browse/FLINK-10150 Project: Flink

[jira] [Commented] (FLINK-10138) Queryable state (rocksdb) end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580805#comment-16580805 ] Chesnay Schepler commented on FLINK-10138: -- failed again today with another exception.

[jira] [Resolved] (FLINK-3785) Add REST resource to query information about checkpointing

[ https://issues.apache.org/jira/browse/FLINK-3785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf resolved FLINK-3785. - Resolution: Information Provided > Add REST resource to query information about

[jira] [Created] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so.

Rune Skou Larsen created FLINK-10149: Summary: Fink Mesos allocates extra port when not configured to do so. Key: FLINK-10149 URL: https://issues.apache.org/jira/browse/FLINK-10149 Project: Flink

[GitHub] pnowojski commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

pnowojski commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#discussion_r210236329 ## File path:

[GitHub] liurenjie1024 commented on issue #6357: [FLINK-9720] [Scheduler] Add ResourceAttribute and MesosResourceAttribute.

liurenjie1024 commented on issue #6357: [FLINK-9720] [Scheduler] Add ResourceAttribute and MesosResourceAttribute. URL: https://github.com/apache/flink/pull/6357#issuecomment-413165529 Hi @tillrohrmann Flink 1.6 has released, could you please help to review this?

[jira] [Commented] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580936#comment-16580936 ] ASF GitHub Bot commented on FLINK-9913: --- pnowojski commented on issue #6417: [FLINK-9913][runtime]

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Updated] (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:all-tabpanel ] Xingcan Cui updated FLINK-9289: --- Affects Version/s: (was: 1.5.3) (was: 1.6.1)

[GitHub] buptljy commented on a change in pull request #6541: [FLINK-9964] [table] Add a CSV table format factory

buptljy commented on a change in pull request #6541: [FLINK-9964] [table] Add a CSV table format factory URL: https://github.com/apache/flink/pull/6541#discussion_r210248775 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowSchemaConverter.java

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

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

[GitHub] yanghua commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

yanghua commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210253268 ## File path:

[GitHub] zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210251656 ## File path:

[jira] [Commented] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580825#comment-16580825 ] ASF GitHub Bot commented on FLINK-9913: --- zhijiangW commented on issue #6417: [FLINK-9913][runtime]

[GitHub] zhijiangW commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

zhijiangW commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#issuecomment-413127511 For benchmark, I also create a new job with only source and map vertex, and the source broadcast Long type

[jira] [Commented] (FLINK-10059) Add LTRIM supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580882#comment-16580882 ] ASF GitHub Bot commented on FLINK-10059: xccui commented on issue #6494: [FLINK-10059] [table]

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210240728 ## File path:

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210239166 ## File path:

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210238813 ## File path:

[jira] [Updated] (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:all-tabpanel ] Xingcan Cui updated FLINK-9289: --- Affects Version/s: (was: 1.6.0) (was: 1.4.2)

[jira] [Commented] (FLINK-10059) Add LTRIM supported in Table API and SQL

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

[GitHub] yanghua commented on issue #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

yanghua commented on issue #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#issuecomment-413125190 @xccui Can you help advance this PR? thanks. This is an

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

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

[jira] [Updated] (FLINK-10148) flink cancel withSavepoint does not seem to use akka properties from flink-conf.yaml with Flink 1.6.0 as with flink 1.4.x

[ https://issues.apache.org/jira/browse/FLINK-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Haglund updated FLINK-10148: -- Environment: Flink 1.6.0 Docker image based on: flink:1.6.0-hadoop27-scala_2.11   The

[GitHub] xccui edited a comment on issue #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

xccui edited a comment on issue #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#issuecomment-413145016 Hi @yanghua, thanks for your effort. The docs for built-in functions have been moved to a new page (functions.md).

[GitHub] buptljy commented on a change in pull request #6541: [FLINK-9964] [table] Add a CSV table format factory

buptljy commented on a change in pull request #6541: [FLINK-9964] [table] Add a CSV table format factory URL: https://github.com/apache/flink/pull/6541#discussion_r210248117 ## File path:

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

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

[GitHub] xccui commented on issue #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

xccui commented on issue #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#issuecomment-413145016 Hi @yanghua, thanks for your effort. The docs for built-in functions have been moved to a new page (functions.md). You could

[jira] [Created] (FLINK-10148) flink cancel withSavepoint does not seem to use akka properties from flink-conf.yaml with Flink 1.6.0 as with flink 1.4.x

David Haglund created FLINK-10148: - Summary: flink cancel withSavepoint does not seem to use akka properties from flink-conf.yaml with Flink 1.6.0 as with flink 1.4.x Key: FLINK-10148 URL:

[jira] [Commented] (FLINK-10059) Add LTRIM supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-10059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580930#comment-16580930 ] ASF GitHub Bot commented on FLINK-10059: xccui edited a comment on issue #6494: [FLINK-10059]

[GitHub] pnowojski commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

pnowojski commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#issuecomment-413167382 @zhijiangW yes, those results from our internal benchmarking tool are a little bit strange since I do not

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

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

[GitHub] buptljy commented on a change in pull request #6541: [FLINK-9964] [table] Add a CSV table format factory

buptljy commented on a change in pull request #6541: [FLINK-9964] [table] Add a CSV table format factory URL: https://github.com/apache/flink/pull/6541#discussion_r210239352 ## File path:

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210240862 ## File path:

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210239256 ## File path:

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210240642 ## File path:

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210241537 ## File path:

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210240596 ## File path:

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210240596 ## File path:

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210239256 ## File path:

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[GitHub] fhueske commented on a change in pull request #6003: [FLINK-9289][Dataset] Parallelism of generated operators should have max parallelism of input

fhueske commented on a change in pull request #6003: [FLINK-9289][Dataset] Parallelism of generated operators should have max parallelism of input URL: https://github.com/apache/flink/pull/6003#discussion_r210240946 ## File path:

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[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=16580960#comment-16580960 ] ASF GitHub Bot commented on FLINK-9289: --- fhueske commented on a change in pull request #6003:

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210242096 ## File path:

[GitHub] pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

pnowojski commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210240875 ## File path:

[jira] [Commented] (FLINK-10012) Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

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

[GitHub] yanghua commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

yanghua commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API URL: https://github.com/apache/flink/pull/6475#issuecomment-413184723 @zentol about this PR, is there anything need to modify?

[GitHub] zhijiangW commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

zhijiangW commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#discussion_r210195493 ## File path:

[jira] [Commented] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so.

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

[GitHub] buptljy commented on a change in pull request #6541: [FLINK-9964] [table] Add a CSV table format factory

buptljy commented on a change in pull request #6541: [FLINK-9964] [table] Add a CSV table format factory URL: https://github.com/apache/flink/pull/6541#discussion_r210249215 ## File path:

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

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

[GitHub] zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210252035 ## File path:

[GitHub] zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210251434 ## File path:

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[GitHub] zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210251882 ## File path:

[GitHub] zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210251656 ## File path:

[GitHub] zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210252151 ## File path:

[GitHub] zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

zentol commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210251440 ## File path:

[GitHub] zhijiangW edited a comment on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

zhijiangW edited a comment on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#issuecomment-413127511 For benchmark, I also create a new job with only source and map vertex, and the source broadcast

[jira] [Commented] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580829#comment-16580829 ] ASF GitHub Bot commented on FLINK-9913: --- zhijiangW edited a comment on issue #6417:

[GitHub] rsltrifork opened a new pull request #6557: [FLINK-10149] [flink-mesos] Don't allocate extra mesos port for TM unless configured to do so.

rsltrifork opened a new pull request #6557: [FLINK-10149] [flink-mesos] Don't allocate extra mesos port for TM unless configured to do so. URL: https://github.com/apache/flink/pull/6557 ## What is the purpose of the change Make sure Flink only allocates the necessary mesos ports.

[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-413163702 Hi @fhueske. I just added some tests for the union operator. Thanks, Xingcan

[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=16580923#comment-16580923 ] ASF GitHub Bot commented on FLINK-9289: --- xccui commented on issue #6003: [FLINK-9289][Dataset]

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

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

[GitHub] buptljy commented on a change in pull request #6541: [FLINK-9964] [table] Add a CSV table format factory

buptljy commented on a change in pull request #6541: [FLINK-9964] [table] Add a CSV table format factory URL: https://github.com/apache/flink/pull/6541#discussion_r210247786 ## File path:

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[jira] [Updated] (FLINK-10045) .bat script to start/stop Flink daemon

[ https://issues.apache.org/jira/browse/FLINK-10045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10045: --- Labels: pull-request-available (was: ) > .bat script to start/stop Flink daemon >

[jira] [Commented] (FLINK-10045) .bat script to start/stop Flink daemon

[ https://issues.apache.org/jira/browse/FLINK-10045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581115#comment-16581115 ] ASF GitHub Bot commented on FLINK-10045: pavel-shvetsov-git opened a new pull request #6559:

[GitHub] pavel-shvetsov-git opened a new pull request #6559: [FLINK-10045] [Startup Shell Scripts] .bat script to start/stop Flink daemon

pavel-shvetsov-git opened a new pull request #6559: [FLINK-10045] [Startup Shell Scripts] .bat script to start/stop Flink daemon URL: https://github.com/apache/flink/pull/6559 Created scripts to start/stop Flink as daemon ## Does this pull request potentially affect one of the

[jira] [Created] (FLINK-10151) [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

Andrey Zagrebin created FLINK-10151: --- Summary: [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource Key: FLINK-10151 URL:

[jira] [Updated] (FLINK-10151) [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

[ https://issues.apache.org/jira/browse/FLINK-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-10151: Description: *TransformingStateTableKeyGroupPartitioner* currently calls *tryAddToSource* 

[jira] [Commented] (FLINK-9850) Add a string to the print method to identify output for DataStream

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

[GitHub] yanghua commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream

yanghua commented on a change in pull request #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#discussion_r210299902 ## File path:

[jira] [Commented] (FLINK-9488) Create common entry point for master and workers

[ https://issues.apache.org/jira/browse/FLINK-9488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581227#comment-16581227 ] Till Rohrmann commented on FLINK-9488: -- [~pr] you can checkout

[jira] [Commented] (FLINK-9013) Document yarn.containers.vcores only being effective when adapting YARN config

[ https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581059#comment-16581059 ] ASF GitHub Bot commented on FLINK-9013: --- dawidwys closed pull request #6294: [FLINK-9013][docs]

[jira] [Updated] (FLINK-9116) Introduce getAll and removeAll for MapState

[ https://issues.apache.org/jira/browse/FLINK-9116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9116: -- Labels: pull-request-available (was: ) > Introduce getAll and removeAll for MapState >

[GitHub] klion26 opened a new pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState

klion26 opened a new pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState URL: https://github.com/apache/flink/pull/6558 ## What is the purpose of the change Introduce getAll and removeAll for MapState ## Verifying this change This change

[jira] [Commented] (FLINK-9116) Introduce getAll and removeAll for MapState

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

[jira] [Updated] (FLINK-10001) Improve Kubernetes documentation

[ https://issues.apache.org/jira/browse/FLINK-10001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10001: --- Labels: pull-request-available (was: ) > Improve Kubernetes documentation >

  1   2   3   >