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
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
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: Docum
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
Componen
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?
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
Guowei Ma created FLINK-21654:
-
Summary:
YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue
fail because of NullPointerException
Key: FLINK-21654
URL: https://issues.apache.org/jira/browse/FL
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: https://issues.ap
退订
Guowei Ma created FLINK-21652:
-
Summary:
Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because
of throwing SocketTimeOut Exception during closing stage.
Key: FLINK-21652
URL: https://issues.
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
Proje
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,
>
> Thank
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: F
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: Sub-
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: Flink
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 Ty
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
Pro
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
Compone
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
19 matches
Mail list logo
