[jira] [Assigned] (FLINK-19835) Don't emit intermediate watermarks from sources in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-19835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19835: Assignee: Aljoscha Krettek > Don't emit intermediate watermarks from sources in

[jira] [Commented] (FLINK-19833) Rename Sink API Writer interface to SinkWriter

[ https://issues.apache.org/jira/browse/FLINK-19833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222056#comment-17222056 ] Aljoscha Krettek commented on FLINK-19833: -- I believe [~kkl0u] or [~maguowei] will work on this

[jira] [Updated] (FLINK-19847) Can we create a fast support on the Nested table join?

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

[jira] [Updated] (FLINK-19494) Add StreamExecutionEnvironment.fromSequence()

[ https://issues.apache.org/jira/browse/FLINK-19494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19494: - Summary: Add StreamExecutionEnvironment.fromSequence() (was: Adjust

[jira] [Closed] (FLINK-19494) Adjust "StreamExecutionEnvironment.generateSequence()" to new API Sources

[ https://issues.apache.org/jira/browse/FLINK-19494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19494. Assignee: Nicholas Jiang Resolution: Fixed master:

[jira] [Closed] (FLINK-19521) Support dynamic properties on DefaultCLI

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

[jira] [Closed] (FLINK-19493) In CliFrontend, make flow of Configuration more obvious

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

[jira] [Updated] (FLINK-19837) Don't emit intermediate watermarks from watermark operators in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-19837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19837: - Summary: Don't emit intermediate watermarks from watermark operators in BATCH execution

[jira] [Updated] (FLINK-19835) Don't emit intermediate watermarks from sources in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-19835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19835: - Summary: Don't emit intermediate watermarks from sources in BATCH execution mode (was:

[jira] [Created] (FLINK-19837) Don't emit intermediate watermarks watermark operators in BATCH execution mode

Aljoscha Krettek created FLINK-19837: Summary: Don't emit intermediate watermarks watermark operators in BATCH execution mode Key: FLINK-19837 URL: https://issues.apache.org/jira/browse/FLINK-19837

[jira] [Created] (FLINK-19835) Don't emit intermediate watermarks in BATCH execution mode

Aljoscha Krettek created FLINK-19835: Summary: Don't emit intermediate watermarks in BATCH execution mode Key: FLINK-19835 URL: https://issues.apache.org/jira/browse/FLINK-19835 Project: Flink

[jira] [Created] (FLINK-19833) Rename Sink API Writer interface to SinkWriter

Aljoscha Krettek created FLINK-19833: Summary: Rename Sink API Writer interface to SinkWriter Key: FLINK-19833 URL: https://issues.apache.org/jira/browse/FLINK-19833 Project: Flink Issue

[jira] [Commented] (FLINK-19671) Update EditorConfig file to be useful

[ https://issues.apache.org/jira/browse/FLINK-19671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221317#comment-17221317 ] Aljoscha Krettek commented on FLINK-19671: -- Those are more arguments for having an opinionated,

[jira] [Updated] (FLINK-19817) Is FileSystem source unsupported?

[ https://issues.apache.org/jira/browse/FLINK-19817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19817: - Component/s: (was: Connectors / FileSystem) Table SQL / Ecosystem

[jira] [Closed] (FLINK-19479) Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()

[ https://issues.apache.org/jira/browse/FLINK-19479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19479. Fix Version/s: 1.12.0 Release Note: Before Flink 1.12 the

[jira] [Commented] (FLINK-19671) Update EditorConfig file to be useful

[ https://issues.apache.org/jira/browse/FLINK-19671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220750#comment-17220750 ] Aljoscha Krettek commented on FLINK-19671: -- I'm afraid the ML discussion has fizzled out, as

[jira] [Commented] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220742#comment-17220742 ] Aljoscha Krettek commented on FLINK-17159: -- Maybe yes. 路‍♂️ But yeah, this issue is quite

[jira] [Closed] (FLINK-5018) Make source idle timeout user configurable

[ https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5018. --- Resolution: Won't Do Thanks for the reminder. > Make source idle timeout user configurable

[jira] [Closed] (FLINK-19769) Reuse StreamRecord in SourceOutputWithWatermarks#collect

[ https://issues.apache.org/jira/browse/FLINK-19769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19769. Resolution: Fixed master: 1c03e581 > Reuse StreamRecord in

[jira] [Commented] (FLINK-19742) Invalid command in flink-end-to-end-tests README

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

[jira] [Commented] (FLINK-19742) Invalid command in flink-end-to-end-tests README

[ https://issues.apache.org/jira/browse/FLINK-19742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220728#comment-17220728 ] Aljoscha Krettek commented on FLINK-19742: -- cc [~rmetzger] > Invalid command in

[jira] [Closed] (FLINK-19326) Allow explicitly configuring time behaviour on CEP PatternStream

[ https://issues.apache.org/jira/browse/FLINK-19326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19326. Fix Version/s: 1.12.0 Release Note: Before Flink 1.12 the CEP operations where

[jira] [Updated] (FLINK-19326) Allow explicitly configuring time behaviour on CEP PatternStream

[ https://issues.apache.org/jira/browse/FLINK-19326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19326: - Release Note: Before Flink 1.12 the CEP operations were changing their behavior based

[jira] [Closed] (FLINK-19676) java package name error in docs

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

[jira] [Updated] (FLINK-19741) InternalTimeServiceManager fails to restore due to corrupt reads if there are other users of raw keyed state streams

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

[jira] [Closed] (FLINK-19268) Introduce batch-style execution for bounded keyed streams

[ https://issues.apache.org/jira/browse/FLINK-19268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19268. Resolution: Implemented All subtasks are done. > Introduce batch-style execution for

[jira] [Commented] (FLINK-19671) Update EditorConfig file to be useful

[ https://issues.apache.org/jira/browse/FLINK-19671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216548#comment-17216548 ] Aljoscha Krettek commented on FLINK-19671: -- I have used 8 for a long time because we don't have

[jira] [Closed] (FLINK-19671) Update EditorConfig file to be useful

[ https://issues.apache.org/jira/browse/FLINK-19671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19671. Resolution: Fixed master: ea599af7f871a7b79c4428db0ce87512a76f88c2 release-1.11:

[jira] [Assigned] (FLINK-19671) Update EditorConfig file to be useful

[ https://issues.apache.org/jira/browse/FLINK-19671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19671: Assignee: Aljoscha Krettek > Update EditorConfig file to be useful >

[jira] [Created] (FLINK-19671) Update EditorConfig file to be useful

Aljoscha Krettek created FLINK-19671: Summary: Update EditorConfig file to be useful Key: FLINK-19671 URL: https://issues.apache.org/jira/browse/FLINK-19671 Project: Flink Issue Type:

[jira] [Closed] (FLINK-19531) Implement writer operator for new Sink API

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

[jira] [Commented] (FLINK-19566) TableITCase.testCollectWithClose failed with "IllegalStateException: MiniCluster is not yet running or has already been shut down"

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

[jira] [Closed] (FLINK-19616) Flink : Formats : Parquet compilation failure

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

[jira] [Updated] (FLINK-19531) Implement writer operator for new Sink API

[ https://issues.apache.org/jira/browse/FLINK-19531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19531: - Summary: Implement writer operator for new Sink API (was: Implement the writer

[jira] [Assigned] (FLINK-19586) Implement StreamCommitterOperator for new Sink API

[ https://issues.apache.org/jira/browse/FLINK-19586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19586: Assignee: Guowei Ma > Implement StreamCommitterOperator for new Sink API >

[jira] [Assigned] (FLINK-19531) Implement writer operator for new Sink API

[ https://issues.apache.org/jira/browse/FLINK-19531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19531: Assignee: Guowei Ma > Implement writer operator for new Sink API >

[jira] [Updated] (FLINK-19586) Implement StreamCommitterOperator for new Sink API

[ https://issues.apache.org/jira/browse/FLINK-19586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19586: - Summary: Implement StreamCommitterOperator for new Sink API (was: Implement the

[jira] [Updated] (FLINK-19634) Official Flink visualizer display bug

[ https://issues.apache.org/jira/browse/FLINK-19634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19634: - Component/s: Project Website > Official Flink visualizer display bug >

[jira] [Commented] (FLINK-19634) Official Flink visualizer display bug

[ https://issues.apache.org/jira/browse/FLINK-19634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213721#comment-17213721 ] Aljoscha Krettek commented on FLINK-19634: -- This visualizer is ancient code that no-one has

[jira] [Commented] (FLINK-19594) SubTasks start index don't unified and may confuse users

[ https://issues.apache.org/jira/browse/FLINK-19594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212961#comment-17212961 ] Aljoscha Krettek commented on FLINK-19594: -- cc [~chesnay] > SubTasks start index don't unified

[jira] [Updated] (FLINK-19594) SubTasks start index don't unified and may confuse users

[ https://issues.apache.org/jira/browse/FLINK-19594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19594: - Component/s: Runtime / Web Frontend > SubTasks start index don't unified and may

[jira] [Commented] (FLINK-19591) Missing @Internal annotation SimpleJdbcConnectionProvider

[ https://issues.apache.org/jira/browse/FLINK-19591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212957#comment-17212957 ] Aljoscha Krettek commented on FLINK-19591: -- I'm closing this for now because I don't want to

[jira] [Closed] (FLINK-19591) Missing @Internal annotation SimpleJdbcConnectionProvider

[ https://issues.apache.org/jira/browse/FLINK-19591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19591. Resolution: Won't Do > Missing @Internal annotation SimpleJdbcConnectionProvider >

[jira] [Commented] (FLINK-19591) Missing @Internal annotation SimpleJdbcConnectionProvider

[ https://issues.apache.org/jira/browse/FLINK-19591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212956#comment-17212956 ] Aljoscha Krettek commented on FLINK-19591: -- I think there are too many inconsistencies in how

[jira] [Commented] (FLINK-19593) FlinkKafkaInternalProducer should be @Internal annotation ?

[ https://issues.apache.org/jira/browse/FLINK-19593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212955#comment-17212955 ] Aljoscha Krettek commented on FLINK-19593: -- I think there are too many inconsistencies in how

[jira] [Commented] (FLINK-19580) Creating PackagedProgram overwrites an actual job name with default JobName

[ https://issues.apache.org/jira/browse/FLINK-19580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212948#comment-17212948 ] Aljoscha Krettek commented on FLINK-19580: -- So we just need to change

[jira] [Closed] (FLINK-11427) Protobuf parquet writer implementation

[ https://issues.apache.org/jira/browse/FLINK-11427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11427. Resolution: Fixed master: b3589266da9cb6d7df2889340d55829a01fd2919 > Protobuf parquet

[jira] [Commented] (FLINK-19521) Support dynamic properties on DefaultCLI

[ https://issues.apache.org/jira/browse/FLINK-19521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212249#comment-17212249 ] Aljoscha Krettek commented on FLINK-19521: -- Yes, the "dynamic properties" implementation is

[jira] [Updated] (FLINK-19512) Introduce new Sink API interfaces

[ https://issues.apache.org/jira/browse/FLINK-19512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19512: - Summary: Introduce new Sink API interfaces (was: Introduce the new sink api) >

[jira] [Commented] (FLINK-19539) JMXReporterFactoryTest fails on Azure

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

[jira] [Commented] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

[ https://issues.apache.org/jira/browse/FLINK-19486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209593#comment-17209593 ] Aljoscha Krettek commented on FLINK-19486: -- Exception message improved: master:

[jira] [Created] (FLINK-19521) Support dynamic properties on DefaultCLI

Aljoscha Krettek created FLINK-19521: Summary: Support dynamic properties on DefaultCLI Key: FLINK-19521 URL: https://issues.apache.org/jira/browse/FLINK-19521 Project: Flink Issue Type:

[jira] [Commented] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

[ https://issues.apache.org/jira/browse/FLINK-19486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208641#comment-17208641 ] Aljoscha Krettek commented on FLINK-19486: -- I've created a PR that makes the exception message

[jira] [Commented] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

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

[jira] [Assigned] (FLINK-19511) Rename the `SinkTransformation` to `LegacySinkTransformation`

[ https://issues.apache.org/jira/browse/FLINK-19511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19511: Assignee: Guowei Ma > Rename the `SinkTransformation` to

[jira] [Updated] (FLINK-19512) Introduce the new sink api interfaces

[ https://issues.apache.org/jira/browse/FLINK-19512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19512: - Summary: Introduce the new sink api interfaces (was: Introduce the new sink api) >

[jira] [Assigned] (FLINK-19512) Introduce the new sink api

[ https://issues.apache.org/jira/browse/FLINK-19512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19512: Assignee: Guowei Ma > Introduce the new sink api > -- >

[jira] [Commented] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

[ https://issues.apache.org/jira/browse/FLINK-19486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208591#comment-17208591 ] Aljoscha Krettek commented on FLINK-19486: -- Setting the RocksDB backend in code will override

[jira] [Commented] (FLINK-19508) Add collect() operation on DataStream

[ https://issues.apache.org/jira/browse/FLINK-19508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208589#comment-17208589 ] Aljoscha Krettek commented on FLINK-19508: -- Otherwise, if we don't do that +1 to what

[jira] [Commented] (FLINK-19508) Add collect() operation on DataStream

[ https://issues.apache.org/jira/browse/FLINK-19508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208587#comment-17208587 ] Aljoscha Krettek commented on FLINK-19508: -- Ah yes, I forgot to mention that we could think

[jira] [Assigned] (FLINK-19510) Introduce a new unified sink api

[ https://issues.apache.org/jira/browse/FLINK-19510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19510: Assignee: Guowei Ma > Introduce a new unified sink api >

[jira] [Commented] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

[ https://issues.apache.org/jira/browse/FLINK-19486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208545#comment-17208545 ] Aljoscha Krettek commented on FLINK-19486: -- Ah, could it be that you're trying to restore a

[jira] [Updated] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

[ https://issues.apache.org/jira/browse/FLINK-19486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19486: - Component/s: Runtime / State Backends Runtime / Checkpointing >

[jira] [Created] (FLINK-19508) Add collect() operation on DataStream

Aljoscha Krettek created FLINK-19508: Summary: Add collect() operation on DataStream Key: FLINK-19508 URL: https://issues.apache.org/jira/browse/FLINK-19508 Project: Flink Issue Type:

[jira] [Closed] (FLINK-19318) Deprecate timeWindow() operations in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19318. Fix Version/s: 1.12.0 Release Note: In Flink 1.12 we deprecated the `timeWindow()`

[jira] [Closed] (FLINK-19123) TestStreamEnvironment does not use shared MiniCluster for executeAsync()

[ https://issues.apache.org/jira/browse/FLINK-19123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19123. Resolution: Fixed master: f9fc140ada79130d11739fb213a6a1c6f1148140 >

[jira] [Commented] (FLINK-19506) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnNonParallelLocalChannel: "Exceeded checkpoint tolerable failure threshold"

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

[jira] [Updated] (FLINK-14068) Use Java's Duration instead of Flink's Time

[ https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14068: - Description: As discussion in mailing list

[jira] [Commented] (FLINK-19493) In CliFrontend, make flow of Configuration more obvious

[ https://issues.apache.org/jira/browse/FLINK-19493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17207878#comment-17207878 ] Aljoscha Krettek commented on FLINK-19493: -- Yes, I'm planning to add tests for the existing

[jira] [Commented] (FLINK-19501) Missing state in enum type

[ https://issues.apache.org/jira/browse/FLINK-19501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17207877#comment-17207877 ] Aljoscha Krettek commented on FLINK-19501: -- Which enum is this about? > Missing state in enum

[jira] [Commented] (FLINK-19494) Adjust "StreamExecutionEnvironment.generateSequence()" to new API Sources

[ https://issues.apache.org/jira/browse/FLINK-19494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17207876#comment-17207876 ] Aljoscha Krettek commented on FLINK-19494: -- Just confirming here.  > Adjust

[jira] [Commented] (FLINK-19493) In CliFrontend, make flow of Configuration more obvious

[ https://issues.apache.org/jira/browse/FLINK-19493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17206164#comment-17206164 ] Aljoscha Krettek commented on FLINK-19493: -- I'll look into it while working on it. > In

[jira] [Created] (FLINK-19493) In CliFrontend, make flow of Configuration more obvious

Aljoscha Krettek created FLINK-19493: Summary: In CliFrontend, make flow of Configuration more obvious Key: FLINK-19493 URL: https://issues.apache.org/jira/browse/FLINK-19493 Project: Flink

[jira] [Commented] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

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

[jira] [Closed] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

[ https://issues.apache.org/jira/browse/FLINK-19486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19486. Resolution: Invalid This issue tracking system is for tracking bugs or new developments.

[jira] [Updated] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

[ https://issues.apache.org/jira/browse/FLINK-19486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19486: - Priority: Minor (was: Blocker) > expected: class

[jira] [Updated] (FLINK-19486) expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

[ https://issues.apache.org/jira/browse/FLINK-19486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19486: - Fix Version/s: (was: 1.11.1) > expected: class

[jira] [Assigned] (FLINK-19479) Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()

[ https://issues.apache.org/jira/browse/FLINK-19479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19479: Assignee: Nicholas Jiang > Allow explicitly configuring time behaviour on

[jira] [Commented] (FLINK-19027) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnParallelRemoteChannel failed because of test timeout

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

[jira] [Closed] (FLINK-19319) Deprecate StreamExecutionEnvironment.setStreamTimeCharacteristic() and TimeCharacteristic

[ https://issues.apache.org/jira/browse/FLINK-19319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19319. Fix Version/s: 1.12.0 Release Note: This is formatted in Markdown for easy inclusion

[jira] [Closed] (FLINK-19317) Make EventTime the default StreamTimeCharacteristic

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

[jira] [Updated] (FLINK-19485) Decouple runtime operator implementation from DataStream operations

[ https://issues.apache.org/jira/browse/FLINK-19485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19485: - Summary: Decouple runtime operator implementation from DataStream operations (was:

[jira] [Closed] (FLINK-18818) HadoopRenameCommitterHDFSTest.testCommitOneFile[Override: false] failed with "java.io.IOException: The stream is closed"

[ https://issues.apache.org/jira/browse/FLINK-18818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18818. Fix Version/s: 1.11.3 1.12.0 Assignee: Yun Gao

[jira] [Commented] (FLINK-19479) Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()

[ https://issues.apache.org/jira/browse/FLINK-19479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205392#comment-17205392 ] Aljoscha Krettek commented on FLINK-19479: -- Yes, it's basically the same but for joins. Should

[jira] [Updated] (FLINK-19319) Deprecate StreamExecutionEnvironment.setStreamTimeCharacteristic() and TimeCharacteristic

[ https://issues.apache.org/jira/browse/FLINK-19319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19319: - Summary: Deprecate StreamExecutionEnvironment.setStreamTimeCharacteristic() and

[jira] [Commented] (FLINK-2491) Checkpointing only works if all operators/tasks are still running

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204619#comment-17204619 ] Aljoscha Krettek commented on FLINK-2491: - What Yun is saying is that he has been investigating

[jira] [Updated] (FLINK-19471) CVE-2020-7712 is reported for flink-streaming-java_2.11:jar:1.11.1

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

[jira] [Created] (FLINK-19479) Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()

Aljoscha Krettek created FLINK-19479: Summary: Allow explicitly configuring time behaviour on KeyedStream.intervalJoin() Key: FLINK-19479 URL: https://issues.apache.org/jira/browse/FLINK-19479

[jira] [Updated] (FLINK-5717) NPE on SessionWindows with ContinuousProcessingTimeTrigger

[ https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5717: Labels: easyfix starter (was: easyfix pull-request-available starter) > NPE on

[jira] [Closed] (FLINK-19137) Bump Apache Parquet to 1.11.1

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

[jira] [Closed] (FLINK-17818) CSV Reader with Pojo Type and no field names fails

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

[jira] [Assigned] (FLINK-17818) CSV Reader with Pojo Type and no field names fails

[ https://issues.apache.org/jira/browse/FLINK-17818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17818: Assignee: Danish Amjad > CSV Reader with Pojo Type and no field names fails >

[jira] [Closed] (FLINK-19208) Refine the tuple's equals

[ https://issues.apache.org/jira/browse/FLINK-19208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19208. Resolution: Won't Fix I'm closing this for now since it's a purely cosmetic change that

[jira] [Closed] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18830. Resolution: Not A Problem Closing for now since it's about an internal implementation

[jira] [Commented] (FLINK-19383) Per Partition State

[ https://issues.apache.org/jira/browse/FLINK-19383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17203126#comment-17203126 ] Aljoscha Krettek commented on FLINK-19383: -- I think this is too specific to be implemented in

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17203111#comment-17203111 ] Aljoscha Krettek commented on FLINK-18830: -- If it's for the Table API then we should keep it as

[jira] [Commented] (FLINK-19326) Allow explicitly configuring time behaviour on CEP PatternStream

[ https://issues.apache.org/jira/browse/FLINK-19326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17203110#comment-17203110 ] Aljoscha Krettek commented on FLINK-19326: -- We should not add a setting for ingestion time

[jira] [Updated] (FLINK-19426) End-to-end test sometimes fails with PartitionConnectionException

[ https://issues.apache.org/jira/browse/FLINK-19426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19426: - Summary: End-to-end test sometimes fails with PartitionConnectionException (was:

[jira] [Updated] (FLINK-19426) End-to-end test sometimes fails with PartitionConnectionException

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

[jira] [Updated] (FLINK-19383) Per Partition State

[ https://issues.apache.org/jira/browse/FLINK-19383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19383: - Component/s: API / DataStream > Per Partition State > --- > >

<    1   2   3   4   5   6   7   8   9   10   >