[GitHub] flink issue #5455: [FLINK-7711][flip6] Port JarListHandler

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5455 Thanks for rebasing @GJL. Changes look good. Merging this PR. ---

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365211#comment-16365211 ] ASF GitHub Bot commented on FLINK-7711: --- Github user tillrohrmann commented on the issue:

[jira] [Updated] (FLINK-8560) add KeyedProcessFunction to expose the key in onTimer() and other methods

[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8560: Summary: add KeyedProcessFunction to expose the key in onTimer() and other methods (was: Access to the

[jira] [Commented] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap()

[ https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365158#comment-16365158 ] mingleizhang commented on FLINK-8661: - Thanks [~yuzhih...@gmail.com] I will take a look on this. >

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365137#comment-16365137 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5282: [FLINK-6352] [kafka] Timestamp-based offset configuration...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5282 @aljoscha regarding the potential flakiness of the test you mentioned: I think the test will be stable, as long as the recorded timestamp of the second run is larger than the first run. We can

[GitHub] flink pull request #5282: [FLINK-6352] [kafka] Timestamp-based offset config...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5282#discussion_r168377242 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java --- @@ -1910,86

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365129#comment-16365129 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365130#comment-16365130 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #5282: [FLINK-6352] [kafka] Timestamp-based offset config...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5282#discussion_r168377228 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -441,28

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365125#comment-16365125 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365126#comment-16365126 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16365127#comment-16365127 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #5282: [FLINK-6352] [kafka] Timestamp-based offset config...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5282#discussion_r168377173 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -343,6

[GitHub] flink pull request #5282: [FLINK-6352] [kafka] Timestamp-based offset config...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5282#discussion_r168377183 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -343,6

[GitHub] flink pull request #5282: [FLINK-6352] [kafka] Timestamp-based offset config...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5282#discussion_r168377156 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -343,6

[jira] [Created] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap()

Ted Yu created FLINK-8661: - Summary: Replace Collections.EMPTY_MAP with Collections.emptyMap() Key: FLINK-8661 URL: https://issues.apache.org/jira/browse/FLINK-8661 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-8100) Consider introducing log4j-extras

[ https://issues.apache.org/jira/browse/FLINK-8100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved FLINK-8100. --- Resolution: Won't Fix > Consider introducing log4j-extras > -- > >

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168343968 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java --- @@ -95,15

[GitHub] flink issue #5272: [Flink-8397][Connectors]Support Row type for Cassandra Ou...

Github user suez1224 commented on the issue: https://github.com/apache/flink/pull/5272 @fhueske can you help take another look? Thanks. ---

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168338536 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java --- @@ -95,15

[jira] [Commented] (FLINK-8543) Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.checkOpen

[ https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364895#comment-16364895 ] chris snow commented on FLINK-8543: --- I didn’t see any errors or suspicious entries in the logs prior to

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168330940 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraTupleOutputFormat.java --- @@ -0,0

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168331011 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraOutputFormat.java --- @@ -37,11

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168330917 --- Diff: flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraRowOutputFormat.java --- @@ -0,0

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168330890 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@

[GitHub] flink pull request #5272: [Flink-8397][Connectors]Support Row type for Cassa...

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/5272#discussion_r168330869 --- Diff: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java --- @@

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364742#comment-16364742 ] ASF GitHub Bot commented on FLINK-7711: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364741#comment-16364741 ] ASF GitHub Bot commented on FLINK-7711: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5455: [FLINK-7711][flip6] Port JarListHandler

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5455#discussion_r168302562 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarListHandler.java --- @@ -0,0 +1,156 @@ +/* + * Licensed to

[GitHub] flink pull request #5455: [FLINK-7711][flip6] Port JarListHandler

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5455#discussion_r168302491 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarListHandler.java --- @@ -0,0 +1,156 @@ +/* + * Licensed to

[GitHub] flink pull request #5455: [FLINK-7711][flip6] Port JarListHandler

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5455#discussion_r168301191 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarListHandler.java --- @@ -0,0 +1,156 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364724#comment-16364724 ] ASF GitHub Bot commented on FLINK-7711: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8658) NoClassDefFoundError: Could not initialize class org.elasticsearch.transport.client.PreBuiltTransportClient

[ https://issues.apache.org/jira/browse/FLINK-8658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364671#comment-16364671 ] sathiyarajan commented on FLINK-8658: - Thanks [Ken Krugler] .  > NoClassDefFoundError: Could not

[jira] [Closed] (FLINK-8658) NoClassDefFoundError: Could not initialize class org.elasticsearch.transport.client.PreBuiltTransportClient

[ https://issues.apache.org/jira/browse/FLINK-8658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sathiyarajan closed FLINK-8658. --- Resolution: Feedback Received > NoClassDefFoundError: Could not initialize class >

[jira] [Commented] (FLINK-7658) Support COLLECT Aggregate function in Flink TABLE API

[ https://issues.apache.org/jira/browse/FLINK-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364641#comment-16364641 ] ASF GitHub Bot commented on FLINK-7658: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-7658) Support COLLECT Aggregate function in Flink TABLE API

[ https://issues.apache.org/jira/browse/FLINK-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7658. Resolution: Implemented Fix Version/s: 1.5.0 Implemented for 1.5.0 with

[jira] [Commented] (FLINK-2366) HA Without ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364648#comment-16364648 ] Krzysztof Białek commented on FLINK-2366: - [~till.rohrmann] - As you suggested I've created

[jira] [Created] (FLINK-8660) Enable the user to provide custom HAServices implementation

Krzysztof Białek created FLINK-8660: --- Summary: Enable the user to provide custom HAServices implementation Key: FLINK-8660 URL: https://issues.apache.org/jira/browse/FLINK-8660 Project: Flink

[jira] [Commented] (FLINK-8652) Reduce log level of QueryableStateClient.getKvState() to DEBUG

[ https://issues.apache.org/jira/browse/FLINK-8652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364642#comment-16364642 ] ASF GitHub Bot commented on FLINK-8652: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5489: [FLINK-8652] [QS] Reduce log level in getKvState t...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5489 ---

[GitHub] flink pull request #5472: [FLINK-7658][Table API & SQL] support Collect aggr...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5472 ---

[jira] [Commented] (FLINK-8411) HeapListState#add(null) will wipe out entire list state

[ https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364588#comment-16364588 ] ASF GitHub Bot commented on FLINK-8411: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-8658) NoClassDefFoundError: Could not initialize class org.elasticsearch.transport.client.PreBuiltTransportClient

[ https://issues.apache.org/jira/browse/FLINK-8658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364597#comment-16364597 ] Ken Krugler commented on FLINK-8658: Hi [~sathyadev] - if you're sure this is a Flink bug, then

[GitHub] flink pull request #5485: [FLINK-8411] Don't allow null in ListState.add()/a...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5485#discussion_r168271328 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseTest.java --- @@

[jira] [Commented] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364547#comment-16364547 ] ASF GitHub Bot commented on FLINK-8560: --- Github user bowenli86 commented on a diff in the pull

[jira] [Created] (FLINK-8659) Add migration tests for Broadcast state.

Kostas Kloudas created FLINK-8659: - Summary: Add migration tests for Broadcast state. Key: FLINK-8659 URL: https://issues.apache.org/jira/browse/FLINK-8659 Project: Flink Issue Type:

[GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/5481#discussion_r168265503 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunction.scala --- @@ -162,7 +162,7 @@ class

[GitHub] flink issue #5485: [FLINK-8411] Don't allow null in ListState.add()/addAll()

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5485 LGTM ---

[jira] [Commented] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364546#comment-16364546 ] ASF GitHub Bot commented on FLINK-8560: --- Github user bowenli86 commented on the issue:

[GitHub] flink issue #5481: [FLINK-8560] Access to the current key in ProcessFunction...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5481 @aljoscha Great idea! I think that's the way to go! Thanks for bringing it up! ---

[jira] [Commented] (FLINK-8411) HeapListState#add(null) will wipe out entire list state

[ https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364536#comment-16364536 ] ASF GitHub Bot commented on FLINK-8411: --- Github user bowenli86 commented on the issue:

[jira] [Created] (FLINK-8658) NoClassDefFoundError: Could not initialize class org.elasticsearch.transport.client.PreBuiltTransportClient

sathiyarajan created FLINK-8658: --- Summary: NoClassDefFoundError: Could not initialize class org.elasticsearch.transport.client.PreBuiltTransportClient Key: FLINK-8658 URL:

[jira] [Commented] (FLINK-8628) BucketingSink does not work with S3

[ https://issues.apache.org/jira/browse/FLINK-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364513#comment-16364513 ] dejan miljkovic commented on FLINK-8628: Thanks for the comments. Do you know when 1.4.1 will go

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364488#comment-16364488 ] Timo Walther commented on FLINK-8538: - [~xccui] I just opened a PR for FLINK-8630. Looking for a

[jira] [Commented] (FLINK-8630) To support JSON schema to TypeInformation conversion

[ https://issues.apache.org/jira/browse/FLINK-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364483#comment-16364483 ] ASF GitHub Bot commented on FLINK-8630: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #5491: [FLINK-8630] [table] To support JSON schema to Typ...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/5491 [FLINK-8630] [table] To support JSON schema to TypeInformation conversion ## What is the purpose of the change This PR implements (almost) full support of the JSON type. It includes:

[jira] [Closed] (FLINK-8642) Initialize descriptors before use at getBroadcastState().

[ https://issues.apache.org/jira/browse/FLINK-8642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8642. - Resolution: Fixed Fixed on master at cd6fe1c84fa97208a3cfd0c02be41c9799ba973a > Initialize

[jira] [Commented] (FLINK-8044) Introduce scheduling mechanism to satisfy both state locality and input

[ https://issues.apache.org/jira/browse/FLINK-8044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364439#comment-16364439 ] Till Rohrmann commented on FLINK-8044: -- Thanks for letting me know. We currently also follow the

[jira] [Updated] (FLINK-8655) Add a default keyspace to CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Hughes updated FLINK-8655: -- Fix Version/s: (was: 1.4.1) 1.5.0 > Add a default keyspace to

[GitHub] flink pull request #5489: [FLINK-8652] [QS] Reduce log level in getKvState t...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5489#discussion_r168239560 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java --- @@ -268,7

[jira] [Commented] (FLINK-8652) Reduce log level of QueryableStateClient.getKvState() to DEBUG

[ https://issues.apache.org/jira/browse/FLINK-8652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364411#comment-16364411 ] ASF GitHub Bot commented on FLINK-8652: --- Github user kl0u commented on a diff in the pull request:

[jira] [Commented] (FLINK-8643) Use JobManagerOptions#SLOT_REQUEST_TIMEOUT in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-8643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364397#comment-16364397 ] ASF GitHub Bot commented on FLINK-8643: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5475: [FLINK-8643] [flip6] Use JobManagerOptions#SLOT_REQUEST_T...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5475 Merging this PR. ---

[jira] [Commented] (FLINK-8644) Shut down AkkaRpcActors with PoisonPill

[ https://issues.apache.org/jira/browse/FLINK-8644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364391#comment-16364391 ] ASF GitHub Bot commented on FLINK-8644: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5476: [FLINK-8644] [flip6] Shut down AkkaRpcActors with PoisonP...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5476 Merging this PR. ---

[jira] [Commented] (FLINK-8530) Enable detached job submission for RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364381#comment-16364381 ] ASF GitHub Bot commented on FLINK-8530: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #5466: [FLINK-8530] [flip6] Enable detached job mode submission ...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5466 Thanks for the review @GJL. I've addressed your feedback and rebased onto the latest soon to be master. ---

[jira] [Commented] (FLINK-8530) Enable detached job submission for RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364373#comment-16364373 ] ASF GitHub Bot commented on FLINK-8530: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8530) Enable detached job submission for RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364374#comment-16364374 ] ASF GitHub Bot commented on FLINK-8530: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8530) Enable detached job submission for RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364372#comment-16364372 ] ASF GitHub Bot commented on FLINK-8530: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5466: [FLINK-8530] [flip6] Enable detached job mode subm...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5466#discussion_r168233528 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java --- @@ -456,7 +483,7 @@ public void

[GitHub] flink pull request #5466: [FLINK-8530] [flip6] Enable detached job mode subm...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5466#discussion_r168233601 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java --- @@ -509,7 +536,7 @@ public void

[GitHub] flink pull request #5466: [FLINK-8530] [flip6] Enable detached job mode subm...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5466#discussion_r168233566 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java --- @@ -493,7 +520,7 @@ public void

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364365#comment-16364365 ] ASF GitHub Bot commented on FLINK-8360: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168231423 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/OperatorStateBackendTest.java --- @@ -355,10 +355,11 @@ public void

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364359#comment-16364359 ] ASF GitHub Bot commented on FLINK-8360: --- Github user StefanRRichter commented on a diff in the pull

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364360#comment-16364360 ] ASF GitHub Bot commented on FLINK-8360: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168229825 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OperatorSnapshotFinalizer.java --- @@ -0,0 +1,83 @@ +/*

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168229878 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java --- @@ -3404,12 +3405,16 @@ public String fold(String

[GitHub] flink issue #5427: [FLINK-8533] [checkpointing] Support MasterTriggerRestore...

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/5427 I feel that we're not addressing the core issue that we're trying to fix. 1. A new job starts up with checkpointing enabled and a hook-based source. 2. The source begins to consume

[jira] [Commented] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization

[ https://issues.apache.org/jira/browse/FLINK-8533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364336#comment-16364336 ] ASF GitHub Bot commented on FLINK-8533: --- Github user EronWright commented on the issue:

[jira] [Commented] (FLINK-7713) Port JarUploadHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364294#comment-16364294 ] ASF GitHub Bot commented on FLINK-7713: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5442: [FLINK-7713][flip6] Implement JarUploadHandler

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5442#discussion_r168212886 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpointConfiguration.java --- @@ -103,6 +126,9 @@ public static

[GitHub] flink issue #5490: Fix incorrect description in the document for externalize...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5490 @aljoscha Cloud you have a look at this? I'm afraid I don't understand things correctly. ---

[jira] [Commented] (FLINK-8657) Fix incorrect description for external checkpoint vs savepoint

[ https://issues.apache.org/jira/browse/FLINK-8657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364278#comment-16364278 ] ASF GitHub Bot commented on FLINK-8657: --- GitHub user sihuazhou opened a pull request:

[GitHub] flink pull request #5490: Fix incorrect description in the document for exte...

GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5490 Fix incorrect description in the document for externalized checkpoint… ## What is the purpose of the change This PR addressed issue

[jira] [Created] (FLINK-8657) Fix incorrect description for external checkpoint vs savepoint

Sihua Zhou created FLINK-8657: - Summary: Fix incorrect description for external checkpoint vs savepoint Key: FLINK-8657 URL: https://issues.apache.org/jira/browse/FLINK-8657 Project: Flink

[jira] [Commented] (FLINK-8044) Introduce scheduling mechanism to satisfy both state locality and input

[ https://issues.apache.org/jira/browse/FLINK-8044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364215#comment-16364215 ] Sihua Zhou commented on FLINK-8044: --- Sorry [~till.rohrmann], finally I can't come up with a perfect

[jira] [Commented] (FLINK-8530) Enable detached job submission for RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364198#comment-16364198 ] ASF GitHub Bot commented on FLINK-8530: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5466: [FLINK-8530] [flip6] Enable detached job mode subm...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5466#discussion_r168200092 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java --- @@ -509,7 +536,7 @@ public void testListJobs() throws

[jira] [Commented] (FLINK-8530) Enable detached job submission for RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364192#comment-16364192 ] ASF GitHub Bot commented on FLINK-8530: --- Github user GJL commented on a diff in the pull request:

[jira] [Commented] (FLINK-8530) Enable detached job submission for RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-8530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364196#comment-16364196 ] ASF GitHub Bot commented on FLINK-8530: --- Github user GJL commented on a diff in the pull request:

[GitHub] flink pull request #5466: [FLINK-8530] [flip6] Enable detached job mode subm...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5466#discussion_r168199770 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java --- @@ -493,7 +520,7 @@ public void

[GitHub] flink pull request #5466: [FLINK-8530] [flip6] Enable detached job mode subm...

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5466#discussion_r168199581 --- Diff: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java --- @@ -456,7 +483,7 @@ public void

[jira] [Commented] (FLINK-8360) Implement task-local state recovery

[ https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364182#comment-16364182 ] ASF GitHub Bot commented on FLINK-8360: --- Github user sihuazhou commented on a diff in the pull

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168193980 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -336,1697

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168198204 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java --- @@ -0,0 +1,298 @@ +/* + * Licensed to the

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168193098 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -336,1697

[jira] [Commented] (FLINK-8613) Return excess container in YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364180#comment-16364180 ] ASF GitHub Bot commented on FLINK-8613: --- Github user tillrohrmann commented on the issue:

  1   2   3   4   5   >