[jira] [Commented] (FLINK-17182) RemoteInputChannelTest.testConcurrentOnSenderBacklogAndRecycle fail on azure

[ https://issues.apache.org/jira/browse/FLINK-17182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106015#comment-17106015 ] Yun Tang commented on FLINK-17182: -- Another instance: https://dev.azure.com/apache-fli

[jira] [Commented] (FLINK-7267) Add support for lists of hosts to connect

[ https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106005#comment-17106005 ] Aljoscha Krettek commented on FLINK-7267: - But options sound good to me! It's rea

[jira] [Commented] (FLINK-17530) Fix illegal reflective access by ClosureCleaner

[ https://issues.apache.org/jira/browse/FLINK-17530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106002#comment-17106002 ] Aljoscha Krettek commented on FLINK-17530: -- I think A) is not an option. We sho

[jira] [Commented] (FLINK-17529) Replace Deprecated RMQ QueueingConsumer

[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105999#comment-17105999 ] Aljoscha Krettek commented on FLINK-17529: -- No worries! If you think we might d

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105982#comment-17105982 ] xiemeilong commented on FLINK-16662: After upgrade to 1.10.1, a similar issue occurr

[jira] [Comment Edited] (FLINK-17528) Use getters instead of RowData#get() utility in JsonRowDataSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-17528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105430#comment-17105430 ] Yichao Yang edited comment on FLINK-17528 at 5/13/20, 4:22 AM: ---

[jira] [Commented] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105957#comment-17105957 ] Lijie Wang commented on FLINK-17645: Thank you, [~zhuzh] > REAPER_THREAD.start() in

[jira] [Updated] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17645: Fix Version/s: 1.11.0 > REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the > repeate

[jira] [Assigned] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17645: --- Assignee: Lijie Wang > REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the > r

[jira] [Updated] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17645: Affects Version/s: (was: 1.6.3) 1.11.0 1.10.1 > REAPER_T

[jira] [Commented] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105952#comment-17105952 ] Zhu Zhu commented on FLINK-17645: - I have assigned the ticket to you [~wanglijie95]. >

[jira] [Commented] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105949#comment-17105949 ] Zhu Zhu commented on FLINK-17645: - [~wanglijie95] you are right that this issue can stil

[jira] [Comment Edited] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105943#comment-17105943 ] Lijie Wang edited comment on FLINK-17645 at 5/13/20, 3:55 AM:

[jira] [Created] (FLINK-17648) YarnApplicationClusterEntryPoint should override getRPCPortRange

Yang Wang created FLINK-17648: - Summary: YarnApplicationClusterEntryPoint should override getRPCPortRange Key: FLINK-17648 URL: https://issues.apache.org/jira/browse/FLINK-17648 Project: Flink I

[jira] [Comment Edited] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105943#comment-17105943 ] Lijie Wang edited comment on FLINK-17645 at 5/13/20, 3:38 AM:

[jira] [Assigned] (FLINK-17028) Introduce a new HBase connector with new property keys

[ https://issues.apache.org/jira/browse/FLINK-17028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-17028: -- Assignee: Jark Wu > Introduce a new HBase connector with new property keys >

[jira] [Created] (FLINK-17647) Improve new connector options exception in old planner

Jark Wu created FLINK-17647: --- Summary: Improve new connector options exception in old planner Key: FLINK-17647 URL: https://issues.apache.org/jira/browse/FLINK-17647 Project: Flink Issue Type: Sub-

[jira] [Commented] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105943#comment-17105943 ] Lijie Wang commented on FLINK-17645: Yes, it still exists in 1.9 and 1.10. I think w

[jira] [Comment Edited] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105938#comment-17105938 ] Zhu Zhu edited comment on FLINK-17645 at 5/13/20, 3:28 AM: --- Th

[jira] [Commented] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105938#comment-17105938 ] Zhu Zhu commented on FLINK-17645: - Does this problem still exist in 1.9 or 1.10? > REAP

[jira] [Commented] (FLINK-16269) Generic type can not be matched when convert table to stream.

[ https://issues.apache.org/jira/browse/FLINK-16269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105934#comment-17105934 ] xiemeilong commented on FLINK-16269: After upgrade to 1.10.1,  a new type mismatch o

[jira] [Created] (FLINK-17646) Reduce the python package size of PyFlink

Wei Zhong created FLINK-17646: - Summary: Reduce the python package size of PyFlink Key: FLINK-17646 URL: https://issues.apache.org/jira/browse/FLINK-17646 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-17645) REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-17645: Summary: REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the repeated failover

[jira] [Closed] (FLINK-17431) Implement table DDLs for Hive dialect part 1

[ https://issues.apache.org/jira/browse/FLINK-17431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17431. Resolution: Fixed master: 78b516ca366e303a0e541aa69bebe1a15ad7a3c8 > Implement table DDLs for Hiv

[jira] [Updated] (FLINK-17645) REAPER_THREAD in SafetyNetCloseableRegistry start() failed, causing the repeated failover.

[ https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-17645: Description: I'm running a modified version of Flink, and encountered the exception below when ta

[jira] [Closed] (FLINK-17633) Improve FactoryUtil to align with new format options keys

[ https://issues.apache.org/jira/browse/FLINK-17633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17633. --- Resolution: Fixed Fixed in master (1.11.0): 646be5a4c635e069614ce6254556b614bf7b9657 > Improve FactoryUtil

[jira] [Created] (FLINK-17645) REAPER_THREAD in SafetyNetCloseableRegistry start() failed, causing the repeated failover.

Zakelly Lan created FLINK-17645: --- Summary: REAPER_THREAD in SafetyNetCloseableRegistry start() failed, causing the repeated failover. Key: FLINK-17645 URL: https://issues.apache.org/jira/browse/FLINK-17645

[jira] [Assigned] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17640: Assignee: Zhijiang > RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() fail

[jira] [Commented] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105899#comment-17105899 ] Zhijiang commented on FLINK-17640: -- The purpose of this test is for guaranteeing no dea

[jira] [Closed] (FLINK-16364) Deprecate the methods in TableEnvironment proposed by FLIP-84

[ https://issues.apache.org/jira/browse/FLINK-16364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-16364. -- Resolution: Fixed master: 5324b0c53d3ad73cea1f97e9861b7b7373d49f77 > Deprecate the methods in TableEn

[jira] [Commented] (FLINK-17394) Add RemoteEnvironment and RemoteStreamEnvironment in Python

[ https://issues.apache.org/jira/browse/FLINK-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105875#comment-17105875 ] Hequn Cheng commented on FLINK-17394: - Thanks a lot for your feedback. [~aljoscha]

[jira] [Updated] (FLINK-17612) Support Python command line options in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17612: Parent: FLINK-16971 Issue Type: Sub-task (was: Bug) > Support Python command line options in SQL

[jira] [Updated] (FLINK-17612) Support Python command line options in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17612: Summary: Support Python command line options in SQL Client (was: The Python command line options are igno

[jira] [Closed] (FLINK-17612) The Python command line options are ignored by the CliOptionsParser in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17612. --- Fix Version/s: 1.11.0 Resolution: Fixed Merged to master via 722f8445b7f8f2df90af9e8c4b3cfa231d71129d

[jira] [Assigned] (FLINK-17612) The Python command line options are ignored by the CliOptionsParser in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17612: --- Assignee: Wei Zhong > The Python command line options are ignored by the CliOptionsParser in SQL >

[jira] [Assigned] (FLINK-17628) Remove the unnecessary py4j log information

[ https://issues.apache.org/jira/browse/FLINK-17628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17628: --- Assignee: shuiqiangchen > Remove the unnecessary py4j log information > ---

[jira] [Closed] (FLINK-17628) Remove the unnecessary py4j log information

[ https://issues.apache.org/jira/browse/FLINK-17628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17628. --- Fix Version/s: 1.11.0 Resolution: Resolved Merged to master via aa263f8a42b43571e9be674f151b0c95a692a

[jira] [Updated] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17565: - Description: Currently, we are using a version of 4.5.2, it's better that we upgrade it to 4.9.

[jira] [Updated] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17565: - Description: Currently, we are using a version of 4.5.2, it's better that we upgrade it to 4.9.

[jira] [Updated] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.9.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17565: - Description: Currently, we are using a version of 4.5.2, it's better that we upgrade it to 4.9.

[jira] [Commented] (FLINK-17623) Elasticsearch sink should support user resource cleanup

[ https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105837#comment-17105837 ] Yun Wang commented on FLINK-17623: -- [~Leonard Xu] Sure! What I'm trying to achieve is:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:42 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:39 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:38 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:37 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:35 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:35 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:34 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:34 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:32 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:29 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:26 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:25 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:23 PM:

[jira] [Comment Edited] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan edited comment on FLINK-17469 at 5/12/20, 10:17 PM:

[jira] [Commented] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105785#comment-17105785 ] John Lonergan commented on FLINK-17469: --- What I'm really after is to be able to pr

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105753#comment-17105753 ] Igal Shilman edited comment on FLINK-17611 at 5/12/20, 9:25 PM: --

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105753#comment-17105753 ] Igal Shilman edited comment on FLINK-17611 at 5/12/20, 9:24 PM: --

[jira] [Commented] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105753#comment-17105753 ] Igal Shilman commented on FLINK-17611: -- Hi [~slinkydeveloper], Welcome to the proj

[jira] [Closed] (FLINK-17307) Add collector to DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-17307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-17307. Resolution: Fixed Implemented in 63f1d40f130e2c7eecfc05599a94213997ca0801...6119c31a8a07b

[jira] [Created] (FLINK-17644) Add support for state TTL.

Igal Shilman created FLINK-17644: Summary: Add support for state TTL. Key: FLINK-17644 URL: https://issues.apache.org/jira/browse/FLINK-17644 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden

[ https://issues.apache.org/jira/browse/FLINK-17642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikola updated FLINK-17642: --- Description: I have a simple setup of a batch job like this: {code:java} BatchTableEnvironment tableEnvFirst

[jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden

[ https://issues.apache.org/jira/browse/FLINK-17642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikola updated FLINK-17642: --- Component/s: Connectors / ORC > Exception while reading broken ORC file is hidden >

[jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden

[ https://issues.apache.org/jira/browse/FLINK-17642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikola updated FLINK-17642: --- Description: I have a simple setup of a batch job like this: {code:java} BatchTableEnvironment tableEnvFirst

[jira] [Updated] (FLINK-17643) LaunchCoordinatorTest fails

[ https://issues.apache.org/jira/browse/FLINK-17643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17643: Description: Here is the [instance|https://dev.azure.com/arvidheise0209/arvidheise/_build/results

[jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden

[ https://issues.apache.org/jira/browse/FLINK-17642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikola updated FLINK-17642: --- Description: I have a simple setup of a batch job like this: {code:java} BatchTableEnvironment tableEnvFirst

[jira] [Created] (FLINK-17643) LaunchCoordinatorTest fails

Arvid Heise created FLINK-17643: --- Summary: LaunchCoordinatorTest fails Key: FLINK-17643 URL: https://issues.apache.org/jira/browse/FLINK-17643 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-17642) Exception while reading broken ORC file is hidden

Nikola created FLINK-17642: -- Summary: Exception while reading broken ORC file is hidden Key: FLINK-17642 URL: https://issues.apache.org/jira/browse/FLINK-17642 Project: Flink Issue Type: Bug Aff

[jira] [Created] (FLINK-17641) How to secure flink applications on yarn on multi-tenant environment

Ethan Li created FLINK-17641: Summary: How to secure flink applications on yarn on multi-tenant environment Key: FLINK-17641 URL: https://issues.apache.org/jira/browse/FLINK-17641 Project: Flink

[jira] [Closed] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17315. -- Resolution: Fixed Test re-enabled and underlying issues are seemed to be fixed via commits 75

[jira] [Updated] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17315: --- Affects Version/s: (was: 1.11.0) > UnalignedCheckpointITCase.shouldPerformUnalignedCheck

[jira] [Commented] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105633#comment-17105633 ] Piotr Nowojski commented on FLINK-17640: I've disabled the test via {{@Ingore}}

[jira] [Closed] (FLINK-17620) Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint

[ https://issues.apache.org/jira/browse/FLINK-17620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17620. -- Resolution: Implemented Merged on master with 6f724019eb1b751934081572175c14f120510103 > Rena

[jira] [Updated] (FLINK-17632) Support to specify a remote path for job jar

[ https://issues.apache.org/jira/browse/FLINK-17632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17632: --- Affects Version/s: 1.11.0 > Support to specify a remote path for job jar > -

[jira] [Comment Edited] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105621#comment-17105621 ] Piotr Nowojski edited comment on FLINK-17640 at 5/12/20, 5:23 PM:

[jira] [Commented] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105621#comment-17105621 ] Piotr Nowojski commented on FLINK-17640: It looks like an incorrect test. Someti

[jira] [Updated] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17640: --- Labels: test-stability (was: ) > RecoveredInputChannelTest.testConcurrentReadStateAndProces

[jira] [Updated] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17640: --- Affects Version/s: (was: 1.11.0) > RecoveredInputChannelTest.testConcurrentReadStateAndP

[jira] [Commented] (FLINK-17592) flink-table-planner doesn't compile on Scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-17592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105597#comment-17105597 ] Robert Metzger commented on FLINK-17592: fixed through https://github.com/flink

[jira] [Resolved] (FLINK-17592) flink-table-planner doesn't compile on Scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-17592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-17592. Assignee: Aljoscha Krettek (was: godfrey he) Resolution: Fixed > flink-table-planne

[jira] [Created] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

Arvid Heise created FLINK-17640: --- Summary: RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed Key: FLINK-17640 URL: https://issues.apache.org/jira/browse/FLINK-17640 Project:

[jira] [Updated] (FLINK-17640) RecoveredInputChannelTest.testConcurrentReadStateAndProcessAndRelease() failed

[ https://issues.apache.org/jira/browse/FLINK-17640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17640: Description: Here is the instance [https://dev.azure.com/apache-flink/apache-flink/_build/results

[jira] [Commented] (FLINK-17591) TableEnvironmentITCase.testExecuteSqlAndToDataStream failed

[ https://issues.apache.org/jira/browse/FLINK-17591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105567#comment-17105567 ] Arvid Heise commented on FLINK-17591: - Another instance on personal AZP: https://de

[jira] [Created] (FLINK-17639) Document which FileSystems are supported by the StreamingFileSink

Kostas Kloudas created FLINK-17639: -- Summary: Document which FileSystems are supported by the StreamingFileSink Key: FLINK-17639 URL: https://issues.apache.org/jira/browse/FLINK-17639 Project: Flink

[jira] [Assigned] (FLINK-17538) Refactor flink-hbase connector structure

[ https://issues.apache.org/jira/browse/FLINK-17538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17538: --- Assignee: Jark Wu > Refactor flink-hbase connector structure >

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105529#comment-17105529 ] Kostas Kloudas commented on FLINK-17444: That maybe could help as by now we supp

[jira] [Updated] (FLINK-13938) Use pre-uploaded libs to accelerate flink submission

[ https://issues.apache.org/jira/browse/FLINK-13938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-13938: --- Affects Version/s: 1.11.0 > Use pre-uploaded libs to accelerate flink submission > -

[jira] [Closed] (FLINK-13938) Use pre-uploaded libs to accelerate flink submission

[ https://issues.apache.org/jira/browse/FLINK-13938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-13938. -- Fix Version/s: 1.11.0 Resolution: Implemented Merged on master with c59e8945f1493bbd1b0

[jira] [Updated] (FLINK-17638) FlinkKafkaConsumerBase restore from empty state will be set consume from earliest forced

[ https://issues.apache.org/jira/browse/FLINK-17638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenchuangchuang updated FLINK-17638: - Description: my work target and data  is like this    : # i need count the number of po

[jira] [Updated] (FLINK-17342) Schedule savepoint if max-inflight-checkpoints limit is reached instead of forcing (in UC mode)

[ https://issues.apache.org/jira/browse/FLINK-17342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17342: --- Affects Version/s: (was: 1.11.0) > Schedule savepoint if max-inflight-checkpoints limit

[jira] [Updated] (FLINK-17342) Schedule savepoint if max-inflight-checkpoints limit is reached instead of forcing (in UC mode)

[ https://issues.apache.org/jira/browse/FLINK-17342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17342: --- Parent: FLINK-14551 Issue Type: Sub-task (was: Improvement) > Schedule savepoint if

[jira] [Closed] (FLINK-17342) Schedule savepoint if max-inflight-checkpoints limit is reached instead of forcing (in UC mode)

[ https://issues.apache.org/jira/browse/FLINK-17342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17342. -- Resolution: Fixed Merged to master as 099ba9809b..355184d69a > Schedule savepoint if max-infl

[jira] [Updated] (FLINK-17638) FlinkKafkaConsumerBase restore from empty state will be set consume from earliest forced

[ https://issues.apache.org/jira/browse/FLINK-17638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chenchuangchuang updated FLINK-17638: - Summary: FlinkKafkaConsumerBase restore from empty state will be set consume from earlie

[jira] [Closed] (FLINK-15841) TimeWindow.intersects return true for consecutive windows

[ https://issues.apache.org/jira/browse/FLINK-15841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15841. Fix Version/s: 1.11.0 Resolution: Fixed master: b9eee7816dda4b29a7f4261a7f461061133

[jira] [Created] (FLINK-17638) FlinkKafkaConsumerBase restore from empty state will be set consum from earliest forced

chenchuangchuang created FLINK-17638: Summary: FlinkKafkaConsumerBase restore from empty state will be set consum from earliest forced Key: FLINK-17638 URL: https://issues.apache.org/jira/browse/FLINK-17638

[jira] [Closed] (FLINK-16521) Remove unused FileUtils#isClassFile

[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-16521. Resolution: Fixed master: 0a34e4a0288172f3b81f6b2f7480adde764cd1cb > Remove unused FileUt

[jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

[ https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105478#comment-17105478 ] Aljoscha Krettek commented on FLINK-5479: - We're currently voting on FLIP-126, wh

[jira] [Commented] (FLINK-17394) Add RemoteEnvironment and RemoteStreamEnvironment in Python

[ https://issues.apache.org/jira/browse/FLINK-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105480#comment-17105480 ] Aljoscha Krettek commented on FLINK-17394: -- Yes, they should be deprecated and

[jira] [Commented] (FLINK-16998) Add a changeflag to Row type

[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105469#comment-17105469 ] Timo Walther commented on FLINK-16998: -- In order to unblock FLINK-14807, I will ope

[jira] [Updated] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policies

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-11499: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Extend StreamingFileSink BulkFo

  1   2   3   >