[GitHub] [flink] flinkbot edited a comment on pull request #12219: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #12219: URL: https://github.com/apache/flink/pull/12219#issuecomment-630123493 ## CI report: * c849ac42145725091a3ab166095a672eaf33f350 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12225: [FLINK-17781][coordination] Use Scheduler and MainThreadExecutor in OperatorCoordinator.Context

flinkbot edited a comment on pull request #12225: URL: https://github.com/apache/flink/pull/12225#issuecomment-630123970 ## CI report: * 98f726234e0bce2e0088bed95efd282462dc5fc1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12220: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

flinkbot edited a comment on pull request #12220: URL: https://github.com/apache/flink/pull/12220#issuecomment-630123571 ## CI report: * 1f7420e803f6c1a3a4596457b13aa3e5bc125199 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

flinkbot edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415 ## CI report: * 79f3bb064a15bfde312932e603ae2a65e67545fd UNKNOWN * ec7e775f83706fe690c3d4214f30c7e81a5167f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * b954ba073cba912b98c5992b05caec91e7657871 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12103: [FLINK-16998][core] Add a changeflag to Row

flinkbot edited a comment on pull request #12103: URL: https://github.com/apache/flink/pull/12103#issuecomment-627456433 ## CI report: * 460711a0fe014e079ea2eb9c6e98da11e1946b48 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

flinkbot edited a comment on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-542518065 ## CI report: * 01016af81f4aca6c28525ef1fe896986bf60592c Azure:

[jira] [Commented] (FLINK-17015) Fix NPE from NullAwareMapIterator

