Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6043#discussion_r190127059
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486739#comment-16486739
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6043#discussion_r190127406
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486737#comment-16486737
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486738#comment-16486738
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6043#discussion_r190126862
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BulkProcessorIndexer.java
---
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486736#comment-16486736
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6043#discussion_r190126707
--- Diff:
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6053#discussion_r190126277
--- Diff: flink-end-to-end-tests/run-nightly-tests.sh ---
@@ -30,168 +30,50 @@ if [ -z "$FLINK_DIR" ] ; then
exit 1
fi
-source
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6053#discussion_r190126071
--- Diff:
flink-end-to-end-tests/test-scripts/test_local_recovery_and_scheduling.sh ---
@@ -53,8 +53,6 @@ function cleanup_after_test {
#
[
https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486731#comment-16486731
]
ASF GitHub Bot commented on FLINK-9257:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486733#comment-16486733
]
ASF GitHub Bot commented on FLINK-9257:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486730#comment-16486730
]
ASF GitHub Bot commented on FLINK-9257:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486732#comment-16486732
]
ASF GitHub Bot commented on FLINK-9257:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6053#discussion_r190124962
--- Diff: flink-end-to-end-tests/run-pre-commit-tests.sh ---
@@ -31,56 +31,23 @@ if [ -z "$FLINK_DIR" ] ; then
fi
source "$(dirname
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6053#discussion_r190125404
--- Diff: flink-end-to-end-tests/test-scripts/test-runner-common.sh ---
@@ -0,0 +1,76 @@
+#!/usr/bin/env bash
[
https://issues.apache.org/jira/browse/FLINK-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486720#comment-16486720
]
ASF GitHub Bot commented on FLINK-9344:
---
Github user walterddr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486725#comment-16486725
]
ASF GitHub Bot commented on FLINK-9344:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5998#discussion_r190124815
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/setop/StreamIntersectCoProcessFunction.scala
---
@@ -0,0 +1,236 @@
[
https://issues.apache.org/jira/browse/FLINK-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486726#comment-16486726
]
ASF GitHub Bot commented on FLINK-9344:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5998#discussion_r190124755
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/setop/StreamIntersectCoProcessFunction.scala
---
@@ -0,0 +1,236 @@
[
https://issues.apache.org/jira/browse/FLINK-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486722#comment-16486722
]
ASF GitHub Bot commented on FLINK-9344:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5998#discussion_r190120842
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/setop/StreamIntersectCoProcessFunction.scala
---
@@ -0,0 +1,236 @@
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5998#discussion_r190119234
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamIntersect.scala
---
@@ -0,0 +1,116 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486724#comment-16486724
]
ASF GitHub Bot commented on FLINK-9344:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5998#discussion_r190123516
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/setop/StreamIntersectCoProcessFunction.scala
---
@@ -0,0 +1,236 @@
[
https://issues.apache.org/jira/browse/FLINK-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486721#comment-16486721
]
ASF GitHub Bot commented on FLINK-9344:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5998#discussion_r190122671
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/setop/StreamIntersectCoProcessFunction.scala
---
@@ -0,0 +1,236 @@
[
https://issues.apache.org/jira/browse/FLINK-9344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486723#comment-16486723
]
ASF GitHub Bot commented on FLINK-9344:
---
Github user walterddr commented on a diff in the pull
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5998#discussion_r190119548
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamIntersect.scala
---
@@ -0,0 +1,116 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-9415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486711#comment-16486711
]
ASF GitHub Bot commented on FLINK-9415:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6058#discussion_r190123863
--- Diff: docs/dev/stream/testing.md ---
@@ -181,7 +181,7 @@ public class ExampleIntegrationTest extends
StreamingMultipleProgramsTestBase {
[
https://issues.apache.org/jira/browse/FLINK-9415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486710#comment-16486710
]
ASF GitHub Bot commented on FLINK-9415:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6058#discussion_r190123818
--- Diff: docs/dev/stream/testing.md ---
@@ -181,7 +181,7 @@ public class ExampleIntegrationTest extends
StreamingMultipleProgramsTestBase {
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r190120134
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486696#comment-16486696
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486694#comment-16486694
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r190111529
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherTest.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r190110928
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486691#comment-16486691
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486693#comment-16486693
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486695#comment-16486695
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r190112933
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r190111239
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherTest.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r190120209
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherTest.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r190111078
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486698#comment-16486698
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486697#comment-16486697
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6040#discussion_r190114844
--- Diff:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherTest.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486692#comment-16486692
]
ASF GitHub Bot commented on FLINK-9349:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9070:
--
Affects Version/s: (was: 1.6.0)
1.5.0
> Improve performance of
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9070:
--
Fix Version/s: (was: 1.6.0)
1.5.0
> Improve performance of
[
https://issues.apache.org/jira/browse/FLINK-9415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486609#comment-16486609
]
ASF GitHub Bot commented on FLINK-9415:
---
GitHub user tweise opened a pull request:
GitHub user tweise opened a pull request:
https://github.com/apache/flink/pull/6058
[FLINK-9415] Remove reference to StreamingMultipleProgramsTestBase in docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tweise/flink
[
https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-9411:
Component/s: filesystem-connector
> Support parquet rolling sink writer
>
Thomas Weise created FLINK-9415:
---
Summary: Remove reference to StreamingMultipleProgramsTestBase in
docs
Key: FLINK-9415
URL: https://issues.apache.org/jira/browse/FLINK-9415
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16486510#comment-16486510
]
Luke Hutchison commented on FLINK-6016:
---
[~pshvetso]: It looks like you were able to replicate the
[
https://issues.apache.org/jira/browse/FLINK-9408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16485772#comment-16485772
]
ASF GitHub Bot commented on FLINK-9408:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9402.
--
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed via
master:
[
https://issues.apache.org/jira/browse/FLINK-9406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16485773#comment-16485773
]
ASF GitHub Bot commented on FLINK-9406:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16485771#comment-16485771
]
ASF GitHub Bot commented on FLINK-9402:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6045
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6057
---
[
https://issues.apache.org/jira/browse/FLINK-9408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9408.
Resolution: Fixed
Fixed via
master: 064379705f36aaea927c44bb303a867c0c66265d
1.5.0:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6056
---
[
https://issues.apache.org/jira/browse/FLINK-9406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9406.
Resolution: Fixed
Fixed via
master: 777f50a91aa60cee9c863b5fca0fd481de8b01b9
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-9414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-9414.
Resolution: Fixed
Fixed via
master: 92e3db74b1b401e2f3357abe6f7d2ca3f5da7050
1.5.0:
Till Rohrmann created FLINK-9414:
Summary: Remove jline-terminal and jline-reader from LICENSE file
Key: FLINK-9414
URL: https://issues.apache.org/jira/browse/FLINK-9414
Project: Flink
Issue
Till Rohrmann created FLINK-9413:
Summary: Tasks can fail with PartitionNotFoundException if
consumer deployment takes too long
Key: FLINK-9413
URL: https://issues.apache.org/jira/browse/FLINK-9413
[
https://issues.apache.org/jira/browse/FLINK-9406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484720#comment-16484720
]
ASF GitHub Bot commented on FLINK-9406:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/6057
[FLINK-9406] Use equals in JobMaster#requestPartitionState
## What is the purpose of the change
Use equals instead of referential equality in
JobMaster#requestPartitionState
when
[
https://issues.apache.org/jira/browse/FLINK-9406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9406:
Assignee: Till Rohrmann (was: Nico Kruber)
> Request finished partition state fails due
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484549#comment-16484549
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user ctamisier commented on the issue:
Github user ctamisier commented on the issue:
https://github.com/apache/flink/pull/5964
Ok great!, I'd like to mention that `CassandraPojoSinkExample.main()`
doesn't seem to work:
`source.getType()` is computed as a `GenericType` in the
`env.fromCollection(messages);`.
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/5996
@zentol I would appreciate if you review this. We use this type of example
for enriching our Steam data via API call which is very common use-case and I
think it would be useful for other people to
[
https://issues.apache.org/jira/browse/FLINK-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484402#comment-16484402
]
ASF GitHub Bot commented on FLINK-9343:
---
Github user medcv commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484226#comment-16484226
]
Xingcan Cui commented on FLINK-9219:
Yes, I agree that we should expose a Flink-specific type for
[
https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484201#comment-16484201
]
Timo Walther commented on FLINK-9219:
-
Maybe we should ask on the Calcite ML why the {{bind()}} is
[
https://issues.apache.org/jira/browse/FLINK-9412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-9412:
Description:
FLINK-8607 and following issues have implemented or are currently implementing
the
Timo Walther created FLINK-9412:
---
Summary: Add a REST-based SQL Client Gateway
Key: FLINK-9412
URL: https://issues.apache.org/jira/browse/FLINK-9412
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484155#comment-16484155
]
ASF GitHub Bot commented on FLINK-9276:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5954
cc @StephanEwen
---
mingleizhang created FLINK-9411:
---
Summary: Support parquet rolling sink writer
Key: FLINK-9411
URL: https://issues.apache.org/jira/browse/FLINK-9411
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484133#comment-16484133
]
ASF GitHub Bot commented on FLINK-9356:
---
Github user yanghua commented on a diff in the pull
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6028#discussion_r189943667
--- Diff:
flink-queryable-state/flink-queryable-state-runtime/src/main/java/org/apache/flink/queryablestate/client/proxy/KvStateClientProxyHandler.java
---
[
https://issues.apache.org/jira/browse/FLINK-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484132#comment-16484132
]
ASF GitHub Bot commented on FLINK-7814:
---
Github user Xpray commented on the issue:
Github user Xpray commented on the issue:
https://github.com/apache/flink/pull/6027
@twalthr I've updated the PR.
Best.
---
[
https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484129#comment-16484129
]
Pavel Shvetsov edited comment on FLINK-6016 at 5/22/18 3:18 PM:
Could you
[
https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484129#comment-16484129
]
Pavel Shvetsov commented on FLINK-6016:
---
Could you please tell how to reproduce the issue?
>
[
https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484117#comment-16484117
]
Xingcan Cui commented on FLINK-9219:
Hi [~twalthr], I cannot think out why the static method
[
https://issues.apache.org/jira/browse/FLINK-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484114#comment-16484114
]
ASF GitHub Bot commented on FLINK-8838:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5619
---
[
https://issues.apache.org/jira/browse/FLINK-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8838.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed in 1.6.0:
[
https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9410:
-
Assignee: Sihua Zhou
> Replace NMClient with NMClientAsync in YarnResourceManager
>
Till Rohrmann created FLINK-9410:
Summary: Replace NMClient with NMClientAsync in YarnResourceManager
Key: FLINK-9410
URL: https://issues.apache.org/jira/browse/FLINK-9410
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484028#comment-16484028
]
ASF GitHub Bot commented on FLINK-9378:
---
Github user snuyanzin commented on the issue:
Github user snuyanzin commented on the issue:
https://github.com/apache/flink/pull/6032
@twalthr thank you for your review.
To be honest thought about such approach indeed
org.apache.flink.api.common.typeinfo.BasicTypeInfo#toString should be changed
at least to fix case from here
[
https://issues.apache.org/jira/browse/FLINK-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-9166:
-
Summary: Performance issue with many topologies in a single job (was:
Performance issue with
Nico Kruber created FLINK-9409:
--
Summary: Missing assembly-dependencies in flink-dist/pom.xml
Key: FLINK-9409
URL: https://issues.apache.org/jira/browse/FLINK-9409
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16484017#comment-16484017
]
ASF GitHub Bot commented on FLINK-8838:
---
Github user twalthr commented on a diff in the pull
1 - 100 of 254 matches
Mail list logo
