GitHub user maqingxiang opened a pull request:
https://github.com/apache/flink/pull/5357
[hotfix] Eliminate the conditions of parallelism in isChainable
When building StreamGraph, the restriction is added, and the upstream and
downstream nodes of the forward are required to have
[
https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16338862#comment-16338862
]
ASF GitHub Bot commented on FLINK-8364:
---
GitHub user bowenli86 opened a pull request:
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5356
[FLINK-8364][state backend] Add iterator() to ListState which returns empty
iterator when it has no value
## What is the purpose of the change
Add iterator() to ListState which returns
Wojciech Luczkow created FLINK-8510:
---
Summary: Provide access to Delivery envelope in RabbitMQ Source
Key: FLINK-8510
URL: https://issues.apache.org/jira/browse/FLINK-8510
Project: Flink
Shuyi Chen created FLINK-8509:
-
Summary: Remove SqlGroupedWindowFunction from Flink repo
Key: FLINK-8509
URL: https://issues.apache.org/jira/browse/FLINK-8509
Project: Flink
Issue Type: Task
Shuyi Chen created FLINK-8508:
-
Summary: Remove RexSimplify from Flink repo
Key: FLINK-8508
URL: https://issues.apache.org/jira/browse/FLINK-8508
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16338748#comment-16338748
]
ASF GitHub Bot commented on FLINK-7934:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5355
Hi, are there anything new in calcite 1.15 that are critical to flink-table?
---
Shuyi Chen created FLINK-8507:
-
Summary: Upgrade Calcite dependency to 1.16
Key: FLINK-8507
URL: https://issues.apache.org/jira/browse/FLINK-8507
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16338650#comment-16338650
]
ASF GitHub Bot commented on FLINK-7934:
---
GitHub user suez1224 opened a pull request:
GitHub user suez1224 opened a pull request:
https://github.com/apache/flink/pull/5355
[FLINK-7934][Table & SQL API] Upgrade Flink to use Calcite 1.15
## Brief change log
- Update flink-table dependency to use Calcite 1.15
- Add new codegen from EXTRACT since Calcite 1.15
Steven Zhen Wu created FLINK-8506:
-
Summary: fullRestarts Gauge not incremented when jobmanager got
killed
Key: FLINK-8506
URL: https://issues.apache.org/jira/browse/FLINK-8506
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16338361#comment-16338361
]
Bowen Li commented on FLINK-7954:
-
I agree. I've tried a few different ways and it's not easily
[
https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-8364:
Description:
Add iterator() to ListState which returns empty iterator when it has no value
was:
per
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16338297#comment-16338297
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user dyanarose commented on a diff in the pull
Github user dyanarose commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r163692223
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java
---
@@ -0,0 +1,101 @@
[
https://issues.apache.org/jira/browse/FLINK-8484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16338292#comment-16338292
]
ASF GitHub Bot commented on FLINK-8484:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5337
good to have the background info from the email thread. I didn't have a
full picture before
---
[
https://issues.apache.org/jira/browse/FLINK-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8406.
---
> BucketingSink does not detect hadoop file systems
> -
>
[
https://issues.apache.org/jira/browse/FLINK-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8406.
-
Resolution: Fixed
Fixed in
- 1.4.1 via eb6380901e0c62c57eb300b730548c8ad9ec15e0
- 1.5.0 via
[
https://issues.apache.org/jira/browse/FLINK-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8466.
-
Resolution: Fixed
Fixed in
- 1.4.1 via 4d1ba45e78fa4ed6cd5af0405c7988ffaa6dee13
- 1.5.0 via
[
https://issues.apache.org/jira/browse/FLINK-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8466.
---
> ErrorInfo needs to hold Exception as SerializedThrowable
>
[
https://issues.apache.org/jira/browse/FLINK-8499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-8499.
---
> Kryo must not be child-first loaded
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-8499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-8499.
-
Resolution: Fixed
Fixed in
- 1.4.1 via 15cb057bffd32ba8a853b46b207a5b7ea6bba430
- 1.5.0 via
Github user walterddr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5295#discussion_r163684364
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java
---
@@ -0,0 +1,101 @@
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16338257#comment-16338257
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user walterddr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16338001#comment-16338001
]
Till Rohrmann commented on FLINK-8505:
--
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-8505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337997#comment-16337997
]
ASF GitHub Bot commented on FLINK-8505:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5354
[FLINK-8505] [flip6] Prevent SlotManager from reaching an inconsistent state
## What is the purpose of the change
The SlotManager could reach an inconsistent state when a formerly free
Till Rohrmann created FLINK-8505:
Summary: SlotManager can reach inconsistent state
Key: FLINK-8505
URL: https://issues.apache.org/jira/browse/FLINK-8505
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337982#comment-16337982
]
ASF GitHub Bot commented on FLINK-6623:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5351
@zentol I revived and rebased an old branch with an attempt to fix the
concurrency issue of file deletes on Windows:
Github user joerg84 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5346#discussion_r163624908
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
---
@@ -365,6 +386,31 @@ public String
[
https://issues.apache.org/jira/browse/FLINK-8490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337961#comment-16337961
]
ASF GitHub Bot commented on FLINK-8490:
---
Github user joerg84 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337906#comment-16337906
]
ASF GitHub Bot commented on FLINK-8406:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337905#comment-16337905
]
ASF GitHub Bot commented on FLINK-8466:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5330
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5348
---
[
https://issues.apache.org/jira/browse/FLINK-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337902#comment-16337902
]
ASF GitHub Bot commented on FLINK-7124:
---
Github user EronWright commented on the issue:
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/4510
@tzulitai is anything left to do here?
---
[
https://issues.apache.org/jira/browse/FLINK-8439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337897#comment-16337897
]
Stephan Ewen commented on FLINK-8439:
-
Big +1!
> Document using a custom AWS Credentials Provider
[
https://issues.apache.org/jira/browse/FLINK-8439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-8439:
Fix Version/s: 1.4.1
> Document using a custom AWS Credentials Provider with flink-3s-fs-hadoop
>
[
https://issues.apache.org/jira/browse/FLINK-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337865#comment-16337865
]
ASF GitHub Bot commented on FLINK-8503:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5353
[FLINK-8503] [flip6] Display TaskExecutor logs and stdout files in web ui
## What is the purpose of the change
Introduce the AbstractHandler which takes a typed request and returns an
[
https://issues.apache.org/jira/browse/FLINK-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337854#comment-16337854
]
Xuan Nguyen commented on FLINK-8485:
I saw the ClassDefNotFound so I included the:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-8485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337852#comment-16337852
]
Xuan Nguyen commented on FLINK-8485:
Hi [~till.rohrmann] and [~StephanEwen]
# I generated the
[
https://issues.apache.org/jira/browse/FLINK-8439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337845#comment-16337845
]
Aljoscha Krettek commented on FLINK-8439:
-
We could also add code that automatically remaps config
[
https://issues.apache.org/jira/browse/FLINK-8439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8439:
Priority: Blocker (was: Trivial)
> Document using a custom AWS Credentials Provider with
[
https://issues.apache.org/jira/browse/FLINK-8439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8439:
Fix Version/s: 1.5.0
> Document using a custom AWS Credentials Provider with
Github user lishim commented on the issue:
https://github.com/apache/flink/pull/5346
Thanks @joerg84 for your review and comments. I have updated the PR to
address your concerns.
---
[
https://issues.apache.org/jira/browse/FLINK-8490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337843#comment-16337843
]
ASF GitHub Bot commented on FLINK-8490:
---
Github user lishim commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8364:
Summary: Add iterator() to ListState which returns empty iterator when it
has no value
Github user lishim commented on a diff in the pull request:
https://github.com/apache/flink/pull/5346#discussion_r163596583
--- Diff:
flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParametersTest.java
---
@@ -84,6 +84,35 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337837#comment-16337837
]
ASF GitHub Bot commented on FLINK-8490:
---
Github user lishim commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337839#comment-16337839
]
ASF GitHub Bot commented on FLINK-8490:
---
Github user lishim commented on a diff in the pull request:
Github user lishim commented on a diff in the pull request:
https://github.com/apache/flink/pull/5346#discussion_r163596501
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java
---
@@ -365,6 +386,31 @@ public String
[
https://issues.apache.org/jira/browse/FLINK-8490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337834#comment-16337834
]
ASF GitHub Bot commented on FLINK-8490:
---
Github user lishim commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337832#comment-16337832
]
ASF GitHub Bot commented on FLINK-8490:
---
Github user lishim commented on a diff in the pull request:
Github user lishim commented on a diff in the pull request:
https://github.com/apache/flink/pull/5346#discussion_r163595840
--- Diff: docs/ops/config.md ---
@@ -508,6 +508,8 @@ May be set to -1 to disable this feature.
- `mesos.resourcemanager.tasks.container.volumes`: A
Github user lishim commented on a diff in the pull request:
https://github.com/apache/flink/pull/5346#discussion_r163595893
--- Diff: docs/ops/deployment/mesos.md ---
@@ -264,6 +264,8 @@ May be set to -1 to disable this feature.
[
https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337794#comment-16337794
]
Aljoscha Krettek commented on FLINK-8093:
-
So this seems more like a Kafka bug than a Flink bug.
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7129:
Summary: Support dynamically changing CEP patterns (was: Dynamically
changing patterns)
>
[
https://issues.apache.org/jira/browse/FLINK-8407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337780#comment-16337780
]
Aljoscha Krettek commented on FLINK-8407:
-
The culprit is actually this piece of code:
[
https://issues.apache.org/jira/browse/FLINK-8492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337710#comment-16337710
]
ASF GitHub Bot commented on FLINK-8492:
---
Github user hequn8128 commented on the issue:
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/5347
Hi, @fhueske @twalthr ,
To solve the problem, we need to make the `estimateRowCount` in
`CommonCalc` more accurate. I will update the pr tomorrow. Anyway, cost model
can't solve the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5309#discussion_r163571196
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java
---
@@ -228,10 +246,10 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337706#comment-16337706
]
ASF GitHub Bot commented on FLINK-8450:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337703#comment-16337703
]
ASF GitHub Bot commented on FLINK-8450:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337704#comment-16337704
]
ASF GitHub Bot commented on FLINK-8450:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5309#discussion_r163570275
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java
---
@@ -199,12 +212,17 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337705#comment-16337705
]
ASF GitHub Bot commented on FLINK-8450:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5309#discussion_r163546199
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.java
---
@@ -30,62 +30,69 @@
import
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5309#discussion_r163549462
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -331,13 +331,13 @@ public void start() throws Exception {
Till Rohrmann created FLINK-8504:
Summary: TaskExecutor does not properly deregisters JobManager
from JobLeaderService
Key: FLINK-8504
URL: https://issues.apache.org/jira/browse/FLINK-8504
Project:
[
https://issues.apache.org/jira/browse/FLINK-8449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337672#comment-16337672
]
ASF GitHub Bot commented on FLINK-8449:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337670#comment-16337670
]
ASF GitHub Bot commented on FLINK-8449:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337669#comment-16337669
]
ASF GitHub Bot commented on FLINK-8449:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337671#comment-16337671
]
ASF GitHub Bot commented on FLINK-8449:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5308#discussion_r163538231
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -752,16 +751,21 @@ public Executor getFutureExecutor()
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5308#discussion_r163536073
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/accumulators/AccumulatorHelper.java
---
@@ -173,4 +173,23 @@ public static String
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5308#discussion_r163540049
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -1701,40 +1705,4 @@ void notifyExecutionChange(
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5308#discussion_r163544619
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerMockTest.java
---
@@ -250,19 +255,15 @@ public void
Till Rohrmann created FLINK-8503:
Summary: Port TaskManagerLogHandler to new REST endpoint
Key: FLINK-8503
URL: https://issues.apache.org/jira/browse/FLINK-8503
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337621#comment-16337621
]
ASF GitHub Bot commented on FLINK-8146:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337618#comment-16337618
]
ASF GitHub Bot commented on FLINK-8466:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5349
Looks good to me, +1
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5348
Thanks for the review.
Merging this to `master` and `release-1.4`.
---
[
https://issues.apache.org/jira/browse/FLINK-6464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337608#comment-16337608
]
ASF GitHub Bot commented on FLINK-6464:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5332
@aljoscha Done, we now include the function name instead. Is a bit more
complicated that I had hoped though...
---
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337598#comment-16337598
]
Aljoscha Krettek commented on FLINK-8500:
-
The timestamp of Kafka messages is attached to
[
https://issues.apache.org/jira/browse/FLINK-8498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8498:
Priority: Blocker (was: Major)
> GetExecutionPlan fails with IllegalArgumentException in
[
https://issues.apache.org/jira/browse/FLINK-8498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8498:
Fix Version/s: 1.4.1
1.5.0
> GetExecutionPlan fails with
[
https://issues.apache.org/jira/browse/FLINK-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337579#comment-16337579
]
Aljoscha Krettek commented on FLINK-8477:
-
Could you please provide some details about what this
Github user GJL commented on the issue:
https://github.com/apache/flink/pull/5309
This PR is based on #5308
---
[
https://issues.apache.org/jira/browse/FLINK-8450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337580#comment-16337580
]
ASF GitHub Bot commented on FLINK-8450:
---
Github user GJL commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8472:
Priority: Blocker (was: Critical)
> Extend migration tests for Flink 1.4
>
[
https://issues.apache.org/jira/browse/FLINK-8470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337578#comment-16337578
]
Aljoscha Krettek commented on FLINK-8470:
-
Hi,
what is the motivation for these types of Triggers?
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16337576#comment-16337576
]
Aljoscha Krettek commented on FLINK-8468:
-
Please open a PR for this change if you want.
>
[
https://issues.apache.org/jira/browse/FLINK-8468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8468:
Summary: Allow RMQSink to be extended (was: Allow the sink to be extended
)
> Allow
[
https://issues.apache.org/jira/browse/FLINK-8445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8445.
---
> hostname used in metric names for taskmanager and jobmanager are not
> consistent
>
1 - 100 of 256 matches
Mail list logo
