Tzu-Li (Gordon) Tai created FLINK-19748:
---
Summary: StateFun's UnboundedFeedbackLogger should call
startNewKeyGroup for all assigned key groups
Key: FLINK-19748
URL: https://issues.apache.org/jira/browse/FLIN
Jingsong Lee created FLINK-19747:
Summary: Move Predicate classes to OrcFilters
Key: FLINK-19747
URL: https://issues.apache.org/jira/browse/FLINK-19747
Project: Flink
Issue Type: Sub-task
appleyuchi created FLINK-19746:
--
Summary: Why delete for
Key: FLINK-19746
URL: https://issues.apache.org/jira/browse/FLINK-19746
Project: Flink
Issue Type: Bug
Reporter: appleyuchi
Zhijiang created FLINK-19745:
Summary: Supplement micro-benchmark for bounded blocking partition
in remote channel case
Key: FLINK-19745
URL: https://issues.apache.org/jira/browse/FLINK-19745
Project: Fli
darion yaphet created FLINK-19744:
-
Summary: Support Nebula Graph Connector
Key: FLINK-19744
URL: https://issues.apache.org/jira/browse/FLINK-19744
Project: Flink
Issue Type: New Feature
+1 (binding)
Thanks for driving this Yuan! It definitely helps in relative scenarios,
especially in the machine learning area.
Best Regards,
Yu
On Wed, 21 Oct 2020 at 03:50, Khachatryan Roman
wrote:
> +1 (non-binding).
>
> It would be a great improvement, thanks for the effort!
>
> Regards,
>
Hi developers,
I hope you are well and safe! This is Chenguang Wang with vesoft.inc. It is
a high-tech startup and the team is developing an open-source distributed
graph database, i.e. Nebula Graph.
A lot of Nebula Graph users are using Flink as their computation engine.
The problem is, they need
Hi all,
I want to describe the discussion process which drove us to have such
conclusion, this might make some of
the design choices easier to understand and keep everyone on the same page.
Back to the motivation, what functionality do we want to provide in the
first place? We got a lot of feedba
Hi blackjact,
We are already working on the design of stateful part, however, it will not be
supported in 1.12. We hope to support it in the later releases, e.g. 1.13.
Thank you for your attention.
Regards,
Shuiqiang
> 在 2020年10月20日，下午7:34，blackjjcat 写道：
>
> May I ask the plan of stateful p
Jiangjie Qin created FLINK-19743:
Summary: Add metrics definitions.
Key: FLINK-19743
URL: https://issues.apache.org/jira/browse/FLINK-19743
Project: Flink
Issue Type: Sub-task
Compo
+1 (non-binding).
It would be a great improvement, thanks for the effort!
Regards,
Roman
On Tue, Oct 20, 2020 at 4:49 PM Steven Wu wrote:
> +1 (non-binding).
>
> Some of our users have asked for this tradeoff of consistency over
> availability for some cases.
>
> On Mon, Oct 19, 2020 at 8:02
Dan Hill created FLINK-19742:
Summary: Invalid command in flink-end-to-end-tests README
Key: FLINK-19742
URL: https://issues.apache.org/jira/browse/FLINK-19742
Project: Flink
Issue Type: Improvem
Tzu-Li (Gordon) Tai created FLINK-19741:
---
Summary: InternalTimeServiceManager fails to restore if there are
other users of raw keyed state streams
Key: FLINK-19741
URL: https://issues.apache.org/jira/browse/
Alex Hall created FLINK-19740:
-
Summary: Error in to_pandas for table containing event time: class
java.time.LocalDateTime cannot be cast to class java.sql.Timestamp
Key: FLINK-19740
URL: https://issues.apache.org/jir
True, thanks for the reminder Till!
I suggest using glibc malloc as default. On one hand this follows our old
behavior (only with glibc malloc support in the image), on the other hand I
believe glibc isn't using jemalloc as its default memory allocator for some
reason.
Please let me know your tho
+1 for Nov. 2nd.
Thank you~
Xintong Song
On Tue, Oct 20, 2020 at 8:56 PM Leonard Xu wrote:
> +1 for **Sunday night**.
>
>
> Best
> Leonard
>
> > 在 2020年10月20日，19:03，Jingsong Li 写道：
> >
> > +1 for Sunday night. This also helps Filesystem and Hive implementation
> for
> > FLIP-27 Source. And
Alex Hall created FLINK-19739:
-
Summary: CompileException when windowing in batch mode: A method
named "replace" is not declared in any enclosing class nor any supertype
Key: FLINK-19739
URL: https://issues.apache.or
+1 (non-binding).
Some of our users have asked for this tradeoff of consistency over
availability for some cases.
On Mon, Oct 19, 2020 at 8:02 PM Zhijiang
wrote:
> Thanks for driving this effort, Yuan.
>
> +1 (binding) on my side.
>
> Best,
> Zhijiang
>
>
> -
May I ask the plan of stateful part, which version is expected to be
integrated?
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
Guowei Ma created FLINK-19738:
-
Summary: Remove the `getCommitter` from the
`AbstractStreamingCommitterOperator`
Key: FLINK-19738
URL: https://issues.apache.org/jira/browse/FLINK-19738
Project: Flink
godfrey he created FLINK-19737:
--
Summary: Introduce TableOperatorWrapperGenerator to translate
transformation DAG in a multiple-input node to TableOperatorWrapper DAG
Key: FLINK-19737
URL: https://issues.apache.org/
The only question left would be what will be the default value?
Cheers,
Till
On Tue, Oct 20, 2020 at 10:16 AM Yu Li wrote:
> I'm also +1 on making it configurable in the same Docker image.
>
> It seems we have reached consensus and there are already enough +1s to move
> forward, and suggest @Yu
+1 for **Sunday night**.
Best
Leonard
> 在 2020年10月20日，19:03，Jingsong Li 写道：
>
> +1 for Sunday night. This also helps Filesystem and Hive implementation for
> FLIP-27 Source. And the implementation will block "Support Multiple Input
> for Blink Planner". Multiple input is very important for Ba
Guowei Ma created FLINK-19736:
-
Summary: Implement the `SinkTransformation`
Key: FLINK-19736
URL: https://issues.apache.org/jira/browse/FLINK-19736
Project: Flink
Issue Type: Sub-task
C
shizhengchao created FLINK-19735:
Summary: TableFunction can not work in Flink View
Key: FLINK-19735
URL: https://issues.apache.org/jira/browse/FLINK-19735
Project: Flink
Issue Type: Bug
+1 for Sunday night. This also helps Filesystem and Hive implementation for
FLIP-27 Source. And the implementation will block "Support Multiple Input
for Blink Planner". Multiple input is very important for Batch performance.
Best,
Jingsong
On Tue, Oct 20, 2020 at 6:36 PM Yu Li wrote:
> +1 for
+1 for Sunday night. This also helps for more thorough testing of the
RocksDB version bumping up job [1].
Thanks.
Best Regards,
Yu
[1] https://issues.apache.org/jira/browse/FLINK-14482
On Tue, 20 Oct 2020 at 17:06, Robert Metzger wrote:
> Thanks a lot.
>
> It seems that a few people are suppo
Leonard Xu created FLINK-19734:
--
Summary: Add scan-only TableSoure tests
Key: FLINK-19734
URL: https://issues.apache.org/jira/browse/FLINK-19734
Project: Flink
Issue Type: Sub-task
R
Hi devs,
As many people are still confused about the difference option behaviours
between the Kafka connector and KTable connector, Jark and I list the
differences in the doc[1].
Best,
Shengkai
[1]
https://docs.google.com/document/d/13oAWAwQez0lZLsyfV21BfTEze1fc2cz4AZKiNOyBNPk/edit
Shengkai Fan
Huang Xingbo created FLINK-19733:
Summary: Make fast_operation and slow_operation produce functions
consistent
Key: FLINK-19733
URL: https://issues.apache.org/jira/browse/FLINK-19733
Project: Flink
Thanks a lot.
It seems that a few people are supportive of the idea of moving the feature
freeze to Friday.
I would actually propose to make it *Sunday night* then. We'll then create
the first release candidate on Monday morning, November 2nd.
On Mon, Oct 19, 2020 at 1:27 PM Danny Chan wrote:
I'm also +1 on making it configurable in the same Docker image.
It seems we have reached consensus and there are already enough +1s to move
forward, and suggest @Yun to conclude the discussion directly if there are
no objections.
Thanks.
Best Regards,
Yu
On Fri, 16 Oct 2020 at 23:16, Till Rohr
Kostas Kloudas created FLINK-19732:
--
Summary: Disable Checkpointing when in BATCH mode
Key: FLINK-19732
URL: https://issues.apache.org/jira/browse/FLINK-19732
Project: Flink
Issue Type: Sub-
little-tomato created FLINK-19731:
-
Summary: 使用了批量执行SQL的api，job执行的时候，DataStream 不触发
Key: FLINK-19731
URL: https://issues.apache.org/jira/browse/FLINK-19731
Project: Flink
Issue Type: Bug
Kostas Kloudas created FLINK-19730:
--
Summary: Create the CoFeedbackTransformation translator
Key: FLINK-19730
URL: https://issues.apache.org/jira/browse/FLINK-19730
Project: Flink
Issue Type
Kostas Kloudas created FLINK-19729:
--
Summary: Create the FeedbackTransformation translator
Key: FLINK-19729
URL: https://issues.apache.org/jira/browse/FLINK-19729
Project: Flink
Issue Type:
36 matches
Mail list logo
