Hi Deep,
Thanks for bringing this on table, I'm also facing a similar kind of issue
while deploying my flink Job w.r.t resources optimization.
Hi Team,
It would be much appreciated if someone helps us here.
Regards,
Satya
On Wed, Nov 4, 2020 at 6:33 PM DEEP NARAYAN Singh
wrote:
> Hi All,
Caizhi Weng created FLINK-19990:
---
Summary: MultipleInputNodeCreationProcessor#isChainableSource
should consider DataStreamScanProvider
Key: FLINK-19990
URL: https://issues.apache.org/jira/browse/FLINK-19990
Dian Fu created FLINK-19989:
---
Summary: Add collect operation in Python DataStream API
Key: FLINK-19989
URL: https://issues.apache.org/jira/browse/FLINK-19989
Project: Flink
Issue Type: Improvement
Hi Guys,
Sorry to bother you again.Someone could help me here for clarifying my
doubt. Any help will be highly appreciated.
Thanks,
-Deep
On Wed, Nov 4, 2020 at 6:26 PM DEEP NARAYAN Singh
wrote:
> Hi All,
>
> I am running a flink streaming job in EMR Cluster with parallelism 21
> having 500 rec
Yuan Mei created FLINK-19988:
Summary: Make Approximate Local Recovery Compatible With Unaligned
Checkpoint
Key: FLINK-19988
URL: https://issues.apache.org/jira/browse/FLINK-19988
Project: Flink
Dian Fu created FLINK-19987:
---
Summary: HBaseDynamicTableFactoryTest.testTableSourceFactory
failed with "NoSuchMethodError:
com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"
Key: FLINK-19987
Dian Fu created FLINK-19986:
---
Summary: The automatic license check failed
Key: FLINK-19986
URL: https://issues.apache.org/jira/browse/FLINK-19986
Project: Flink
Issue Type: Bug
Components
Lu Niu created FLINK-19985:
--
Summary: job went into zombie state after ZK session timeout
Key: FLINK-19985
URL: https://issues.apache.org/jira/browse/FLINK-19985
Project: Flink
Issue Type: Bug
A
Nicholas Jiang created FLINK-19984:
--
Summary: Add TypeSerializerTestCoverageTest to check whether tests
based on SerializerTestBase and TypeSerializerUpgradeTestBase
Key: FLINK-19984
URL: https://issues.apache.or
+1 binding
Checks:
- source sha and signature
- mvn clean install passed on source archive
- staging artifacts have correct version, also in quickstart, NOTICE files
seem correct
On Wed, Nov 4, 2020 at 11:20 AM Tzu-Li (Gordon) Tai
wrote:
> Hi everyone,
>
> Please review and vote on the releas
Hi all,
We are soon approaching the feature freeze of the 1.12 release. I would
like to make the stabilization phase as short as possible, so that we can
release in a timely manner.
One important aspect of making the stabilization phase short is knowing all
the major bugs.
For testing Flink in a
Robert Metzger created FLINK-19983:
--
Summary:
ShuffleCompressionITCase.testDataCompressionForSortMergeBlockingShuffle unstable
Key: FLINK-19983
URL: https://issues.apache.org/jira/browse/FLINK-19983
Robert Metzger created FLINK-19982:
--
Summary: AggregateReduceGroupingITCase.testSingleAggOnTable_SortAgg
Key: FLINK-19982
URL: https://issues.apache.org/jira/browse/FLINK-19982
Project: Flink
Timo Walther created FLINK-19981:
Summary: Improve dealing with Row in DataStream API
Key: FLINK-19981
URL: https://issues.apache.org/jira/browse/FLINK-19981
Project: Flink
Issue Type: Sub-ta
Timo Walther created FLINK-19980:
Summary: Add StreamTableEnvironment.to/fromChangelogStream
Key: FLINK-19980
URL: https://issues.apache.org/jira/browse/FLINK-19980
Project: Flink
Issue Type:
Robert Metzger created FLINK-19979:
--
Summary: Sanity check after bash e2e tests for no leftover
processes
Key: FLINK-19979
URL: https://issues.apache.org/jira/browse/FLINK-19979
Project: Flink
Timo Walther created FLINK-19978:
Summary: Add StreamStatementSet.attachToStream
Key: FLINK-19978
URL: https://issues.apache.org/jira/browse/FLINK-19978
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-19977:
Summary: Add new toDataStream and toDataStream
Key: FLINK-19977
URL: https://issues.apache.org/jira/browse/FLINK-19977
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-19976:
Summary: FLIP-136: Improve interoperability between DataStream and
Table API
Key: FLINK-19976
URL: https://issues.apache.org/jira/browse/FLINK-19976
Project: Flink
Hi all,
sorry, I forgot to close the voting thread for FLIP-136. I will do this now.
The voting time for FLIP-136 has passed.
- Kurt (binding)
- Jingsong (binding)
- Jark (binding)
- Xingcan (binding)
There were 4 votes, 4 of them were binding. There were no disapproving
votes.
Thus, FLIP-136
Igal Shilman created FLINK-19975:
Summary: Bump testconatiners version
Key: FLINK-19975
URL: https://issues.apache.org/jira/browse/FLINK-19975
Project: Flink
Issue Type: Improvement
Robert Metzger created FLINK-19974:
--
Summary: SQLClientKafkaITCase.testKafka times out while creating
topic
Key: FLINK-19974
URL: https://issues.apache.org/jira/browse/FLINK-19974
Project: Flink
Hi All,
I am running a flink streaming job in EMR Cluster with parallelism 21
having 500 records per second.But still seeing cpu utilization is
approximate 5-8 percent.
Below is the long running session command in EMR Cluster having 3 instance
of type C52xlarge(8vcore, 16 GB memory, AWS resource)
zhisheng created FLINK-19973:
Summary: 【Flink-Deployment】YARN CLI Parameter doesn't work
Key: FLINK-19973
URL: https://issues.apache.org/jira/browse/FLINK-19973
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-19972:
---
Summary: Provide more details when type serializers are not
compatible
Key: FLINK-19972
URL: https://issues.apache.org/jira/browse/FLINK-19972
Project: Flink
Robert Metzger created FLINK-19971:
--
Summary: flink-connector-hbase-base depends on hbase-server,
instead of hbase-client
Key: FLINK-19971
URL: https://issues.apache.org/jira/browse/FLINK-19971
Proje
Thomas Wozniakowski created FLINK-19970:
---
Summary: State leak in CEP Operators (expired events/keys not
removed from state)
Key: FLINK-19970
URL: https://issues.apache.org/jira/browse/FLINK-19970
Flavio Pompermaier created FLINK-19969:
--
Summary: CliFrontendParser does not provide any help for
run-application
Key: FLINK-19969
URL: https://issues.apache.org/jira/browse/FLINK-19969
Project:
Thanks everyone for the feedback.
I've just updated the status of Flink 1.11.3 earlier, in its corresponding
discussion thread [1].
>From the looks of it, it seems like it makes sense to proceed with StateFun
2.2.1 without waiting for Flink 1.11.3.
Since this is also the consensus we've reached h
Hi everyone,
Please review and vote on the release candidate #1 for the version 2.2.1 of
Apache Flink Stateful Functions,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
***Testing Guideline***
You can find here [1] a page in the proj
PeteZhang created FLINK-19968:
-
Summary: Exception in thread "main"
java.lang.IllegalStateException: No ExecutorFactory found to execute the
application.
Key: FLINK-19968
URL: https://issues.apache.org/jira/browse/FL
Jingsong Lee created FLINK-19967:
Summary: Clean legacy classes for Parquet and Orc
Key: FLINK-19967
URL: https://issues.apache.org/jira/browse/FLINK-19967
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-19966:
Summary: Filter push down not work for filesystem connector
Key: FLINK-19966
URL: https://issues.apache.org/jira/browse/FLINK-19966
Project: Flink
Issue Type
Rui Li created FLINK-19965:
--
Summary: Refactor HiveMapredSplitReader to adapt to the new hive
source
Key: FLINK-19965
URL: https://issues.apache.org/jira/browse/FLINK-19965
Project: Flink
Issue Typ
Chesnay Schepler created FLINK-19964:
Summary: Gelly ITCase stuck on Azure
Key: FLINK-19964
URL: https://issues.apache.org/jira/browse/FLINK-19964
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-19963:
-
Summary: Let the `SinkWriter` support using the `TimerService`
Key: FLINK-19963
URL: https://issues.apache.org/jira/browse/FLINK-19963
Project: Flink
Issue Type: S
Mulan created FLINK-19962:
-
Summary: fix doc: more examples for expanding arrays into a
relation
Key: FLINK-19962
URL: https://issues.apache.org/jira/browse/FLINK-19962
Project: Flink
Issue Type: Im
37 matches
Mail list logo
