[
https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18881:
Fix Version/s: (was: 1.11.3)
1.11.2
> Modify the Access Broken Link
>
[
https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-18881.
---
Resolution: Fixed
I can access the link [Rides and Fares
[
https://issues.apache.org/jira/browse/FLINK-18881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18881:
Fix Version/s: (was: 1.11.2)
1.11.3
> Modify the Access Broken Link
>
[
https://issues.apache.org/jira/browse/FLINK-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19027:
Fix Version/s: (was: 1.11.2)
1.11.3
>
[
https://issues.apache.org/jira/browse/FLINK-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17191453#comment-17191453
]
Zhu Zhu commented on FLINK-19061:
-
[~lzljs3620320] I can see the fix is merged into master but not into
[
https://issues.apache.org/jira/browse/FLINK-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19061:
Affects Version/s: 1.11.0
> HiveCatalog fails to get partition column stats if partition value contains
[
https://issues.apache.org/jira/browse/FLINK-19061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19061:
Fix Version/s: (was: 1.11.2)
1.11.3
> HiveCatalog fails to get partition column
[
https://issues.apache.org/jira/browse/FLINK-19094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19094:
Fix Version/s: (was: 1.11.2)
1.11.3
> Revise the description of watermark strategy
[
https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18206:
Fix Version/s: (was: 1.11.2)
1.11.3
1.10.3
[
https://issues.apache.org/jira/browse/FLINK-18206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17191450#comment-17191450
]
Zhu Zhu commented on FLINK-18206:
-
Hi [~twalthr], is this issue fixed?
> The timestamp is displayed
[
https://issues.apache.org/jira/browse/FLINK-18460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18460:
Fix Version/s: (was: 1.11.2)
1.11.3
> If the Python UDFs are called before calling
[
https://issues.apache.org/jira/browse/FLINK-18734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18734:
Fix Version/s: (was: 1.11.2)
1.11.3
> Add documentation for DynamoStreams Consumer
[
https://issues.apache.org/jira/browse/FLINK-18654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18654:
Fix Version/s: (was: 1.11.2)
1.11.3
> Correct missleading documentation in
[
https://issues.apache.org/jira/browse/FLINK-18624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18624:
Fix Version/s: (was: 1.11.2)
1.11.3
> Document CREATE TEMPORARY TABLE
>
[
https://issues.apache.org/jira/browse/FLINK-18624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18624:
Affects Version/s: (was: 1.11.0)
> Document CREATE TEMPORARY TABLE
> ---
[
https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18640:
Fix Version/s: (was: 1.11.2)
1.11.3
> Flink jdbc not support postgresql with
[
https://issues.apache.org/jira/browse/FLINK-18633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18633:
Fix Version/s: (was: 1.11.2)
1.11.3
> Download miniconda is instable
>
[
https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18592:
Fix Version/s: (was: 1.11.2)
1.11.3
> StreamingFileSink fails due to truncating
[
https://issues.apache.org/jira/browse/FLINK-18624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18624:
Affects Version/s: 1.11.0
> Document CREATE TEMPORARY TABLE
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-18624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18624:
Fix Version/s: 1.12.0
> Document CREATE TEMPORARY TABLE
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-18479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18479:
Fix Version/s: (was: 1.11.2)
1.11.3
1.12.0
> can not commit
flinkbot edited a comment on pull request #13331:
URL: https://github.com/apache/flink/pull/13331#issuecomment-687585649
## CI report:
* 6a79badae175128326ed4e77708b48488009731c Azure:
[
https://issues.apache.org/jira/browse/FLINK-18376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18376:
Fix Version/s: (was: 1.11.2)
1.11.3
1.10.3
[
https://issues.apache.org/jira/browse/FLINK-18438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18438:
Fix Version/s: (was: 1.11.2)
1.11.3
> TaskManager start failed
>
[
https://issues.apache.org/jira/browse/FLINK-18365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18365:
Fix Version/s: (was: 1.11.2)
1.11.3
1.12.0
> The same sql in a
[
https://issues.apache.org/jira/browse/FLINK-18347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18347:
Fix Version/s: (was: 1.11.2)
1.11.3
> kinesis connector throw Error
[
https://issues.apache.org/jira/browse/FLINK-16612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-16612:
Fix Version/s: (was: 1.11.2)
1.11.3
> Submit job through the rest api, job name
[
https://issues.apache.org/jira/browse/FLINK-17405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17405:
Fix Version/s: (was: 1.11.2)
1.11.3
> add test cases for cancel job in SQL client
[
https://issues.apache.org/jira/browse/FLINK-17329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17329:
Fix Version/s: (was: 1.11.2)
1.11.3
> Quickstarts Scala nightly e2e test failed on
[
https://issues.apache.org/jira/browse/FLINK-16622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-16622:
Fix Version/s: (was: 1.11.2)
1.11.3
> Type ARRAY of table field 'id' does not
dianfu commented on pull request #13232:
URL: https://github.com/apache/flink/pull/13232#issuecomment-688048715
@shuiqiangchen As StreamExecutionEnvironment#add_jars has been merged. Could
you rebase the PR and add documentation on how to specify Java dependencies in
Python DataStream
[
https://issues.apache.org/jira/browse/FLINK-17458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17458:
Fix Version/s: (was: 1.11.2)
1.11.3
>
[
https://issues.apache.org/jira/browse/FLINK-17677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17677:
Fix Version/s: (was: 1.11.2)
1.11.3
> FLINK_LOG_PREFIX recommended in docs is not
[
https://issues.apache.org/jira/browse/FLINK-17691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17691:
Fix Version/s: (was: 1.11.2)
1.11.3
> FlinkKafkaProducer011 transactional.id too
[
https://issues.apache.org/jira/browse/FLINK-17742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17742:
Fix Version/s: (was: 1.11.2)
1.11.3
> Blob file not removed after task was
[
https://issues.apache.org/jira/browse/FLINK-17964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17964:
Fix Version/s: (was: 1.11.2)
1.11.3
> Hivemodule does not support map type
>
[
https://issues.apache.org/jira/browse/FLINK-17964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17964:
Fix Version/s: 1.10.3
> Hivemodule does not support map type
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-18196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18196:
Fix Version/s: (was: 1.11.2)
1.11.3
> flink throws `NullPointerException` when
[
https://issues.apache.org/jira/browse/FLINK-18276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18276:
Fix Version/s: (was: 1.11.2)
1.11.3
> NullPointerException (and potential leak)
[
https://issues.apache.org/jira/browse/FLINK-19097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-19097.
---
Assignee: Shuiqiang Chen
Resolution: Fixed
master: 71ffab626fd69d4ec75a63405637d5e63c8c5ccc
>
dianfu closed pull request #13292:
URL: https://github.com/apache/flink/pull/13292
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
flinkbot edited a comment on pull request #13334:
URL: https://github.com/apache/flink/pull/13334#issuecomment-688015921
## CI report:
* 953e4950c2849bc90c9ef1cd612f6281ddf5c86b Azure:
flinkbot edited a comment on pull request #13209:
URL: https://github.com/apache/flink/pull/13209#issuecomment-677744672
## CI report:
* a343c2c3bf36c97dca7045c65eccbcccfbbef5bf UNKNOWN
* 5c5e70c8a3a1831c1e4715378158eafa93bed707 Azure:
shuiqiangchen opened a new pull request #16:
URL: https://github.com/apache/flink-playgrounds/pull/16
This is a walkthrough for PyFlink, you will learn how to manage and run
PyFlink Jobs. The pipeline of this walkthrough reads data from Kafka, performs
aggregations and writes results to
[
https://issues.apache.org/jira/browse/FLINK-19145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19145:
---
Labels: pull-request-available (was: )
> Add PyFlink-walkthrough to Flink playground.
>
flinkbot edited a comment on pull request #13334:
URL: https://github.com/apache/flink/pull/13334#issuecomment-688015921
## CI report:
* 953e4950c2849bc90c9ef1cd612f6281ddf5c86b Azure:
[
https://issues.apache.org/jira/browse/FLINK-19125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17191433#comment-17191433
]
Yun Tang commented on FLINK-19125:
--
[~fly_in_gis], as discussed offline, jemalloc and JDK are totally
flinkbot edited a comment on pull request #13209:
URL: https://github.com/apache/flink/pull/13209#issuecomment-677744672
## CI report:
* a343c2c3bf36c97dca7045c65eccbcccfbbef5bf UNKNOWN
* 5c5e70c8a3a1831c1e4715378158eafa93bed707 Azure:
[
https://issues.apache.org/jira/browse/FLINK-12148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-12148.
---
Resolution: Won't Fix
> Give precedence to specified local jar when same mainClass is included in
> both
[
https://issues.apache.org/jira/browse/FLINK-12148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reopened FLINK-12148:
-
> Give precedence to specified local jar when same mainClass is included in
> both lib and specified jar
>
[
https://issues.apache.org/jira/browse/FLINK-12148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-12148.
---
Resolution: Fixed
Closing it for now since there was no update from the initial reporter and 1.8
is
JingsongLi commented on a change in pull request #13306:
URL: https://github.com/apache/flink/pull/13306#discussion_r484170111
##
File path:
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcFilters.java
##
@@ -0,0 +1,372 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-15262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15262:
Fix Version/s: (was: 1.11.2)
1.11.3
> kafka connector doesn't read from beginning
[
https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14159:
Fix Version/s: (was: 1.11.2)
1.11.3
> flink rocksdb StreamCompressionDecorator not
[
https://issues.apache.org/jira/browse/FLINK-19125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19125:
Fix Version/s: (was: 1.11.2)
1.11.3
> Avoid memory fragmentation when running
flinkbot edited a comment on pull request #13334:
URL: https://github.com/apache/flink/pull/13334#issuecomment-688015921
## CI report:
* 953e4950c2849bc90c9ef1cd612f6281ddf5c86b Azure:
flinkbot edited a comment on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-684516974
## CI report:
* d56c66109ce4d8f4012e4e1470b88f34fb68dd99 Azure:
flinkbot edited a comment on pull request #13209:
URL: https://github.com/apache/flink/pull/13209#issuecomment-677744672
## CI report:
* a343c2c3bf36c97dca7045c65eccbcccfbbef5bf UNKNOWN
* 5c5e70c8a3a1831c1e4715378158eafa93bed707 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuiqiang Chen updated FLINK-19145:
---
Description: Add the walkthrough for PyFlink in Flink playground.
> Add PyFlink-walkthrough
[
https://issues.apache.org/jira/browse/FLINK-19145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuiqiang Chen updated FLINK-19145:
---
Summary: Add PyFlink-walkthrough to Flink playground. (was: Add
PyFlink-walkthrough in
Shuiqiang Chen created FLINK-19145:
--
Summary: Add PyFlink-walkthrough in Flink playground.
Key: FLINK-19145
URL: https://issues.apache.org/jira/browse/FLINK-19145
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-19131:
Labels: pull-request-available (was: )
> Add py38 support in PyFlink
>
[
https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-19131:
Labels: (was: python)
> Add py38 support in PyFlink
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-19131:
Labels: python (was: pull-request-available)
> Add py38 support in PyFlink
>
flinkbot commented on pull request #13334:
URL: https://github.com/apache/flink/pull/13334#issuecomment-688015921
## CI report:
* 953e4950c2849bc90c9ef1cd612f6281ddf5c86b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13292:
URL: https://github.com/apache/flink/pull/13292#issuecomment-684516974
## CI report:
* d56c66109ce4d8f4012e4e1470b88f34fb68dd99 Azure:
flinkbot commented on pull request #13334:
URL: https://github.com/apache/flink/pull/13334#issuecomment-688014367
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
flinkbot edited a comment on pull request #6613:
URL: https://github.com/apache/flink/pull/6613#issuecomment-526964862
## CI report:
* 4d48ab513b2b38147013f2b4b824493188fb9269 Azure:
zhijiangW commented on a change in pull request #13209:
URL: https://github.com/apache/flink/pull/13209#discussion_r484169545
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java
##
@@ -609,6 +609,32 @@
[
https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19131:
---
Labels: pull-request-available (was: )
> Add py38 support in PyFlink
>
sunjincheng121 opened a new pull request #13334:
URL: https://github.com/apache/flink/pull/13334
## What is the purpose of the change
*At present, py39 has been released, and many open source projects have
supported PY38, such as, beam, arrow, pandas, etc. so, in this pull
RocMarshal commented on pull request #13271:
URL: https://github.com/apache/flink/pull/13271#issuecomment-688012267
LGTM.
ping @wuchong , @dianfu
This is an automated message from the Apache Git Service.
To respond to
zhijiangW commented on a change in pull request #13209:
URL: https://github.com/apache/flink/pull/13209#discussion_r484164187
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java
##
@@ -136,6 +172,14 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-15298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15298:
Fix Version/s: (was: 1.11.2)
1.11.3
> Wrong dependencies in the DataStream API
JingsongLi commented on a change in pull request #13010:
URL: https://github.com/apache/flink/pull/13010#discussion_r484163628
##
File path:
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/datagen/DataGenVisitorBase.java
##
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-19131:
Environment: (was: At present, py39 has been released, and many open
source projects have
[
https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-19131:
Description: At present, py39 has been released, and many open source
projects have supported
[
https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15471:
Fix Version/s: (was: 1.11.2)
1.11.3
> HA e2e check for empty .out files does not
[
https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhui updated FLINK-19141:
---
Description:
1. I create a flink cluster on yarn
2. I submit my job
3. The job manager logs:
[
https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhui updated FLINK-19141:
---
Description:
1. I create a flink cluster on yarn
2. I submit my job
3. The job manager print logs with
[
https://issues.apache.org/jira/browse/FLINK-15524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15524:
Fix Version/s: (was: 1.11.2)
1.11.3
> Some links in Chinese documents points to
[
https://issues.apache.org/jira/browse/FLINK-15788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15788:
Fix Version/s: (was: 1.11.2)
1.11.3
> Various Kubernetes integration improvements
[
https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhui updated FLINK-19141:
---
Summary: Flink Job Submitted on Yarn Does not Assign Task Manager (was:
Flink Job Submitted on Yarn Does
[
https://issues.apache.org/jira/browse/FLINK-16585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-16585:
Fix Version/s: (was: 1.11.2)
1.11.3
> Table program cannot be compiled.Cannot
[
https://issues.apache.org/jira/browse/FLINK-16324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-16324:
Fix Version/s: (was: 1.11.2)
1.11.3
> Checkpoint tasks progress would display 100%
[
https://issues.apache.org/jira/browse/FLINK-16246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-16246:
Fix Version/s: (was: 1.11.2)
1.11.3
> Exclude "SdkMBeanRegistrySupport" from
[
https://issues.apache.org/jira/browse/FLINK-16218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-16218:
Fix Version/s: (was: 1.11.2)
1.11.3
> Chinese character is garbled when reading
[
https://issues.apache.org/jira/browse/FLINK-15801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15801:
Fix Version/s: (was: 1.11.2)
1.11.3
> Timestamp extractor created from properties
[
https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhui updated FLINK-19141:
---
Description:
1. I create a flink cluster on yarn
2. I submit my job
3. The job manager logs.
[
https://issues.apache.org/jira/browse/FLINK-17642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17642:
Fix Version/s: (was: 1.11.2)
1.11.3
> Exception while reading broken ORC file is
zhijiangW commented on a change in pull request #13209:
URL: https://github.com/apache/flink/pull/13209#discussion_r484164586
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
##
@@ -99,6 +99,10 @@
zhijiangW commented on a change in pull request #13209:
URL: https://github.com/apache/flink/pull/13209#discussion_r484164187
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java
##
@@ -136,6 +172,14 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhui updated FLINK-19141:
---
Attachment: (was: image-2020-09-07-10-52-44-997.png)
> Flink Job Submitted on Yarn Does not Assigned
[
https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhui updated FLINK-19141:
---
Attachment: (was: image-2020-09-07-10-51-49-889.png)
> Flink Job Submitted on Yarn Does not Assigned
zhijiangW commented on a change in pull request #13209:
URL: https://github.com/apache/flink/pull/13209#discussion_r484164187
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java
##
@@ -136,6 +172,14 @@ public void
zhijiangW commented on a change in pull request #13209:
URL: https://github.com/apache/flink/pull/13209#discussion_r484164187
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java
##
@@ -136,6 +172,14 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhui updated FLINK-19141:
---
Description:
1. I create a flink cluster on yarn
2. I submit my job
3. The job manager logs. However, it
[
https://issues.apache.org/jira/browse/FLINK-18915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18915:
Fix Version/s: (was: 1.11.2)
1.11.3
1.12.0
> FIXED_PATH(dummy
[
https://issues.apache.org/jira/browse/FLINK-18815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18815:
Fix Version/s: (was: 1.11.2)
1.11.3
> AbstractCloseableRegistryTest.testClose
[
https://issues.apache.org/jira/browse/FLINK-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19022:
Fix Version/s: (was: 1.11.2)
1.11.3
> AkkaRpcActor failed to start but no
1 - 100 of 207 matches
Mail list logo
