[jira] [Created] (FLINK-21659) Running HA per-job cluster (rocks, incremental) end-to-end test fails

2021-03-07 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21659: - Summary: Running HA per-job cluster (rocks, incremental) end-to-end test fails Key: FLINK-21659 URL: https://issues.apache.org/jira/browse/FLINK-21659 Project: Flink

[jira] [Created] (FLINK-21658) Align flink-benchmarks with job graph builder

2021-03-07 Thread Yun Tang (Jira)
Yun Tang created FLINK-21658: Summary: Align flink-benchmarks with job graph builder Key: FLINK-21658 URL: https://issues.apache.org/jira/browse/FLINK-21658 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21657) flink doc fails to display a picture

2021-03-07 Thread zl (Jira)
zl created FLINK-21657: -- Summary: flink doc fails to display a picture Key: FLINK-21657 URL: https://issues.apache.org/jira/browse/FLINK-21657 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-21656) Add antlr parser for hive dialect

2021-03-07 Thread Rui Li (Jira)
Rui Li created FLINK-21656: -- Summary: Add antlr parser for hive dialect Key: FLINK-21656 URL: https://issues.apache.org/jira/browse/FLINK-21656 Project: Flink Issue Type: Sub-task

How do I call an algorithm written in C++ in Flink?

2021-03-07 Thread 苏喜 张
My company has provided an algorithm written in C++, which has been packaged into a.so file. I have built a SpringBoot project, which uses JNI to operate the algorithm written in C++. Could you please tell me how to call it in Flink?Do i need to define operators, chains of operators?

[jira] [Created] (FLINK-21655) Incorrect simplification for coalesce call on a groupingsets' result

2021-03-07 Thread lincoln lee (Jira)
lincoln lee created FLINK-21655: --- Summary: Incorrect simplification for coalesce call on a groupingsets' result Key: FLINK-21655 URL: https://issues.apache.org/jira/browse/FLINK-21655 Project: Flink

[jira] [Created] (FLINK-21654) YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue fail because of NullPointerException

2021-03-07 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21654: - Summary: YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue fail because of NullPointerException Key: FLINK-21654 URL:

[jira] [Created] (FLINK-21653) org.apache.flink.streaming.scala.api.TextOutputFormatITCase.testPath failed because of "Not enough resources available for scheduling."

2021-03-07 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21653: - Summary: org.apache.flink.streaming.scala.api.TextOutputFormatITCase.testPath failed because of "Not enough resources available for scheduling." Key: FLINK-21653 URL:

退订

2021-03-07 Thread 吴新乐
退订

[jira] [Created] (FLINK-21652) Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because of throwing SocketTimeOut Exception during closing stage.

2021-03-07 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21652: - Summary: Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because of throwing SocketTimeOut Exception during closing stage. Key: FLINK-21652 URL:

[jira] [Created] (FLINK-21651) Migrate module-related tests in LocalExecutorITCase to new integration test framework

2021-03-07 Thread Jane Chan (Jira)
Jane Chan created FLINK-21651: - Summary: Migrate module-related tests in LocalExecutorITCase to new integration test framework Key: FLINK-21651 URL: https://issues.apache.org/jira/browse/FLINK-21651

Re: [DISCUSS] Apache Flink Jira Process

2021-03-07 Thread Xintong Song
Thanks for the updates, Konstantin. The changes look good to me. Minor: - typo: The last two `auto-deprioritized-blocker` in rule 1 details should be `auto-deprioritized-critical/major`. Thank you~ Xintong Song On Fri, Mar 5, 2021 at 7:33 PM Konstantin Knauf wrote: > Hi everyone, > >

[jira] [Created] (FLINK-21650) On heap state restore, skip key groups from other state backends

2021-03-07 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-21650: - Summary: On heap state restore, skip key groups from other state backends Key: FLINK-21650 URL: https://issues.apache.org/jira/browse/FLINK-21650 Project:

[jira] [Created] (FLINK-21649) Refactor CopyOnWrite state classes

2021-03-07 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-21649: - Summary: Refactor CopyOnWrite state classes Key: FLINK-21649 URL: https://issues.apache.org/jira/browse/FLINK-21649 Project: Flink Issue Type:

[jira] [Created] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend

2021-03-07 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-21648: - Summary: FLIP-151: Incremental snapshots for heap-based state backend Key: FLINK-21648 URL: https://issues.apache.org/jira/browse/FLINK-21648 Project:

[jira] [Created] (FLINK-21647) 'Run kubernetes session test (default input)' failed on Azure

2021-03-07 Thread Jark Wu (Jira)
Jark Wu created FLINK-21647: --- Summary: 'Run kubernetes session test (default input)' failed on Azure Key: FLINK-21647 URL: https://issues.apache.org/jira/browse/FLINK-21647 Project: Flink Issue

[jira] [Created] (FLINK-21646) Support json serialization/deserialization for the states in StreamExecGroupAggregate

2021-03-07 Thread godfrey he (Jira)
godfrey he created FLINK-21646: -- Summary: Support json serialization/deserialization for the states in StreamExecGroupAggregate Key: FLINK-21646 URL: https://issues.apache.org/jira/browse/FLINK-21646

[jira] [Created] (FLINK-21645) Introduce StateDeclaration

2021-03-07 Thread godfrey he (Jira)
godfrey he created FLINK-21645: -- Summary: Introduce StateDeclaration Key: FLINK-21645 URL: https://issues.apache.org/jira/browse/FLINK-21645 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21644) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failed

2021-03-07 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21644: - Summary: Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failed Key: FLINK-21644 URL: https://issues.apache.org/jira/browse/FLINK-21644 Project: Flink