[GitHub] asfgit closed pull request #6522: [FLINK-10101][mesos] Add web ui url for mesos.

asfgit closed pull request #6522: [FLINK-10101][mesos] Add web ui url for mesos. URL: https://github.com/apache/flink/pull/6522 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 provenance: As this is a foreign

[jira] [Commented] (FLINK-9054) IllegalStateException: Buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582054#comment-16582054 ] Shimin Yang commented on FLINK-9054: Could you please attach more logs? Feels like it's not enough to

[jira] [Resolved] (FLINK-10101) Mesos web ui url is missing.

[ https://issues.apache.org/jira/browse/FLINK-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10101. --- Resolution: Fixed Fix Version/s: 1.7.0 1.6.1

[jira] [Resolved] (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:all-tabpanel ] Dawid Wysakowicz resolved FLINK-9013. - Resolution: Fixed Fix Version/s: 1.6.1 > Document yarn.containers.vcores only

[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=16582073#comment-16582073 ] Dawid Wysakowicz commented on FLINK-9013: - Resolved in master via:

[jira] [Commented] (FLINK-8336) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3 test instability

[ https://issues.apache.org/jira/browse/FLINK-8336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582057#comment-16582057 ] Till Rohrmann commented on FLINK-8336: -- Another instance on the master:

[jira] [Reopened] (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:all-tabpanel ] Dawid Wysakowicz reopened FLINK-9013: - > Document yarn.containers.vcores only being effective when adapting YARN config >

[jira] [Commented] (FLINK-10101) Mesos web ui url is missing.

[ https://issues.apache.org/jira/browse/FLINK-10101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582059#comment-16582059 ] ASF GitHub Bot commented on FLINK-10101: asfgit closed pull request #6522: [FLINK-10101][mesos]

[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=16582143#comment-16582143 ] ASF GitHub Bot commented on FLINK-9116: --- StefanRRichter commented on a change in pull request

[GitHub] StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState

StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState URL: https://github.com/apache/flink/pull/6558#discussion_r210509286 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState

StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState URL: https://github.com/apache/flink/pull/6558#discussion_r210509235 ## File path:

[jira] [Updated] (FLINK-10157) The TTL state not allow `null` state value

[ https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chengjie.wu updated FLINK-10157: Description: Thanks for the StateTtl feature,this is exactly what I need now! But I found an

[GitHub] TisonKun commented on issue #6345: [FLINK-9869][runtime] Send PartitionInfo in batch to Improve perfornance

TisonKun commented on issue #6345: [FLINK-9869][runtime] Send PartitionInfo in batch to Improve perfornance URL: https://github.com/apache/flink/pull/6345#issuecomment-413463126 ping @tillrohrmann FYI, travis fails on `BucketingSinkFaultToleranceITCase`, but I run ~1000 times locally

[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=16582158#comment-16582158 ] 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_r210511275 ## 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_r210509687 ## 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=16582159#comment-16582159 ] ASF GitHub Bot commented on FLINK-9850: --- pnowojski commented on a change in pull request #6367:

[GitHub] StefanRRichter edited a comment on issue #6498: [FLINK-10065] InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

StefanRRichter edited a comment on issue #6498: [FLINK-10065] InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream URL: https://github.com/apache/flink/pull/6498#issuecomment-413465964 @klion26 The mentioned method is a

[GitHub] StefanRRichter commented on issue #6498: [FLINK-10065] InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

StefanRRichter commented on issue #6498: [FLINK-10065] InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream URL: https://github.com/apache/flink/pull/6498#issuecomment-413465964 @klion26 The mentioned method is a legacy

[jira] [Commented] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

[ https://issues.apache.org/jira/browse/FLINK-10065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582164#comment-16582164 ] ASF GitHub Bot commented on FLINK-10065: StefanRRichter commented on issue #6498: [FLINK-10065]

[jira] [Commented] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

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

[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=16582193#comment-16582193 ] ASF GitHub Bot commented on FLINK-9913: --- zhijiangW commented on issue #6417: [FLINK-9913][runtime]

[jira] [Created] (FLINK-10158) The DataOutputSerializer may consume excessive memory

aitozi created FLINK-10158: -- Summary: The DataOutputSerializer may consume excessive memory Key: FLINK-10158 URL: https://issues.apache.org/jira/browse/FLINK-10158 Project: Flink Issue Type:

[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=16582205#comment-16582205 ] ASF GitHub Bot commented on FLINK-9850: --- yanghua commented on issue #6367: [FLINK-9850] Add a

[jira] [Commented] (FLINK-9054) IllegalStateException: Buffer pool is destroyed

[ https://issues.apache.org/jira/browse/FLINK-9054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582220#comment-16582220 ] aitozi commented on FLINK-9054: --- It may be caused by the timerService not shutdown correctly, Is it

[jira] [Commented] (FLINK-10153) Add tutorial section to documentation

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

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

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

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

zentol commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#issuecomment-413476883 yes. This is an automated message from

[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=16582239#comment-16582239 ] ASF GitHub Bot commented on FLINK-9850: --- zentol commented on issue #6367: [FLINK-9850] Add a string

[jira] [Commented] (FLINK-10158) The DataOutputSerializer may consume excessive memory

[ https://issues.apache.org/jira/browse/FLINK-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582241#comment-16582241 ] zhijiang commented on FLINK-10158: -- I already improved it in 

[jira] [Comment Edited] (FLINK-8037) Missing cast in integer arithmetic in TransactionalIdsGenerator#generateIdsToAbort

[ https://issues.apache.org/jira/browse/FLINK-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16427664#comment-16427664 ] Ted Yu edited comment on FLINK-8037 at 8/16/18 7:35 AM: Please rebase PR. was

[jira] [Comment Edited] (FLINK-8554) Upgrade AWS SDK

[ https://issues.apache.org/jira/browse/FLINK-8554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507192#comment-16507192 ] Ted Yu edited comment on FLINK-8554 at 8/16/18 7:35 AM: Or use this JIRA for the

[jira] [Commented] (FLINK-10072) Syntax and consistency issues in "The Broadcast State Pattern"

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

[GitHub] rickhofstede commented on a change in pull request #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern"

rickhofstede commented on a change in pull request #6503: [FLINK-10072] [docs] Syntax and consistency issues in "The Broadcast State Pattern" URL: https://github.com/apache/flink/pull/6503#discussion_r210502182 ## File path: docs/dev/stream/state/broadcast_state.md ## @@

[GitHub] tillrohrmann closed pull request #6531: [release-1.6][FLINK-10110][tests] Harden Kafka component shut down for E2E tests

tillrohrmann closed pull request #6531: [release-1.6][FLINK-10110][tests] Harden Kafka component shut down for E2E tests URL: https://github.com/apache/flink/pull/6531 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[GitHub] tillrohrmann commented on issue #6531: [release-1.6][FLINK-10110][tests] Harden Kafka component shut down for E2E tests

tillrohrmann commented on issue #6531: [release-1.6][FLINK-10110][tests] Harden Kafka component shut down for E2E tests URL: https://github.com/apache/flink/pull/6531#issuecomment-413458673 Merged via 17eeb5aa665b8fa8ae49e6d7179af67136f377bd

[jira] [Commented] (FLINK-9859) More Akka config

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

[jira] [Commented] (FLINK-9859) More Akka config

[ https://issues.apache.org/jira/browse/FLINK-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582112#comment-16582112 ] ASF GitHub Bot commented on FLINK-9859: --- TisonKun commented on issue #6339: [FLINK-9859] [runtime]

[jira] [Commented] (FLINK-10110) Harden e2e Kafka shutdown

[ https://issues.apache.org/jira/browse/FLINK-10110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582114#comment-16582114 ] ASF GitHub Bot commented on FLINK-10110: tillrohrmann commented on issue #6531:

[jira] [Commented] (FLINK-10110) Harden e2e Kafka shutdown

[ https://issues.apache.org/jira/browse/FLINK-10110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582115#comment-16582115 ] ASF GitHub Bot commented on FLINK-10110: tillrohrmann closed pull request #6531:

[GitHub] StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState

StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState URL: https://github.com/apache/flink/pull/6558#discussion_r210507286 ## File path:

[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=16582130#comment-16582130 ] ASF GitHub Bot commented on FLINK-9116: --- StefanRRichter commented on a change in pull request

[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_r210514030 ## File path:

[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_r210513770 ## 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=16582169#comment-16582169 ] ASF GitHub Bot commented on FLINK-9850: --- yanghua commented on a change in pull request #6367:

[jira] [Commented] (FLINK-10157) The TTL state not allow `null` state value

[ https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582175#comment-16582175 ] Andrey Zagrebin commented on FLINK-10157: - Thanks for reporting this issue [~wucj]! I will have

[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=16582191#comment-16582191 ] ASF GitHub Bot commented on FLINK-9850: --- zentol commented on issue #6367: [FLINK-9850] Add a string

[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-413468551 @pnowojski , I think I got the reason of regression in some non-broadcast cases. The key point is

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

zentol commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#issuecomment-413468227 Personally I would prefer if we'd not change the python API in this PR, because we're now in the exact

[jira] [Comment Edited] (FLINK-10119) JsonRowDeserializationSchema deserialize kafka message

[ https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579779#comment-16579779 ] buptljy edited comment on FLINK-10119 at 8/16/18 7:43 AM: -- [~twalthr] I don't

[GitHub] TisonKun commented on issue #6339: [FLINK-9859] [runtime] More Akka config

TisonKun commented on issue #6339: [FLINK-9859] [runtime] More Akka config URL: https://github.com/apache/flink/pull/6339#issuecomment-413458376 @tillrohrmann The original purpose of this PR is to distinguish akka config of JM and TM, since JM would require more resource. Now we

[GitHub] TisonKun edited a comment on issue #6339: [FLINK-9859] [runtime] More Akka config

TisonKun edited a comment on issue #6339: [FLINK-9859] [runtime] More Akka config URL: https://github.com/apache/flink/pull/6339#issuecomment-413458376 @tillrohrmann The original purpose of this PR is to distinguish akka config of JM and TM, since JM would require more resource.

[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=16582132#comment-16582132 ] ASF GitHub Bot commented on FLINK-9116: --- StefanRRichter commented on a change in pull request

[jira] [Created] (FLINK-10157) The TTL state not allow `null` state value

chengjie.wu created FLINK-10157: --- Summary: The TTL state not allow `null` state value Key: FLINK-10157 URL: https://issues.apache.org/jira/browse/FLINK-10157 Project: Flink Issue Type: Bug

[GitHub] StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState

StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState URL: https://github.com/apache/flink/pull/6558#discussion_r210507581 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapMapState.java

[GitHub] StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState

StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState URL: https://github.com/apache/flink/pull/6558#discussion_r210508829 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapMapState.java

[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=16582141#comment-16582141 ] ASF GitHub Bot commented on FLINK-9116: --- StefanRRichter commented on a change in pull request

[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=16582142#comment-16582142 ] ASF GitHub Bot commented on FLINK-9116: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance

[ https://issues.apache.org/jira/browse/FLINK-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582149#comment-16582149 ] ASF GitHub Bot commented on FLINK-9869: --- TisonKun commented on issue #6345: [FLINK-9869][runtime]

[jira] [Commented] (FLINK-10157) The TTL state not allow `null` state value

[ https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582152#comment-16582152 ] chengjie.wu commented on FLINK-10157: - [~azagrebin] thanks for your answer! > The TTL state not

[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=16582151#comment-16582151 ] ASF GitHub Bot commented on FLINK-9116: --- StefanRRichter commented on a change in pull request

[GitHub] StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState

StefanRRichter commented on a change in pull request #6558: [FLINK-9116] Introduce getAll and removeAll for MapState URL: https://github.com/apache/flink/pull/6558#discussion_r210510928 ## File path:

[jira] [Commented] (FLINK-10156) Drop the Table.writeToSink() method

[ https://issues.apache.org/jira/browse/FLINK-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582153#comment-16582153 ] Fabian Hueske commented on FLINK-10156: --- We can also deprecate it and remove it in a later

[jira] [Commented] (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:comment-tabpanel=16582177#comment-16582177 ] ASF GitHub Bot commented on FLINK-10151: StefanRRichter commented on issue #6563: [FLINK-10151]

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

[ https://issues.apache.org/jira/browse/FLINK-10001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16582173#comment-16582173 ] ASF GitHub Bot commented on FLINK-10001: tillrohrmann closed pull request #6561:

[GitHub] tillrohrmann closed pull request #6561: [FLINK-10001][docs] Update Docker and Kubernetes documentation

tillrohrmann closed pull request #6561: [FLINK-10001][docs] Update Docker and Kubernetes documentation URL: https://github.com/apache/flink/pull/6561 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] [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=16582171#comment-16582171 ] ASF GitHub Bot commented on FLINK-9850: --- zentol commented on a change in pull request #6367:

[GitHub] tillrohrmann opened a new pull request #6561: [FLINK-10001][docs] Update Docker and Kubernetes documentation

tillrohrmann opened a new pull request #6561: [FLINK-10001][docs] Update Docker and Kubernetes documentation URL: https://github.com/apache/flink/pull/6561 ## What is the purpose of the change This PR updates Flink's Docker and Kubernetes documentation to include the job mode for

[GitHub] StefanRRichter commented on issue #6563: [FLINK-10151] [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

StefanRRichter commented on issue #6563: [FLINK-10151] [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource URL: https://github.com/apache/flink/pull/6563#issuecomment-413466827 LGTM  Merging.

[jira] [Assigned] (FLINK-10157) The TTL state not allow `null` state value

[ https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-10157: --- Assignee: Andrey Zagrebin > The TTL state not allow `null` state value >

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

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

[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_r210515127 ## File path:

[GitHub] asfgit closed pull request #6563: [FLINK-10151] [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

asfgit closed pull request #6563: [FLINK-10151] [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource URL: https://github.com/apache/flink/pull/6563 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[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_r210514892 ## 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=16582186#comment-16582186 ] ASF GitHub Bot commented on FLINK-9850: --- zentol commented on a change in pull request #6367:

[jira] [Commented] (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:comment-tabpanel=16582185#comment-16582185 ] ASF GitHub Bot commented on FLINK-10151: asfgit closed pull request #6563: [FLINK-10151] [State

[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=16582184#comment-16582184 ] 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=16582181#comment-16582181 ] 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_r210514892 ## File path:

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

yanghua commented on issue #6367: [FLINK-9850] Add a string to the print method to identify output for DataStream URL: https://github.com/apache/flink/pull/6367#issuecomment-413470612 @zentol Do you mean that we don't change the python API here and remove the tests for the Python API?

[GitHub] fhueske commented on a change in pull request #6565: [FLINK-10153] [docs] Add Tutorials section and rework structure.

fhueske commented on a change in pull request #6565: [FLINK-10153] [docs] Add Tutorials section and rework structure. URL: https://github.com/apache/flink/pull/6565#discussion_r210521666 ## File path: docs/tutorials/local_setup.md ## @@ -1,8 +1,8 @@ --- -title:

[GitHub] maqingxiang opened a new pull request #6566: Feature add host in checkpoint detail

maqingxiang opened a new pull request #6566: Feature add host in checkpoint detail URL: https://github.com/apache/flink/pull/6566 Add the host information to the checkpoint so that if the checkpoint fails, you can specifically login to the appropriate machine to see the cause of the

[GitHub] fhueske commented on a change in pull request #6565: [FLINK-10153] [docs] Add Tutorials section and rework structure.

fhueske commented on a change in pull request #6565: [FLINK-10153] [docs] Add Tutorials section and rework structure. URL: https://github.com/apache/flink/pull/6565#discussion_r210522579 ## File path: docs/dev/batch/examples.md ## @@ -27,8 +27,7 @@ The following example

[jira] [Commented] (FLINK-10153) Add tutorial section to documentation

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

[GitHub] alpinegizmo commented on a change in pull request #6561: [FLINK-10001][docs] Update Docker and Kubernetes documentation

alpinegizmo commented on a change in pull request #6561: [FLINK-10001][docs] Update Docker and Kubernetes documentation URL: https://github.com/apache/flink/pull/6561#discussion_r210523296 ## File path: docs/ops/deployment/kubernetes.md ## @@ -23,51 +23,78 @@ specific

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

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

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

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

[GitHub] alpinegizmo commented on a change in pull request #6561: [FLINK-10001][docs] Update Docker and Kubernetes documentation

alpinegizmo commented on a change in pull request #6561: [FLINK-10001][docs] Update Docker and Kubernetes documentation URL: https://github.com/apache/flink/pull/6561#discussion_r210522820 ## File path: docs/ops/deployment/kubernetes.md ## @@ -23,51 +23,78 @@ specific

[GitHub] alpinegizmo commented on a change in pull request #6561: [FLINK-10001][docs] Update Docker and Kubernetes documentation

alpinegizmo commented on a change in pull request #6561: [FLINK-10001][docs] Update Docker and Kubernetes documentation URL: https://github.com/apache/flink/pull/6561#discussion_r210522416 ## File path: docs/ops/deployment/kubernetes.md ## @@ -23,51 +23,78 @@ specific

[GitHub] yanghua opened a new pull request #6567: [FLINK-10074] Allowable number of checkpoint failures

yanghua opened a new pull request #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567 ## What is the purpose of the change *This pull request allows number of checkpoint failures* ## Brief change log - *Add a new

[GitHub] pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r210531098 ## File path:

[GitHub] pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r210523907 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java ##

[GitHub] pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r210529443 ## File path:

[GitHub] pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r210514431 ## File path:

[GitHub] pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r210515177 ## File path:

[GitHub] pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r210515882 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java ##

[GitHub] pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options

pnowojski commented on a change in pull request #6355: [FLINK-9878][network][ssl] add more low-level ssl options URL: https://github.com/apache/flink/pull/6355#discussion_r210515985 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java ##

[GitHub] yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures

yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#issuecomment-413486884 cc @tillrohrmann This is an automated message from the Apache Git

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

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

[jira] [Commented] (FLINK-9878) IO worker threads BLOCKED on SSL Session Cache while CMS full gc

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

  1   2   3   4   >