[
https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512210#comment-17512210
]
Yuan Zhu commented on FLINK-25409:
--
Hi, [~martijnvisser], [~jingzhang], [~wenlong.lwl].
I have
[
https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509632#comment-17509632
]
Zhu Zhu commented on FLINK-26760:
-
cc [~afedulov]
> The new CSV source (file system source + CSV
[
https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26760:
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> The new CSV source (file system source +
[
https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reopened FLINK-24892:
-
Would you add a release note for this feature? [~wanglijie95]
> FLIP-187: Adaptive Batch Scheduler
>
[
https://issues.apache.org/jira/browse/FLINK-25226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25226.
---
Resolution: Done
Merged into
master: 192351ecfb0392fa0ad32f40b84306b1f8d6c69c
release-1.15:
[
https://issues.apache.org/jira/browse/FLINK-26722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-26722.
---
Resolution: Not A Problem
> the result is wrong when using file connector with csv format
>
[
https://issues.apache.org/jira/browse/FLINK-26692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26692:
Fix Version/s: 1.16.0
> migrate TpcdsTestProgram.java to new source
>
[
https://issues.apache.org/jira/browse/FLINK-26692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26692:
Affects Version/s: 1.15.0
> migrate TpcdsTestProgram.java to new source
>
[
https://issues.apache.org/jira/browse/FLINK-26692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508538#comment-17508538
]
Zhu Zhu commented on FLINK-26692:
-
Thanks for the offering to take the ticket [~Leo Zhou].
I have assign
[
https://issues.apache.org/jira/browse/FLINK-26692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-26692:
---
Assignee: zl
> migrate TpcdsTestProgram.java to new source
>
[
https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507075#comment-17507075
]
Zhu Zhu edited comment on FLINK-26548 at 3/15/22, 5:19 PM:
---
As discussed in
[
https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507075#comment-17507075
]
Zhu Zhu commented on FLINK-26548:
-
As discussed in #19040, a proper fix of this problem would be to
[
https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26548:
Priority: Critical (was: Blocker)
> the source parallelism is not set correctly with
[
https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26548:
Fix Version/s: 1.16.0
(was: 1.15.0)
> the source parallelism is not set correctly
[
https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504192#comment-17504192
]
Zhu Zhu commented on FLINK-26548:
-
Thanks for reporting this issue and offering to fix it! [~Leo Zhou]
I
[
https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-26548:
---
Assignee: zl
> the source parallelism is not set correctly with AdaptiveBatchScheduler
>
[
https://issues.apache.org/jira/browse/FLINK-26579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-26579.
---
Fix Version/s: (was: 1.15.0)
Resolution: Duplicate
> The default source parallelism
[
https://issues.apache.org/jira/browse/FLINK-26517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-26517.
---
Resolution: Fixed
master/release-1.15:
4d42c642cc3c45acf25d41172f6a2132d4c6c60b
> Normalize the decided
[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503331#comment-17503331
]
Yuan Zhu commented on FLINK-26437:
--
[~jark] Thanks for your advice. [~arindbha], you can try as [~jark]
[
https://issues.apache.org/jira/browse/FLINK-26517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26517:
Affects Version/s: 1.15.0
> Normalize the decided parallelism to power of 2 when using adaptive batch
>
[
https://issues.apache.org/jira/browse/FLINK-26517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-26517:
---
Assignee: Lijie Wang
> Normalize the decided parallelism to power of 2 when using adaptive batch
[
https://issues.apache.org/jira/browse/FLINK-26400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500466#comment-17500466
]
Zhu Zhu edited comment on FLINK-26400 at 3/3/22, 2:44 AM:
--
Here's what I see on
[
https://issues.apache.org/jira/browse/FLINK-26400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500466#comment-17500466
]
Zhu Zhu commented on FLINK-26400:
-
Here's what I see on the page "Limited integration with Flink’s Web
[
https://issues.apache.org/jira/browse/FLINK-26400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26400:
Attachment: errors_on_opening_job_page_when_job_gets_no_resources.png
> Release Testing: Explicit
[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500459#comment-17500459
]
Yuan Zhu commented on FLINK-26437:
--
In my local env(wsl-ubuntu-20.04), I can run "sql-client.sh
[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Zhu updated FLINK-26437:
-
Attachment: image-2022-03-03-10-03-50-763.png
> Cannot discover a connector using option:
[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500215#comment-17500215
]
Yuan Zhu commented on FLINK-26437:
--
How do you submit your sql? Are you using sql client locally?
>
[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500105#comment-17500105
]
Yuan Zhu commented on FLINK-26437:
--
You can try add [hadoop
[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500105#comment-17500105
]
Yuan Zhu edited comment on FLINK-26437 at 3/2/22, 12:28 PM:
You can try
[
https://issues.apache.org/jira/browse/FLINK-26400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1740#comment-1740
]
Zhu Zhu edited comment on FLINK-26400 at 3/2/22, 9:09 AM:
--
I have done the test
[
https://issues.apache.org/jira/browse/FLINK-26400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1740#comment-1740
]
Zhu Zhu commented on FLINK-26400:
-
I have done the test and the result looks good. The stopped
[
https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499843#comment-17499843
]
Yuan Zhu commented on FLINK-26437:
--
Do you have
[
https://issues.apache.org/jira/browse/FLINK-26400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499370#comment-17499370
]
Zhu Zhu commented on FLINK-26400:
-
I'd like to take this ticket if no one else already plans to take it.
[
https://issues.apache.org/jira/browse/FLINK-26052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498670#comment-17498670
]
Shen Zhu commented on FLINK-26052:
--
Hi [~dwysakowicz] , I'm interested in translating these commits to
[
https://issues.apache.org/jira/browse/FLINK-26358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498532#comment-17498532
]
Shen Zhu edited comment on FLINK-26358 at 2/27/22, 6:38 AM:
Hi Fabian,
I
[
https://issues.apache.org/jira/browse/FLINK-26358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498532#comment-17498532
]
Shen Zhu commented on FLINK-26358:
--
Hi Fabian,
I did some investigations about this issue and seems
[
https://issues.apache.org/jira/browse/FLINK-26217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495884#comment-17495884
]
Shen Zhu commented on FLINK-26217:
--
Hey [~lzljs3620320] , I'm interested in working on this ticket,
[
https://issues.apache.org/jira/browse/FLINK-25225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25225.
---
Resolution: Done
master/release-1.15:
5c7a432778f2f8494e104fa89ea08a71e83978b1
> Add e2e TPCDS tests to
[
https://issues.apache.org/jira/browse/FLINK-26168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26168:
Component/s: Runtime / Coordination
> The judgment of chainable ignores StreamExchangeMode when
[
https://issues.apache.org/jira/browse/FLINK-26168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-26168.
---
Resolution: Done
master/release-1.15:
8f3a0251d195ed2532abc31e602029dfcbf7bc77
> The judgment of chainable
[
https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493621#comment-17493621
]
Yuan Zhu edited comment on FLINK-25409 at 2/17/22, 3:08 AM:
Hi, all. Sorry
[
https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493621#comment-17493621
]
Yuan Zhu commented on FLINK-25409:
--
Hi, all. Sorry for my late reply. As discussion before, I make a
[
https://issues.apache.org/jira/browse/FLINK-26148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493154#comment-17493154
]
Zhu Zhu commented on FLINK-26148:
-
[~wanglijie95] would you update FLIP-187 for the configuration name
[
https://issues.apache.org/jira/browse/FLINK-26148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-26148.
---
Resolution: Done
master/release-1.15:
4f20772ca2e36358f51d656b78e45a3e966d6f9e
> Change the format of
[
https://issues.apache.org/jira/browse/FLINK-26168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-26168:
---
Assignee: Lijie Wang
> The judgment of chainable ignores StreamExchangeMode when partitioner is
>
[
https://issues.apache.org/jira/browse/FLINK-26168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26168:
Fix Version/s: 1.15.0
> The judgment of chainable ignores StreamExchangeMode when partitioner is
>
[
https://issues.apache.org/jira/browse/FLINK-26148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26148:
Fix Version/s: 1.15.0
> Change the format of adaptive batch scheduler config option to
>
[
https://issues.apache.org/jira/browse/FLINK-26148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-26148:
---
Assignee: Lijie Wang
> Change the format of adaptive batch scheduler config option to
>
[
https://issues.apache.org/jira/browse/FLINK-25225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25225:
---
Assignee: Lijie Wang
> Add e2e TPCDS tests to run against the AdaptiveBatchScheduler
>
[
https://issues.apache.org/jira/browse/FLINK-25226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25226:
---
Assignee: Lijie Wang
> Add documentation about the AdaptiveBatchScheduler
>
[
https://issues.apache.org/jira/browse/FLINK-25046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25046.
---
Resolution: Done
master/release-1.15:
d0859f6a74e883a9f3123d2e83b154568e202f7a
> Convert unspecified edge
[
https://issues.apache.org/jira/browse/FLINK-25046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25046:
---
Assignee: Lijie Wang
> Convert unspecified edge to rescale when using adapive batch scheduler
>
[
https://issues.apache.org/jira/browse/FLINK-25046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-25046:
Fix Version/s: 1.15.0
> Convert unspecified edge to rescale when using adapive batch scheduler
>
[
https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491959#comment-17491959
]
Yuan Zhu commented on FLINK-25529:
--
Replacing orc-core-1.5.6 with orc-core-1.5.6-nohive will invoke
[
https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491547#comment-17491547
]
Yuan Zhu commented on FLINK-25529:
--
[~luoyuxia] You are right that there is no orc-core classes in
[
https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-26004.
---
Fix Version/s: 1.15.0
Resolution: Done
master/release-1.15:
b4d5b66df4066ab9d97e9263714c3a8bcc3063a2
[
https://issues.apache.org/jira/browse/FLINK-25996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25996.
---
Resolution: Done
master/release-1.15:
90159f4c7f364f9264e0373c0b1ffa7cafa04cbc
> Introduce job property
[
https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-26004:
---
Assignee: Lijie Wang
> Introduce ForwardForConsecutiveHashPartitioner
>
[
https://issues.apache.org/jira/browse/FLINK-25996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25996:
---
Assignee: Lijie Wang
> Introduce job property isDynamicGraph to ExecutionConfig
>
[
https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-25995:
Summary: Make implicit assumption of SQL local hash explicit (was: Make
implicit assumption of SQL local
[
https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-25995:
Description:
If there are multiple consecutive and the same hash shuffles, SQL planner will
change them
[
https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26004:
Description:
If there are multiple consecutive and the same hash shuffles, SQL planner will
change them
[
https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-26004:
Description:
If there are multiple consecutive the same hash shuffle(i.e. keyBy), SQL
planner will
[
https://issues.apache.org/jira/browse/FLINK-25996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-25996:
Description:
To enable FLINK-25995 and FLINK-25046 only in dynamic graph scenario, we need a
property
[
https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488779#comment-17488779
]
Yuan Zhu commented on FLINK-25529:
--
[~luoyuxia] I try hive-exec-2.2.0.jar. It will cause Exception:
[
https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-25995:
Description:
If there are multiple consecutive the same groupBy(i.e. keyBy), SQL planner
will change
[
https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-25995:
Description:
If there are multiple consecutive the same groupBy(i.e. keyBy), SQL planner
will change
Zhu Zhu created FLINK-25996:
---
Summary: Introduce job property isDynamicGraph to ExecutionConfig
Key: FLINK-25996
URL: https://issues.apache.org/jira/browse/FLINK-25996
Project: Flink
Issue Type:
Zhu Zhu created FLINK-25995:
---
Summary: Make implicit assumption of SQL local keyBy/groupBy
explicit
Key: FLINK-25995
URL: https://issues.apache.org/jira/browse/FLINK-25995
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487402#comment-17487402
]
Yuan Zhu commented on FLINK-18779:
--
Hi [~godfreyhe] , I have fixed the conflicts of this pr. Since it
[
https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486799#comment-17486799
]
Yuan Zhu commented on FLINK-25529:
--
[~luoyuxia] If I add the hive-exec-2.1.1.jar and
[
https://issues.apache.org/jira/browse/FLINK-25045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25045.
---
Fix Version/s: 1.15.0
Resolution: Done
master/release-1.15:
f42a92ccfbace9871834dd039a4e2025926b190c
[
https://issues.apache.org/jira/browse/FLINK-25035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25035.
---
Fix Version/s: 1.15.0
Resolution: Done
master/release-1.15:
f4fd4f8bb66867821cb0f171218d85f8386b0897
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482848#comment-17482848
]
Zhu Zhu commented on FLINK-25649:
-
Yes, your Flink session uses kubernetes to serve as its HA service,
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482307#comment-17482307
]
Zhu Zhu commented on FLINK-25649:
-
I took a look at the logs. Looks to me the problem is the slow leader
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17482307#comment-17482307
]
Zhu Zhu edited comment on FLINK-25649 at 1/26/22, 7:40 AM:
---
I took a look at
[
https://issues.apache.org/jira/browse/FLINK-25668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25668.
---
Fix Version/s: 1.15.0
Resolution: Done
master/release-1.15:
7962a5d9c47f49f435f822a1af2c4141c42a849b
[
https://issues.apache.org/jira/browse/FLINK-25669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25669.
---
Fix Version/s: 1.15.0
Resolution: Done
master/release-1.5:
8fc657b899ec740a348c84a6f387c3806584f999
[
https://issues.apache.org/jira/browse/FLINK-25036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25036.
---
Fix Version/s: 1.15.0
Resolution: Done
master/release-1.15:
e5c1e67e2169534d5e837e5690360b075b66dd75
[
https://issues.apache.org/jira/browse/FLINK-25033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25033.
---
Fix Version/s: 1.15.0
Resolution: Done
master/release-1.15:
82b07035719ac25c9256a1f273019410ee3ca4e7
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479064#comment-17479064
]
Zhu Zhu edited comment on FLINK-25649 at 1/20/22, 4:25 AM:
---
You can also send
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479064#comment-17479064
]
Zhu Zhu commented on FLINK-25649:
-
You can also send the logs to me (reed...@gmail.com).
> Scheduling
[
https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478638#comment-17478638
]
Yuan Zhu commented on FLINK-25529:
--
Hi, [~luoyuxia] , thanks for your attention.
My hive version is
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478365#comment-17478365
]
Zhu Zhu commented on FLINK-25649:
-
>> Would it make sens to say that we encounter this issue because 2
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477072#comment-17477072
]
Zhu Zhu commented on FLINK-25649:
-
>From your description, it's possible that your cluster does not have
[
https://issues.apache.org/jira/browse/FLINK-25668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25668:
---
Assignee: Lijie Wang
> Support calcuate network memory for dynamic graph.
>
[
https://issues.apache.org/jira/browse/FLINK-25669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25669:
---
Assignee: Lijie Wang
> Support register operator coordinators for newly initialized
>
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476945#comment-17476945
]
Zhu Zhu edited comment on FLINK-25649 at 1/17/22, 8:19 AM:
---
Hi [~gdegrove],
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476945#comment-17476945
]
Zhu Zhu commented on FLINK-25649:
-
Hi Gil, just to confirm the scenario,
1. are all the jobs unbounded
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476945#comment-17476945
]
Zhu Zhu edited comment on FLINK-25649 at 1/17/22, 3:59 AM:
---
Hi [~gdegrove],
[
https://issues.apache.org/jira/browse/FLINK-25034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25034.
---
Fix Version/s: 1.15.0
Resolution: Done
master/release-1.15:
856652435b2b65933c0b09e780a6229c62a854e4
[
https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-24892:
Fix Version/s: 1.15.0
> FLIP-187: Adaptive Batch Scheduler
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-25032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25032.
---
Fix Version/s: 1.15.0
Resolution: Done
master/1.15:
d2bfe404e199f98115df419232399bcc11b59e5a
Yuan Zhu created FLINK-25529:
Summary: java.lang.ClassNotFoundException:
org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table
Key: FLINK-25529
URL:
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-18295.
---
Fix Version/s: 1.15.0
Resolution: Fixed
master/1.15:
15255565ad1ec6261db4e1c9211fe9b85ca77ac3
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-18295:
---
Assignee: Zhu Zhu
> Remove the hack logics of result consumers
>
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Description:
Currently an {{IntermediateDataSet}} can have multiple consumer {{JobEdge}}.
That's why the
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Description:
Currently an {{IntermediateDataSet}} can have multiple consumer {{JobEdge}}.
That's why the
[
https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463553#comment-17463553
]
Yuan Zhu edited comment on FLINK-25409 at 12/22/21, 3:06 AM:
-
In 1.14.2,
[
https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463553#comment-17463553
]
Yuan Zhu commented on FLINK-25409:
--
In 1.14.2, neglecting some private LookupFunctions outside of
701 - 800 of 2585 matches
Mail list logo