Hello,
Let me share my views on this issue, correct me if there is anything wrong.
To get a state handle, you have to create a StateDescriptor. This holds the
name of the state, the type of the values that the state holds and other
information. You could pass the type serializer or the type inform
gaoyajun02 created FLINK-24013:
--
Summary: Add IssueNavigationLink for IDEA
Key: FLINK-24013
URL: https://issues.apache.org/jira/browse/FLINK-24013
Project: Flink
Issue Type: Improvement
Thanks for the post, Dong :)
We welcome everyone to drop us an email on Flink ML. Let's work together to
build machine learning on Flink :)
Dong Lin 于2021年8月25日周三 下午8:58写道：
> Hi everyone,
>
> Based on the feedback received in the online/offline discussion in the
> past few weeks, we (Zhepeng,
Xintong Song created FLINK-24012:
Summary: PulsarSourceITCase.testTaskManagerFailure fails due to
NoResourceAvailableException
Key: FLINK-24012
URL: https://issues.apache.org/jira/browse/FLINK-24012
P
James Kim created FLINK-24011:
-
Summary: SET 'sql-client.verbose' = 'true'; on Flink SQL client
does not give full stack trace
Key: FLINK-24011
URL: https://issues.apache.org/jira/browse/FLINK-24011
Proje
Thomas Weise created FLINK-24010:
Summary: HybridSourceReader needs to forward checkpoint
notifications
Key: FLINK-24010
URL: https://issues.apache.org/jira/browse/FLINK-24010
Project: Flink
Kevin Ratnasekera created FLINK-24009:
-
Summary: Upgrade to Apache pom parent 24
Key: FLINK-24009
URL: https://issues.apache.org/jira/browse/FLINK-24009
Project: Flink
Issue Type: Improve
Hello,
I have been trying to understand how serialization works for the Flink Heap
Keyed state backend when a checkpoint happens. I want to know how Flink knows
which type of serializer to use to serialize the values for different states
during the snapshot.
I have debugged both RocksDB and he
Nico Kruber created FLINK-24008:
---
Summary: Support state cleanup based on unique keys
Key: FLINK-24008
URL: https://issues.apache.org/jira/browse/FLINK-24008
Project: Flink
Issue Type: New Feat
Xingcan Cui created FLINK-24007:
---
Summary: Support Avro timestamp conversion with precision greater
than three
Key: FLINK-24007
URL: https://issues.apache.org/jira/browse/FLINK-24007
Project: Flink
Fabian Paul created FLINK-24006:
---
Summary: MailboxExecutorImplTest#testIsIdle does not test the
correct behaviour
Key: FLINK-24006
URL: https://issues.apache.org/jira/browse/FLINK-24006
Project: Flink
Cool, thanks for letting us know Jeff. Hopefully, many users use Zeppelin
together with Flink.
Cheers,
Till
On Thu, Aug 26, 2021 at 4:47 AM Leonard Xu wrote:
> Thanks Jeff for the great work !
>
> Best,
> Leonard
>
> 在 2021年8月25日，22:48，Jeff Zhang 写道：
>
> Hi Flink users,
>
> We (Zeppelin commun
Zhu Zhu created FLINK-24005:
---
Summary: Resource requirements declaration may be incorrect if
JobMaster disconnects with a TaskManager with available slots in the SlotPool
Key: FLINK-24005
URL: https://issues.apache.org/
Dian Fu created FLINK-24003:
---
Summary: Lookback mode doesn't work when mixing use of Python
Table API and Python DataStream API
Key: FLINK-24003
URL: https://issues.apache.org/jira/browse/FLINK-24003
Projec
Ingo Bürk created FLINK-24004:
-
Summary: Introduce a source/sink testing harness
Key: FLINK-24004
URL: https://issues.apache.org/jira/browse/FLINK-24004
Project: Flink
Issue Type: Improvement
JING ZHANG created FLINK-24002:
--
Summary: Support count window with the window TVF in planner
Key: FLINK-24002
URL: https://issues.apache.org/jira/browse/FLINK-24002
Project: Flink
Issue Type: S
JING ZHANG created FLINK-24001:
--
Summary: Support evaluating individual window table-valued
function in runtime
Key: FLINK-24001
URL: https://issues.apache.org/jira/browse/FLINK-24001
Project: Flink
+1 (binding)
- Build project on Java 8 (maven command line) with full end to end tests
- Compiled and ran tests in IDE (IntelliJ) with Java 11 (possible after
some manual config, see comment below to automate this)
- No binaries in the distribution
- Verified license and notice files
- C
JING ZHANG created FLINK-24000:
--
Summary: window aggregate support allow lateness
Key: FLINK-24000
URL: https://issues.apache.org/jira/browse/FLINK-24000
Project: Flink
Issue Type: Sub-task
JING ZHANG created FLINK-23999:
--
Summary: Support evaluating individual window table-valued function
Key: FLINK-23999
URL: https://issues.apache.org/jira/browse/FLINK-23999
Project: Flink
Issue
+1 (binding)
- Built from downloaded sources with Java 8 (mvn install -Prun-e2e-tests)
- Verified signatures and hashes
Best,
Arvid
On Thu, Aug 26, 2021 at 8:32 AM Tzu-Li (Gordon) Tai
wrote:
> +1 (binding)
>
> - Built from source with Java 11 and Java 8 (mvn clean install
> -Prun-e2e-tests)
>
Chesnay Schepler created FLINK-23998:
Summary: Scopt not mentioned in flink-dist NOTICE file
Key: FLINK-23998
URL: https://issues.apache.org/jira/browse/FLINK-23998
Project: Flink
Issue T
JING ZHANG created FLINK-23997:
--
Summary: SQL windowing table-valued function improvement
Key: FLINK-23997
URL: https://issues.apache.org/jira/browse/FLINK-23997
Project: Flink
Issue Type: Bug
I have raised the Jira [1]. If no one picks this up I will try to find some
time next week to make a start.
Thanks.
[1] https://issues.apache.org/jira/browse/FLINK-23996
On Tue, Aug 24, 2021 at 11:37 AM Till Rohrmann wrote:
> Great, thanks Danny.
>
> On Mon, Aug 23, 2021 at 9:41 PM Danny Cranm
Danny Cranmer created FLINK-23996:
-
Summary: Make Scala 2.12 default build target
Key: FLINK-23996
URL: https://issues.apache.org/jira/browse/FLINK-23996
Project: Flink
Issue Type: Improvemen
luoyuxia created FLINK-23995:
Summary: Hive dialect: `insert overwrite table partition if not
exists` will throw exception when tablename is like 'database.table'
Key: FLINK-23995
URL: https://issues.apache.org/ji
Dian Fu created FLINK-23994:
---
Summary: ArrayDataSerializer and MapDataSerializer doesn't handle
correctly for Null values
Key: FLINK-23994
URL: https://issues.apache.org/jira/browse/FLINK-23994
Project: Fli
Nico Kruber created FLINK-23993:
---
Summary: Describe eventually-consistency of materializing upserts
Key: FLINK-23993
URL: https://issues.apache.org/jira/browse/FLINK-23993
Project: Flink
Issue
Yun Tang created FLINK-23992:
Summary: Update doc version in release-1.13 to 1.13.2
Key: FLINK-23992
URL: https://issues.apache.org/jira/browse/FLINK-23992
Project: Flink
Issue Type: Bug
Junfan Zhang created FLINK-23991:
Summary: Specifying yarn.staging-dir fail when staging scheme is
different from default fs scheme
Key: FLINK-23991
URL: https://issues.apache.org/jira/browse/FLINK-23991
Ingo Bürk created FLINK-23990:
-
Summary: Replace custom monaco editor component
Key: FLINK-23990
URL: https://issues.apache.org/jira/browse/FLINK-23990
Project: Flink
Issue Type: Improvement
wangzhihao created FLINK-23989:
--
Summary: Flink SQL visibility
Key: FLINK-23989
URL: https://issues.apache.org/jira/browse/FLINK-23989
Project: Flink
Issue Type: New Feature
Component
Piotr Nowojski created FLINK-23988:
--
Summary: Test corner cases
Key: FLINK-23988
URL: https://issues.apache.org/jira/browse/FLINK-23988
Project: Flink
Issue Type: Sub-task
Componen
Chesnay Schepler created FLINK-23987:
Summary: Move Powered By section into separate page
Key: FLINK-23987
URL: https://issues.apache.org/jira/browse/FLINK-23987
Project: Flink
Issue Type
34 matches
Mail list logo
