tillrohrmann closed pull request #11313: [FLINK-16373] Make
JobManagerLeaderListener thread safe
URL: https://github.com/apache/flink/pull/11313
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061775#comment-17061775
]
Jiayi Liao edited comment on FLINK-16001 at 3/18/20, 3:49 PM:
--
[~gjy]
[
https://issues.apache.org/jira/browse/FLINK-16432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061840#comment-17061840
]
Piotr Nowojski commented on FLINK-16432:
another instances:
[
https://issues.apache.org/jira/browse/FLINK-16432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-16432:
---
Fix Version/s: 1.11.0
> Building Hive connector gives problems
>
[
https://issues.apache.org/jira/browse/FLINK-16277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061838#comment-17061838
]
Timo Walther commented on FLINK-16277:
--
A workaround is to simply call:
{code}
tEnv.toAppendStream(
tillrohrmann commented on issue #11313: [FLINK-16373] Make
JobManagerLeaderListener thread safe
URL: https://github.com/apache/flink/pull/11313#issuecomment-600703742
Thanks for the review @zentol and @TisonKun. Merging this PR now.
[
https://issues.apache.org/jira/browse/FLINK-16373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-16373:
--
Fix Version/s: 1.11.0
> EmbeddedLeaderService: IllegalStateException: The RPC connection is
[
https://issues.apache.org/jira/browse/FLINK-16432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061835#comment-17061835
]
Robert Metzger commented on FLINK-16432:
For better discoverability of this ticket, this is a
[
https://issues.apache.org/jira/browse/FLINK-16411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061833#comment-17061833
]
Robert Metzger commented on FLINK-16411:
[~pnowojski] The first message belongs to this ticket
[
https://issues.apache.org/jira/browse/FLINK-16583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061832#comment-17061832
]
Piotr Nowojski commented on FLINK-16583:
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061834#comment-17061834
]
Timo Walther commented on FLINK-16622:
--
This code is very confusing. {{BasicArrayTypeInfo}} should
flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support
LocalZonedTimestampType for Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11439#issuecomment-600585411
## CI report:
* b8aa27ee90dac9820c29551644431f004094c527 Travis:
flinkbot commented on issue #11445: [FLINK-16615] Introduce data structures and
utilities to calculate Job Manager memory components
URL: https://github.com/apache/flink/pull/11445#issuecomment-600698458
## CI report:
* f52138d05035c45dcb23dccf644b977fabeaa269 UNKNOWN
[
https://issues.apache.org/jira/browse/FLINK-15661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-15661.
-
Fix Version/s: (was: 1.11.0)
Resolution: Cannot Reproduce
Closing this issue for the
[
https://issues.apache.org/jira/browse/FLINK-16411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061825#comment-17061825
]
Piotr Nowojski edited comment on FLINK-16411 at 3/18/20, 3:42 PM:
--
Is
[
https://issues.apache.org/jira/browse/FLINK-16411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061825#comment-17061825
]
Piotr Nowojski edited comment on FLINK-16411 at 3/18/20, 3:42 PM:
--
Is
rmetzger edited a comment on issue #11316: [FLINK-16432] Fix dependencies in
Hive Connector build
URL: https://github.com/apache/flink/pull/11316#issuecomment-600546333
According to my local testing (currently being verified on CI), moving the
repository definition Niels proposed to the
[
https://issues.apache.org/jira/browse/FLINK-16411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061825#comment-17061825
]
Piotr Nowojski edited comment on FLINK-16411 at 3/18/20, 3:39 PM:
--
Is
[
https://issues.apache.org/jira/browse/FLINK-16433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee resolved FLINK-16433.
--
Resolution: Fixed
release-1.10: 15b08d0d9da49a92640a9bb59567292eb544947f
master:
[
https://issues.apache.org/jira/browse/FLINK-16411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061825#comment-17061825
]
Piotr Nowojski commented on FLINK-16411:
Is this Another example of this issue?
{noformat}
JingsongLi merged pull request #11442: [FLINK-16433][table-api]
TableEnvironmentImpl doesn't clear buffered …
URL: https://github.com/apache/flink/pull/11442
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-16476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-16476:
---
Priority: Critical (was: Major)
> SelectivityEstimatorTest logs LinkageErrors
>
[
https://issues.apache.org/jira/browse/FLINK-16476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-16476:
---
Fix Version/s: 1.11.0
> SelectivityEstimatorTest logs LinkageErrors
>
[
https://issues.apache.org/jira/browse/FLINK-16476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061819#comment-17061819
]
Piotr Nowojski commented on FLINK-16476:
Is this the same failure/issue?
{noformat}
flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support
LocalZonedTimestampType for Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11439#issuecomment-600585411
## CI report:
* b8aa27ee90dac9820c29551644431f004094c527 Travis:
flinkbot edited a comment on issue #11444: [FLINK-16608][python] Support
primitive data types for vectorized Python UDF
URL: https://github.com/apache/flink/pull/11444#issuecomment-600678571
## CI report:
* f2ef0c0c560faa93cc7663ae7080676488066a10 Travis:
flinkbot edited a comment on issue #11443: [FLINK-14791][coordination]
ResourceManager tracks ClusterPartitions
URL: https://github.com/apache/flink/pull/11443#issuecomment-600657884
## CI report:
* 0240c441a2ea285e49af3172c2e5829207be011b Travis:
[
https://issues.apache.org/jira/browse/FLINK-16659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061810#comment-17061810
]
Jark Wu commented on FLINK-16659:
-
Hi [~robinjun]. Thanks for reporting. Could you translate the content
[
https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061809#comment-17061809
]
Piyush Narang commented on FLINK-11499:
---
Adding a couple of questions we had based on an offline
wuchong commented on issue #11442: [FLINK-16433][table-api]
TableEnvironmentImpl doesn't clear buffered …
URL: https://github.com/apache/flink/pull/11442#issuecomment-600686486
cc @godfreyhe
This is an automated message
flinkbot commented on issue #11445: [FLINK-16615] Introduce data structures and
utilities to calculate Job Manager memory components
URL: https://github.com/apache/flink/pull/11445#issuecomment-600686373
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
azagrebin commented on issue #11445: [FLINK-16615] Introduce data structures
and utilities to calculate Job Manager memory components
URL: https://github.com/apache/flink/pull/11445#issuecomment-600685879
cc @xintongsong
[
https://issues.apache.org/jira/browse/FLINK-16615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16615:
---
Labels: pull-request-available (was: )
> Introduce data structures and utilities to
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reopened FLINK-16651:
-
> flink stream SQL INNER JOIN out-of-order
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-16651.
---
Resolution: Not A Problem
> flink stream SQL INNER JOIN out-of-order
>
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-16651.
---
Resolution: Not A Problem
> flink stream SQL INNER JOIN out-of-order
>
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061805#comment-17061805
]
Jark Wu commented on FLINK-16651:
-
Hi [~wangtaiyang], I guess your question is "the order of join output
azagrebin opened a new pull request #11445: [FLINK-16615] Introduce data
structures and utilities to calculate Job Manager memory components
URL: https://github.com/apache/flink/pull/11445
## What is the purpose of the change
This PR introduces new memory model and its configuration
[
https://issues.apache.org/jira/browse/FLINK-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061802#comment-17061802
]
Jark Wu commented on FLINK-16567:
-
There is an earlier issue for this: FLINK-13691. Please also consider
[
https://issues.apache.org/jira/browse/FLINK-16567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061802#comment-17061802
]
Jark Wu edited comment on FLINK-16567 at 3/18/20, 3:14 PM:
---
There is an
[
https://issues.apache.org/jira/browse/FLINK-16615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-16615:
Description: See [FLIP-116: Unified Memory Configuration for Job
flinkbot edited a comment on issue #11442: [FLINK-16433][table-api]
TableEnvironmentImpl doesn't clear buffered …
URL: https://github.com/apache/flink/pull/11442#issuecomment-600611240
## CI report:
* da405211c976f91760e3cff10ce56554e79a3d8e Travis:
flinkbot commented on issue #11444: [FLINK-16608][python] Support primitive
data types for vectorized Python UDF
URL: https://github.com/apache/flink/pull/11444#issuecomment-600678571
## CI report:
* f2ef0c0c560faa93cc7663ae7080676488066a10 UNKNOWN
Bot commands
flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and
read log by name for taskmanager
URL: https://github.com/apache/flink/pull/11250#issuecomment-592336212
## CI report:
* e474761e49927bb30bac6a297e992dc2ec98e01a UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-16262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061795#comment-17061795
]
Guowei Ma commented on FLINK-16262:
---
hi, [~jkreileder] could you reproduce this problem in the session
[
https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-16627:
Fix Version/s: 1.11.0
> Support only generate non-null values when serializing into JSON
>
[
https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-16627:
Summary: Support only generate non-null values when serializing into JSON
(was: Remove keys with null
[
https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061793#comment-17061793
]
Jark Wu commented on FLINK-16627:
-
Thanks [~jackray], [~libenchao]. Looking forward to a pull request.
twalthr commented on a change in pull request #11340: [Flink 14338] Upgrade
Calcite version to 1.22 for Flink SQL
URL: https://github.com/apache/flink/pull/11340#discussion_r394416361
##
File path:
flink-table/flink-table-planner-blink/src/main/resources/META-INF/NOTICE
[
https://issues.apache.org/jira/browse/FLINK-16090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-16090:
---
Assignee: ShijieZhang
> Translate "Table API" page of "Table API & SQL" into Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061790#comment-17061790
]
Jark Wu commented on FLINK-16622:
-
It looks like a bug to me. But maybe [~twalthr] is more familiar with
twalthr commented on a change in pull request #11340: [Flink 14338] Upgrade
Calcite version to 1.22 for Flink SQL
URL: https://github.com/apache/flink/pull/11340#discussion_r394414753
##
File path: flink-table/flink-table-planner-blink/pom.xml
##
@@ -149,20 +135,28 @@
twalthr commented on a change in pull request #11340: [Flink 14338] Upgrade
Calcite version to 1.22 for Flink SQL
URL: https://github.com/apache/flink/pull/11340#discussion_r394411152
##
File path: flink-table/flink-sql-parser/pom.xml
##
@@ -38,25 +38,39 @@ under the
twalthr commented on a change in pull request #11340: [Flink 14338] Upgrade
Calcite version to 1.22 for Flink SQL
URL: https://github.com/apache/flink/pull/11340#discussion_r394408590
##
File path: flink-table/flink-sql-parser/pom.xml
##
@@ -38,25 +38,39 @@ under the
flinkbot commented on issue #11444: [FLINK-16608][python] Support primitive
data types for vectorized Python UDF
URL: https://github.com/apache/flink/pull/11444#issuecomment-600669960
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
flinkbot edited a comment on issue #11443: [FLINK-14791][coordination]
ResourceManager tracks ClusterPartitions
URL: https://github.com/apache/flink/pull/11443#issuecomment-600657884
## CI report:
* 0240c441a2ea285e49af3172c2e5829207be011b Travis:
flinkbot edited a comment on issue #11441: [FLINK-16653][network][tests]
Introduce ResultPartitionWriterTestBase for simplifying tests
URL: https://github.com/apache/flink/pull/11441#issuecomment-600603644
## CI report:
* 868a19b2c11913e814c529698178234c23fa3e92 Travis:
chenxyz created FLINK-16662:
---
Summary: Blink Planner failed to generate JobGraph for POJO
DataStream converting to Table (Cannot determine simple type name)
Key: FLINK-16662
URL:
flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and
read log by name for taskmanager
URL: https://github.com/apache/flink/pull/11250#issuecomment-592336212
## CI report:
* e474761e49927bb30bac6a297e992dc2ec98e01a UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-16608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16608:
---
Labels: pull-request-available (was: )
> Support primitive data types for vectorized
[
https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061785#comment-17061785
]
Jason Kania commented on FLINK-16468:
-
[~gjy] I will happily update the user docs, but would
dianfu opened a new pull request #11444: [FLINK-16608][python] Support
primitive data types for vectorized Python UDF
URL: https://github.com/apache/flink/pull/11444
## What is the purpose of the change
*This pull request adds support of BooleanType, FloatType, DoubleType,
[
https://issues.apache.org/jira/browse/FLINK-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao closed FLINK-16001.
--
Resolution: Not A Problem
> Avoid using Java Streams in construction of ExecutionGraph
>
[
https://issues.apache.org/jira/browse/FLINK-16001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061775#comment-17061775
]
Jiayi Liao commented on FLINK-16001:
[~gjy] You're right that this doesn't help the performance. I'm
flinkbot edited a comment on issue #11440:
[FLINK-16647][table-runtime-blink][hive] Miss file extension when ins…
URL: https://github.com/apache/flink/pull/11440#issuecomment-600593420
## CI report:
* 728cb59444f3e7b863d1d9faf906038bf1653270 Travis:
flinkbot commented on issue #11443: [FLINK-14791][coordination] ResourceManager
tracks ClusterPartitions
URL: https://github.com/apache/flink/pull/11443#issuecomment-600657884
## CI report:
* 0240c441a2ea285e49af3172c2e5829207be011b UNKNOWN
Bot commands
The
flinkbot edited a comment on issue #11250: [FLINK-16302][rest]add log list and
read log by name for taskmanager
URL: https://github.com/apache/flink/pull/11250#issuecomment-592336212
## CI report:
* e474761e49927bb30bac6a297e992dc2ec98e01a UNKNOWN
*
flinkbot commented on issue #11443: [FLINK-14791][coordination] ResourceManager
tracks ClusterPartitions
URL: https://github.com/apache/flink/pull/11443#issuecomment-600653689
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
[
https://issues.apache.org/jira/browse/FLINK-14791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14791:
---
Labels: pull-request-available (was: )
> Process ClusterPartitionReport on ResourceManager
zentol opened a new pull request #11443: [FLINK-14791][coordination]
ResourceManager tracks ClusterPartitions
URL: https://github.com/apache/flink/pull/11443
Based on #10362 (FLINK-14792).
With this PR the ResourceManager tracks cluster partitions hosted on task
executors, based on
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061762#comment-17061762
]
王太阳 commented on FLINK-16651:
-
[~libenchao] Thank you. I thought I was the only one in this situation
>
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061756#comment-17061756
]
王太阳 edited comment on FLINK-16651 at 3/18/20, 2:11 PM:
---
English has been added
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061756#comment-17061756
]
王太阳 commented on FLINK-16651:
-
z
> flink stream SQL INNER JOIN out-of-order
>
jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add
log list and read log by name for taskmanager
URL: https://github.com/apache/flink/pull/11250#discussion_r394367376
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
王太阳 updated FLINK-16651:
Description:
flink1.9.1：
Chinese：在读取kafka的两个topic(单分区)的时候，注册为两个表并进行 INNER JOIN，数出的结果是乱序的
English：When you read
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
王太阳 updated FLINK-16651:
Description:
flink1.9.1：
Chinese：在读取kafka的两个topic(单分区)的时候，注册为两个表并进行 INNER JOIN，数出的结果是乱序的
English：When you read
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
王太阳 updated FLINK-16651:
Description:
flink1.9.1：
Chinese：在读取kafka的两个topic(单分区)的时候，注册为两个表并进行 INNER JOIN，数出的结果是乱序的
English：When you read
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
王太阳 updated FLINK-16651:
Summary: flink stream SQL INNER JOIN out-of-order (was: flink stream SQL
INNER JOIN乱序)
> flink stream SQL INNER
jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add
log list and read log by name for taskmanager
URL: https://github.com/apache/flink/pull/11250#discussion_r394367376
##
File path:
flinkbot edited a comment on issue #11439: [FLINK-16650][python] Support
LocalZonedTimestampType for Python UDF in blink planner
URL: https://github.com/apache/flink/pull/11439#issuecomment-600585411
## CI report:
* b8aa27ee90dac9820c29551644431f004094c527 Travis:
flinkbot edited a comment on issue #11438: [FLINK-15771][FLINK-16583][tests]
Fix issues around SQLClientKafkaITCase
URL: https://github.com/apache/flink/pull/11438#issuecomment-600585341
## CI report:
* 931d3a26e800af3271851a313e1d9bf5647fa468 Travis:
[
https://issues.apache.org/jira/browse/FLINK-16461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-16461:
--
Priority: Minor (was: Major)
changing priority to minor
> Multiple Bindings with
flinkbot edited a comment on issue #11441: [FLINK-16653][network][tests]
Introduce ResultPartitionWriterTestBase for simplifying tests
URL: https://github.com/apache/flink/pull/11441#issuecomment-600603644
## CI report:
* 868a19b2c11913e814c529698178234c23fa3e92 Travis:
[
https://issues.apache.org/jira/browse/FLINK-16661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-16661:
---
Description:
This will be the final step to support "Application Mode" for Yarn.
So far,
Kostas Kloudas created FLINK-16661:
--
Summary: Introduce the YarnApplicationClusterEntrypoint
Key: FLINK-16661
URL: https://issues.apache.org/jira/browse/FLINK-16661
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-16187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-16187.
---
Resolution: Resolved
> Support Python ML Pipeline API
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-16187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-16187:
Fix Version/s: 1.11.0
> Support Python ML Pipeline API
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-16659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061732#comment-17061732
]
Kurt Young commented on FLINK-16659:
hi, can you translate these to English?
> flink 1.9.1
Kostas Kloudas created FLINK-16660:
--
Summary: Introduce the ApplicationDispatcherBootstrap
Key: FLINK-16660
URL: https://issues.apache.org/jira/browse/FLINK-16660
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-16659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wuchangjun updated FLINK-16659:
---
Description:
流模式排序，多并发运行抛出排序相关异常，1个并发处理正常，替换成CEP模式遇到同样的问题，CEP异常见附件word
wuchangjun created FLINK-16659:
--
Summary: flink 1.9.1 流排序（普通模式、CEP模式）多并发情况下分组异常
Key: FLINK-16659
URL: https://issues.apache.org/jira/browse/FLINK-16659
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-16658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-16658:
---
Description: This will replace the current logic of job execution in the
[
https://issues.apache.org/jira/browse/FLINK-16658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-16658:
---
Summary: Wire the EmbeddedExecutor to the StandaloneJobClusterEntryPoint.
(was: Wire the
[
https://issues.apache.org/jira/browse/FLINK-16655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-16655:
---
Description:
Running the user's {{main}} method in "Application Mode" implies:
1)
[
https://issues.apache.org/jira/browse/FLINK-16651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061725#comment-17061725
]
Jingsong Lee commented on FLINK-16651:
--
Hi [~wangtaiyang], Thanks for reporting. Can you use
Kostas Kloudas created FLINK-16658:
--
Summary: Wire the EmbeddedExecutor to the
StandaloneClusterEntrypoint.
Key: FLINK-16658
URL: https://issues.apache.org/jira/browse/FLINK-16658
Project: Flink
Kostas Kloudas created FLINK-16657:
--
Summary: Wire the EmbeddedExecutor to the Web Submission logic.
Key: FLINK-16657
URL: https://issues.apache.org/jira/browse/FLINK-16657
Project: Flink
Kostas Kloudas created FLINK-16656:
--
Summary: Introduce the DispatcherBootstrap
Key: FLINK-16656
URL: https://issues.apache.org/jira/browse/FLINK-16656
Project: Flink
Issue Type: Sub-task
flinkbot edited a comment on issue #11442: [FLINK-16433][table-api]
TableEnvironmentImpl doesn't clear buffered …
URL: https://github.com/apache/flink/pull/11442#issuecomment-600611240
## CI report:
* da405211c976f91760e3cff10ce56554e79a3d8e Travis:
Kostas Kloudas created FLINK-16655:
--
Summary: Introduce the EmbeddedExecutor
Key: FLINK-16655
URL: https://issues.apache.org/jira/browse/FLINK-16655
Project: Flink
Issue Type: Sub-task
201 - 300 of 564 matches
Mail list logo
