[jira] [Commented] (FLINK-16976) Update chinese documentation for ListCheckpointed deprecation

[ https://issues.apache.org/jira/browse/FLINK-16976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085592#comment-17085592 ] Aljoscha Krettek commented on FLINK-16976: -- also cc [~jark] > Update chinese documentation for

[jira] [Commented] (FLINK-17110) Make StreamExecutionEnvironment#configure also affects StreamExecutionEnvironment#configuration

[ https://issues.apache.org/jira/browse/FLINK-17110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084697#comment-17084697 ] Aljoscha Krettek commented on FLINK-17110: -- I think it should be OK to apply the Configuration.

[jira] [Commented] (FLINK-15557) Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue

[ https://issues.apache.org/jira/browse/FLINK-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084695#comment-17084695 ] Aljoscha Krettek commented on FLINK-15557: -- [~cmichels] do you know if updating to Kafka 2.2.2

[jira] [Commented] (FLINK-16057) Performance regression in ContinuousFileReaderOperator

[ https://issues.apache.org/jira/browse/FLINK-16057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084694#comment-17084694 ] Aljoscha Krettek commented on FLINK-16057: -- [~pnowojski] [~roman_khachatryan] Is there any more

[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.5.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084693#comment-17084693 ] Aljoscha Krettek commented on FLINK-15362: -- By the way, I think we still can't upgrade if the

[jira] [Updated] (FLINK-15362) Bump Kafka client version to 2.5.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15362: - Summary: Bump Kafka client version to 2.5.0 for universal Kafka connector (was: Bump

[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084692#comment-17084692 ] Aljoscha Krettek commented on FLINK-15362: -- Thanks for the heads up! > Bump Kafka client

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084690#comment-17084690 ] Aljoscha Krettek commented on FLINK-16662: -- What's the proposed fix? > Blink Planner failed to

[jira] [Commented] (FLINK-17058) Adding TimeoutTrigger support nested triggers

[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084674#comment-17084674 ] Aljoscha Krettek commented on FLINK-17058: -- The new version you posted doesn't fire itself on

[jira] [Commented] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys

[ https://issues.apache.org/jira/browse/FLINK-17074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084672#comment-17084672 ] Aljoscha Krettek commented on FLINK-17074: -- I'd say this is only about the DataStream API, we

[jira] [Closed] (FLINK-17136) Rename toplevel DataSet/DataStream section titles

[ https://issues.apache.org/jira/browse/FLINK-17136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17136. Fix Version/s: 1.11.0 Resolution: Done master:

[jira] [Closed] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow

[ https://issues.apache.org/jira/browse/FLINK-3344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3344. --- Resolution: Cannot Reproduce Closing for now since it's likely caused by FLINK-16770 >

[jira] [Commented] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed

[ https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083201#comment-17083201 ] Aljoscha Krettek commented on FLINK-17135: -- Another instance:

[jira] [Created] (FLINK-17136) Rename toplevel DataSet/DataStream section titles

Aljoscha Krettek created FLINK-17136: Summary: Rename toplevel DataSet/DataStream section titles Key: FLINK-17136 URL: https://issues.apache.org/jira/browse/FLINK-17136 Project: Flink

[jira] [Assigned] (FLINK-17136) Rename toplevel DataSet/DataStream section titles

[ https://issues.apache.org/jira/browse/FLINK-17136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17136: Assignee: Aljoscha Krettek > Rename toplevel DataSet/DataStream section titles >

[jira] [Closed] (FLINK-17134) Wrong logging information in Kafka010PartitionDiscoverer#L80

[ https://issues.apache.org/jira/browse/FLINK-17134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17134. Fix Version/s: 1.11.0 Resolution: Fixed master:

[jira] [Assigned] (FLINK-17134) Wrong logging information in Kafka010PartitionDiscoverer#L80

[ https://issues.apache.org/jira/browse/FLINK-17134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17134: Assignee: Jiayi Liao > Wrong logging information in

[jira] [Commented] (FLINK-17058) Adding TimeoutTrigger support nested triggers

[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083045#comment-17083045 ] Aljoscha Krettek commented on FLINK-17058: -- Sorry, we had public vacation on Friday and Monday

[jira] [Commented] (FLINK-17083) Restrict users of accumulators not to return null in Accumulator#getLocalValue

[ https://issues.apache.org/jira/browse/FLINK-17083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083040#comment-17083040 ] Aljoscha Krettek commented on FLINK-17083: -- Yes, I think that restriction makes sense. >

[jira] [Closed] (FLINK-17123) flink-sql-connector-elasticsearch版本与 es 版本不对应

[ https://issues.apache.org/jira/browse/FLINK-17123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17123. Resolution: Invalid > flink-sql-connector-elasticsearch版本与 es 版本不对应 >

[jira] [Commented] (FLINK-17110) Make StreamExecutionEnvironment#configure also affects configuration

[ https://issues.apache.org/jira/browse/FLINK-17110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083032#comment-17083032 ] Aljoscha Krettek commented on FLINK-17110: -- What do you mean by "also affects configuration"?

[jira] [Reopened] (FLINK-17123) flink-sql-connector-elasticsearch版本与 es 版本不对应

[ https://issues.apache.org/jira/browse/FLINK-17123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-17123: -- > flink-sql-connector-elasticsearch版本与 es 版本不对应 >

[jira] [Commented] (FLINK-17076) Revamp Kafka Connector Documentation

[ https://issues.apache.org/jira/browse/FLINK-17076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083029#comment-17083029 ] Aljoscha Krettek commented on FLINK-17076: -- Oh yes +1 > Revamp Kafka Connector Documentation >

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082921#comment-17082921 ] Aljoscha Krettek commented on FLINK-16770: -- Another occurrence of the general problem:

[jira] [Updated] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys

[ https://issues.apache.org/jira/browse/FLINK-17074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17074: - Description: Currently you can either specify a {{KeySelector}}, tuple positions, and

[jira] [Updated] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys

[ https://issues.apache.org/jira/browse/FLINK-17074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17074: - Environment: (was: Currently you can either specify a {{KeySelector}}, tuple

[jira] [Created] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys

Aljoscha Krettek created FLINK-17074: Summary: Deprecate DataStream.keyBy() that use tuple/expression keys Key: FLINK-17074 URL: https://issues.apache.org/jira/browse/FLINK-17074 Project: Flink

[jira] [Updated] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys

[ https://issues.apache.org/jira/browse/FLINK-17074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17074: - Fix Version/s: 1.11.0 > Deprecate DataStream.keyBy() that use tuple/expression keys >

[jira] [Commented] (FLINK-17058) Adding TimeoutTrigger support nested triggers

[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079201#comment-17079201 ] Aljoscha Krettek commented on FLINK-17058: -- Hi could you maybe post example code? It seems you

[jira] [Updated] (FLINK-17058) Adding TimeoutTrigger support nested triggers

[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17058: - Component/s: (was: API / DataSet) API / DataStream > Adding

[jira] [Updated] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

[ https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16533: - Fix Version/s: (was: 1.11.0) > ExecutionEnvironment supports execution of existing

[jira] [Commented] (FLINK-16521) Remove unused FileUtils#isClassFile

[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079112#comment-17079112 ] Aljoscha Krettek commented on FLINK-16521: -- Any news on this? > Remove unused

[jira] [Closed] (FLINK-992) Create CollectionDataSets by reading (client) local files.

[ https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-992. -- Resolution: Won't Do We're not putting effort in the DataSet API anymore. > Create

[jira] [Commented] (FLINK-15557) Cannot connect to Azure Event Hub/Kafka since Jan 5th 2020. Kafka version issue

[ https://issues.apache.org/jira/browse/FLINK-15557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079022#comment-17079022 ] Aljoscha Krettek commented on FLINK-15557: -- There is a problem with bumping the version because

[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078507#comment-17078507 ] Aljoscha Krettek commented on FLINK-15362: -- I did the easy fixing of the reflective code but

[jira] [Assigned] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15362: Assignee: Aljoscha Krettek (was: vinoyang) > Bump Kafka client version to 2.4.0

[jira] [Commented] (FLINK-17053) RecordWriterTest.testClearBuffersAfterInterruptDuringBlockingBufferRequest fails

[ https://issues.apache.org/jira/browse/FLINK-17053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078315#comment-17078315 ] Aljoscha Krettek commented on FLINK-17053: -- Another occurrence:

[jira] [Closed] (FLINK-10598) Maintain modern Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-10598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10598. Resolution: Fixed All sub-issues are closed, for future version updates or such we should

[jira] [Closed] (FLINK-12976) Bump Kafka client version to 2.3.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-12976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-12976. Resolution: Won't Fix Closing in favour of FLINK-15362, which updates to 2.4.x > Bump

[jira] [Updated] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15362: - Parent: (was: FLINK-10598) Issue Type: Improvement (was: Sub-task) > Bump

[jira] [Updated] (FLINK-12976) Bump Kafka client version to 2.3.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-12976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-12976: - Parent: (was: FLINK-10598) Issue Type: Improvement (was: Sub-task) > Bump

[jira] [Closed] (FLINK-11257) FlinkKafkaConsumer should support assgin partition

[ https://issues.apache.org/jira/browse/FLINK-11257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11257. Resolution: Not A Problem I'm closing this for now because I don't understand what the

[jira] [Updated] (FLINK-11257) FlinkKafkaConsumer should support assgin partition

[ https://issues.apache.org/jira/browse/FLINK-11257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11257: - Parent: (was: FLINK-10598) Issue Type: Improvement (was: Sub-task) >

[jira] [Updated] (FLINK-10603) Reduce kafka test duration

[ https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10603: - Affects Version/s: 1.11.0 1.8.0 1.9.0

[jira] [Updated] (FLINK-10603) Reduce kafka test duration

[ https://issues.apache.org/jira/browse/FLINK-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10603: - Parent: (was: FLINK-10598) Issue Type: Improvement (was: Sub-task) >

[jira] [Closed] (FLINK-10701) Move modern kafka connector module into connector profile

[ https://issues.apache.org/jira/browse/FLINK-10701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10701. Resolution: Abandoned Closing this for now. With the move to Azure there's also other

[jira] [Updated] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks

[ https://issues.apache.org/jira/browse/FLINK-5015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5015: Priority: Major (was: Critical) > Add Tests/ITCase for Kafka Per-Partition Watermarks >

[jira] [Updated] (FLINK-4859) Clearly Separate Responsibilities of StreamOperator and StreamTask

[ https://issues.apache.org/jira/browse/FLINK-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4859: Priority: Major (was: Critical) > Clearly Separate Responsibilities of StreamOperator and

[jira] [Updated] (FLINK-4859) Clearly Separate Responsibilities of StreamOperator and StreamTask

[ https://issues.apache.org/jira/browse/FLINK-4859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4859: Component/s: Runtime / Task > Clearly Separate Responsibilities of StreamOperator and

[jira] [Updated] (FLINK-3431) Add retrying logic for RocksDB snapshots

[ https://issues.apache.org/jira/browse/FLINK-3431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-3431: Component/s: (was: API / DataStream) > Add retrying logic for RocksDB snapshots >

[jira] [Closed] (FLINK-6993) Not reading recursive files in Batch by using readTextFile when file name contains _ in starting.

[ https://issues.apache.org/jira/browse/FLINK-6993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6993. --- Resolution: Abandoned Closing for now since this is expected Hadoop behaviour. > Not

[jira] [Updated] (FLINK-7151) Support function DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7151: Priority: Major (was: Critical) > Support function DDL > > >

[jira] [Updated] (FLINK-9189) Add a SBT Quickstart

[ https://issues.apache.org/jira/browse/FLINK-9189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9189: Priority: Major (was: Critical) > Add a SBT Quickstart > > >

[jira] [Closed] (FLINK-9307) Running flink program doesn't print infos in console any more

[ https://issues.apache.org/jira/browse/FLINK-9307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9307. --- Resolution: Won't Fix This is a side effect of switching to the REST API quite a while ago.

[jira] [Closed] (FLINK-9433) SystemProcessingTimeService does not work properly

[ https://issues.apache.org/jira/browse/FLINK-9433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9433. --- Resolution: Abandoned I'm closing this as "Abandoned", since there is no more activity and

[jira] [Closed] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9528. --- Resolution: Abandoned I'm closing this as "Abandoned", since there is no more activity and

[jira] [Closed] (FLINK-9544) Downgrade kinesis protocol from CBOR to JSON not possible as required by kinesalite

[ https://issues.apache.org/jira/browse/FLINK-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9544. --- Resolution: Abandoned I'm closing this as "Abandoned", since there is no more activity and

[jira] [Closed] (FLINK-9812) SpanningRecordSerializationTest fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9812. --- Resolution: Cannot Reproduce This has not occured for very long now, please re-open if it

[jira] [Closed] (FLINK-9992) FsStorageLocationReferenceTest#testEncodeAndDecode failed in Travis CI

[ https://issues.apache.org/jira/browse/FLINK-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9992. --- Resolution: Cannot Reproduce This has not occured for very long now, please re-open if it

[jira] [Closed] (FLINK-10100) Optimizer pushes partitioning past Null-Filter

[ https://issues.apache.org/jira/browse/FLINK-10100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10100. Resolution: Won't Fix We're not actively developing the DataSet API anymore. > Optimizer

[jira] [Closed] (FLINK-1915) Faulty plan selection by optimizer

[ https://issues.apache.org/jira/browse/FLINK-1915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1915. --- Resolution: Won't Fix We're not actively developing the DataSet API anymore. > Faulty plan

[jira] [Updated] (FLINK-10134) UTF-16 support for TextInputFormat

[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10134: - Priority: Major (was: Critical) > UTF-16 support for TextInputFormat >

[jira] [Updated] (FLINK-10694) ZooKeeperHaServices Cleanup

[ https://issues.apache.org/jira/browse/FLINK-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10694: - Component/s: (was: API / DataStream) Runtime / Coordination >

[jira] [Updated] (FLINK-10231) Add a view SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-10231: - Priority: Major (was: Critical) > Add a view SQL DDL > -- > >

[jira] [Updated] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13052: - Priority: Major (was: Critical) > Supporting multi-topic when using >

[jira] [Closed] (FLINK-13459) Violation of the order queue messages from RabbitMQ.

[ https://issues.apache.org/jira/browse/FLINK-13459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-13459. Resolution: Abandoned There was no more activity from the reporter. > Violation of the

[jira] [Updated] (FLINK-12089) Broadcasting Dynamic Configuration

[ https://issues.apache.org/jira/browse/FLINK-12089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-12089: - Priority: Major (was: Critical) > Broadcasting Dynamic Configuration >

[jira] [Updated] (FLINK-15674) Let Java and Scala Type Extraction go through the same stack

[ https://issues.apache.org/jira/browse/FLINK-15674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15674: - Priority: Major (was: Critical) > Let Java and Scala Type Extraction go through the

[jira] [Updated] (FLINK-14644) Improve the usability of connector properties

[ https://issues.apache.org/jira/browse/FLINK-14644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14644: - Priority: Major (was: Critical) > Improve the usability of connector properties >

[jira] [Updated] (FLINK-15877) Stop using deprecated methods from TableSource interface

[ https://issues.apache.org/jira/browse/FLINK-15877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15877: - Priority: Major (was: Critical) > Stop using deprecated methods from TableSource

[jira] [Updated] (FLINK-15849) Update SQL-CLIENT document from type to data-type

[ https://issues.apache.org/jira/browse/FLINK-15849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15849: - Priority: Major (was: Critical) > Update SQL-CLIENT document from type to data-type >

[jira] [Updated] (FLINK-15758) Investigate potential out-of-memory problems due to managed unsafe memory allocation

[ https://issues.apache.org/jira/browse/FLINK-15758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15758: - Component/s: (was: API / DataSet) > Investigate potential out-of-memory problems

[jira] [Updated] (FLINK-15986) support setting or changing session properties in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-15986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15986: - Priority: Major (was: Critical) > support setting or changing session properties in

[jira] [Closed] (FLINK-16555) Preflight check for known unstable hashCodes.

[ https://issues.apache.org/jira/browse/FLINK-16555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-16555. Resolution: Fixed master: 7cf0f6880896bb30bec2f8fc0c6193bfa35c4f04 This adds rejection

[jira] [Assigned] (FLINK-15674) Let Java and Scala Type Extraction go through the same stack

[ https://issues.apache.org/jira/browse/FLINK-15674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15674: Assignee: Guowei Ma > Let Java and Scala Type Extraction go through the same

[jira] [Assigned] (FLINK-17041) Migrate current TypeInformation creation to the TypeInformationExtractor framework

[ https://issues.apache.org/jira/browse/FLINK-17041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17041: Assignee: Guowei Ma > Migrate current TypeInformation creation to the

[jira] [Assigned] (FLINK-17039) Introduce TypeInformationExtractor famework

[ https://issues.apache.org/jira/browse/FLINK-17039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17039: Assignee: Guowei Ma > Introduce TypeInformationExtractor famework >

[jira] [Assigned] (FLINK-17038) Decouple resolving Type from creating TypeInformation process

[ https://issues.apache.org/jira/browse/FLINK-17038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17038: Assignee: Guowei Ma > Decouple resolving Type from creating TypeInformation

[jira] [Updated] (FLINK-17038) Decouple resolving Type from creating TypeInformation process

[ https://issues.apache.org/jira/browse/FLINK-17038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17038: - Priority: Major (was: Critical) > Decouple resolving Type from creating

[jira] [Updated] (FLINK-17039) Introduce TypeInformationExtractor famework

[ https://issues.apache.org/jira/browse/FLINK-17039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17039: - Priority: Major (was: Critical) > Introduce TypeInformationExtractor famework >

[jira] [Closed] (FLINK-9429) Quickstart E2E not working locally

[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9429. --- Fix Version/s: 1.11.0 Resolution: Fixed Closing this for now since cancelling seems

[jira] [Commented] (FLINK-15772) Shaded Hadoop S3A with credentials provider end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078068#comment-17078068 ] Aljoscha Krettek commented on FLINK-15772: -- Fix on release-1.10: 

[jira] [Comment Edited] (FLINK-9429) Quickstart E2E not working locally

[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078021#comment-17078021 ] Aljoscha Krettek edited comment on FLINK-9429 at 4/8/20, 10:58 AM: --- The

[jira] [Comment Edited] (FLINK-9429) Quickstart E2E not working locally

[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078021#comment-17078021 ] Aljoscha Krettek edited comment on FLINK-9429 at 4/8/20, 10:58 AM: --- The

[jira] [Commented] (FLINK-9429) Quickstart E2E not working locally

[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078062#comment-17078062 ] Aljoscha Krettek commented on FLINK-9429: - Fixed test

[jira] [Commented] (FLINK-9429) Quickstart E2E not working locally

[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078059#comment-17078059 ] Aljoscha Krettek commented on FLINK-9429: - I think this is a different bug from the one

[jira] [Assigned] (FLINK-9429) Quickstart E2E not working locally

[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-9429: --- Assignee: Aljoscha Krettek (was: zhangminglei) > Quickstart E2E not working

[jira] [Commented] (FLINK-9429) Quickstart E2E not working locally

[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078021#comment-17078021 ] Aljoscha Krettek commented on FLINK-9429: - The reason the test doesn't work locally is that

[jira] [Commented] (FLINK-15772) Shaded Hadoop S3A with credentials provider end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-15772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17077993#comment-17077993 ] Aljoscha Krettek commented on FLINK-15772: -- {{release-1.10}} doesn't have the fix. I will also

[jira] [Closed] (FLINK-9017) FlinkKafkaProducer011ITCase.testFlinkKafkaProducer011FailBeforeNotify times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-9017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9017. --- Resolution: Cannot Reproduce I'm closing this for new since there have been no new reported

[jira] [Closed] (FLINK-12540) Kafka011ProducerExactlyOnceITCase.testExactlyOnceCustomOperator

[ https://issues.apache.org/jira/browse/FLINK-12540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-12540. Resolution: Cannot Reproduce I'm closing this for new since there have been no new

[jira] [Closed] (FLINK-12032) KafkaProducerAtLeastOnceITCase failed to bind to address

[ https://issues.apache.org/jira/browse/FLINK-12032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-12032. Resolution: Cannot Reproduce I'm closing this for new since there have been no new

[jira] [Closed] (FLINK-11995) Kafka09SecuredRunITCase fails due to port conflict

[ https://issues.apache.org/jira/browse/FLINK-11995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11995. Resolution: Cannot Reproduce I'm closing this for new since there have been no new

[jira] [Closed] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10737. Resolution: Cannot Reproduce I'm closing this for new since there have been no new

[jira] [Closed] (FLINK-12033) KafkaITCase.testCancelingFullTopic failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-12033. Resolution: Cannot Reproduce I'm closing this for new since there have been no new

[jira] [Closed] (FLINK-11426) Kafka09ProducerITCase test case failed while starting KafkaCluster

[ https://issues.apache.org/jira/browse/FLINK-11426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11426. Resolution: Cannot Reproduce I'm closing this for new since there have been no new

[jira] [Closed] (FLINK-10837) Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic?

[ https://issues.apache.org/jira/browse/FLINK-10837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10837. Resolution: Cannot Reproduce I'm closing this for new since there have been no new

[jira] [Closed] (FLINK-13709) Kafka09ITCase hangs when starting the KafkaServer on Travis

[ https://issues.apache.org/jira/browse/FLINK-13709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-13709. Resolution: Cannot Reproduce I'm closing this for new since there have been no new

[jira] [Closed] (FLINK-12034) KafkaITCase.testAllDeletes failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-12034. Resolution: Cannot Reproduce I'm closing this for new since there have been no new

[jira] [Closed] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-8521. --- Resolution: Cannot Reproduce I'm closing this for new since there have been no new reported

<    5   6   7   8   9   10   11   12   13   14   >