[ https://issues.apache.org/jira/browse/FLINK-17015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110197#comment-17110197 ] Yu Li commented on FLINK-17015: --- [~jark] is this a critical bug that need to be fixed in 1.11.0? Asking

[jira] [Commented] (FLINK-17676) Is there some way to rollback the .out file of TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110196#comment-17110196 ] Robert Metzger commented on FLINK-17676: Probably not ... but it is somehow the closest

[GitHub] [flink] aljoscha commented on pull request #12189: [FLINK-17376][API/DataStream]Deprecated methods and related code updated

aljoscha commented on pull request #12189: URL: https://github.com/apache/flink/pull/12189#issuecomment-630133483 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] aljoscha commented on a change in pull request #12189: [FLINK-17376][API/DataStream]Deprecated methods and related code updated

aljoscha commented on a change in pull request #12189: URL: https://github.com/apache/flink/pull/12189#discussion_r426572441 ## File path: flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java ## @@

[jira] [Commented] (FLINK-17676) Is there some way to rollback the .out file of TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110192#comment-17110192 ] Gary Yao commented on FLINK-17676: -- [~rmetzger] I think Command Line Client is not the right component.

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110191#comment-17110191 ] Timo Walther commented on FLINK-17793: -- [~ykt836] I'm fine with `CatalogTableSchema`, however, it

[jira] [Updated] (FLINK-13857) Remove remaining UdfAnalyzer configurations

[ https://issues.apache.org/jira/browse/FLINK-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-13857: - Fix Version/s: (was: 1.11.0) 1.12.0 > Remove remaining

[jira] [Updated] (FLINK-15947) Finish moving scala expression DSL to flink-table-api-scala

[ https://issues.apache.org/jira/browse/FLINK-15947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15947: - Fix Version/s: (was: 1.11.0) 1.12.0 > Finish moving scala

[jira] [Assigned] (FLINK-13857) Remove remaining UdfAnalyzer configurations

[ https://issues.apache.org/jira/browse/FLINK-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-13857: Assignee: (was: Dawid Wysakowicz) > Remove remaining UdfAnalyzer

[jira] [Updated] (FLINK-16079) Primary key should use a deterministic name by default

[ https://issues.apache.org/jira/browse/FLINK-16079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16079: - Fix Version/s: (was: 1.11.0) 1.12.0 > Primary key should use a

[jira] [Commented] (FLINK-17511) "RocksDB Memory Management end-to-end test" fails with "Current block cache usage 202123272 larger than expected memory limit 200000000"

[ https://issues.apache.org/jira/browse/FLINK-17511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110179#comment-17110179 ] Yu Li commented on FLINK-17511: --- [~yunta] Please take a look here. Thanks. > "RocksDB Memory Management

[jira] [Assigned] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved

[ https://issues.apache.org/jira/browse/FLINK-15729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-15729: Assignee: (was: Dawid Wysakowicz) > Table planner dependency instructions

[jira] [Updated] (FLINK-17511) "RocksDB Memory Management end-to-end test" fails with "Current block cache usage 202123272 larger than expected memory limit 200000000"

[ https://issues.apache.org/jira/browse/FLINK-17511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17511: -- Fix Version/s: 1.11.0 > "RocksDB Memory Management end-to-end test" fails with "Current block cache > usage

[jira] [Updated] (FLINK-15869) Support to read and write meta information of a table

[ https://issues.apache.org/jira/browse/FLINK-15869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15869: - Fix Version/s: 1.12.0 > Support to read and write meta information of a table >

[jira] [Updated] (FLINK-15729) Table planner dependency instructions for executing in IDE can be improved

[ https://issues.apache.org/jira/browse/FLINK-15729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15729: - Fix Version/s: 1.12.0 > Table planner dependency instructions for executing in IDE can

[jira] [Updated] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17796: --- Priority: Critical (was: Major) > Application mode should respect user specified classpath

[jira] [Closed] (FLINK-17305) Add open/close and collector to (De)serializationSchema

[ https://issues.apache.org/jira/browse/FLINK-17305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-17305. Resolution: Implemented > Add open/close and collector to (De)serializationSchema >

[jira] [Updated] (FLINK-14482) Bump up rocksdb version

[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14482: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Bump up rocksdb version >

[jira] [Commented] (FLINK-17775) Cannot set batch job name when using collect

[ https://issues.apache.org/jira/browse/FLINK-17775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110176#comment-17110176 ] Nikola commented on FLINK-17775: Hi [~aljoscha], I have tried running without the env.execute() but then

[GitHub] [flink] kl0u commented on a change in pull request #12222: [FLINK-17796] Respect user specified classpath for application mode

kl0u commented on a change in pull request #1: URL: https://github.com/apache/flink/pull/1#discussion_r426565650 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationClusterEntryPoint.java ## @@ -69,4 +78,21 @@ protected

[GitHub] [flink] rmetzger commented on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

rmetzger commented on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-630127290 To trigger a new build, you need to push a change (rebase, or empty commit) This is an automated message from

[jira] [Updated] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable

[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14032: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Make the cache size of

[GitHub] [flink] rmetzger commented on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

rmetzger commented on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-630126819 Hey, sorry for these issues. The Kafka issue is a known problem, also the maven artifact download. You don't have to do anything to resolve them.

[jira] [Updated] (FLINK-16444) Count the read/write/seek/next latency of RocksDB as metrics

[ https://issues.apache.org/jira/browse/FLINK-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-16444: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Count the read/write/seek/next latency of

[jira] [Commented] (FLINK-17775) Cannot set batch job name when using collect

[ https://issues.apache.org/jira/browse/FLINK-17775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110173#comment-17110173 ] Aljoscha Krettek commented on FLINK-17775: -- This is a different issue, {{collect()}} will

[jira] [Closed] (FLINK-17615) flink batch job name doesn't show as defined in program

[ https://issues.apache.org/jira/browse/FLINK-17615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17615. Resolution: Not A Problem This was fixed by recent changes, {{OptimizerPlanEnvironment}}

[jira] [Updated] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-12692: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Support disk spilling in HeapKeyedStateBackend >

[jira] [Commented] (FLINK-17077) FLINK_CONF_DIR environment variable to locate flink-conf.yaml in Docker container

[ https://issues.apache.org/jira/browse/FLINK-17077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110172#comment-17110172 ] Eui Heo commented on FLINK-17077: - I considered your suggested way also. In that case, some properties

[GitHub] [flink] aljoscha closed pull request #12081: [FLINK-17615][flink-clients]fix flink batch job name showed in flink web ui

aljoscha closed pull request #12081: URL: https://github.com/apache/flink/pull/12081 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] aljoscha commented on pull request #12081: [FLINK-17615][flink-clients]fix flink batch job name showed in flink web ui

aljoscha commented on pull request #12081: URL: https://github.com/apache/flink/pull/12081#issuecomment-630125250 Sorry about this, but `OptimizerPlanEnvironment` doesn't exist anymore in the current code base. This is an

[jira] [Updated] (FLINK-15012) Checkpoint directory not cleaned up

[ https://issues.apache.org/jira/browse/FLINK-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15012: -- Fix Version/s: 1.12.0 > Checkpoint directory not cleaned up > --- > >

[GitHub] [flink] flinkbot commented on pull request #12224: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

flinkbot commented on pull request #12224: URL: https://github.com/apache/flink/pull/12224#issuecomment-630123879 ## CI report: * 354620f64883486ddf2c02dddf0633b51d0444d9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12225: [FLINK-17781][coordination] Use Scheduler and MainThreadExecutor in OperatorCoordinator.Context

flinkbot commented on pull request #12225: URL: https://github.com/apache/flink/pull/12225#issuecomment-630123970 ## CI report: * 98f726234e0bce2e0088bed95efd282462dc5fc1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12222: [FLINK-17796] Respect user specified classpath for application mode

flinkbot commented on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-630123726 ## CI report: * 16460c8237e1206fc6a74cac5fc8c0ec6ef4eaf1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-14236) Make LazyFromSourcesSchedulingStrategy do lazy scheduling based on partition state only

[ https://issues.apache.org/jira/browse/FLINK-14236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14236: Fix Version/s: (was: 1.11.0) > Make LazyFromSourcesSchedulingStrategy do lazy scheduling based on

[GitHub] [flink] flinkbot commented on pull request #12223: [FLINK-15813][runtime] Set default value of config “jobmanager.execution.failover-strategy” to “region”

flinkbot commented on pull request #12223: URL: https://github.com/apache/flink/pull/12223#issuecomment-630123802 ## CI report: * 1984222ee161599a34d41ba2d8dc6466b4858fab UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-14233) All task state changes should be notified to SchedulingStrategy (SchedulerNG)

[ https://issues.apache.org/jira/browse/FLINK-14233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14233: Fix Version/s: (was: 1.11.0) > All task state changes should be notified to SchedulingStrategy

[GitHub] [flink] flinkbot edited a comment on pull request #12210: [FLINK-17792][tests] Catch and log exception if jstack fails

flinkbot edited a comment on pull request #12210: URL: https://github.com/apache/flink/pull/12210#issuecomment-630018809 ## CI report: * 35a0b961d4d1a1dbb7485ff847c7b5e2a5068c80 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12204: [FLINK-17777][tests] Set HADOOP_CLASSPATH for Mesos TaskManagers

flinkbot edited a comment on pull request #12204: URL: https://github.com/apache/flink/pull/12204#issuecomment-629847515 ## CI report: * 097ac2b06f10900c435115c24e699c5328ee3227 Azure:

[jira] [Updated] (FLINK-14606) Simplify params of Execution#processFail

[ https://issues.apache.org/jira/browse/FLINK-14606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14606: Fix Version/s: (was: 1.11.0) > Simplify params of Execution#processFail >

[GitHub] [flink] flinkbot edited a comment on pull request #12213: Revert "[FLINK-13827][script] shell variable should be escaped"

flinkbot edited a comment on pull request #12213: URL: https://github.com/apache/flink/pull/12213#issuecomment-630019128 ## CI report: * 74c9e440c684f255faa2075c12e4438590631dae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12211: [FLINK-17790][kafka] Fix JDK 11 compile error

flinkbot edited a comment on pull request #12211: URL: https://github.com/apache/flink/pull/12211#issuecomment-630018919 ## CI report: * 439f4f136e73eebb6c424f7f706ab91655516ed3 Azure:

[jira] [Updated] (FLINK-15178) TaskExecutor crashes due to mmap allocation failure for BLOCKING shuffle

[ https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15178: Fix Version/s: (was: 1.11.0) > TaskExecutor crashes due to mmap allocation failure for BLOCKING

[jira] [Updated] (FLINK-14510) Remove the lazy vertex attaching mechanism from ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-14510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14510: Fix Version/s: (was: 1.11.0) 1.12.0 > Remove the lazy vertex attaching mechanism

[GitHub] [flink] flinkbot commented on pull request #12221: [FLINK-17797][FLINK-17798][hbase][jdbc] Align the behavior between the new and legacy HBase/JDBC table source

flinkbot commented on pull request #12221: URL: https://github.com/apache/flink/pull/12221#issuecomment-630123655 ## CI report: * 129d85d4bcc2b032ff5be1999a8a0277f31a2848 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12220: [FLINK-14255][hive] Integrate mapred record writer to hive streaming sink

flinkbot commented on pull request #12220: URL: https://github.com/apache/flink/pull/12220#issuecomment-630123571 ## CI report: * 1f7420e803f6c1a3a4596457b13aa3e5bc125199 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12212: [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style

flinkbot edited a comment on pull request #12212: URL: https://github.com/apache/flink/pull/12212#issuecomment-630019032 ## CI report: * 0ec02542ed4721376e60ea71090cbb335885e6b0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12217: [FLINK-17786][sql-client] Remove dialect from ExecutionEntry

flinkbot edited a comment on pull request #12217: URL: https://github.com/apache/flink/pull/12217#issuecomment-630047579 ## CI report: * a9407fa236d3cb710f131c04ced0ae449bbc15a9 Azure:

[GitHub] [flink] flinkbot commented on pull request #12219: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot commented on pull request #12219: URL: https://github.com/apache/flink/pull/12219#issuecomment-630123493 ## CI report: * c849ac42145725091a3ab166095a672eaf33f350 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12218: [FLINK-16160][table] Fix proctime()/rowtime() doesn't work for TableE…

flinkbot edited a comment on pull request #12218: URL: https://github.com/apache/flink/pull/12218#issuecomment-630087514 ## CI report: * ced394a88ef14eb97b61391aa2fb8b571c6b5977 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/166677325) Bot

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * f11005c6596ecf41efd898ba324374948b2eb8cb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * b954ba073cba912b98c5992b05caec91e7657871 Azure:

[jira] [Closed] (FLINK-17624) "TPC-DS end-to-end test (Blink planner)" is unstable

[ https://issues.apache.org/jira/browse/FLINK-17624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-17624. - Resolution: Fixed > "TPC-DS end-to-end test (Blink planner)" is unstable >

[jira] [Updated] (FLINK-17705) Add rat license checks for flink-benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17705: - Summary: Add rat license checks for flink-benchmarks (was: Add rat license checks) >

[jira] [Updated] (FLINK-17706) Clarify licensing situation for flink-benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17706: - Summary: Clarify licensing situation for flink-benchmarks (was: Clarify licensing

[GitHub] [flink] flinkbot edited a comment on pull request #12103: [FLINK-16998][core] Add a changeflag to Row

flinkbot edited a comment on pull request #12103: URL: https://github.com/apache/flink/pull/12103#issuecomment-627456433 ## CI report: * 460711a0fe014e079ea2eb9c6e98da11e1946b48 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

flinkbot edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415 ## CI report: * 79f3bb064a15bfde312932e603ae2a65e67545fd UNKNOWN * ec7e775f83706fe690c3d4214f30c7e81a5167f5 Azure:

[jira] [Closed] (FLINK-17676) Is there some way to rollback the .out file of TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17676. Resolution: Won't Do I think we can't fix that from the Flink side, printing to stdout

[jira] [Updated] (FLINK-17357) add "DROP catalog" DDL to blink planner

[ https://issues.apache.org/jira/browse/FLINK-17357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17357: - Fix Version/s: 1.11.0 > add "DROP catalog" DDL to blink planner >

[jira] [Closed] (FLINK-17357) add "DROP catalog" DDL to blink planner

[ https://issues.apache.org/jira/browse/FLINK-17357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17357. Resolution: Implemented master: bf5594cdde428be3521810cb3f44db0462db35df > add "DROP catalog"

[GitHub] [flink] JingsongLi merged pull request #12197: [FLINK-17357][table-planner-blink] add 'DROP catalog' DDL to blink pl…

JingsongLi merged pull request #12197: URL: https://github.com/apache/flink/pull/12197 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Updated] (FLINK-16116) Remove shading from oss filesystems build

[ https://issues.apache.org/jira/browse/FLINK-16116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-16116: -- Fix Version/s: (was: 1.10.2) (was: 1.11.0) 1.12.0 >

[jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11937: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Resolve small

[jira] [Updated] (FLINK-17760) Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

[ https://issues.apache.org/jira/browse/FLINK-17760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17760: Fix Version/s: 1.12.0 > Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore >

[jira] [Updated] (FLINK-17760) Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

[ https://issues.apache.org/jira/browse/FLINK-17760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17760: Affects Version/s: 1.11.0 > Rework tests to not rely on legacy scheduling logics in ExecutionGraph

[GitHub] [flink] flinkbot edited a comment on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

flinkbot edited a comment on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-542518065 ## CI report: * 01016af81f4aca6c28525ef1fe896986bf60592c Azure:

[jira] [Updated] (FLINK-16077) Translate "Custom State Serialization" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-16077: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Translate

[jira] [Updated] (FLINK-15626) Remove legacy scheduler

[ https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15626: Fix Version/s: (was: 1.11.0) 1.12.0 > Remove legacy scheduler >

[jira] [Updated] (FLINK-15031) Calculate required shuffle memory before allocating slots if resources are specified

[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15031: Fix Version/s: (was: 1.11.0) 1.12.0 > Calculate required shuffle memory before

[jira] [Updated] (FLINK-15747) Enable setting RocksDB log level from configuration

[ https://issues.apache.org/jira/browse/FLINK-15747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-15747: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Enable setting

[jira] [Updated] (FLINK-13056) Optimize region failover performance on calculating vertices to restart

[ https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-13056: Fix Version/s: (was: 1.11.0) > Optimize region failover performance on calculating vertices to

[jira] [Updated] (FLINK-17208) Reduce redundant data available notification of PipelinedSubpartition

[ https://issues.apache.org/jira/browse/FLINK-17208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-17208: Fix Version/s: (was: 1.11.0) 1.12.0 > Reduce redundant data available

[jira] [Updated] (FLINK-16074) Translate the "Overview" page for "State & Fault Tolerance" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-16074: -- Fix Version/s: (was: 1.11.0) 1.12.0 > Translate the

[jira] [Updated] (FLINK-17300) Log the lineage information between ExecutionAttemptID and AllocationID

[ https://issues.apache.org/jira/browse/FLINK-17300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17300: --- Fix Version/s: 1.11.0 > Log the lineage information between ExecutionAttemptID and AllocationID >

[jira] [Updated] (FLINK-17542) Unify slot request timeout handling for streaming and batch tasks

[ https://issues.apache.org/jira/browse/FLINK-17542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17542: Fix Version/s: (was: 1.11.0) 1.12.0 > Unify slot request timeout handling for

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by cyclic input dependencies between regions

[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Fix Version/s: (was: 1.11.0) 1.12.0 > Avoid scheduling deadlocks caused by cyclic

[jira] [Updated] (FLINK-15448) Log host informations for TaskManager failures.

[ https://issues.apache.org/jira/browse/FLINK-15448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-15448: --- Fix Version/s: 1.12.0 > Log host informations for TaskManager failures. >

[jira] [Closed] (FLINK-14460) Active Kubernetes integration phase 2 - Advanced Features

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-14460. - Resolution: Fixed > Active Kubernetes integration phase 2 - Advanced Features >

[jira] [Updated] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17295: --- Fix Version/s: 1.12.0 > Refactor the ExecutionAttemptID to consist of ExecutionVertexID and >

[jira] [Updated] (FLINK-17017) Implement Bulk Slot Allocation

[ https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17017: Fix Version/s: (was: 1.11.0) 1.12.0 > Implement Bulk Slot Allocation >

[jira] [Updated] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17018: Fix Version/s: (was: 1.11.0) 1.12.0 > DefaultExecutionSlotAllocator allocates

[jira] [Updated] (FLINK-17016) Use PipelinedRegionSchedulingStrategy in DefaultScheduler (for Blink Planner)

[ https://issues.apache.org/jira/browse/FLINK-17016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17016: Fix Version/s: (was: 1.11.0) 1.12.0 > Use PipelinedRegionSchedulingStrategy in

[jira] [Updated] (FLINK-17298) Log the lineage information between SlotRequestID and AllocationID

[ https://issues.apache.org/jira/browse/FLINK-17298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17298: --- Fix Version/s: 1.11.0 > Log the lineage information between SlotRequestID and AllocationID >

[jira] [Updated] (FLINK-17297) Log the lineage information between ExecutionAttemptID and SlotRequestID

[ https://issues.apache.org/jira/browse/FLINK-17297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17297: --- Fix Version/s: 1.11.0 > Log the lineage information between ExecutionAttemptID and SlotRequestID >

[jira] [Updated] (FLINK-17019) Implement FIFO Physical Slot Assignment in SlotPoolImpl

[ https://issues.apache.org/jira/browse/FLINK-17019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17019: Fix Version/s: (was: 1.11.0) 1.12.0 > Implement FIFO Physical Slot Assignment in

[jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm

[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16548: --- Fix Version/s: 1.12.0 > Expose consistent environment variable to identify the component name and

[jira] [Updated] (FLINK-17579) Set the resource id of taskexecutor according to environment variable if exist in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-17579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17579: --- Fix Version/s: 1.12.0 > Set the resource id of taskexecutor according to environment variable if >

[jira] [Updated] (FLINK-16430) FLIP-119 Pipelined Region Scheduling

[ https://issues.apache.org/jira/browse/FLINK-16430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-16430: Fix Version/s: (was: 1.11.0) 1.12.0 > FLIP-119 Pipelined Region Scheduling >

[jira] [Updated] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17758: Affects Version/s: (was: 1.11.0) 1.10.0 > Remove

[jira] [Updated] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17759: Affects Version/s: (was: 1.10.0) 1.11.0 > Remove RestartIndividualStrategy >

[jira] [Updated] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17758: Affects Version/s: (was: 1.10.0) 1.11.0 > Remove

[jira] [Updated] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17796: --- Fix Version/s: 1.11.0 > Application mode should respect user specified classpath

[jira] [Updated] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17759: Affects Version/s: (was: 1.11.0) 1.10.0 > Remove RestartIndividualStrategy >

<    1   2   3   4   5   6   7   8   9   >