[jira] [Closed] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19940. Resolution: Fixed master: 542b9fd5e5614db7c7f8bbe99f7e8ef73721182a > Task names on web UI

[jira] [Commented] (FLINK-20312) The documentation is incomplete

[ https://issues.apache.org/jira/browse/FLINK-20312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237946#comment-17237946 ] Aljoscha Krettek commented on FLINK-20312: -- What would you add to the descripti

[jira] [Commented] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate

[ https://issues.apache.org/jira/browse/FLINK-20305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237944#comment-17237944 ] Aljoscha Krettek commented on FLINK-20305: -- I would not upgrade it because this

[jira] [Assigned] (FLINK-20153) Add documentation for BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20153: Assignee: Aljoscha Krettek > Add documentation for BATCH execution mode > ---

[jira] [Created] (FLINK-20302) Suggest DataStream API with BATCH execution mode in DataSet docs

Aljoscha Krettek created FLINK-20302: Summary: Suggest DataStream API with BATCH execution mode in DataSet docs Key: FLINK-20302 URL: https://issues.apache.org/jira/browse/FLINK-20302 Project: Fli

[jira] [Commented] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237453#comment-17237453 ] Aljoscha Krettek commented on FLINK-20190: -- Why did you base this on {{Continuo

[jira] [Assigned] (FLINK-17691) FlinkKafkaProducer transactional.id too long when using Semantic.EXACTLY_ONCE

[ https://issues.apache.org/jira/browse/FLINK-17691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17691: Assignee: John Mathews > FlinkKafkaProducer transactional.id too long when using

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237432#comment-17237432 ] Aljoscha Krettek commented on FLINK-19461: -- I commented there. To summarize: I

[jira] [Commented] (FLINK-20212) Fail command line interfaces when provided with an unrecognized option

[ https://issues.apache.org/jira/browse/FLINK-20212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17237431#comment-17237431 ] Aljoscha Krettek commented on FLINK-20212: -- Yes, I'm afraid we cannot change th

[jira] [Assigned] (FLINK-20297) Make `SerializerTestBase::getTestData` return List

[ https://issues.apache.org/jira/browse/FLINK-20297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20297: Assignee: Guowei Ma > Make `SerializerTestBase::getTestData` return List > --

[jira] [Commented] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236165#comment-17236165 ] Aljoscha Krettek commented on FLINK-19940: -- What [~TsReaper] is referring to is

[jira] [Updated] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19940: - Attachment: without-chaining.png with-multi-source-chaining.png > Task n

[jira] [Commented] (FLINK-19940) Task names on web UI should change when an operator chain is chained with sources

[ https://issues.apache.org/jira/browse/FLINK-19940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235497#comment-17235497 ] Aljoscha Krettek commented on FLINK-19940: -- Isn't the problem that the {{TableS

[jira] [Commented] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload

[ https://issues.apache.org/jira/browse/FLINK-20220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235487#comment-17235487 ] Aljoscha Krettek commented on FLINK-20220: -- I would close the issue because we

[jira] [Closed] (FLINK-20227) Kafka transaction IDs exceeding limit

[ https://issues.apache.org/jira/browse/FLINK-20227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20227. Resolution: Duplicate Thanks for reporting this! Another issue already exists for this, th

[jira] [Closed] (FLINK-20098) Don't add flink-connector-files to flink-dist, make dependencies explicit

[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20098. Resolution: Fixed master: 02eb6dcf071f06c4affb574acb4df535f21947c3 > Don't add flink-conn

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234722#comment-17234722 ] Aljoscha Krettek commented on FLINK-20115: -- [~dwysakowicz] & [~kkl0u] I think T

[jira] [Commented] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234630#comment-17234630 ] Aljoscha Krettek commented on FLINK-17470: -- Ah sorry, yes. I'm running macOS Ca

[jira] [Commented] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234617#comment-17234617 ] Aljoscha Krettek commented on FLINK-17470: -- This fails on my machine with {cod

[jira] [Updated] (FLINK-20098) Don't add flink-connector-files to flink-dist, make dependencies explicit

[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20098: - Summary: Don't add flink-connector-files to flink-dist, make dependencies explicit (was

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

[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17159. Resolution: Fixed This is hopefully fixed by switching to use testcontainers for the ES i

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

[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17159: - Fix Version/s: (was: 1.11.3) > ES6 ElasticsearchSinkITCase unstable > --

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234562#comment-17234562 ] Aljoscha Krettek commented on FLINK-20115: -- I initially wanted to have the disc

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234534#comment-17234534 ] Aljoscha Krettek commented on FLINK-20115: -- Thanks for the thorough testing! So

[jira] [Commented] (FLINK-20098) Don't add flink-connector-files to flink-dist

[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234523#comment-17234523 ] Aljoscha Krettek commented on FLINK-20098: -- The root problem that I'm trying to

[jira] [Closed] (FLINK-20196) flink-connector-files needs explicit flink-connector-base dependency to run

[ https://issues.apache.org/jira/browse/FLINK-20196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20196. Resolution: Duplicate > flink-connector-files needs explicit flink-connector-base dependen

[jira] [Commented] (FLINK-20196) flink-connector-files needs explicit flink-connector-base dependency to run

[ https://issues.apache.org/jira/browse/FLINK-20196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234521#comment-17234521 ] Aljoscha Krettek commented on FLINK-20196: -- Thanks for reporting this! I've tri

[jira] [Commented] (FLINK-20153) Add documentation for BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234516#comment-17234516 ] Aljoscha Krettek commented on FLINK-20153: -- Not in the strict sense, that it sh

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234470#comment-17234470 ] Aljoscha Krettek commented on FLINK-19461: -- [~rmetzger] doesn't FLINK-20171 cov

[jira] [Assigned] (FLINK-20197) FileSink fails with UnsupportedOperationException when using default values

[ https://issues.apache.org/jira/browse/FLINK-20197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20197: Assignee: Yun Gao > FileSink fails with UnsupportedOperationException when using

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233639#comment-17233639 ] Aljoscha Krettek commented on FLINK-20115: -- Work-in-progress documentation is a

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233575#comment-17233575 ] Aljoscha Krettek commented on FLINK-20115: -- There is no e2e test and I don't th

[jira] [Commented] (FLINK-20153) Add documentation for BATCH execution mode

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

[jira] [Updated] (FLINK-20153) Add documentation for BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20153: - Priority: Critical (was: Major) > Add documentation for BATCH execution mode >

[jira] [Closed] (FLINK-2320) Enable DataSet DataStream Joins

[ https://issues.apache.org/jira/browse/FLINK-2320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2320. --- Resolution: Won't Do I don't think we should do this anymore because we decided to deprecate

[jira] [Updated] (FLINK-20172) Unify the behavior for file committers when the source or dest files are not exists

[ https://issues.apache.org/jira/browse/FLINK-20172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20172: - Issue Type: Bug (was: Improvement) > Unify the behavior for file committers when the so

[jira] [Commented] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232662#comment-17232662 ] Aljoscha Krettek commented on FLINK-20149: -- Sorry about this one, I saw the "te

[jira] [Created] (FLINK-20153) Add documentation for BATCH execution mode

Aljoscha Krettek created FLINK-20153: Summary: Add documentation for BATCH execution mode Key: FLINK-20153 URL: https://issues.apache.org/jira/browse/FLINK-20153 Project: Flink Issue Type

[jira] [Updated] (FLINK-20153) Add documentation for BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20153: - Fix Version/s: 1.12.0 > Add documentation for BATCH execution mode > ---

[jira] [Updated] (FLINK-20153) Add documentation for BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20153: - Component/s: API / DataStream > Add documentation for BATCH execution mode > ---

[jira] [Updated] (FLINK-15992) Incorrect classloader when finding TableFactory

[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15992: - Labels: pull-request-available (was: pull-request-available test-stability) > Incorrect

[jira] [Closed] (FLINK-20098) Don't add flink-connector-files to flink-dist

[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20098. Resolution: Done master: 3bd1a8163b6b9d1a1b7f3a293b919ea0af551c54 > Don't add flink-conne

[jira] [Assigned] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19984: Assignee: Nicholas Jiang > Add TypeSerializerTestCoverageTest to check whether te

[jira] [Updated] (FLINK-19984) Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBase

[ https://issues.apache.org/jira/browse/FLINK-19984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19984: - Description: Currently, we have {{TypeInfoTestCoverageTest}} which checks that we have a

[jira] [Updated] (FLINK-20098) Don't add flink-connector-files to flink-dist

[ https://issues.apache.org/jira/browse/FLINK-20098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20098: - Issue Type: Improvement (was: Bug) > Don't add flink-connector-files to flink-dist > --

[jira] [Created] (FLINK-20098) Don't add flink-connector-files to flink-dist

Aljoscha Krettek created FLINK-20098: Summary: Don't add flink-connector-files to flink-dist Key: FLINK-20098 URL: https://issues.apache.org/jira/browse/FLINK-20098 Project: Flink Issue T

[jira] [Updated] (FLINK-19345) In Table File Sink, introduce streaming sink compaction

[ https://issues.apache.org/jira/browse/FLINK-19345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19345: - Summary: In Table File Sink, introduce streaming sink compaction (was: Introduce File s

[jira] [Commented] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229959#comment-17229959 ] Aljoscha Krettek commented on FLINK-18934: -- I don't think we can fix it for Fli

[jira] [Updated] (FLINK-19510) FLIP-143: 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 updated FLINK-19510: - Summary: FLIP-143: Introduce a new unified sink api (was: Introduce a new unified sink

[jira] [Updated] (FLINK-19582) FLIP-148: Introduce sort-merge based blocking shuffle to Flink

[ https://issues.apache.org/jira/browse/FLINK-19582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19582: - Summary: FLIP-148: Introduce sort-merge based blocking shuffle to Flink (was: Introduce

[jira] [Updated] (FLINK-19268) FLIP-140: 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 updated FLINK-19268: - Summary: FLIP-140: Introduce batch-style execution for bounded keyed streams (was: Intr

[jira] [Updated] (FLINK-19697) Make the Sink API committer retry-able

[ https://issues.apache.org/jira/browse/FLINK-19697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19697: - Summary: Make the Sink API committer retry-able (was: Make the committer retry-able) >

[jira] [Closed] (FLINK-19491) AvroSerializerSnapshot cannot handle large schema

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

[jira] [Closed] (FLINK-20006) FileSinkITCase.testFileSink: The record 0 should occur 4 times, but only occurs 8time expected:<4> but was:<8>

[ https://issues.apache.org/jira/browse/FLINK-20006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-20006. Resolution: Fixed Those last two runs that were posted didn't have the recently merged fix

[jira] [Closed] (FLINK-20031) Keep the UID of SinkWriter same as the SinkTransformation

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

[jira] [Closed] (FLINK-19850) Add E2E tests for the new streaming case of the new FileSink

[ https://issues.apache.org/jira/browse/FLINK-19850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19850. Resolution: Implemented master: a6bea224ed012e5594ee755526f54ae7f3b0d22f > Add E2E tests

[jira] [Assigned] (FLINK-20031) Keep the UID of SinkWriter same as the SinkTransformation

[ https://issues.apache.org/jira/browse/FLINK-20031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-20031: Assignee: Guowei Ma > Keep the UID of SinkWriter same as the SinkTransformation >

[jira] [Updated] (FLINK-19963) Give SinkWriter access to processing-time service

[ https://issues.apache.org/jira/browse/FLINK-19963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19963: - Description: Some sinks, like the new unified {{FileSink}} will need low-level processin

[jira] [Updated] (FLINK-19963) Give SinkWriter access to processing-time service

[ https://issues.apache.org/jira/browse/FLINK-19963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19963: - Summary: Give SinkWriter access to processing-time service (was: Let the `SinkWriter` s

[jira] [Updated] (FLINK-20031) Keep the UID of SinkWriter same as the SinkTransformation

[ https://issues.apache.org/jira/browse/FLINK-20031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-20031: - Summary: Keep the UID of SinkWriter same as the SinkTransformation (was: Keep the uid o

[jira] [Closed] (FLINK-20006) FileSinkITCase.testFileSink: The record 0 should occur 4 times, but only occurs 8time expected:<4> but was:<8>

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

[jira] [Closed] (FLINK-19850) Add E2E tests for the new streaming case of the new FileSink

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

[jira] [Closed] (FLINK-20001) Don't use setAllVerticesInSameSlotSharingGroupByDefault in StreamGraphGenerator

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

[jira] [Assigned] (FLINK-19998) Invalid Link to checkpoints and Savepoints in stateful stream processing concepts

[ https://issues.apache.org/jira/browse/FLINK-19998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19998: Assignee: Aditya Agarwal > Invalid Link to checkpoints and Savepoints in stateful

[jira] [Commented] (FLINK-19998) Invalid Link to checkpoints and Savepoints in stateful stream processing concepts

[ https://issues.apache.org/jira/browse/FLINK-19998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226801#comment-17226801 ] Aljoscha Krettek commented on FLINK-19998: -- Please go ahead with a PR! > Inval

[jira] [Updated] (FLINK-19995) 【Flink SQL Client】Use Flink Kafka Connector in SQL-Client has more than one exception

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

[jira] [Created] (FLINK-20001) Don't use setAllVerticesInSameSlotSharingGroupByDefault in StreamGraphGenerator

Aljoscha Krettek created FLINK-20001: Summary: Don't use setAllVerticesInSameSlotSharingGroupByDefault in StreamGraphGenerator Key: FLINK-20001 URL: https://issues.apache.org/jira/browse/FLINK-20001

[jira] [Closed] (FLINK-19758) Implement a new unified File Sink based on the new Sink API

[ https://issues.apache.org/jira/browse/FLINK-19758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19758. Resolution: Implemented master: 1f5055c473c45348b794ff9c9ed8f0759d32a691 > Implement a ne

[jira] [Reopened] (FLINK-19758) Implement a new unified File Sink based on the new Sink API

[ https://issues.apache.org/jira/browse/FLINK-19758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-19758: -- > Implement a new unified File Sink based on the new Sink API > --

[jira] [Closed] (FLINK-19958) Add the IOException to all the I/O related methods' signature in Sink API.

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

[jira] [Closed] (FLINK-19758) Implement a new unified File Sink based on the new Sink API

[ https://issues.apache.org/jira/browse/FLINK-19758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19758. Resolution: Fixed master: 1f5055c473c45348b794ff9c9ed8f0759d32a691 > Implement a new unif

[jira] [Commented] (FLINK-19968) Exception in thread "main" java.lang.IllegalStateException: No ExecutorFactory found to execute the application.

[ https://issues.apache.org/jira/browse/FLINK-19968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226073#comment-17226073 ] Aljoscha Krettek commented on FLINK-19968: -- Could you please translate to Engli

[jira] [Assigned] (FLINK-19958) Add the IOException to all the I/O related methods' signature in Sink API.

[ https://issues.apache.org/jira/browse/FLINK-19958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19958: Assignee: Guowei Ma > Add the IOException to all the I/O related methods' signatu

[jira] [Closed] (FLINK-19932) Add "sanity-check" integration test for BATCH execution on DataStream API

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

[jira] [Updated] (FLINK-19932) Add "sanity-check" integration test for BATCH execution on DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19932: - Description: We should add a sanity check to ensure that BATCH execution on the DataStre

[jira] [Updated] (FLINK-19932) Add "sanity-check" integration test for BATCH execution on DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19932: - Summary: Add "sanity-check" integration test for BATCH execution on DataStream API (was

[jira] [Updated] (FLINK-19932) Add integration test for BATCH execution on DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19932: - Description: We should add a > Add integration test for BATCH execution on DataStream A

[jira] [Created] (FLINK-19932) Add integration test for BATCH execution on DataStream API

Aljoscha Krettek created FLINK-19932: Summary: Add integration test for BATCH execution on DataStream API Key: FLINK-19932 URL: https://issues.apache.org/jira/browse/FLINK-19932 Project: Flink

[jira] [Assigned] (FLINK-19932) Add integration test for BATCH execution on DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19932: Assignee: Aljoscha Krettek > Add integration test for BATCH execution on DataStre

[jira] [Deleted] (FLINK-19738) Remove the `getCommitter` from the `AbstractStreamingCommitterOperator`

[ https://issues.apache.org/jira/browse/FLINK-19738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek deleted FLINK-19738: - > Remove the `getCommitter` from the `AbstractStreamingCommitterOperator` > ---

[jira] [Assigned] (FLINK-19760) Make the `GlobalCommitter` a standalone interface that does not extend the `Committer`

[ https://issues.apache.org/jira/browse/FLINK-19760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19760: Assignee: Guowei Ma > Make the `GlobalCommitter` a standalone interface that does

[jira] [Assigned] (FLINK-19841) Rename GlobalStreamingCommitterOperator to StreamingGlobalCommitterOperator

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

[jira] [Closed] (FLINK-19736) Implement the `SinkTransformation`

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

[jira] [Commented] (FLINK-19645) ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable

[ https://issues.apache.org/jira/browse/FLINK-19645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224608#comment-17224608 ] Aljoscha Krettek commented on FLINK-19645: -- Another one: https://dev.azure.com

[jira] [Updated] (FLINK-19903) Implement equivalent of Spark's f.input_file_name()

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

[jira] [Closed] (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 closed FLINK-19835. Fix Version/s: 1.12.0 Resolution: Implemented master: 16e40b6239d41dd33db1b7bcc4fa1

[jira] [Closed] (FLINK-19836) Add SimpleVersionedSerializerTypeSerializerProxy

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

[jira] [Assigned] (FLINK-19850) Add E2E tests for the new streaming case of the new FileSink

[ https://issues.apache.org/jira/browse/FLINK-19850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19850: Assignee: Yun Gao > Add E2E tests for the new streaming case of the new FileSink

[jira] [Assigned] (FLINK-19758) Implement a new unified File Sink based on the new Sink API

[ https://issues.apache.org/jira/browse/FLINK-19758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19758: Assignee: Yun Gao > Implement a new unified File Sink based on the new Sink API >

[jira] [Updated] (FLINK-19836) Add SimpleVersionedSerializerTypeSerializerProxy

[ https://issues.apache.org/jira/browse/FLINK-19836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19836: - Summary: Add SimpleVersionedSerializerTypeSerializerProxy (was: Use provided Serializer

[jira] [Updated] (FLINK-19836) Add SimpleVersionedSerializerTypeSerializerProxy

[ https://issues.apache.org/jira/browse/FLINK-19836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19836: - Description: This allows using a {{SimpleVersionedSerializer}}, which the Source and Sin

[jira] [Assigned] (FLINK-19836) Use provided Serializer for Sink Committables sent between operators

[ https://issues.apache.org/jira/browse/FLINK-19836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19836: Assignee: Aljoscha Krettek > Use provided Serializer for Sink Committables sent b

[jira] [Updated] (FLINK-19836) Use provided Serializer for Sink Committables between operators

[ https://issues.apache.org/jira/browse/FLINK-19836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19836: - Summary: Use provided Serializer for Sink Committables between operators (was: Serializ

[jira] [Updated] (FLINK-19836) Use provided Serializer for Sink Committables sent between operators

[ https://issues.apache.org/jira/browse/FLINK-19836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19836: - Summary: Use provided Serializer for Sink Committables sent between operators (was: Use

[jira] [Assigned] (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 reassigned FLINK-19837: Assignee: Nicholas Jiang > Don't emit intermediate watermarks from watermark oper

[jira] [Closed] (FLINK-19834) Make the TestSink reusable in all the sink related tests.

[ https://issues.apache.org/jira/browse/FLINK-19834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19834. Resolution: Implemented master: 0a983188cdcde0c8a5f024e59a3fb5ddc65f16b8 > Make the TestS

[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: - Component/s: API / DataStream > Don't emit intermediate watermarks from sources in BATCH

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17222059#comment-17222059 ] Aljoscha Krettek commented on FLINK-19837: -- I will have a PR ready for https://

[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: - Component/s: API / DataStream > Don't emit intermediate watermarks from watermark operat

[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&focusedCommentId=17222058#comment-17222058 ] Aljoscha Krettek commented on FLINK-19671: -- There was this discussion where I p

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