[
https://issues.apache.org/jira/browse/FLINK-10880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10880.
---
Resolution: Fixed
Fix Version/s: 1.5.6
Fixed via
master:
24d70417411ae7c87bae4b607e0b
[
https://issues.apache.org/jira/browse/FLINK-10880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690682#comment-16690682
]
ASF GitHub Bot commented on FLINK-10880:
tillrohrmann closed pull request #7129:
tillrohrmann closed pull request #7131: [BP-1.6][FLINK-10880] Exclude
JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation
URL: https://github.com/apache/flink/pull/7131
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed b
tillrohrmann closed pull request #7132: [BP-1.5][FLINK-10880] Exclude
JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation
URL: https://github.com/apache/flink/pull/7132
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed b
tillrohrmann closed pull request #7130: [BP-1.7][FLINK-10880] Exclude
JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation
URL: https://github.com/apache/flink/pull/7130
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed b
tillrohrmann closed pull request #7129: [FLINK-10880] Exclude
JobManagerOptions#EXECUTION_FAILOVER_STRATEGY from documentation
URL: https://github.com/apache/flink/pull/7129
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
[
https://issues.apache.org/jira/browse/FLINK-10915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fengge updated FLINK-10915:
---
Description:
{code:java}
(deftype Cflatmapfunction [] FlatMapFunction
(flatMap [this value collector]
fengge created FLINK-10915:
--
Summary: clojure context.collectWithTimestamp Will be blocked.
Key: FLINK-10915
URL: https://issues.apache.org/jira/browse/FLINK-10915
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-10915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fengge updated FLINK-10915:
---
Description:
```
(defn -main [& args]
(let [flink-env (StreamExecutionEnvironment/getExecutionEnvironment)
[
https://issues.apache.org/jira/browse/FLINK-10915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fengge updated FLINK-10915:
---
Description:
{code:java}
//代码占位符
{code}
(defn -main [& args] (let [flink-env
(StreamExecutionEnvironment/ge
[
https://issues.apache.org/jira/browse/FLINK-10915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fengge updated FLINK-10915:
---
Description:
{code:java}
(defn -main [& args]
(let [flink-env (StreamExecutionEnvironment/getExecutionEnvi
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690566#comment-16690566
]
ASF GitHub Bot commented on FLINK-9083:
---
BazzalSeed commented on issue #6782: [FLIN
BazzalSeed commented on issue #6782: [FLINK-9083][Cassandra Connector] Add
async backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#issuecomment-439619677
@jparkie thanks. this will be very beneficial for our system. Currently, we
are self-rate limit
TisonKun created FLINK-10914:
Summary: Prefer notifying status changed to waiting and checking
in ExecutionGraph tests
Key: FLINK-10914
URL: https://issues.apache.org/jira/browse/FLINK-10914
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-10914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10914:
-
Description:
Currently there are several tests of {{ExecutionGraph}} based on
{{ExecutionGraphTestUtils
[
https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690520#comment-16690520
]
Shimin Yang commented on FLINK-6756:
Well, I can take this over.
> Provide RichAsync
[
https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690502#comment-16690502
]
wgcn commented on FLINK-10884:
--
Cool. it's my first experience in the community. I will fix
[
https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10884:
--
Affects Version/s: 1.7.0
1.5.5
> Flink on yarn TM container will be ki
[
https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690488#comment-16690488
]
Till Rohrmann commented on FLINK-10884:
---
I think you are right [~1026688210]. We s
[
https://issues.apache.org/jira/browse/FLINK-10913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10913.
-
Resolution: Fixed
Fix Version/s: 1.5.6
Fixed via
master: 1175dbafb0c40808b73016fa554b43bd
Till Rohrmann created FLINK-10913:
-
Summary: ExecutionGraphRestartTest.testRestartAutomatically
unstable on Travis
Key: FLINK-10913
URL: https://issues.apache.org/jira/browse/FLINK-10913
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690474#comment-16690474
]
ASF GitHub Bot commented on FLINK-10845:
xueyumusic commented on a change in pul
xueyumusic commented on a change in pull request #7079: [FLINK-10845][table]
Support multiple different DISTINCT aggregates for batch
URL: https://github.com/apache/flink/pull/7079#discussion_r234403497
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table
tillrohrmann closed pull request #7128: [BP-1.5][FLINK-10906][docker] Don't
print configuration in docker-entrypoint.sh
URL: https://github.com/apache/flink/pull/7128
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sa
[
https://issues.apache.org/jira/browse/FLINK-10906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10906.
---
Resolution: Fixed
Fixed via
master:
https://github.com/apache/flink/commit/3609f36c634027f1
tillrohrmann closed pull request #7127: [BP-1.6][FLINK-10906][docker] Don't
print configuration in docker-entrypoint.sh
URL: https://github.com/apache/flink/pull/7127
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sa
tillrohrmann closed pull request #7126: [BP-1.7][FLINK-10906][docker] Don't
print configuration in docker-entrypoint.sh
URL: https://github.com/apache/flink/pull/7126
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sa
[
https://issues.apache.org/jira/browse/FLINK-10906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690471#comment-16690471
]
ASF GitHub Bot commented on FLINK-10906:
tillrohrmann commented on issue #7125:
[
https://issues.apache.org/jira/browse/FLINK-10906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16690472#comment-16690472
]
ASF GitHub Bot commented on FLINK-10906:
tillrohrmann closed pull request #7125:
tillrohrmann commented on issue #7125: [FLINK-10906][docker] Don't print
configuration in docker-entrypoint.sh
URL: https://github.com/apache/flink/pull/7125#issuecomment-439605128
Thanks for the review @zentol. Merging this PR.
-
tillrohrmann closed pull request #7125: [FLINK-10906][docker] Don't print
configuration in docker-entrypoint.sh
URL: https://github.com/apache/flink/pull/7125
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 pr
31 matches
Mail list logo