Details

      Description

      FLINK-12801 has introduce parallelism setting for table, but because TableSource generate DataStream, maybe DataStream is not a real source, that will lead to some shuffle errors. So FLINK-13494 remove these implementations.

      In this ticket, I would like to introduce parallelism inference only for InputFormatTableSource, the RowCount of InputFormatTableSource is more accurate than downstream stages. It is worth to automatically generate its parallelism.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                lzljs3620320 Jingsong Lee
                Reporter:
                lzljs3620320 Jingsong Lee
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m