[
https://issues.apache.org/jira/browse/FLINK-32315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17810742#comment-17810742
]
Paul Lin commented on FLINK-32315:
--
[~mbalassi] Please go ahead. Thanks!
> Support local file upload
[
https://issues.apache.org/jira/browse/FLINK-32143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760752#comment-17760752
]
Paul Lin commented on FLINK-32143:
--
Looks great! Thanks [~gyfora]
> Automatic cleanup of terminated
Paul Lin created FLINK-32315:
Summary: Support local file upload in K8s mode
Key: FLINK-32315
URL: https://issues.apache.org/jira/browse/FLINK-32315
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727239#comment-17727239
]
Paul Lin commented on FLINK-26541:
--
I've created
Paul Lin created FLINK-32143:
Summary: Automatic cleanup of terminated flinkdeployments
Key: FLINK-32143
URL: https://issues.apache.org/jira/browse/FLINK-32143
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-31965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-31965:
-
Priority: Minor (was: Major)
> Fix ClassNotFoundException in benchmarks
>
[
https://issues.apache.org/jira/browse/FLINK-31965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717573#comment-17717573
]
Paul Lin commented on FLINK-31965:
--
Yes, it runs fine with source codes.
> Fix ClassNotFoundException
[
https://issues.apache.org/jira/browse/FLINK-31965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-31965:
-
Description:
The benchmarks rely on the test jar of `flink-streaming-java`. However, the jar
is set to
Paul Lin created FLINK-31965:
Summary: Fix ClassNotFoundException in benchmarks
Key: FLINK-31965
URL: https://issues.apache.org/jira/browse/FLINK-31965
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690985#comment-17690985
]
Paul Lin commented on FLINK-26541:
--
Is there any ongoing effort currently? I'm happy to take over this
[
https://issues.apache.org/jira/browse/FLINK-30811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682881#comment-17682881
]
Paul Lin edited comment on FLINK-30811 at 2/1/23 8:00 AM:
--
[~qingyue] [~fsk119]
[
https://issues.apache.org/jira/browse/FLINK-30811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17682881#comment-17682881
]
Paul Lin commented on FLINK-30811:
--
[~qingyue] [~fsk119] Sorry for introducing this bug, I should have
[
https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677720#comment-17677720
]
Paul Lin edited comment on FLINK-30677 at 1/17/23 11:28 AM:
[~fsk119] I
[
https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677720#comment-17677720
]
Paul Lin commented on FLINK-30677:
--
[~fsk119] I prefer the old approach too. It's instinctive and
[
https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676872#comment-17676872
]
Paul Lin edited comment on FLINK-30677 at 1/17/23 9:13 AM:
---
-I couldn't
[
https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676872#comment-17676872
]
Paul Lin edited comment on FLINK-30677 at 1/17/23 9:12 AM:
---
~~I couldn't
[
https://issues.apache.org/jira/browse/FLINK-30698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677278#comment-17677278
]
Paul Lin commented on FLINK-30698:
--
Duplicate of https://issues.apache.org/jira/browse/FLINK-30677
>
[
https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676872#comment-17676872
]
Paul Lin commented on FLINK-30677:
--
I couldn't reproduce the error locally. Is that fixed already?
>
[
https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676835#comment-17676835
]
Paul Lin edited comment on FLINK-30677 at 1/14/23 4:16 AM:
---
I think the
[
https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17676835#comment-17676835
]
Paul Lin commented on FLINK-30677:
--
I think the problem lies here:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-28655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-28655:
-
Summary: Support show jobs statement in SqlGatewayService (was: Support
show jobs statement in
Paul Lin created FLINK-30538:
Summary: Improve error handling of stop job operation
Key: FLINK-30538
URL: https://issues.apache.org/jira/browse/FLINK-30538
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616929#comment-17616929
]
Paul Lin commented on FLINK-27344:
--
[~AlexeyLV] Thanks a lot for your input! It's very informative.
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615441#comment-17615441
]
Paul Lin commented on FLINK-27344:
--
[~ekoblov] Sure. It's documented in the FLIP
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17614320#comment-17614320
]
Paul Lin commented on FLINK-27344:
--
[~ekoblov] Yes, we've roughly considered the stored procedures
[
https://issues.apache.org/jira/browse/FLINK-28685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-28685:
-
Priority: Minor (was: Major)
> Optimize CatalogManager getTable implementation
>
[
https://issues.apache.org/jira/browse/FLINK-28685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571188#comment-17571188
]
Paul Lin commented on FLINK-28685:
--
Please assign this issue to me. I have fixed it in our in-house
[
https://issues.apache.org/jira/browse/FLINK-28685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-28685:
-
Description:
Currently, Catalog#getTable(ObjectPath) might be abused in CatalogManager.
CatalogManager
Paul Lin created FLINK-28685:
Summary: Optimize CatalogManager getTable implementation
Key: FLINK-28685
URL: https://issues.apache.org/jira/browse/FLINK-28685
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-28656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-28656:
-
Component/s: Table SQL / API
Table SQL / Gateway
> Support savepoint statements in
[
https://issues.apache.org/jira/browse/FLINK-28657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-28657:
-
Component/s: Table SQL / API
Table SQL / Gateway
> Support drop savepoint statement in
Paul Lin created FLINK-28658:
Summary: Add document for job lifecycle statements
Key: FLINK-28658
URL: https://issues.apache.org/jira/browse/FLINK-28658
Project: Flink
Issue Type: Sub-task
Paul Lin created FLINK-28657:
Summary: Support drop savepoint statement in SqlGatewayService
Key: FLINK-28657
URL: https://issues.apache.org/jira/browse/FLINK-28657
Project: Flink
Issue Type:
Paul Lin created FLINK-28656:
Summary: Support savepoint statements in SqlGatewayService
Key: FLINK-28656
URL: https://issues.apache.org/jira/browse/FLINK-28656
Project: Flink
Issue Type:
Paul Lin created FLINK-28655:
Summary: Support show jobs statement in SqlGatewatService
Key: FLINK-28655
URL: https://issues.apache.org/jira/browse/FLINK-28655
Project: Flink
Issue Type:
Paul Lin created FLINK-28617:
Summary: Support stop job statement in SqlGatewayService
Key: FLINK-28617
URL: https://issues.apache.org/jira/browse/FLINK-28617
Project: Flink
Issue Type: Sub-task
Paul Lin created FLINK-28391:
Summary: DefaultBlocklistHandlerTest unstable
Key: FLINK-28391
URL: https://issues.apache.org/jira/browse/FLINK-28391
Project: Flink
Issue Type: Bug
Paul Lin created FLINK-28363:
Summary: Support drop savepoint statement in SQL client
Key: FLINK-28363
URL: https://issues.apache.org/jira/browse/FLINK-28363
Project: Flink
Issue Type: Sub-task
Paul Lin created FLINK-28362:
Summary: Support savepoint statements in SQL client
Key: FLINK-28362
URL: https://issues.apache.org/jira/browse/FLINK-28362
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-28360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-28360:
-
Summary: Support stop job statement in SQL client (was: Support stop job
operation in SQL client)
>
[
https://issues.apache.org/jira/browse/FLINK-28361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-28361:
-
Summary: Support show jobs statement in SQL client (was: Support show jobs
operation in SQL client)
>
Paul Lin created FLINK-28361:
Summary: Support show jobs operation in SQL client
Key: FLINK-28361
URL: https://issues.apache.org/jira/browse/FLINK-28361
Project: Flink
Issue Type: Sub-task
Paul Lin created FLINK-28360:
Summary: Support stop job operation in SQL client
Key: FLINK-28360
URL: https://issues.apache.org/jira/browse/FLINK-28360
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17558714#comment-17558714
]
Paul Lin commented on FLINK-27344:
--
[~jark][~fsk119][~martijnvisser] please assign this ticket to me,
[
https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-27344:
-
Description:
With the efforts in FLIP-24 and FLIP-91, Flink SQL client supports submitting
SQL jobs
[
https://issues.apache.org/jira/browse/FLINK-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin resolved FLINK-25558.
--
Resolution: Fixed
> TableResult OK may be empty if returned by multiple queries
>
[
https://issues.apache.org/jira/browse/FLINK-27585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-27585:
-
Description:
Currently, JdbcOutpuFormat may periodically flush the batches, and store the
exception if
Paul Lin created FLINK-27585:
Summary: JdbcOutpuFormat fails to flush data on checkpoint and
causes data loss
Key: FLINK-27585
URL: https://issues.apache.org/jira/browse/FLINK-27585
Project: Flink
Paul Lin created FLINK-27344:
Summary: FLIP-222: Support full query lifecycle statements in SQL
client
Key: FLINK-27344
URL: https://issues.apache.org/jira/browse/FLINK-27344
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-26651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510246#comment-17510246
]
Paul Lin commented on FLINK-26651:
--
[~leonard] Looks like it's related to this bug
Paul Lin created FLINK-26720:
Summary: Support stop-with-savepoint on web UI
Key: FLINK-26720
URL: https://issues.apache.org/jira/browse/FLINK-26720
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-23513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-23513:
-
Attachment: Catch(03-16-16-22-14).jpg
> Remove old connectors and formats stack around descriptors
>
[
https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506662#comment-17506662
]
Paul Lin commented on FLINK-26618:
--
cc [~jark][~twalthr]
> Remove jar statement not aligned with
[
https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-26618:
-
Description: Currently, `remove jar` statement doesn't remove the
corresponding jars in pipeline.jars.
[
https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-26618:
-
Component/s: Table SQL / Client
> Remove jar statement not aligned with pipleline.jars
>
Paul Lin created FLINK-26618:
Summary: Remove jar statement not aligned with pipleline.jars
Key: FLINK-26618
URL: https://issues.apache.org/jira/browse/FLINK-26618
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500575#comment-17500575
]
Paul Lin commented on FLINK-25558:
--
Seems that the issue is fixed by FLINK-24685 in Flink 1.15.0.
>
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-26204:
-
Attachment: output-of-window-tvf-test.png
> set table.optimizer.distinct-agg.split.enabled to true and
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497257#comment-17497257
]
Paul Lin edited comment on FLINK-26204 at 2/24/22, 8:43 AM:
I've reproduced
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497257#comment-17497257
]
Paul Lin edited comment on FLINK-26204 at 2/24/22, 8:41 AM:
I've reproduced
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497257#comment-17497257
]
Paul Lin commented on FLINK-26204:
--
I've reproduced the problem with minimum external dependencies.
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-26204:
-
Attachment: WindowTvfTest.java
> set table.optimizer.distinct-agg.split.enabled to true and using
[
https://issues.apache.org/jira/browse/FLINK-26204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495963#comment-17495963
]
Paul Lin commented on FLINK-26204:
--
[~jark] I reproduced the problem locally. It seems that it only
[
https://issues.apache.org/jira/browse/FLINK-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470039#comment-17470039
]
Paul Lin commented on FLINK-25558:
--
Working on the fix. Please assign this issue to me.
> TableResult
[
https://issues.apache.org/jira/browse/FLINK-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-25558:
-
Component/s: Table SQL / API
Affects Version/s: 1.14.0
> TableResult OK may be empty if
[
https://issues.apache.org/jira/browse/FLINK-25558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-25558:
-
Description:
Many queries return `TABLE_RESULT_OK`, which is a static member for reducing
memory
Paul Lin created FLINK-25558:
Summary: TableResult OK may be empty if returned by multiple
queries
Key: FLINK-25558
URL: https://issues.apache.org/jira/browse/FLINK-25558
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-12022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin closed FLINK-12022.
Resolution: Won't Fix
> Enable StreamWriter to update file length on sync flush
>
[
https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459681#comment-17459681
]
Paul Lin commented on FLINK-24948:
--
[~jark] I've prepared a PR, PTAL. Thanks!
> Special character in
[
https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-22300:
-
Issue Type: Bug (was: Improvement)
> Why TimeEvictor of Keyed Windows evictor do not support
[
https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450970#comment-17450970
]
Paul Lin commented on FLINK-22300:
--
[~arvid] For a usage case, how about a global window (no window
[
https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450847#comment-17450847
]
Paul Lin commented on FLINK-22300:
--
[~arvid] Please let me clarify a bit more. The problem is that
[
https://issues.apache.org/jira/browse/FLINK-22300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448954#comment-17448954
]
Paul Lin commented on FLINK-22300:
--
Any follow-ups? I would be happy to take this issue if we reach a
[
https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447789#comment-17447789
]
Paul Lin commented on FLINK-24948:
--
Yes, I'm working on it. May I ask your opinion on the solution?
[
https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447746#comment-17447746
]
Paul Lin commented on FLINK-24948:
--
[~jark] Sure. For example, a table name tbl_a with schema `(.a
[
https://issues.apache.org/jira/browse/FLINK-24948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445685#comment-17445685
]
Paul Lin commented on FLINK-24948:
--
Working on the fix. Please assign this issue to me.
> Special
Paul Lin created FLINK-24948:
Summary: Special character in column names breaks JDBC statement
parsing
Key: FLINK-24948
URL: https://issues.apache.org/jira/browse/FLINK-24948
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433601#comment-17433601
]
Paul Lin commented on FLINK-24628:
--
I'm working on the fix. Please assign this to me.
> Invalid JDBC
Paul Lin created FLINK-24628:
Summary: Invalid JDBC query template when no fields are selected
Key: FLINK-24628
URL: https://issues.apache.org/jira/browse/FLINK-24628
Project: Flink
Issue Type:
Paul Lin created FLINK-24319:
Summary: Jar not found in ClassLoaderITCase
Key: FLINK-24319
URL: https://issues.apache.org/jira/browse/FLINK-24319
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408693#comment-17408693
]
Paul Lin commented on FLINK-19816:
--
Still getting this error with Flink 1.12.3. The jobmanager logs are
[
https://issues.apache.org/jira/browse/FLINK-19816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-19816:
-
Attachment: jm.log
> Flink restored from a wrong checkpoint (a very old one and not the last
>
[
https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403704#comment-17403704
]
Paul Lin commented on FLINK-23725:
--
[~sewen] In the cases I met, the users performed a clean restart
[
https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403519#comment-17403519
]
Paul Lin commented on FLINK-23725:
--
[~todd5167] You're right. The commit operations should be retryable
[
https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-18592:
-
Priority: Major (was: Minor)
> StreamingFileSink fails due to truncating HDFS file failure
>
[
https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402652#comment-17402652
]
Paul Lin commented on FLINK-23725:
--
[~todd5167] Would you like to provide a fix? If not I could take
[
https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402650#comment-17402650
]
Paul Lin edited comment on FLINK-23725 at 8/21/21, 5:18 PM:
I've also met
[
https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402650#comment-17402650
]
Paul Lin edited comment on FLINK-23725 at 8/21/21, 5:17 PM:
I've also met
[
https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402650#comment-17402650
]
Paul Lin commented on FLINK-23725:
--
I've also met this issue. If the file name already exists,
[
https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-23868:
-
Summary: JobExecutionResult printed even if suppressSysout is on (was:
JobExecutionResult printed
[
https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401491#comment-17401491
]
Paul Lin commented on FLINK-23868:
--
Since this is a minor fix, to facilitate the discussion, I made a
[
https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-23868:
-
Description: Environments prints job execution results to stdout by default
and provides a flag
[
https://issues.apache.org/jira/browse/FLINK-23868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-23868:
-
Description: Environments prints job execution results to stdout by default
and provided a flag
Paul Lin created FLINK-23868:
Summary: JobExecutionResult printed event if suppressSysout is on
Key: FLINK-23868
URL: https://issues.apache.org/jira/browse/FLINK-23868
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401428#comment-17401428
]
Paul Lin commented on FLINK-23727:
--
[~paul8263] Thanks for your contribution, but the PR involves
[
https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400787#comment-17400787
]
Paul Lin edited comment on FLINK-23727 at 8/18/21, 5:13 AM:
[~paul8263] WRT
[
https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400787#comment-17400787
]
Paul Lin commented on FLINK-23727:
--
[~paul8263] WRT solutions, I've considered adding a flag as you
[
https://issues.apache.org/jira/browse/FLINK-23703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398420#comment-17398420
]
Paul Lin commented on FLINK-23703:
--
cc [~arvid] [~trohrmann] WDYT?
> Support unrecoverable exception
[
https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-23727:
-
Description: In Kafka use cases, it's valid to send a message with a key
and a null payload as a
[
https://issues.apache.org/jira/browse/FLINK-23727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-23727:
-
Summary: Skip null values in SimpleStringSchema#deserialize (was: Skip
null values in
1 - 100 of 303 matches
Mail list logo
